return 0;
}
+faim_internal int aim_tx_enqueue(struct aim_session_t *sess, struct command_tx_struct *command)
+{
+ /*
+ * If we want to send a connection thats inprogress, we have to force
+ * them to use the queue based version. Otherwise, use whatever they
+ * want.
+ */
+ if (command && command->conn && (command->conn->status & AIM_CONN_STATUS_INPROGRESS)) {
+ return aim_tx_enqueue__queuebased(sess, command);
+ }
+ return (*sess->tx_enqueue)(sess, command);
+}
+
/*
* aim_get_next_txseqnum()
*
} else if (cur->hdrtype == AIM_FRAMETYPE_OFT) {
int z = 0;
- z += aimutil_put8(curPacket+z, 0x4f);
- z += aimutil_put8(curPacket+z, 0x44);
- z += aimutil_put8(curPacket+z, 0x43);
- z += aimutil_put8(curPacket+z, 0x32);
+ z += aimutil_put8(curPacket+z, cur->hdr.oft.magic[0]);
+ z += aimutil_put8(curPacket+z, cur->hdr.oft.magic[1]);
+ z += aimutil_put8(curPacket+z, cur->hdr.oft.magic[2]);
+ z += aimutil_put8(curPacket+z, cur->hdr.oft.magic[3]);
z += aimutil_put16(curPacket+z, cur->hdr.oft.hdr2len + 8);
z += aimutil_put16(curPacket+z, cur->hdr.oft.type);
if (send(cur->conn->fd, curPacket, buflen, 0) != buflen) {
faim_mutex_unlock(&cur->conn->active);
cur->sent = 1;
- aim_conn_kill(sess, &cur->conn);
+ aim_conn_close(cur->conn);
return 0; /* bail out */
}
/* only process if its unlocked and unsent */
if (!cur->lock && !cur->sent) {
+ if (cur->conn && (cur->conn->status & AIM_CONN_STATUS_INPROGRESS))
+ continue;
+
/*
* And now for the meager attempt to force transmit
* latency and avoid missed messages.