Ignore:
Timestamp:
May 1, 2020, 1:10:58 PM (4 years ago)
Author:
Thierry Delisle <tdelisle@…>
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
Message:

Added second io printing group with less verbose prints.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • libcfa/src/concurrency/io.cfa

    r93f7c001 r0a805f2  
    1515
    1616// #define __CFA_DEBUG_PRINT_IO__
     17// #define __CFA_DEBUG_PRINT_IO_CORE__
    1718
    1819#include "kernel.hfa"
     
    212213        void __kernel_io_finish_start( cluster & this ) {
    213214                #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);
    215216                        (this.io.poller.fast){ this };
    216217                        __thrd_start( this.io.poller.fast, main );
     
    218219
    219220                // 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);
    221222                this.io.poller.slow.stack = __create_pthread( &this.io.poller.slow.kthrd, __io_poller_slow, &this );
    222223        }
    223224
    224225        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);
    226227                // Notify the poller thread of the shutdown
    227228                __atomic_store_n(&this.io.done, true, __ATOMIC_SEQ_CST);
     
    238239                free( this.io.poller.slow.stack );
    239240
    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);
    241242
    242243                #if defined(__CFA_IO_POLLING_USER__)
     
    246247                        ^(this.io.poller.fast){};
    247248
    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);
    249250                #endif
    250251        }
     
    378379                                int count = __drain_io( ring, &mask, 1, true );
    379380                                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);
    381382                                        __unpark( &ring.poller.fast.thrd __cfaabi_dbg_ctx2 );
    382383                                        wait( ring.poller.sem );
     
    408409                                else {
    409410                                        // 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);
    411412                                        post( this.ring->poller.sem );
    412413                                        park( __cfaabi_dbg_ctx );
Note: See TracChangeset for help on using the changeset viewer.