File tree Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -101,6 +101,10 @@ function SubscriptionConnection(parent::SubscribableConnection)
101101end
102102
103103function on_connect (conn:: RedisConnectionBase )
104+ # disable nagle and enable quickack to speed up the usually small exchanges
105+ Sockets. nagle (conn. socket, false )
106+ Sockets. quickack (conn. socket, true )
107+
104108 conn. password != " " && auth (conn, conn. password)
105109 conn. db != 0 && select (conn, conn. db)
106110 conn
Original file line number Diff line number Diff line change 8888
8989function execute_command_without_reply (conn:: RedisConnectionBase , command)
9090 is_connected (conn) || throw (ConnectionException (" Socket is disconnected" ))
91- lock (conn. socket. lock) do
92- pack_command (conn. socket, command)
91+ iob = IOBuffer ()
92+ pack_command (iob, command)
93+ lock (conn. socket. lock) do
94+ write (conn. socket, take! (iob))
9395 end
9496end
9597
You can’t perform that action at this time.
0 commit comments