|
190 | 190 | #define STEM_LAZY (0L)
|
191 | 191 | #endif
|
192 | 192 |
|
193 |
| -#define STEM_SHUTDOWN_SEQ (ULONG_MAX-1UL) |
194 |
| - |
195 | 193 | static inline void
|
196 | 194 | STEM_(in_update)( fd_stem_tile_in_t * in ) {
|
197 | 195 | fd_fseq_update( in->fseq, in->seq );
|
@@ -433,10 +431,6 @@ STEM_(run1)( ulong in_cnt,
|
433 | 431 | ulong out_idx = cons_out[ cons_idx ];
|
434 | 432 | ulong cons_cr_avail = (ulong)fd_long_max( (long)out_depth[ out_idx ]-fd_long_max( fd_seq_diff( out_seq[ out_idx ], cons_seq[ cons_idx ] ), 0L ), 0L );
|
435 | 433 |
|
436 |
| - /* If a reliable consumer exits, they can set the credit |
437 |
| - return fseq to STEM_SHUTDOWN_SEQ to indicate they are no |
438 |
| - longer actively consuming. */ |
439 |
| - cons_cr_avail = fd_ulong_if( cons_seq[ cons_idx ]==STEM_SHUTDOWN_SEQ, out_depth[ out_idx ], cons_cr_avail ); |
440 | 434 | slowest_cons = fd_ulong_if( cons_cr_avail<min_cr_avail, cons_idx, slowest_cons );
|
441 | 435 |
|
442 | 436 | cr_avail[ out_idx ] = fd_ulong_min( cr_avail[ out_idx ], cons_cr_avail );
|
@@ -789,7 +783,7 @@ STEM_(run)( fd_topo_t * topo,
|
789 | 783 | ulong fseq_id = tile->in_link_fseq_obj_id[ i ];
|
790 | 784 | ulong * fseq = fd_fseq_join( fd_topo_obj_laddr( topo, fseq_id ) );
|
791 | 785 | FD_TEST( fseq );
|
792 |
| - fd_fseq_update( fseq, STEM_SHUTDOWN_SEQ ); |
| 786 | + fd_fseq_update( fseq, ULONG_MAX ); |
793 | 787 | }
|
794 | 788 | }
|
795 | 789 | }
|
|
0 commit comments