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

Merge pull request #17 from footer/master

Browse Source 
bug fix in gate
This commit is contained in:
云风
2013-06-16 02:58:07 -07:00
parent c8b5c9ed89 e2c33c3ef6
commit 0e34fdd249
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
gate/mread.c
View File

@@ -449,11 +449,12 @@ _read_one(struct mread_pool * self) {
if (ret == LISTENSOCKET) {
return ret;
}
if (writeflag) {
if (writeflag && ret->status != SOCKET_CLOSED) {
client_send(&ret->client, ret->fd);
try_close(self, ret);
}
if (readflag)
if (readflag && ret->status != SOCKET_HALFCLOSE &&
ret->status != SOCKET_CLOSED)
return ret;
}
}
@@ -527,10 +528,10 @@ mread_poll(struct mread_pool * self , int timeout) {
return self->active;
}
}
if (self->closed > 0 ) {
return _report_closed(self);
}
if (self->queue_head >= self->queue_len) {
if (self->closed > 0 ) {
return _report_closed(self);
}
if (_read_queue(self, timeout) == -1) {
self->active = -1;
return -1;
@@ -778,8 +779,7 @@ mread_closed(struct mread_pool * self) {
return 0;
}
struct socket * s = &self->sockets[self->active];
if ((s->status == SOCKET_CLOSED ||
s->status == SOCKET_HALFCLOSE) && s->node == NULL) {
if (s->status == SOCKET_CLOSED && s->node == NULL) {
mread_yield(self);
return 1;
}