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

minor style changes

Browse Source
This commit is contained in:
Ronnie Sahlberg
2012-11-28 07:40:10 -08:00
parent 4f32723b4c
commit bd86570b4f
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lib/socket.c
View File

@@ -51,15 +51,15 @@ static uint32_t iface_rr = 0;
void void
iscsi_add_to_outqueue(struct iscsi_context *iscsi, struct iscsi_pdu *pdu) iscsi_add_to_outqueue(struct iscsi_context *iscsi, struct iscsi_pdu *pdu)
{ {
struct iscsi_pdu *current = iscsi->outqueue;
struct iscsi_pdu *last = NULL;
if (iscsi->outqueue == NULL) { if (iscsi->outqueue == NULL) {
iscsi->outqueue = pdu; iscsi->outqueue = pdu;
pdu->next = NULL; pdu->next = NULL;
return; return;
} }
struct iscsi_pdu *current = iscsi->outqueue;
struct iscsi_pdu *last = NULL;
/* queue pdus in ascending order of itt. /* queue pdus in ascending order of itt.
* ensure that pakets with the same itt are kept in order. * ensure that pakets with the same itt are kept in order.
* queue pdus with itt = 0xffffffff (SNACK / DataACK) in order but at head of queue. * queue pdus with itt = 0xffffffff (SNACK / DataACK) in order but at head of queue.
@@ -332,7 +332,7 @@ iscsi_which_events(struct iscsi_context *iscsi)
{ {
int events = iscsi->is_connected ? POLLIN : POLLOUT; int events = iscsi->is_connected ? POLLIN : POLLOUT;
if (iscsi->outqueue && iscsi_serial32_compare(iscsi->outqueue->cmdsn,iscsi->maxcmdsn) <= 0) { if (iscsi->outqueue && iscsi_serial32_compare(iscsi->outqueue->cmdsn, iscsi->maxcmdsn) <= 0) {
events |= POLLOUT; events |= POLLOUT;
} }
return events; return events;
@@ -472,7 +472,7 @@ iscsi_write_to_socket(struct iscsi_context *iscsi)
while (iscsi->outqueue) { while (iscsi->outqueue) {
ssize_t total; ssize_t total;
if (iscsi_serial32_compare(iscsi->outqueue->cmdsn,iscsi->maxcmdsn) > 0) { if (iscsi_serial32_compare(iscsi->outqueue->cmdsn, iscsi->maxcmdsn) > 0) {
/* stop sending. maxcmdsn is reached */ /* stop sending. maxcmdsn is reached */
return 0; return 0;
} }