log(DEBUG,"Write error on socket: %s",strerror(errno));
this->OnError(I_ERR_WRITE);
this->state = I_ERROR;
+ this->ClosePending = true;
return true;
}
}
}
- return (fd > -1);
+ return (fd < 0);
}
bool InspSocket::Timeout(time_t current)
this->OnError(I_ERR_TIMEOUT);
timeout = true;
this->state = I_ERROR;
+ this->ClosePending = true;
return true;
}
return this->FlushWriteBuffer();
* Both FlushWriteBuffer AND the return result of OnDataReady must
* return true for this to be ok.
*/
- if (!this->FlushWriteBuffer())
+ if (this->FlushWriteBuffer())
return false;
return n;
break;