Skip to content

Commit

Permalink
* FIX [websocket] nanomsg sync fix
Browse files Browse the repository at this point in the history
Signed-off-by: wayne <[email protected]>
  • Loading branch information
StargazerWayne committed Dec 27, 2023
1 parent 5c2d8c1 commit c0fba12
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 3 deletions.
2 changes: 1 addition & 1 deletion src/supplemental/http/http_api.h
Original file line number Diff line number Diff line change
Expand Up @@ -219,7 +219,7 @@ extern int nni_http_server_start(nni_http_server *);
// Connections will be aborted but may not have terminated all the way.
extern void nni_http_server_stop(nni_http_server *);

/ nni_http_server_close closes down the socket, but does not shut down
// nni_http_server_close closes down the socket, but does not shut down
// any connections that are already open. This is useful for example
// when shutting down an SP listener, and we don't want to break established
// sessions.
Expand Down
2 changes: 0 additions & 2 deletions src/supplemental/websocket/websocket.c
Original file line number Diff line number Diff line change
Expand Up @@ -643,9 +643,7 @@ ws_write_cb(void *arg)
}
}
if (ws->peer_closed) {
ws->wclose = false;
if (ws->wclose) { // could assert this?
nni_aio_finish(ws->closeaio, 0, 0);
ws->wclose = false;
nni_aio_finish(ws->closeaio, 0, 0);
}
Expand Down

0 comments on commit c0fba12

Please sign in to comment.