Type: fix
Signed-off-by: Florin Coras <fcoras@cisco.com>
Change-Id: I1f981e909c45f1731ce4bdfa959b41d349e22ef1
+ c = svm_fifo_tail_chunk (f);
+ while ((c = c->next) && read < enq_max)
- c = svm_fifo_tail_chunk (f);
- while (read < enq_max)
- {
- c = c->next;
- enq_now = clib_min (c->length, enq_max - read);
- rv = BIO_read (bio, c->data, enq_now);
- read += rv > 0 ? rv : 0;
+ enq_now = clib_min (c->length, enq_max - read);
+ rv = BIO_read (bio, c->data, enq_now);
+ read += rv > 0 ? rv : 0;
- if (rv < enq_now)
- break;
- }
+ if (rv < enq_now)
+ break;
}
svm_fifo_enqueue_nocopy (f, read);
}
svm_fifo_enqueue_nocopy (f, read);
+ c = svm_fifo_tail_chunk (f);
+ while ((c = c->next) && read < enq_max)
- c = svm_fifo_tail_chunk (f);
- while (read < enq_max)
- {
- c = c->next;
- if (!c)
- break;
- enq_now = clib_min (c->length, enq_max - read);
- rv = SSL_read (ssl, c->data, enq_now);
- read += rv > 0 ? rv : 0;
-
- if (rv < enq_now)
- break;
- }
+ enq_now = clib_min (c->length, enq_max - read);
+ rv = SSL_read (ssl, c->data, enq_now);
+ read += rv > 0 ? rv : 0;
+
+ if (rv < enq_now)
+ break;
}
svm_fifo_enqueue_nocopy (f, read);
}
svm_fifo_enqueue_nocopy (f, read);
if (wrote <= 0)
return 0;
if (wrote <= 0)
return 0;
+ c = svm_fifo_head_chunk (f);
+ while ((c = c->next) && wrote < len)
- c = svm_fifo_head_chunk (f);
- while (wrote < len)
- {
- c = c->next;
- deq_now = clib_min (c->length, len - wrote);
- rv = BIO_write (bio, c->data, deq_now);
- wrote += rv > 0 ? rv : 0;
+ deq_now = clib_min (c->length, len - wrote);
+ rv = BIO_write (bio, c->data, deq_now);
+ wrote += rv > 0 ? rv : 0;
- if (rv < deq_now)
- break;
- }
+ if (rv < deq_now)
+ break;
}
svm_fifo_dequeue_drop (f, wrote);
}
svm_fifo_dequeue_drop (f, wrote);
if (wrote <= 0)
return 0;
if (wrote <= 0)
return 0;
+ c = svm_fifo_head_chunk (f);
+ while ((c = c->next) && wrote < len)
- c = svm_fifo_head_chunk (f);
- while (wrote < len)
- {
- c = c->next;
- deq_now = clib_min (c->length, len - wrote);
- rv = SSL_write (ssl, c->data, deq_now);
- wrote += rv > 0 ? rv : 0;
+ deq_now = clib_min (c->length, len - wrote);
+ rv = SSL_write (ssl, c->data, deq_now);
+ wrote += rv > 0 ? rv : 0;
- if (rv < deq_now)
- break;
- }
+ if (rv < deq_now)
+ break;
}
svm_fifo_dequeue_drop (f, wrote);
}
svm_fifo_dequeue_drop (f, wrote);