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 | |||||