Changeset 0335620 for libcfa/src/concurrency
- Timestamp:
- May 7, 2020, 5:12:47 PM (4 years ago)
- Branches:
- ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast, new-ast-unique-expr, pthread-emulation, qualifiedEnum
- Children:
- dd4e2d7
- Parents:
- 5dadc9b
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
libcfa/src/concurrency/io.cfa
r5dadc9b r0335620 280 280 281 281 if( io_flags & CFA_CLUSTER_IO_POLLER_THREAD_SUBMITS ) { 282 sq.ready_cnt = 10;283 sq.ready = alloc (sq.ready_cnt );282 sq.ready_cnt = 32; 283 sq.ready = alloc_align( 64, sq.ready_cnt ); 284 284 for(i; sq.ready_cnt) { 285 285 sq.ready[i] = -1ul32; … … 584 584 int count; 585 585 bool again; 586 [count, again] = __drain_io( ring, &mask, 1, true );586 [count, again] = __drain_io( ring, &mask, 0, true ); 587 587 588 588 // Update statistics … … 665 665 } 666 666 667 static inline void __wake_poller( struct __io_data & ring ) __attribute__((artificial)); 667 668 static inline void __wake_poller( struct __io_data & ring ) { 668 sigval val = { 1 };669 pthread_sigqueue( ring.poller.slow.kthrd, SIGUSR1, val );669 // sigval val = { 1 }; 670 // pthread_sigqueue( ring.poller.slow.kthrd, SIGUSR1, val ); 670 671 } 671 672
Note: See TracChangeset
for help on using the changeset viewer.