|
|
|
@ -168,14 +168,12 @@ serverRun(Server this) |
|
|
|
|
|
|
|
message = (HttpMessage)streamWriterWrite(writer, fd); |
|
|
|
|
|
|
|
if (NULL != message && writer->state == HTTP_RESPONSE_GET) { |
|
|
|
if (httpMessageHasKeepAlive(message)) { |
|
|
|
(this->fds)[i].events &= ~POLLOUT; |
|
|
|
} |
|
|
|
else { |
|
|
|
delete(&message); |
|
|
|
serverCloseConn(this, i); |
|
|
|
} |
|
|
|
if (NULL == message) { |
|
|
|
(this->fds)[i].events &= ~POLLOUT; |
|
|
|
} |
|
|
|
else { |
|
|
|
delete(&message); |
|
|
|
serverCloseConn(this, i); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|