From 7d990a3bc177271eb64af2f58c30a5253507fa7f Mon Sep 17 00:00:00 2001 From: Alex Hultman Date: Sat, 26 Jan 2019 17:20:47 +0100 Subject: [PATCH] API CHANGE: ws.close -> ws.end, ws.terminate -> ws.close --- src/WebSocket.h | 11 ++++------- src/WebSocketContext.h | 4 ++-- 2 files changed, 6 insertions(+), 9 deletions(-) diff --git a/src/WebSocket.h b/src/WebSocket.h index f3ab22811..21a52f15d 100644 --- a/src/WebSocket.h +++ b/src/WebSocket.h @@ -48,6 +48,9 @@ struct WebSocket : AsyncSocket { /* See AsyncSocket */ using Super::getBufferedAmount; + /* Simple, immediate close of the socket. Emits close event */ + using Super::close; + /* Send or buffer a WebSocket frame, compressed or not. Returns false on increased user space backpressure. */ bool send(std::string_view message, uWS::OpCode opCode = uWS::OpCode::BINARY, bool compress = false) { /* Transform the message to compressed domain if requested */ @@ -87,7 +90,7 @@ struct WebSocket : AsyncSocket { } /* Send websocket close frame, emit close event, send FIN if successful */ - void close(int code, std::string_view message = {}) { + void end(int code, std::string_view message = {}) { /* Check if we already called this one */ WebSocketData *webSocketData = (WebSocketData *) us_new_socket_ext(SSL, (us_new_socket_t *) this); if (webSocketData->isShuttingDown) { @@ -122,12 +125,6 @@ struct WebSocket : AsyncSocket { webSocketContextData->closeHandler(this, code, message); } } - - /* Simple, immediate close of the socket. Emits close event */ - void terminate() { - /* This calls close event in context where it checks for isShuttingDown and either emits websocket close or not */ - Super::close(); - } }; } diff --git a/src/WebSocketContext.h b/src/WebSocketContext.h index fc1904da6..c7358df4a 100644 --- a/src/WebSocketContext.h +++ b/src/WebSocketContext.h @@ -167,7 +167,7 @@ struct WebSocketContext { if (!remainingBytes && fin && !webSocketData->controlTipLength) { if (opCode == CLOSE) { auto closeFrame = protocol::parseClosePayload(data, length); - webSocket->close(closeFrame.code, std::string_view(closeFrame.message, closeFrame.length)); + webSocket->end(closeFrame.code, std::string_view(closeFrame.message, closeFrame.length)); return true; } else { if (opCode == PING) { @@ -192,7 +192,7 @@ struct WebSocketContext { char *controlBuffer = (char *) webSocketData->fragmentBuffer.data() + webSocketData->fragmentBuffer.length() - webSocketData->controlTipLength; if (opCode == CLOSE) { protocol::CloseFrame closeFrame = protocol::parseClosePayload(controlBuffer, webSocketData->controlTipLength); - webSocket->close(closeFrame.code, std::string_view(closeFrame.message, closeFrame.length)); + webSocket->end(closeFrame.code, std::string_view(closeFrame.message, closeFrame.length)); return true; } else { if (opCode == PING) {