return NT_STATUS_INTERNAL_ERROR;
}
- if (e->count > 0) {
- /* we have more to write */
- TEVENT_FD_WRITEABLE(xconn->transport.fde);
- return NT_STATUS_OK;
- }
-
if (e->ack.req != NULL && e->ack.started) {
int _ret;
_ret = ioctl(xconn->transport.sock, SIOCOUTQ, &value2);
}
}
+ if (e->count > 0) {
+ /* we have more to write */
+ TEVENT_FD_WRITEABLE(xconn->transport.fde);
+ return NT_STATUS_OK;
+ }
+
if (e->ack.req != NULL && e->ack.started) {
tevent_wait_done(e->ack.req);
}
xconn->smb2.send_queue_len--;
DLIST_REMOVE(xconn->smb2.send_queue, e);
+
if (e->ack.req != NULL && e->ack.started) {
DLIST_ADD_END(xconn->smb2.ack_queue, e);
continue;
}
+
talloc_free(e->mem_ctx);
}