diff options
| author |   Aritra Basu <aritrbas@cisco.com> | 2024-08-27 18:05:17 -0700 |
|---|---|---|
| committer | Aritra Basu <aritrbas@cisco.com> | 2024-08-29 13:51:05 -0700 |
| commit | f0e81d247b7cd13b621262f29ed1ae6366b68b78 (patch) | |
| tree | 2f5f7bc47c7bca3bea151f61e2d7bc819430400d /src/plugins/hs_apps/vcl/vcl_test.h | |
| parent | e9bc3320192d72f817379aa4621c1dff15bdee29 (diff) | |
vcl: add support to write segments
Type: improvement
Change-Id: Icfdaed6b70b83668127656930afcb4ac3c63b234
Signed-off-by: Aritra Basu <aritrbas@cisco.com>
Diffstat (limited to 'src/plugins/hs_apps/vcl/vcl_test.h')
| -rw-r--r-- | src/plugins/hs_apps/vcl/vcl_test.h | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/src/plugins/hs_apps/vcl/vcl_test.h b/src/plugins/hs_apps/vcl/vcl_test.h index 0ce27ef84e2..2b45339099e 100644 --- a/src/plugins/hs_apps/vcl/vcl_test.h +++ b/src/plugins/hs_apps/vcl/vcl_test.h @@ -420,6 +420,39 @@ vcl_test_write (vcl_test_session_t *ts, void *buf, uint32_t nbytes) return (tx_bytes); } +static inline int +vcl_test_write_ds (vcl_test_session_t *ts) +{ + vcl_test_stats_t *stats = &ts->stats; + int tx_bytes; + + do + { + stats->tx_xacts++; + if (ts->ds[1].len) + tx_bytes = vppcom_session_write_segments (ts->fd, ts->ds, 2); + else + tx_bytes = vppcom_session_write_segments (ts->fd, ts->ds, 1); + + if (tx_bytes < 0) + errno = -tx_bytes; + if ((tx_bytes == 0) || + ((tx_bytes < 0) && ((errno == EAGAIN) || (errno == EWOULDBLOCK)))) + stats->rx_eagain++; + } + while ((tx_bytes == 0) || + ((tx_bytes < 0) && ((errno == EAGAIN) || (errno == EWOULDBLOCK)))); + + if (tx_bytes < 0) + { + vterr ("vppcom_session_write_segments()", -errno); + } + else + stats->tx_bytes += tx_bytes; + + return (tx_bytes); +} + static inline void dump_help (void) { |