Changeset 0a805f2 for libcfa/src
- Timestamp:
- May 1, 2020, 1:10:58 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:
- 6136ecc
- Parents:
- 93f7c001
- Location:
- libcfa/src
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
libcfa/src/bits/debug.hfa
r93f7c001 r0a805f2 107 107 # define __CFADBG_PRINT_GROUP_io(...) ((void)0) 108 108 #endif 109 #if defined(__CFA_DEBUG_PRINT__) || defined(__CFA_DEBUG_PRINT_IO__) || defined(__CFA_DEBUG_PRINT_IO_CORE__) 110 # define __CFADBG_PRINT_GROUP_io_core(...) __VA_ARGS__ 111 #else 112 # define __CFADBG_PRINT_GROUP_io_core(...) ((void)0) 113 #endif 109 114 #if defined(__CFA_DEBUG_PRINT__) || defined(__CFA_DEBUG_PRINT_MONITOR__) 110 115 # define __CFADBG_PRINT_GROUP_monitor(...) __VA_ARGS__ -
libcfa/src/concurrency/io.cfa
r93f7c001 r0a805f2 15 15 16 16 // #define __CFA_DEBUG_PRINT_IO__ 17 // #define __CFA_DEBUG_PRINT_IO_CORE__ 17 18 18 19 #include "kernel.hfa" … … 212 213 void __kernel_io_finish_start( cluster & this ) { 213 214 #if defined(__CFA_IO_POLLING_USER__) 214 __cfadbg_print_safe(io , "Kernel I/O : Creating fast poller for cluter %p\n", &this);215 __cfadbg_print_safe(io_core, "Kernel I/O : Creating fast poller for cluter %p\n", &this); 215 216 (this.io.poller.fast){ this }; 216 217 __thrd_start( this.io.poller.fast, main ); … … 218 219 219 220 // Create the poller thread 220 __cfadbg_print_safe(io , "Kernel I/O : Creating slow poller for cluter %p\n", &this);221 __cfadbg_print_safe(io_core, "Kernel I/O : Creating slow poller for cluter %p\n", &this); 221 222 this.io.poller.slow.stack = __create_pthread( &this.io.poller.slow.kthrd, __io_poller_slow, &this ); 222 223 } 223 224 224 225 void __kernel_io_prepare_stop( cluster & this ) { 225 __cfadbg_print_safe(io , "Kernel I/O : Stopping pollers for cluster\n", &this);226 __cfadbg_print_safe(io_core, "Kernel I/O : Stopping pollers for cluster\n", &this); 226 227 // Notify the poller thread of the shutdown 227 228 __atomic_store_n(&this.io.done, true, __ATOMIC_SEQ_CST); … … 238 239 free( this.io.poller.slow.stack ); 239 240 240 __cfadbg_print_safe(io , "Kernel I/O : Slow poller stopped for cluster\n", &this);241 __cfadbg_print_safe(io_core, "Kernel I/O : Slow poller stopped for cluster\n", &this); 241 242 242 243 #if defined(__CFA_IO_POLLING_USER__) … … 246 247 ^(this.io.poller.fast){}; 247 248 248 __cfadbg_print_safe(io , "Kernel I/O : Fast poller stopped for cluster\n", &this);249 __cfadbg_print_safe(io_core, "Kernel I/O : Fast poller stopped for cluster\n", &this); 249 250 #endif 250 251 } … … 378 379 int count = __drain_io( ring, &mask, 1, true ); 379 380 if(count > 0) { 380 __cfadbg_print_safe(io , "Kernel I/O : Moving to ring %p to fast poller\n", &ring);381 __cfadbg_print_safe(io_core, "Kernel I/O : Moving to ring %p to fast poller\n", &ring); 381 382 __unpark( &ring.poller.fast.thrd __cfaabi_dbg_ctx2 ); 382 383 wait( ring.poller.sem ); … … 408 409 else { 409 410 // We didn't get anything baton pass to the slow poller 410 __cfadbg_print_safe(io , "Kernel I/O : Moving to ring %p to slow poller\n", &this.ring);411 __cfadbg_print_safe(io_core, "Kernel I/O : Moving to ring %p to slow poller\n", &this.ring); 411 412 post( this.ring->poller.sem ); 412 413 park( __cfaabi_dbg_ctx );
Note: See TracChangeset
for help on using the changeset viewer.