Merge pull request #748 from KeepSafe/client_nodelay

Use CORK/NODELAY in client API

Author: asvetlov

aiohttp/client.py

@@ -322,6 +322,7 @@ def _ws_connect(self, url, *,
                         break
 
             reader = resp.connection.reader.set_parser(WebSocketParser)
+            resp.connection.writer.set_tcp_nodelay(True)
             writer = WebSocketWriter(resp.connection.writer, use_mask=True)
         except Exception:
             resp.close()

aiohttp/client_reqrep.py

@@ -373,6 +373,7 @@ def write_bytes(self, request, reader):
 
         try:
             if asyncio.iscoroutine(self.body):
+                request.transport.set_tcp_nodelay(True)
                 exc = None
                 value = None
                 stream = self.body
@@ -407,12 +408,14 @@ def write_bytes(self, request, reader):
                             type(result))
 
             elif isinstance(self.body, asyncio.StreamReader):
+                request.transport.set_tcp_nodelay(True)
                 chunk = yield from self.body.read(streams.DEFAULT_LIMIT)
                 while chunk:
                     yield from request.write(chunk, drain=True)
                     chunk = yield from self.body.read(streams.DEFAULT_LIMIT)
 
             elif isinstance(self.body, streams.DataQueue):
+                request.transport.set_tcp_nodelay(True)
                 while True:
                     try:
                         chunk = yield from self.body.read()
@@ -427,20 +430,24 @@ def write_bytes(self, request, reader):
                 while chunk:
                     request.write(chunk)
                     chunk = self.body.read(self.chunked)
+                request.transport.set_tcp_nodelay(True)
 
             else:
                 if isinstance(self.body, (bytes, bytearray)):
                     self.body = (self.body,)
 
                 for chunk in self.body:
                     request.write(chunk)
+                request.transport.set_tcp_nodelay(True)
+
         except Exception as exc:
             new_exc = aiohttp.ClientRequestError(
                 'Can not write request body for %s' % self.url)
             new_exc.__context__ = exc
             new_exc.__cause__ = exc
             reader.set_exception(new_exc)
         else:
+            assert request.transport.tcp_nodelay
             try:
                 ret = request.write_eof()
                 # NB: in asyncio 3.4.1+ StreamWriter.drain() is coroutine
@@ -458,6 +465,7 @@ def write_bytes(self, request, reader):
         self._writer = None
 
     def send(self, writer, reader):
+        writer.set_tcp_cork(True)
         request = aiohttp.Request(writer, self.method, self.path, self.version)
 
         if self.compress: