Commit 9fd1664b authored by Heinz N. Gies's avatar Heinz N. Gies

Fix hpts on tcp listeners

parent 9881a2d9
Pipeline #18751153 passed with stage
in 1 minute and 20 seconds
......@@ -14,7 +14,7 @@ init(Ref, Socket, Transport, M = #{bucket := Bucket}) ->
C = dp_util:ddb_c(ddb_tcp:connect(Host, Port)),
{ok, #{resolution := Res, hpts := HPTS}, C1} = ddb_tcp:bucket_info(Bucket, C),
C2 = dp_util:ddb_c(ddb_tcp:stream_mode(Bucket, 5, HPTS, C1)),
loop(Socket, Transport, <<>>, M#{ddb => C2, hpts := HPTS, res => Res}).
loop(Socket, Transport, <<>>, M#{ddb => C2, hpts => HPTS, res => Res}).
loop(Socket, Transport, Acc, State) ->
case Transport:recv(Socket, 0, 5000) of
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment