admin/libiscsi
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Create a wrapper function for when we add pdus to the out queue

Browse Source 
so that we can add them so that they are send in increasing itt order.
This commit is contained in:
Ronnie Sahlberg
2012-11-27 20:26:13 -08:00
parent efc556e2e9
commit 700d363a88
3 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
include/iscsi-private.h
View File

@@ -322,6 +322,9 @@ void iscsi_decrement_iface_rr(void);
void
iscsi_log_message(struct iscsi_context *iscsi, int level, const char *format, ...);
void
iscsi_add_to_outqueue(struct iscsi_context *iscsi, struct iscsi_pdu *pdu);
#ifdef __cplusplus
}
#endif

4
lib/connect.c
View File

@@ -289,7 +289,7 @@ try_again:
iscsi->statsn++;
pdu->written = 0;
SLIST_ADD_END(&iscsi->outqueue, pdu);
iscsi_add_to_outqueue(iscsi, pdu);
}
while (old_iscsi->outqueue) {
@@ -319,7 +319,7 @@ try_again:
iscsi->statsn++;
pdu->written = 0;
SLIST_ADD_END(&iscsi->outqueue, pdu);
iscsi_add_to_outqueue(iscsi, pdu);
}
if (dup2(iscsi->fd, old_iscsi->fd) == -1) {

8
lib/socket.c
View File

@@ -48,6 +48,12 @@
static uint32_t iface_rr = 0;
void
iscsi_add_to_outqueue(struct iscsi_context *iscsi, struct iscsi_pdu *pdu)
{
SLIST_ADD_END(&iscsi->outqueue, pdu);
}
void iscsi_decrement_iface_rr() {
iface_rr--;
}
@@ -596,7 +602,7 @@ iscsi_queue_pdu(struct iscsi_context *iscsi, struct iscsi_pdu *pdu)
pdu->outdata.data[ISCSI_RAW_HEADER_SIZE+0] = (crc) &0xff;
}
SLIST_ADD_END(&iscsi->outqueue, pdu);
iscsi_add_to_outqueue(iscsi, pdu);
return 0;
}