quic: tx_buf_sz pow2

Author: akhinvasara-jumptrading

src/app/shared_dev/commands/bench/fd_benchs.c

@@ -176,7 +176,7 @@ populate_quic_limits( fd_quic_limits_t * limits ) {
   limits->handshake_cnt = limits->conn_cnt;
   limits->conn_id_cnt = 16;
   limits->inflight_frame_cnt = 1500;
-  limits->tx_buf_sz = FD_TXN_MTU;
+  limits->tx_buf_sz = 1UL<<11;
   limits->stream_pool_cnt = 1UL<<16;
   limits->stream_id_cnt = 1UL<<16;
 }

src/discof/send/fd_send_tile.c

@@ -48,7 +48,7 @@ fd_quic_limits_t quic_limits = {
   .inflight_frame_cnt          = 16UL * MAX_STAKED_LEADERS,
   .min_inflight_frame_cnt_conn = 4UL,
   .stream_id_cnt               = 16UL,
-  .tx_buf_sz                   = FD_TXN_MTU,
+  .tx_buf_sz                   = 1UL<<11,
   .stream_pool_cnt             = 2048UL
 };
 

src/waltz/quic/fd_quic_stream.c

@@ -75,7 +75,7 @@ fd_quic_buffer_load( fd_quic_buffer_t * buf,
 
   if( mtail >= mhead ) {
     /* free space split */
-    ulong end_sz = cap - mhead;
+    ulong end_sz = cap - mtail;
     if( data_sz <= end_sz ) {
       /* consists entirely of space at end of buffer */
       fd_memcpy( data, raw + mtail, data_sz );
@@ -97,6 +97,8 @@ fd_quic_stream_align( void );
 
 ulong
 fd_quic_stream_footprint( ulong tx_buf_sz ) {
+  if( FD_UNLIKELY( !fd_ulong_is_pow2( tx_buf_sz ) ) ) return 0UL;
+
   ulong align           = fd_quic_stream_align();
   ulong offs            = 0ul;
 

src/waltz/quic/fd_quic_stream_pool.c

@@ -13,6 +13,7 @@ fd_quic_stream_pool_footprint( ulong count, ulong tx_buf_sz ) {
       FD_QUIC_STREAM_POOL_ALIGN );
 
   ulong stream_foot = fd_quic_stream_footprint( tx_buf_sz );
+  if( FD_UNLIKELY( !stream_foot ) ) return 0UL;
 
   return foot + stream_foot * count;
 }
@@ -38,6 +39,7 @@ fd_quic_stream_pool_new( void * mem, ulong count, ulong tx_buf_sz ) {
   offs += fd_ulong_align_up( sizeof( fd_quic_stream_pool_t ), FD_QUIC_STREAM_POOL_ALIGN );
 
   ulong stream_foot = fd_quic_stream_footprint( tx_buf_sz );
+  if( FD_UNLIKELY( !stream_foot ) ) { FD_LOG_WARNING(( "stream_foot is 0" )); return NULL; }
 
   FD_QUIC_STREAM_LIST_SENTINEL( pool->head );
 

src/waltz/quic/tests/test_quic_bw.c

@@ -94,7 +94,7 @@ main( int     argc,
   float        loss     = fd_env_strip_cmdline_float ( &argc, &argv, "--loss",      NULL, 0.0f                         );
   float        reorder  = fd_env_strip_cmdline_float ( &argc, &argv, "--reorder",   NULL, 0.0f                         );
   float        duration = fd_env_strip_cmdline_float ( &argc, &argv, "--duration",  NULL, 10.0f                        );
-  ushort       sz       = fd_env_strip_cmdline_ushort( &argc, &argv, "--sz",        NULL, FRAG_SZ                      );
+  ushort       sz       = fd_env_strip_cmdline_ushort( &argc, &argv, "--sz",        NULL, 1UL<<10                      );
   FD_TEST( sz<=FRAG_SZ );
 
   ulong page_sz = fd_cstr_to_shmem_page_sz( _page_sz );