File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -2559,7 +2559,7 @@ static int ring_numa_ingest_main(int argc, char **argv) {
25592559 // =========================================================================
25602560 uint64_t total_batches = 0 ;
25612561 uint64_t total_workers = 0 ;
2562- for (uint32_t i = 0 ; i < num_nodes ; i ++ ) {
2562+ for (uint32_t i = 0 ; i < ( uint32_t ) num_nodes ; i ++ ) {
25632563 total_batches += atomic_load_relaxed (& state [i ].write_idx );
25642564 total_workers += atomic_load_relaxed (& state [i ].active_workers );
25652565 }
@@ -2597,8 +2597,8 @@ static int ring_numa_ingest_main(int argc, char **argv) {
25972597
25982598 // Dynamic Stealing Threshold Scaling (Born-Local Preservation)
25992599 uint32_t scale_factor = (min_buf > 4 ) ? min_buf : 4 ;
2600- for (uint32_t n = 0 ; n < num_nodes ; n ++ ) {
2601- for (uint32_t i = 0 ; i < num_nodes ; i ++ ) {
2600+ for (uint32_t n = 0 ; n < ( uint32_t ) num_nodes ; n ++ ) {
2601+ for (uint32_t i = 0 ; i < ( uint32_t ) num_nodes ; i ++ ) {
26022602 uint32_t base = state [n ].base_steal_threshold [i ];
26032603 // Dynamic formula: (max(4, min_buf) * base_threshold) / 4
26042604 uint32_t dynamic_thresh = (scale_factor * base ) / 4 ;
You can’t perform that action at this time.
0 commit comments