Changeset View
Changeset View
Standalone View
Standalone View
src/eimap.erl
Show First 20 Lines • Show All 472 Lines • ▼ Show 20 Lines | enque_command(Command, State) -> | ||||
%%lager:info("Enqueuing command ~p", [Command]), | %%lager:info("Enqueuing command ~p", [Command]), | ||||
State#state { command_queue = queue:in(Command, State#state.command_queue) }. | State#state { command_queue = queue:in(Command, State#state.command_queue) }. | ||||
reenque_command(Command, State) -> | reenque_command(Command, State) -> | ||||
%%lager:info("Re-queueing command ~p", [Command]), | %%lager:info("Re-queueing command ~p", [Command]), | ||||
State#state { command_queue = queue:in_r(Command, State#state.command_queue) }. | State#state { command_queue = queue:in_r(Command, State#state.command_queue) }. | ||||
inflated(Data, #state{ inflator = undefined }) -> Data; | inflated(Data, #state{ inflator = undefined }) -> Data; | ||||
inflated(Data, #state{ inflator = Inflator }) -> joined(zlib:inflate(Inflator, Data), <<>>). | inflated(Data, #state{ inflator = Inflator }) -> iolist_to_binary(zlib:inflate(Inflator, Data)). | ||||
deflated(Data, #state{ deflator = undefined }) -> Data; | deflated(Data, #state{ deflator = undefined }) -> Data; | ||||
deflated(Data, #state{ deflator = Deflator }) -> joined(zlib:deflate(Deflator, Data, sync), <<>>). | deflated(Data, #state{ deflator = Deflator }) -> iolist_to_binary(zlib:deflate(Deflator, Data, sync)). | ||||
joined([], Binary) -> Binary; | |||||
joined([H|Rest], Binary) -> joined(Rest, <<Binary/binary, H/binary>>). | |||||
reset_timeout(#state{ command_timeout = Timeout } = State) -> | reset_timeout(#state{ command_timeout = Timeout } = State) -> | ||||
cancel_timeout(State), | cancel_timeout(State), | ||||
{ ok, TimerRef } = | { ok, TimerRef } = | ||||
case Timeout of | case Timeout of | ||||
Timeout when is_integer(Timeout), Timeout >= 0 -> | Timeout when is_integer(Timeout), Timeout >= 0 -> | ||||
timer:send_after(Timeout, response_timeout); | timer:send_after(Timeout, response_timeout); | ||||
_ -> | _ -> | ||||
Show All 9 Lines |