diff --git a/src/Http/WebSocketSession.h b/src/Http/WebSocketSession.h index ed9dd140..440a99e7 100644 --- a/src/Http/WebSocketSession.h +++ b/src/Http/WebSocketSession.h @@ -177,6 +177,7 @@ protected: switch (header._opcode){ case WebSocketHeader::CLOSE:{ HttpSessionType::encode(header,nullptr); + HttpSessionType::shutdown(SockException(Err_shutdown, "recv close request from client")); } break; case WebSocketHeader::PING:{