Changeset View
Changeset View
Standalone View
Standalone View
apps/kolab_guam/src/kolab_guam_session.erl
Show First 20 Lines • Show All 232 Lines • ▼ Show 20 Lines | %buffered_client_data is already in DataToBuffer via preprocess_client_data | ||||
inflator = CurrentInflator, deflator = CurrentDeflator, | inflator = CurrentInflator, deflator = CurrentDeflator, | ||||
buffered_client_data = <<DataToBuffer/binary>>, | buffered_client_data = <<DataToBuffer/binary>>, | ||||
current_command_split = SplitCommand, | current_command_split = SplitCommand, | ||||
command_split_reset_trigger = SplitResetTrigger } }. | command_split_reset_trigger = SplitResetTrigger } }. | ||||
preprocess_client_data(undefined, Data, #state{ buffered_client_data = Buffered }) -> | preprocess_client_data(undefined, Data, #state{ buffered_client_data = Buffered }) -> | ||||
<<Buffered/binary, Data/binary>>; | <<Buffered/binary, Data/binary>>; | ||||
preprocess_client_data(Z, Data, #state{ buffered_client_data = Buffered }) -> | preprocess_client_data(Z, Data, #state{ buffered_client_data = Buffered }) -> | ||||
Inflated = joined(zlib:inflate(Z, Data), <<>>), | Inflated = iolist_to_binary(zlib:inflate(Z, Data)), | ||||
<<Buffered/binary, Inflated/binary>>. | <<Buffered/binary, Inflated/binary>>. | ||||
postprocess_server_data(undefined, Data) -> | postprocess_server_data(undefined, Data) -> | ||||
%% we aren't compressing so there is nothing to do | %% we aren't compressing so there is nothing to do | ||||
Data; | Data; | ||||
postprocess_server_data(Z, Data) -> | postprocess_server_data(Z, Data) -> | ||||
joined(zlib:deflate(Z, Data, sync), <<>>). | iolist_to_binary(zlib:deflate(Z, Data, sync)). | ||||
joined([], Binary) -> Binary; | |||||
joined([H|Rest], Binary) -> joined(Rest, <<Binary/binary, H/binary>>). | |||||
init_rules(RuleConfig) -> init_rule(RuleConfig, []). | init_rules(RuleConfig) -> init_rule(RuleConfig, []). | ||||
init_rule([], Acc) -> Acc; | init_rule([], Acc) -> Acc; | ||||
init_rule([{ RuleName, Config }|RuleConfig], Acc) -> | init_rule([{ RuleName, Config }|RuleConfig], Acc) -> | ||||
Module = full_rule_name(RuleName), | Module = full_rule_name(RuleName), | ||||
%% we try to new the module, but if something goes wrong, e.g. it does not exist, | %% we try to new the module, but if something goes wrong, e.g. it does not exist, | ||||
%% then we skip this config block because it is BROKEN | %% then we skip this config block because it is BROKEN | ||||
try Module:new(Config) of | try Module:new(Config) of | ||||
▲ Show 20 Lines • Show All 186 Lines • Show Last 20 Lines |