Changeset 762fbc1 for libcfa/src/concurrency/io.cfa
- Timestamp:
- Aug 15, 2020, 12:20:44 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:
- 36de20d
- Parents:
- 7f51b9d (diff), 5715d43 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the(diff)
links above to see all the changes relative to each parent. - File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
libcfa/src/concurrency/io.cfa
r7f51b9d r762fbc1 359 359 360 360 // We got the lock 361 // Collect the submissions 361 362 unsigned to_submit = __collect_submitions( ring ); 363 364 // Actually submit 362 365 int ret = __io_uring_enter( ring, to_submit, false ); 363 if( ret < 0 ) { 364 unlock(ring.submit_q.lock); 365 return; 366 } 367 368 /* paranoid */ verify( ret > 0 || to_submit == 0 || (ring.ring_flags & IORING_SETUP_SQPOLL) ); 366 367 unlock(ring.submit_q.lock); 368 if( ret < 0 ) return; 369 369 370 370 // Release the consumed SQEs … … 372 372 373 373 // update statistics 374 __STATS__( true,374 __STATS__( false, 375 375 io.submit_q.submit_avg.rdy += to_submit; 376 376 io.submit_q.submit_avg.csm += ret; 377 377 io.submit_q.submit_avg.cnt += 1; 378 378 ) 379 380 unlock(ring.submit_q.lock);381 379 } 382 380 else {
Note: See TracChangeset
for help on using the changeset viewer.