Kolab Groupware OBS

erlang-eimap.spec Changed

@@ -8,7 +8,7 @@
 %define lock_version() %{1}%{?_isa} = %(rpm -q --queryformat "%%{VERSION}" %{1})
 
 Name:           erlang-%{realname}
-Version:        0.4.0
+Version:        0.4.3
 Release:        1%{?dist}
 Summary:        Erlang IMAP client
 Group:          Development/Libraries
@@ -19,17 +19,16 @@
 %endif
 Source0:        erlang-eimap-%{version}.tar.gz
 
-Patch1:         untagged-commands.patch
-Patch2:         eimap-0.4.0-otp-20.patch
-Patch3:         make-things-easy-for-rebar3.patch
-Patch4:         use_iolist_to_binary.patch
+# Keep rebar3 from downloading dependencies, we want package provide ones.
+Patch1:         nodeps.patch
 
 BuildRequires:	erlang-goldrush
-BuildRequires:	erlang-lager
+BuildRequires:	erlang-lager >= 3.1.0
 BuildRequires:	erlang-rebar3 >= 3.3.2
 
 Requires:       %lock_version erlang-erts
 Requires:       %lock_version erlang-stdlib
+Requires:       %lock_version erlang-lager
 
 %description
 IMAP client library for Erlang
@@ -38,9 +37,6 @@
 %setup -q -n eimap-%{version}
 
 %patch1 -p1
-%patch2 -p1
-%patch3 -p1
-%patch4 -p1
 
 %build
 DEBUG=1
