lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-24 12:20:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

raise error on start, fix #1374

Browse Source
This commit is contained in:
Cloud Wu
2021-04-07 03:39:22 +00:00
parent f9dc6a3756
commit e69f876867
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
skynet-src/socket_server.c
View File

@@ -1188,8 +1188,11 @@ resume_socket(struct socket_server *ss, struct request_resumepause *request, str
result->data = "invalid socket"; result->data = "invalid socket";
return SOCKET_ERR; return SOCKET_ERR;
} }
if (halfclose_read(s)) if (halfclose_read(s)) {
return -1; // The closing socket may be in transit, so raise an error. See https://github.com/cloudwu/skynet/issues/1374
result->data = "socket closed";
return SOCKET_ERR;
}
struct socket_lock l; struct socket_lock l;
socket_lock_init(s, &l); socket_lock_init(s, &l);
if (enable_read(ss, s, true)) { if (enable_read(ss, s, true)) {
@@ -1208,7 +1211,7 @@ resume_socket(struct socket_server *ss, struct request_resumepause *request, str
result->data = "transfer"; result->data = "transfer";
return SOCKET_OPEN; return SOCKET_OPEN;
} }
// if s->type == SOCKET_TYPE_HALFCLOSE_* , SOCKET_CLOSE message will send later // if s->type == SOCKET_TYPE_HALFCLOSE_WRITE , SOCKET_CLOSE message will send later
return -1; return -1;
} }