mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-24 20:23:06 +00:00
Do not close on error, see #1373
This commit is contained in:
@@ -1421,8 +1421,6 @@ forward_message_tcp(struct socket_server *ss, struct socket *s, struct socket_lo
|
|||||||
case AGAIN_WOULDBLOCK:
|
case AGAIN_WOULDBLOCK:
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
// close when error
|
|
||||||
force_close(ss, s, l, result);
|
|
||||||
result->data = strerror(errno);
|
result->data = strerror(errno);
|
||||||
return SOCKET_ERR;
|
return SOCKET_ERR;
|
||||||
}
|
}
|
||||||
@@ -1737,7 +1735,6 @@ socket_server_poll(struct socket_server *ss, struct socket_message * result, int
|
|||||||
return type;
|
return type;
|
||||||
}
|
}
|
||||||
if (e->error) {
|
if (e->error) {
|
||||||
// close when error
|
|
||||||
int error;
|
int error;
|
||||||
socklen_t len = sizeof(error);
|
socklen_t len = sizeof(error);
|
||||||
int code = getsockopt(s->fd, SOL_SOCKET, SO_ERROR, &error, &len);
|
int code = getsockopt(s->fd, SOL_SOCKET, SO_ERROR, &error, &len);
|
||||||
@@ -1749,7 +1746,6 @@ socket_server_poll(struct socket_server *ss, struct socket_message * result, int
|
|||||||
} else {
|
} else {
|
||||||
err = "Unknown error";
|
err = "Unknown error";
|
||||||
}
|
}
|
||||||
force_close(ss, s, &l, result);
|
|
||||||
result->data = (char *)err;
|
result->data = (char *)err;
|
||||||
return SOCKET_ERR;
|
return SOCKET_ERR;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user