Bump uS

src/AsyncSocket.h

@@ -130,7 +130,7 @@ struct AsyncSocket {
     }
 
     /* Cork this socket. Only one socket may ever be corked per-loop at any given time */
-    void cork() {
+    void cork(char *sendBuffer = nullptr) {
         /* Extra check for invalid corking of others */
         if (getLoopData()->corkOffset && getLoopData()->corkedSocket != this) {
             std::cerr << "Error: Cork buffer must not be acquired without checking canCork!" << std::endl;
@@ -139,6 +139,15 @@ struct AsyncSocket {
 
         /* What if another socket is corked? */
         getLoopData()->corkedSocket = this;
+
+        if (sendBuffer) {
+            setCorkBuffer(sendBuffer, 0);
+        }
+    }
+
+    void setCorkBuffer(char *buffer, int offset) {
+        getLoopData()->corkBuffer = buffer;
+        getLoopData()->corkOffset = offset;
     }
 
     /* Returns the corked socket or nullptr */

src/HttpContext.h

@@ -122,7 +122,7 @@ struct HttpContext {
             HttpResponseData<SSL> *httpResponseData = (HttpResponseData<SSL> *) us_socket_ext(SSL, s);
 
             /* Cork this socket */
-            ((AsyncSocket<SSL> *) s)->cork();
+            ((AsyncSocket<SSL> *) s)->cork(us_socket_send_buffer(0, s));
 
             /* Mark that we are inside the parser now */
             httpContextData->isParsingHttp = true;

src/WebSocketContext.h

@@ -300,7 +300,7 @@ struct WebSocketContext {
             webSocketData->hasTimedOut = false;
 
             /* We always cork on data */
-            asyncSocket->cork();
+            asyncSocket->cork(us_socket_send_buffer(0, s));
 
             /* This parser has virtually no overhead */
             WebSocketProtocol<isServer, WebSocketContext<SSL, isServer, USERDATA>>::consume(data, (unsigned int) length, (WebSocketState<isServer> *) webSocketData, s);