@@ -80,8 +76,15 @@
 %{_libdir}/erlang/lib/%{realname}-%{version}/ebin/*.beam
 
 %changelog
-* Sat Mar 21 2020 hede <kolab983@der-he.de> - 0.4.0-1
-- use iolist_to_binary() to convert iolist to binary
+
+* Wed Oct 28 2020 Christian Mollekopf <mollekopf@kolabsys.com> - 0.4.3-1
+- Upstream release 0.4.3
+
+* Wed Apr 15 2020 Christian Mollekopf <mollekopf@kolabsys.com> - 0.4.2-1
+- Upstream release 0.4.2
+
+* Sat Mar 28 2020 Christian Mollekopf <mollekopf@kolabsys.com> - 0.4.1-1
+- Upstream release 0.4.1
 
 * Sun Apr 08 2018 Christoph Erhardt <kolab@sicherha.de> - 0.4.0-1
 - Upstream release 0.4.0

eimap-0.4.0-otp-20.patch Deleted

make-things-easy-for-rebar3.patch Deleted

nodeps.patch Added

untagged-commands.patch Deleted

@@ -1,43 +0,0 @@
-diff --git a/src/eimap_utils.erl b/src/eimap_utils.erl
-index 163229b..230ab60 100644
---- a/src/eimap_utils.erl
-+++ b/src/eimap_utils.erl
-@@ -156,14 +156,20 @@ remove_tag_from_response(Buffer, Tag, trust) ->
- %% Private
- split_command(<<>>) -> { <<>>, <<>>, <<>> };
- split_command(Buffer) ->
--    End = eol_found(Buffer, binary:match(Buffer, <<"\r\n">>)),
-+    {Terminated, End} = eol_found(Buffer, binary:match(Buffer, <<"\r\n">>)),
-     { Tag, CommandStart } = searched_in_buffer(Buffer, 0, End, binary:match(Buffer, <<" ">>, [ { scope, { 0, End } } ])),
--    { Command, DataStart } = searched_in_buffer(Buffer, CommandStart, End, binary:match(Buffer, <<" ">>, [ { scope, { CommandStart, End - CommandStart  } } ])),
--    Data = binary:part(Buffer, DataStart, End - (DataStart)),
--    { Tag, Command, Data }.
-+    case Terminated of
-+         true when End == CommandStart ->
-+            %% when we have a newline, and the tag takes the entire line, the "tag" is actually the command
-+            {<<>>, Tag, <<>>};
-+         _ ->
-+            { Command, DataStart } = searched_in_buffer(Buffer, CommandStart, End, binary:match(Buffer, <<" ">>, [ { scope, { CommandStart, End - CommandStart  } } ])),
-+            Data = binary:part(Buffer, DataStart, End - (DataStart)),
-+            { Tag, Command, Data }
-+    end.
- 
--eol_found(Buffer, nomatch) -> size(Buffer);
--eol_found(_Buffer, { MatchStart, _MatchLength }) -> MatchStart.
-+eol_found(Buffer, nomatch) -> {false, size(Buffer)};
-+eol_found(_Buffer, { MatchStart, _MatchLength }) -> {true, MatchStart}.
- 
- searched_in_buffer(Buffer, Start, End, nomatch) -> { binary:part(Buffer, Start, End - Start), End };
- searched_in_buffer(Buffer, Start, _End, { MatchStart, MatchLength } ) -> { binary:part(Buffer, Start, MatchStart - Start), MatchStart + MatchLength }.
-diff --git a/test/eimap_utils_tests.erl b/test/eimap_utils_tests.erl
-index 389be6f..81631c1 100644
---- a/test/eimap_utils_tests.erl
-+++ b/test/eimap_utils_tests.erl
-@@ -79,6 +79,7 @@ split_command_into_components_test_() ->
-     Data =
-     [
-         { { <<>>, <<>>, <<>> }, <<>> },
-+        { { <<>>, <<"DONE">>, <<>> }, <<"DONE\r\n">> },
-         { { <<".">>, <<"LIST">>, <<"\"\" \"*\"">> }, <<". LIST \"\" \"*\"">> },
-         { { <<"1">>, <<"STARTTLS">>, <<>> }, <<"1 STARTTLS">> },
-         { { <<"1">>, <<"STARTTLS">>, <<>> }, <<"1 STARTTLS\r\n">> },

_link Changed

debian.changelog Changed

debian.series Changed

erlang-eimap-0.4.3.tar.gz/.arcconfig Added

erlang-eimap-0.4.0.tar.gz/CHANGELOG.md -> erlang-eimap-0.4.3.tar.gz/CHANGELOG.md Changed

erlang-eimap-0.4.3.tar.gz/LICENSE Added

erlang-eimap-0.4.0.tar.gz/rebar.config -> erlang-eimap-0.4.3.tar.gz/rebar.config Changed

erlang-eimap-0.4.0.tar.gz/rebar3 -> erlang-eimap-0.4.3.tar.gz/rebar3 Changed

erlang-eimap-0.4.0.tar.gz/src/eimap.app.src -> erlang-eimap-0.4.3.tar.gz/src/eimap.app.src Changed

erlang-eimap-0.4.0.tar.gz/src/eimap.erl -> erlang-eimap-0.4.3.tar.gz/src/eimap.erl Changed

@@ -146,6 +146,21 @@
 disconnected(Command, State) when is_record(Command, command) ->
     { next_state, disconnected, enque_command(Command, State) }.
 
+
+%Throttle if the target process is getting overloaded.
+%This allows the socket buffers to fill up eventually,
+%so regular congestion control can kick in.
+throttle(Receiver, Limit) ->
+    {_, MessageQueueLength} = process_info(Receiver, message_queue_len),
+    if
+        MessageQueueLength > Limit ->
+            SleepDuration = trunc(MessageQueueLength / 2),
+            lager:debug("Throttling for ~p with queue length ~p", [SleepDuration, MessageQueueLength]),
+            timer:sleep(SleepDuration),
+            throttle(Receiver, Limit);
+        true -> false
+    end.
+
 passthrough(flush_passthrough_buffer, #state{ passthrough_send_buffer = Buffer } = State) ->
     %lager:info("Passing through ~p", [Buffer]),
     passthrough({ passthrough, Buffer }, State#state{ passthrough_send_buffer = <<>> });
@@ -159,6 +174,8 @@
     { next_state, passthrough, State };
 passthrough({ data, Data }, #state{ passthrough_recv = Receiver } = State) ->
     %lager:info("Passing back ~p", [Data]),
+
+    throttle(Receiver, 100),
     Receiver ! { imap_server_response, Data },
     { next_state, passthrough, State };
 passthrough(Command, State) when is_record(Command, command) ->
@@ -211,6 +228,21 @@
 wait_response({ data, Data }, #state{ current_command = #command{ response_type = ResponseType, parse_state = CommandState , tag = Tag } } = State) ->
     Response = eimap_command:parse_response(ResponseType, Data, Tag, CommandState),
     %%lager:info("Response from parser was ~p ~p, size of queue ~p", [More, Response, queue:len(State#state.command_queue)]),
+    % FIXME
+    % Because several commands can be in flight at the same time, it can happen that we have something like:
+    % * Client send: CMD1, CMD2 (triggering a request for metadata)
+    % * Because we immediately after processing CMD2 from the client request metadata and start waiting for the response,
+    % a response that actually still belongs to CMD1 will not be recognized as such (will end up in here).
+    %
+    % Below is a workaround for that case; If we fail to parse the repsonse we simply assume it's none of our business and pass it trough.
+    %
+    % For a proper fix more work would be required, here are some ideas:
+    % * Track pending tags and only start associating with this command once we have all outstanding tags completed. The problem is that we don't know about pending tags because normally we don't look for them while passing through.
+    % * Buffer data and watch out for any tag. If its not ours pass the data through (would result in performance penalty only while waiting for the command).
+    case Response of
+        {more,{<<>>,[],_}} -> passthrough({data, Data}, State);
+        _ -> {}
+    end,
     NewState = cancel_timeout(State),
     next_command_after_response(Response, NewState);
 wait_response(process_command_queue, State) ->
@@ -404,7 +436,7 @@
 create_socket(Host, Port, _, _Receiver, _ResponseToken, CommandQueue) ->
     { gen_tcp:connect(Host, Port, socket_options(), ?TCP_CONNECT_TIMEOUT), false, self(), CommandQueue }.
 
-socket_options() -> [binary, { active, once }, { send_timeout, 5000 }].
+socket_options() -> [binary, { active, once }, { send_timeout, 5000 }, { keepalive, true }].
 
 upgrade_socket(#state{ socket = Socket, tls_state = true, current_command = Command }) ->
     notify_of_response(starttls_complete, Command),
@@ -478,13 +510,10 @@
     State#state { command_queue = queue:in_r(Command, State#state.command_queue) }.
 
 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 = Deflator }) ->  joined(zlib:deflate(Deflator, Data, sync), <<>>).
-
-joined([], Binary) -> Binary;
-joined([H|Rest], Binary) -> joined(Rest, <<Binary/binary, H/binary>>).
+deflated(Data, #state{ deflator = Deflator }) ->  iolist_to_binary(zlib:deflate(Deflator, Data, sync)).
 
 reset_timeout(#state{ command_timeout = Timeout } = State) ->
     cancel_timeout(State),

erlang-eimap-0.4.0.tar.gz/src/eimap_utils.erl -> erlang-eimap-0.4.3.tar.gz/src/eimap_utils.erl Changed

@@ -156,14 +156,20 @@
 %% Private
 split_command(<<>>) -> { <<>>, <<>>, <<>> };
 split_command(Buffer) ->
-    End = eol_found(Buffer, binary:match(Buffer, <<"\r\n">>)),
+    {Terminated, End} = eol_found(Buffer, binary:match(Buffer, <<"\r\n">>)),
     { Tag, CommandStart } = searched_in_buffer(Buffer, 0, End, binary:match(Buffer, <<" ">>, [ { scope, { 0, End } } ])),
-    { Command, DataStart } = searched_in_buffer(Buffer, CommandStart, End, binary:match(Buffer, <<" ">>, [ { scope, { CommandStart, End - CommandStart  } } ])),
-    Data = binary:part(Buffer, DataStart, End - (DataStart)),
-    { Tag, Command, Data }.
+    case Terminated of
+         true when End == CommandStart ->
+            %% when we have a newline, and the tag takes the entire line, the "tag" is actually the command
+            {<<>>, Tag, <<>>};
+         _ ->
+            { Command, DataStart } = searched_in_buffer(Buffer, CommandStart, End, binary:match(Buffer, <<" ">>, [ { scope, { CommandStart, End - CommandStart  } } ])),
+            Data = binary:part(Buffer, DataStart, End - (DataStart)),
+            { Tag, Command, Data }
+    end.
 
-eol_found(Buffer, nomatch) -> size(Buffer);
-eol_found(_Buffer, { MatchStart, _MatchLength }) -> MatchStart.
+eol_found(Buffer, nomatch) -> {false, size(Buffer)};
+eol_found(_Buffer, { MatchStart, _MatchLength }) -> {true, MatchStart}.
 
 searched_in_buffer(Buffer, Start, End, nomatch) -> { binary:part(Buffer, Start, End - Start), End };
 searched_in_buffer(Buffer, Start, _End, { MatchStart, MatchLength } ) -> { binary:part(Buffer, Start, MatchStart - Start), MatchStart + MatchLength }.

erlang-eimap-0.4.0.tar.gz/test/eimap_utils_tests.erl -> erlang-eimap-0.4.3.tar.gz/test/eimap_utils_tests.erl Changed

erlang-eimap.dsc Changed

Changes of Revision 6