mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-24 12:20:41 +00:00
socket id can't be less then 0
This commit is contained in:
@@ -942,6 +942,8 @@ socket_server_connect(struct socket_server *ss, uintptr_t opaque, const char * a
|
|||||||
// return -1 when error
|
// return -1 when error
|
||||||
int64_t
|
int64_t
|
||||||
socket_server_send(struct socket_server *ss, int id, const void * buffer, int sz) {
|
socket_server_send(struct socket_server *ss, int id, const void * buffer, int sz) {
|
||||||
|
if (id < 0)
|
||||||
|
return -1;
|
||||||
struct socket * s = &ss->slot[id % MAX_SOCKET];
|
struct socket * s = &ss->slot[id % MAX_SOCKET];
|
||||||
if (s->id != id || s->type == SOCKET_TYPE_INVALID) {
|
if (s->id != id || s->type == SOCKET_TYPE_INVALID) {
|
||||||
return -1;
|
return -1;
|
||||||
@@ -958,6 +960,8 @@ socket_server_send(struct socket_server *ss, int id, const void * buffer, int sz
|
|||||||
|
|
||||||
void
|
void
|
||||||
socket_server_send_lowpriority(struct socket_server *ss, int id, const void * buffer, int sz) {
|
socket_server_send_lowpriority(struct socket_server *ss, int id, const void * buffer, int sz) {
|
||||||
|
if (id < 0)
|
||||||
|
return;
|
||||||
struct socket * s = &ss->slot[id % MAX_SOCKET];
|
struct socket * s = &ss->slot[id % MAX_SOCKET];
|
||||||
if (s->id != id || s->type == SOCKET_TYPE_INVALID) {
|
if (s->id != id || s->type == SOCKET_TYPE_INVALID) {
|
||||||
return;
|
return;
|
||||||
|
|||||||
Reference in New Issue
Block a user