|
@@ -110,7 +110,7 @@ handle_cast(_Req, State) ->
|
|
|
handle_info(check_time_process, State) ->
|
|
|
erlang:send_after(1000, self(), check_time_process),
|
|
|
|
|
|
- ok = check_time_h(ets:first(events_time_table), false, erlang:system_time(second) ),
|
|
|
+ ok = check_time_h(ets:first(events_time_table), erlang:system_time(second) ),
|
|
|
|
|
|
{noreply, State};
|
|
|
|
|
@@ -126,29 +126,19 @@ code_change(_OldVsn, State, _Extra) ->
|
|
|
{ok, State}.
|
|
|
|
|
|
|
|
|
-%check_time_h(Key, Prev_Key, Timestamp_Now)
|
|
|
-check_time_h('$end_of_table', Prev_Key, _Timestamp_Now) ->
|
|
|
- case Prev_Key of
|
|
|
- false -> ok;
|
|
|
- _ ->
|
|
|
- ets:delete_object(events_time_table, {Prev_Key}),
|
|
|
- ok
|
|
|
- end;
|
|
|
-check_time_h({Time, Task_Id, Proc_Id}=Key, Prev_Key, Timestamp_Now) ->
|
|
|
- case Prev_Key of
|
|
|
- false -> ok;
|
|
|
- _ ->
|
|
|
- ets:delete_object(events_time_table, {Prev_Key}),
|
|
|
- ok
|
|
|
- end,
|
|
|
+%check_time_h(Key, Timestamp_Now)
|
|
|
+check_time_h({Time, Task_Id, Proc_Id}=Key, Timestamp_Now) when Time =< Timestamp_Now ->
|
|
|
+ % send_to_rabbitmq({call_timer, Proc_Id, Task_Id}),
|
|
|
+
|
|
|
+ ets:delete(events_table, {Task_Id, Proc_Id}),
|
|
|
+ ets:delete_object(events_time_table, {Key}),
|
|
|
|
|
|
- if Time =< Timestamp_Now ->
|
|
|
- % send_to_rabbitmq({call_timer, Proc_Id, Task_Id}),
|
|
|
- ets:delete(events_table, {Task_Id, Proc_Id}),
|
|
|
- check_time_h(ets:next(events_time_table, Key), Key, Timestamp_Now);
|
|
|
-
|
|
|
- true -> ok
|
|
|
- end.
|
|
|
+ check_time_h(ets:first(events_time_table), Timestamp_Now);
|
|
|
+
|
|
|
+%check_time_h('$end_of_table', _Timestamp_Now) -> ok;
|
|
|
+check_time_h(_, _) -> ok.
|
|
|
+
|
|
|
+
|
|
|
|
|
|
check_ets_count() -> ets:info(events_table, 'size').
|
|
|
check_ets_count2() -> ets:info(events_time_table, 'size').
|