ClabureDB: Classified Bug-Reports Database

   #include "platform.h"
   #include "pc.h"
   #include "di_defs.h"
   #include "debug_if.h"
   #include "divasync.h"
   #include "kst_ifc.h"
   #include "maintidi.h"
   #include "man_defs.h"
   
  /*
    LOCALS
    */
  #define DBG_MAGIC (0x47114711L)
  
  static void DI_register (void *arg);
  static void DI_deregister (pDbgHandle hDbg);
  static void DI_format (int do_lock, word id, int type, char *format, va_list argument_list);
  static void DI_format_locked   (word id, int type, char *format, va_list argument_list);
  static void DI_format_old (word id, char *format, va_list ap) { }
  static void DiProcessEventLog (unsigned short id, unsigned long msgID, va_list ap) { }
  static void single_p (byte * P, word * PLength, byte Id);
  static void diva_maint_xdi_cb (ENTITY* e);
  static word SuperTraceCreateReadReq (byte* P, const char* path);
  static int diva_mnt_cmp_nmbr (const char* nmbr);
  static void diva_free_dma_descriptor (IDI_CALL request, int nr);
  static int diva_get_dma_descriptor (IDI_CALL request, dword *dma_magic);
  void diva_mnt_internal_dprintf (dword drv_id, dword type, char* p, ...);
  
  static dword MaxDumpSize = 256 ;
  static dword MaxXlogSize = 2 + 128 ;
  static char  TraceFilter[DIVA_MAX_SELECTIVE_FILTER_LENGTH+1];
  static int TraceFilterIdent   = -1;
  static int TraceFilterChannel = -1;
  
  typedef struct _diva_maint_client {
    dword       sec;
    dword       usec;
    pDbgHandle  hDbg;
    char        drvName[128];
    dword       dbgMask;
    dword       last_dbgMask;
    IDI_CALL    request;
    _DbgHandle_ Dbg;
    int         logical;
    int         channels;
    diva_strace_library_interface_t* pIdiLib;
    BUFFERS     XData;
    char        xbuffer[2048+512];
    byte*       pmem;
    int         request_pending;
    int         dma_handle;
  } diva_maint_client_t;
  static diva_maint_client_t clients[MAX_DESCRIPTORS];
  
  static void diva_change_management_debug_mask (diva_maint_client_t* pC, dword old_mask);
  
  static void diva_maint_error (void* user_context,
                                diva_strace_library_interface_t* hLib,
                                int Adapter,
                                int error,
                                const char* file,
                                int line);
  static void diva_maint_state_change_notify (void* user_context,
                                              diva_strace_library_interface_t* hLib,
                                              int Adapter,
                                              diva_trace_line_state_t* channel,
                                              int notify_subject);
  static void diva_maint_trace_notify (void* user_context,
                                       diva_strace_library_interface_t* hLib,
                                       int Adapter,
                                       void* xlog_buffer,
                                       int length);
  
  
  
  typedef struct MSG_QUEUE {
          dword        Size;                /* total size of queue (constant)        */
          byte        *Base;                /* lowest address (constant)                */
          byte        *High;                /* Base + Size (constant)                */
          byte        *Head;                /* first message in queue (if any)        */
          byte        *Tail;                /* first free position                        */
          byte        *Wrap;                /* current wraparound position                 */
          dword        Count;                /* current no of bytes in queue                */
  } MSG_QUEUE;
  
  typedef struct MSG_HEAD {
          volatile dword        Size;                /* size of data following MSG_HEAD        */
  #define        MSG_INCOMPLETE        0x8000        /* ored to Size until queueCompleteMsg         */
  } MSG_HEAD;
  
  #define queueCompleteMsg(p) do{ ((MSG_HEAD *)p - 1)->Size &= ~MSG_INCOMPLETE; }while(0)
  #define queueCount(q)        ((q)->Count)
  #define MSG_NEED(size) \
          ( (sizeof(MSG_HEAD) + size + sizeof(dword) - 1) & ~(sizeof(dword) - 1) )
  
  static void queueInit (MSG_QUEUE *Q, byte *Buffer, dword sizeBuffer) {
          Q->Size = sizeBuffer;
          Q->Base = Q->Head = Q->Tail = Buffer;
          Q->High = Buffer + sizeBuffer;
         Q->Wrap = NULL;
         Q->Count= 0;
 }
 
 static byte *queueAllocMsg (MSG_QUEUE *Q, word size) {
         /* Allocate 'size' bytes at tail of queue which will be filled later
    * directly with callers own message header info and/or message.
    * An 'alloced' message is marked incomplete by oring the 'Size' field
    * with MSG_INCOMPLETE.
    * This must be reset via queueCompleteMsg() after the message is filled.
    * As long as a message is marked incomplete queuePeekMsg() will return
    * a 'queue empty' condition when it reaches such a message.  */
 
         MSG_HEAD *Msg;
         word need = MSG_NEED(size);
 
         if (Q->Tail == Q->Head) {
                 if (Q->Wrap || need > Q->Size) {
                         return NULL; /* full */
                 }
                 goto alloc; /* empty */
         }
         
         if (Q->Tail > Q->Head) {
                 if (Q->Tail + need <= Q->High) goto alloc; /* append */
                 if (Q->Base + need > Q->Head) {
                         return NULL; /* too much */
                 }
                 /* wraparound the queue (but not the message) */
                 Q->Wrap = Q->Tail;
                 Q->Tail = Q->Base;
                 goto alloc;
         }
 
         if (Q->Tail + need > Q->Head) {
                 return NULL; /* too much */
         }
 
 alloc:
         Msg = (MSG_HEAD *)Q->Tail;
 
         Msg->Size = size | MSG_INCOMPLETE;
 
         Q->Tail         += need;
         Q->Count += size;
 
 
 
         return ((byte*)(Msg + 1));
 }
 
 static void queueFreeMsg (MSG_QUEUE *Q) {
 /* Free the message at head of queue */
 
         word size = ((MSG_HEAD *)Q->Head)->Size & ~MSG_INCOMPLETE;
 
         Q->Head  += MSG_NEED(size);
         Q->Count -= size;
 
         if (Q->Wrap) {
                 if (Q->Head >= Q->Wrap) {
                         Q->Head = Q->Base;
                         Q->Wrap = NULL;
                 }
         } else if (Q->Head >= Q->Tail) {
                 Q->Head = Q->Tail = Q->Base;
         }
 }
 
 static byte *queuePeekMsg (MSG_QUEUE *Q, word *size) {
         /* Show the first valid message in queue BUT DON'T free the message.
    * After looking on the message contents it can be freed queueFreeMsg()
    * or simply remain in message queue.  */
 
         MSG_HEAD *Msg = (MSG_HEAD *)Q->Head;
 
         if (((byte *)Msg == Q->Tail && !Q->Wrap) ||
             (Msg->Size & MSG_INCOMPLETE)) {
                 return NULL;
         } else {
                 *size = Msg->Size;
                 return ((byte *)(Msg + 1));
         }
 }
 
 /*
   Message queue header
   */
 static MSG_QUEUE*          dbg_queue;
 static byte*               dbg_base;
 static int                 external_dbg_queue;
 static diva_os_spin_lock_t dbg_q_lock;
 static diva_os_spin_lock_t dbg_adapter_lock;
 static int                 dbg_q_busy;
 static volatile dword      dbg_sequence;
 static dword               start_sec;
 static dword               start_usec;
 
 /*
         INTERFACE:
     Initialize run time queue structures.
     base:    base of the message queue
     length:  length of the message queue
     do_init: perfor queue reset
 
     return:  zero on success, -1 on error
   */
 int diva_maint_init (byte* base, unsigned long length, int do_init) {
   if (dbg_queue || (!base) || (length < (4096*4))) {
     return (-1);
   }
 
   TraceFilter[0]     =  0;
   TraceFilterIdent   = -1;
   TraceFilterChannel = -1;
 
   dbg_base = base;
 
   diva_os_get_time (&start_sec, &start_usec);
 
   *(dword*)base  = (dword)DBG_MAGIC; /* Store Magic */
   base   += sizeof(dword);
   length -= sizeof(dword);
 
   *(dword*)base = 2048; /* Extension Field Length */
   base   += sizeof(dword);
   length -= sizeof(dword);
 
   strcpy (base, "KERNEL MODE BUFFER\n");
   base   += 2048;
   length -= 2048;
 
   *(dword*)base = 0; /* Terminate extension */
   base   += sizeof(dword);
   length -= sizeof(dword);
 
   *(void**)base  =  (void*)(base+sizeof(void*)); /* Store Base  */
   base   += sizeof(void*);
   length -= sizeof(void*);
 
   dbg_queue = (MSG_QUEUE*)base;
   queueInit (dbg_queue, base + sizeof(MSG_QUEUE), length - sizeof(MSG_QUEUE) - 512);
   external_dbg_queue = 0;
 
   if (!do_init) {
     external_dbg_queue = 1; /* memory was located on the external device */
   }
 
 
         if (diva_os_initialize_spin_lock (&dbg_q_lock, "dbg_init")) {
     dbg_queue = NULL;
     dbg_base = NULL;
     external_dbg_queue = 0;
                 return (-1);
   }
 
         if (diva_os_initialize_spin_lock (&dbg_adapter_lock, "dbg_init")) {
     diva_os_destroy_spin_lock(&dbg_q_lock, "dbg_init");
     dbg_queue = NULL;
     dbg_base = NULL;
     external_dbg_queue = 0;
                 return (-1);
   }
 
   return (0);
 }
 
 /*
   INTERFACE:
     Finit at unload time
     return address of internal queue or zero if queue
     was external
   */
 void* diva_maint_finit (void) {
   void* ret = (void*)dbg_base;
   int i;
 
   dbg_queue = NULL;
   dbg_base  = NULL;
 
   if (ret) {
     diva_os_destroy_spin_lock(&dbg_q_lock, "dbg_finit");
     diva_os_destroy_spin_lock(&dbg_adapter_lock, "dbg_finit");
   }
 
   if (external_dbg_queue) {
     ret = NULL;
   }
   external_dbg_queue = 0;
 
   for (i = 1; i < ARRAY_SIZE(clients); i++) {
     if (clients[i].pmem) {
       diva_os_free (0, clients[i].pmem);
     }
   }
 
   return (ret);
 }
 
 /*
   INTERFACE:
     Return amount of messages in debug queue
   */
 dword diva_dbg_q_length (void) {
         return (dbg_queue ? queueCount(dbg_queue)        : 0);
 }
 
 /*
   INTERFACE:
     Lock message queue and return the pointer to the first
     entry.
   */
 diva_dbg_entry_head_t* diva_maint_get_message (word* size,
                                                diva_os_spin_lock_magic_t* old_irql) {
   diva_dbg_entry_head_t*     pmsg = NULL;
 
   diva_os_enter_spin_lock (&dbg_q_lock, old_irql, "read");
   if (dbg_q_busy) {
     diva_os_leave_spin_lock (&dbg_q_lock, old_irql, "read_busy");
     return NULL;
   }
   dbg_q_busy = 1;
 
   if (!(pmsg = (diva_dbg_entry_head_t*)queuePeekMsg (dbg_queue, size))) {
     dbg_q_busy = 0;
     diva_os_leave_spin_lock (&dbg_q_lock, old_irql, "read_empty");
   }
 
   return (pmsg);
 }
 
 /*
   INTERFACE:
     acknowledge last message and unlock queue
   */
 void diva_maint_ack_message (int do_release,
                              diva_os_spin_lock_magic_t* old_irql) {
         if (!dbg_q_busy) {
                 return;
         }
         if (do_release) {
                 queueFreeMsg (dbg_queue);
         }
         dbg_q_busy = 0;
   diva_os_leave_spin_lock (&dbg_q_lock, old_irql, "read_ack");
 }
 
 
 /*
   INTERFACE:
     PRT COMP function used to register
     with MAINT adapter or log in compatibility
     mode in case older driver version is connected too
   */
 void diva_maint_prtComp (char *format, ...) {
   void    *hDbg;
   va_list ap;
 
   if (!format)
     return;
 
   va_start(ap, format);
 
   /*
     register to new log driver functions
    */
   if ((format[0] == 0) && ((unsigned char)format[1] == 255)) {
     hDbg = va_arg(ap, void *); /* ptr to DbgHandle */
     DI_register (hDbg);
   }
 
   va_end (ap);
 }
 
 static void DI_register (void *arg) {
   diva_os_spin_lock_magic_t old_irql;
   dword sec, usec;
   pDbgHandle          hDbg ;
   int id, free_id = -1, best_id = 0;
   
   diva_os_get_time (&sec, &usec);
 
         hDbg = (pDbgHandle)arg ;
   /*
     Check for bad args, specially for the old obsolete debug handle
     */
   if ((hDbg == NULL) ||
       ((hDbg->id == 0) && (((_OldDbgHandle_ *)hDbg)->id == -1)) ||
       (hDbg->Registered != 0)) {
                 return ;
   }
 
   diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "register");
 
   for (id = 1; id < ARRAY_SIZE(clients); id++) {
     if (clients[id].hDbg == hDbg) {
       /*
         driver already registered
         */
       diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "register");
       return;
     }
     if (clients[id].hDbg) { /* slot is busy */
       continue;
     }
     free_id = id;
     if (!strcmp (clients[id].drvName, hDbg->drvName)) {
       /*
         This driver was already registered with this name
         and slot is still free - reuse it
         */
       best_id = 1;
       break;
     }
     if (!clients[id].hDbg) { /* slot is busy */
       break;
     }
   }
 
   if (free_id != -1) {
     diva_dbg_entry_head_t* pmsg = NULL;
     int len;
     char tmp[256];
     word size;
 
     /*
       Register new driver with id == free_id
       */
     clients[free_id].hDbg = hDbg;
     clients[free_id].sec  = sec;
     clients[free_id].usec = usec;
     strcpy (clients[free_id].drvName, hDbg->drvName);
 
     clients[free_id].dbgMask = hDbg->dbgMask;
     if (best_id) {
       hDbg->dbgMask |= clients[free_id].last_dbgMask;
     } else {
       clients[free_id].last_dbgMask = 0;
     }
 
     hDbg->Registered = DBG_HANDLE_REG_NEW ;
     hDbg->id         = (byte)free_id;
     hDbg->dbg_end    = DI_deregister;
     hDbg->dbg_prt    = DI_format_locked;
     hDbg->dbg_ev     = DiProcessEventLog;
     hDbg->dbg_irq    = DI_format_locked;
     if (hDbg->Version > 0) {
       hDbg->dbg_old  = DI_format_old;
     }
     hDbg->next       = (pDbgHandle)DBG_MAGIC;
 
     /*
       Log driver register, MAINT driver ID is '0'
       */
     len = sprintf (tmp, "DIMAINT - drv # %d = '%s' registered",
                    free_id, hDbg->drvName);
 
     while (!(pmsg = (diva_dbg_entry_head_t*)queueAllocMsg (dbg_queue,
                                         (word)(len+1+sizeof(*pmsg))))) {
       if ((pmsg = (diva_dbg_entry_head_t*)queuePeekMsg (dbg_queue, &size))) {
         queueFreeMsg (dbg_queue);
       } else {
         break;
       }
     }
 
     if (pmsg) {
       pmsg->sequence    = dbg_sequence++;
       pmsg->time_sec    = sec;
       pmsg->time_usec   = usec;
       pmsg->facility    = MSG_TYPE_STRING;
       pmsg->dli         = DLI_REG;
       pmsg->drv_id      = 0; /* id 0 - DIMAINT */
       pmsg->di_cpu      = 0;
       pmsg->data_length = len+1;
 
       memcpy (&pmsg[1], tmp, len+1);
                   queueCompleteMsg (pmsg);
       diva_maint_wakeup_read();
     }
   }
 
   diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "register");
 }
 
 static void DI_deregister (pDbgHandle hDbg) {
   diva_os_spin_lock_magic_t old_irql, old_irql1;
   dword sec, usec;
   int i;
   word size;
   byte* pmem = NULL;
 
   diva_os_get_time (&sec, &usec);
 
   diva_os_enter_spin_lock (&dbg_adapter_lock, &old_irql1, "read");
   diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "read");
 
   for (i = 1; i < ARRAY_SIZE(clients); i++) {
     if (clients[i].hDbg == hDbg) {
       diva_dbg_entry_head_t* pmsg;
       char tmp[256];
       int len;
 
       clients[i].hDbg = NULL;
 
       hDbg->id       = -1;
       hDbg->dbgMask  = 0;
       hDbg->dbg_end  = NULL;
       hDbg->dbg_prt  = NULL;
       hDbg->dbg_irq  = NULL;
       if (hDbg->Version > 0)
         hDbg->dbg_old = NULL;
       hDbg->Registered = 0;
       hDbg->next     = NULL;
 
       if (clients[i].pIdiLib) {
         (*(clients[i].pIdiLib->DivaSTraceLibraryFinit))(clients[i].pIdiLib->hLib);
         clients[i].pIdiLib = NULL;
 
         pmem = clients[i].pmem;
         clients[i].pmem = NULL;
       }
 
       /*
         Log driver register, MAINT driver ID is '0'
         */
       len = sprintf (tmp, "DIMAINT - drv # %d = '%s' de-registered",
                      i, hDbg->drvName);
 
       while (!(pmsg = (diva_dbg_entry_head_t*)queueAllocMsg (dbg_queue,
                                         (word)(len+1+sizeof(*pmsg))))) {
         if ((pmsg = (diva_dbg_entry_head_t*)queuePeekMsg (dbg_queue, &size))) {
           queueFreeMsg (dbg_queue);
         } else {
           break;
         }
       }
 
       if (pmsg) {
         pmsg->sequence    = dbg_sequence++;
         pmsg->time_sec    = sec;
         pmsg->time_usec   = usec;
         pmsg->facility    = MSG_TYPE_STRING;
         pmsg->dli         = DLI_REG;
         pmsg->drv_id      = 0; /* id 0 - DIMAINT */
         pmsg->di_cpu      = 0;
         pmsg->data_length = len+1;
 
         memcpy (&pmsg[1], tmp, len+1);
                     queueCompleteMsg (pmsg);
         diva_maint_wakeup_read();
       }
 
       break;
     }
   }
 
   diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "read_ack");
   diva_os_leave_spin_lock (&dbg_adapter_lock, &old_irql1, "read_ack");
 
   if (pmem) {
     diva_os_free (0, pmem);
   }
 }
 
 static void DI_format_locked (unsigned short id,
                        int type,
                        char *format,
                        va_list argument_list) {
   DI_format (1, id, type, format, argument_list);
 }
 
 static void DI_format (int do_lock,
                        unsigned short id,
                        int type,
                        char *format,
                        va_list ap) {
   diva_os_spin_lock_magic_t old_irql;
   dword sec, usec;
   diva_dbg_entry_head_t* pmsg = NULL;
   dword length;
   word size;
   static char fmtBuf[MSG_FRAME_MAX_SIZE+sizeof(*pmsg)+1];
   char          *data;
   unsigned short code;
 
   if (diva_os_in_irq()) {
     dbg_sequence++;
     return;
   }
 
         if ((!format) ||
                         ((TraceFilter[0] != 0) && ((TraceFilterIdent < 0) || (TraceFilterChannel < 0)))) {
                 return;
         }
 
 
   
   diva_os_get_time (&sec, &usec);
 
   if (do_lock) {
     diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "format");
   }
 
   switch (type) {
   case DLI_MXLOG :
   case DLI_BLK :
   case DLI_SEND:
   case DLI_RECV:
     if (!(length = va_arg(ap, unsigned long))) {
       break;
     }
     if (length > MaxDumpSize) {
       length = MaxDumpSize;
     }
     while (!(pmsg = (diva_dbg_entry_head_t*)queueAllocMsg (dbg_queue,
                                 (word)length+sizeof(*pmsg)))) {
       if ((pmsg = (diva_dbg_entry_head_t*)queuePeekMsg (dbg_queue, &size))) {
         queueFreeMsg (dbg_queue);
       } else {
         break;
       }
     }
     if (pmsg) {
       memcpy (&pmsg[1], format, length);
       pmsg->sequence    = dbg_sequence++;
       pmsg->time_sec    = sec;
       pmsg->time_usec   = usec;
       pmsg->facility    = MSG_TYPE_BINARY ;
       pmsg->dli         = type; /* DLI_XXX */
       pmsg->drv_id      = id;   /* driver MAINT id */
       pmsg->di_cpu      = 0;
       pmsg->data_length = length;
       queueCompleteMsg (pmsg);
     }
                 break;
 
   case DLI_XLOG: {
     byte* p;
     data    = va_arg(ap, char*);
     code    = (unsigned short)va_arg(ap, unsigned int);
     length        = (unsigned long) va_arg(ap, unsigned int);
 
     if (length > MaxXlogSize)
       length = MaxXlogSize;
 
     while (!(pmsg = (diva_dbg_entry_head_t*)queueAllocMsg (dbg_queue,
                                   (word)length+sizeof(*pmsg)+2))) {
       if ((pmsg = (diva_dbg_entry_head_t*)queuePeekMsg (dbg_queue, &size))) {
         queueFreeMsg (dbg_queue);
       } else {
         break;
       }
     }
     if (pmsg) {
       p = (byte*)&pmsg[1];
       p[0] = (char)(code) ;
       p[1] = (char)(code >> 8) ;
       if (data && length) {
         memcpy (&p[2], &data[0], length) ;
       }
       length += 2 ;
 
       pmsg->sequence    = dbg_sequence++;
       pmsg->time_sec    = sec;
       pmsg->time_usec   = usec;
       pmsg->facility    = MSG_TYPE_BINARY ;
       pmsg->dli         = type; /* DLI_XXX */
       pmsg->drv_id      = id;   /* driver MAINT id */
       pmsg->di_cpu      = 0;
       pmsg->data_length = length;
       queueCompleteMsg (pmsg);
     }
   } break;
 
   case DLI_LOG :
   case DLI_FTL :
   case DLI_ERR :
   case DLI_TRC :
   case DLI_REG :
   case DLI_MEM :
   case DLI_SPL :
   case DLI_IRP :
   case DLI_TIM :
   case DLI_TAPI:
   case DLI_NDIS:
   case DLI_CONN:
   case DLI_STAT:
   case DLI_PRV0:
   case DLI_PRV1:
   case DLI_PRV2:
   case DLI_PRV3:
     if ((length = (unsigned long)vsprintf (&fmtBuf[0], format, ap)) > 0) {
       length += (sizeof(*pmsg)+1);
 
       while (!(pmsg = (diva_dbg_entry_head_t*)queueAllocMsg (dbg_queue,
                                                           (word)length))) {
         if ((pmsg = (diva_dbg_entry_head_t*)queuePeekMsg (dbg_queue, &size))) {
           queueFreeMsg (dbg_queue);
         } else {
           break;
         }
       }
 
       pmsg->sequence    = dbg_sequence++;
       pmsg->time_sec    = sec;
       pmsg->time_usec   = usec;
       pmsg->facility    = MSG_TYPE_STRING;
       pmsg->dli         = type; /* DLI_XXX */
       pmsg->drv_id      = id;   /* driver MAINT id */
       pmsg->di_cpu      = 0;
       pmsg->data_length = length - sizeof(*pmsg);
 
       memcpy (&pmsg[1], fmtBuf, pmsg->data_length);
                   queueCompleteMsg (pmsg);
     }
     break;
 
   } /* switch type */
 
 
   if (queueCount(dbg_queue)) {
     diva_maint_wakeup_read();
   }
 
   if (do_lock) {
     diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "format");
   }
 }
 
 /*
   Write driver ID and driver revision to callers buffer
   */
 int diva_get_driver_info (dword id, byte* data, int data_length) {
   diva_os_spin_lock_magic_t old_irql;
   byte* p = data;
   int to_copy;
 
   if (!data || !id || (data_length < 17) ||
       (id >= ARRAY_SIZE(clients))) {
     return (-1);
   }
 
   diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "driver info");
 
   if (clients[id].hDbg) {
     *p++ = 1;
     *p++ = (byte)clients[id].sec; /* save seconds */
     *p++ = (byte)(clients[id].sec >>  8);
     *p++ = (byte)(clients[id].sec >> 16);
     *p++ = (byte)(clients[id].sec >> 24);
 
     *p++ = (byte)(clients[id].usec/1000); /* save mseconds */
     *p++ = (byte)((clients[id].usec/1000) >>  8);
     *p++ = (byte)((clients[id].usec/1000) >> 16);
     *p++ = (byte)((clients[id].usec/1000) >> 24);
 
     data_length -= 9;
 
     if ((to_copy = min(strlen(clients[id].drvName), (size_t)(data_length-1)))) {
       memcpy (p, clients[id].drvName, to_copy);
       p += to_copy;
       data_length -= to_copy;
       if ((data_length >= 4) && clients[id].hDbg->drvTag[0]) {
         *p++ = '(';
         data_length -= 1;
         if ((to_copy = min(strlen(clients[id].hDbg->drvTag), (size_t)(data_length-2)))) {
           memcpy (p, clients[id].hDbg->drvTag, to_copy);
           p += to_copy;
           data_length -= to_copy;
           if (data_length >= 2) {
             *p++ = ')';
             data_length--;
           }
         }
       }
     }
   }
   *p++ = 0;
 
   diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "driver info");
 
   return (p - data);
 }
 
 int diva_get_driver_dbg_mask (dword id, byte* data) {
   diva_os_spin_lock_magic_t old_irql;
   int ret = -1;
 
   if (!data || !id || (id >= ARRAY_SIZE(clients))) {
     return (-1);
   }
   diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "driver info");
 
   if (clients[id].hDbg) {
     ret = 4;
     *data++= (byte)(clients[id].hDbg->dbgMask);
     *data++= (byte)(clients[id].hDbg->dbgMask >>  8);
     *data++= (byte)(clients[id].hDbg->dbgMask >> 16);
     *data++= (byte)(clients[id].hDbg->dbgMask >> 24);
   }
 
   diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "driver info");
 
   return (ret);
 }
 
 int diva_set_driver_dbg_mask (dword id, dword mask) {
   diva_os_spin_lock_magic_t old_irql, old_irql1;
   int ret = -1;
   
 
   if (!id || (id >= ARRAY_SIZE(clients))) {
     return (-1);
   }
 
   diva_os_enter_spin_lock (&dbg_adapter_lock, &old_irql1, "dbg mask");
   diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "dbg mask");
 
   if (clients[id].hDbg) {
     dword old_mask = clients[id].hDbg->dbgMask;
     mask &= 0x7fffffff;
     clients[id].hDbg->dbgMask = mask;
     clients[id].last_dbgMask = (clients[id].hDbg->dbgMask | clients[id].dbgMask);
     ret = 4;
     diva_change_management_debug_mask (&clients[id], old_mask);
   }
 
 
   diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "dbg mask");
 
   if (clients[id].request_pending) {
     clients[id].request_pending = 0;
     (*(clients[id].request))((ENTITY*)(*(clients[id].pIdiLib->DivaSTraceGetHandle))(clients[id].pIdiLib->hLib));
   }
 
   diva_os_leave_spin_lock (&dbg_adapter_lock, &old_irql1, "dbg mask");
 
   return (ret);
 }
 
 static int diva_get_idi_adapter_info (IDI_CALL request, dword* serial, dword* logical) {
   IDI_SYNC_REQ sync_req;
 
   sync_req.xdi_logical_adapter_number.Req = 0;
   sync_req.xdi_logical_adapter_number.Rc = IDI_SYNC_REQ_XDI_GET_LOGICAL_ADAPTER_NUMBER;
   (*request)((ENTITY *)&sync_req);
   *logical = sync_req.xdi_logical_adapter_number.info.logical_adapter_number;
 
   sync_req.GetSerial.Req = 0;
   sync_req.GetSerial.Rc = IDI_SYNC_REQ_GET_SERIAL;
   sync_req.GetSerial.serial = 0;
   (*request)((ENTITY *)&sync_req);
         *serial = sync_req.GetSerial.serial;
 
   return (0);
 }
 
 /*
   Register XDI adapter as MAINT compatible driver
   */
 void diva_mnt_add_xdi_adapter (const DESCRIPTOR* d) {
   diva_os_spin_lock_magic_t old_irql, old_irql1;
   dword sec, usec, logical, serial, org_mask;
   int id, best_id = 0, free_id = -1;
   char tmp[256];
   diva_dbg_entry_head_t* pmsg = NULL;
   int len;
   word size;
   byte* pmem;
 
   diva_os_get_time (&sec, &usec);
   diva_get_idi_adapter_info (d->request, &serial, &logical);
   if (serial & 0xff000000) {
     sprintf (tmp, "ADAPTER:%d SN:%u-%d",
              (int)logical,
              serial & 0x00ffffff,
              (byte)(((serial & 0xff000000) >> 24) + 1));
   } else {
     sprintf (tmp, "ADAPTER:%d SN:%u", (int)logical, serial);
   }
 
   if (!(pmem = diva_os_malloc (0, DivaSTraceGetMemotyRequirement (d->channels)))) {
     return;
   }
   memset (pmem, 0x00, DivaSTraceGetMemotyRequirement (d->channels));
 
   diva_os_enter_spin_lock (&dbg_adapter_lock, &old_irql1, "register");
   diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "register");
 
   for (id = 1; id < ARRAY_SIZE(clients); id++) {
     if (clients[id].hDbg && (clients[id].request == d->request)) {
       diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "register");
       diva_os_leave_spin_lock (&dbg_adapter_lock, &old_irql1, "register");
       diva_os_free(0, pmem);
       return;
     }
     if (clients[id].hDbg) { /* slot is busy */
       continue;
     }
     if (free_id < 0) {
       free_id = id;
     }
     if (!strcmp (clients[id].drvName, tmp)) {
       /*
         This driver was already registered with this name
         and slot is still free - reuse it
         */
       free_id = id;
       best_id = 1;
       break;
     }
   }
 
   if (free_id < 0) {
     diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "register");
     diva_os_leave_spin_lock (&dbg_adapter_lock, &old_irql1, "register");
     diva_os_free (0, pmem);
     return;
   }
 
   id = free_id;
   clients[id].request  = d->request;
   clients[id].request_pending = 0;
   clients[id].hDbg     = &clients[id].Dbg;
   clients[id].sec      = sec;
   clients[id].usec     = usec;
   strcpy (clients[id].drvName,     tmp);
   strcpy (clients[id].Dbg.drvName, tmp);
   clients[id].Dbg.drvTag[0] = 0;
   clients[id].logical  = (int)logical;
   clients[id].channels = (int)d->channels;
   clients[id].dma_handle = -1;
 
   clients[id].Dbg.dbgMask    = 0;
   clients[id].dbgMask        = clients[id].Dbg.dbgMask;
   if (id) {
     clients[id].Dbg.dbgMask |= clients[free_id].last_dbgMask;
   } else {
     clients[id].last_dbgMask = 0;
   }
   clients[id].Dbg.Registered = DBG_HANDLE_REG_NEW;
   clients[id].Dbg.id         = (byte)id;
   clients[id].Dbg.dbg_end    = DI_deregister;
   clients[id].Dbg.dbg_prt    = DI_format_locked;
   clients[id].Dbg.dbg_ev     = DiProcessEventLog;
   clients[id].Dbg.dbg_irq    = DI_format_locked;
   clients[id].Dbg.next       = (pDbgHandle)DBG_MAGIC;
 
   {
     diva_trace_library_user_interface_t diva_maint_user_ifc = { &clients[id],
                                                                                                                                                                                          diva_maint_state_change_notify,
                                                                                                                                                                                          diva_maint_trace_notify,
                                                                                                                                                                                          diva_maint_error };
 
     /*
       Attach to adapter management interface
       */
     if ((clients[id].pIdiLib =
                DivaSTraceLibraryCreateInstance ((int)logical, &diva_maint_user_ifc, pmem))) {
       if (((*(clients[id].pIdiLib->DivaSTraceLibraryStart))(clients[id].pIdiLib->hLib))) {
         diva_mnt_internal_dprintf (0, DLI_ERR, "Adapter(%d) Start failed", (int)logical);
         (*(clients[id].pIdiLib->DivaSTraceLibraryFinit))(clients[id].pIdiLib->hLib);
         clients[id].pIdiLib = NULL;
       }
     } else {
       diva_mnt_internal_dprintf (0, DLI_ERR, "A(%d) management init failed", (int)logical);
     }
   }
 
   if (!clients[id].pIdiLib) {
     clients[id].request = NULL;
     clients[id].request_pending = 0;
     clients[id].hDbg    = NULL;
     diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "register");
     diva_os_leave_spin_lock (&dbg_adapter_lock, &old_irql1, "register");
     diva_os_free (0, pmem);
     return;
   }
 
   /*
     Log driver register, MAINT driver ID is '0'
     */
   len = sprintf (tmp, "DIMAINT - drv # %d = '%s' registered",
                  id, clients[id].Dbg.drvName);
 
   while (!(pmsg = (diva_dbg_entry_head_t*)queueAllocMsg (dbg_queue,
                                       (word)(len+1+sizeof(*pmsg))))) {
     if ((pmsg = (diva_dbg_entry_head_t*)queuePeekMsg (dbg_queue, &size))) {
       queueFreeMsg (dbg_queue);
     } else {
       break;
     }
   }
 
   if (pmsg) {
     pmsg->sequence    = dbg_sequence++;
     pmsg->time_sec    = sec;
     pmsg->time_usec   = usec;
     pmsg->facility    = MSG_TYPE_STRING;
    pmsg->dli         = DLI_REG;
    pmsg->drv_id      = 0; /* id 0 - DIMAINT */
    pmsg->di_cpu      = 0;
    pmsg->data_length = len+1;

    memcpy (&pmsg[1], tmp, len+1);
    queueCompleteMsg (pmsg);
    diva_maint_wakeup_read();
  }

  org_mask = clients[id].Dbg.dbgMask;
  clients[id].Dbg.dbgMask = 0;

  diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "register");

  if (clients[id].request_pending) {
    clients[id].request_pending = 0;
    (*(clients[id].request))((ENTITY*)(*(clients[id].pIdiLib->DivaSTraceGetHandle))(clients[id].pIdiLib->hLib));
  }

  diva_os_leave_spin_lock (&dbg_adapter_lock, &old_irql1, "register");

        diva_set_driver_dbg_mask (id, org_mask);
}

/*
  De-Register XDI adapter
  */
void diva_mnt_remove_xdi_adapter (const DESCRIPTOR* d) {
  diva_os_spin_lock_magic_t old_irql, old_irql1;
  dword sec, usec;
  int i;
  word size;
  byte* pmem = NULL;

  diva_os_get_time (&sec, &usec);

  diva_os_enter_spin_lock (&dbg_adapter_lock, &old_irql1, "read");
  diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "read");

  for (i = 1; i < ARRAY_SIZE(clients); i++) {
    if (clients[i].hDbg && (clients[i].request == d->request)) {
      diva_dbg_entry_head_t* pmsg;
      char tmp[256];
      int len;

      if (clients[i].pIdiLib) {
        (*(clients[i].pIdiLib->DivaSTraceLibraryFinit))(clients[i].pIdiLib->hLib);
        clients[i].pIdiLib = NULL;

        pmem = clients[i].pmem;
        clients[i].pmem = NULL;
      }

      clients[i].hDbg    = NULL;
      clients[i].request_pending = 0;
      if (clients[i].dma_handle >= 0) {
        /*
          Free DMA handle
          */
        diva_free_dma_descriptor (clients[i].request, clients[i].dma_handle);
        clients[i].dma_handle = -1;
      }
      clients[i].request = NULL;

      /*
        Log driver register, MAINT driver ID is '0'
        */
      len = sprintf (tmp, "DIMAINT - drv # %d = '%s' de-registered",
                     i, clients[i].Dbg.drvName);

      memset (&clients[i].Dbg, 0x00, sizeof(clients[i].Dbg));

      while (!(pmsg = (diva_dbg_entry_head_t*)queueAllocMsg (dbg_queue,
                                        (word)(len+1+sizeof(*pmsg))))) {
        if ((pmsg = (diva_dbg_entry_head_t*)queuePeekMsg (dbg_queue, &size))) {
          queueFreeMsg (dbg_queue);
        } else {
          break;
        }
      }

      if (pmsg) {
        pmsg->sequence    = dbg_sequence++;
        pmsg->time_sec    = sec;
        pmsg->time_usec   = usec;
        pmsg->facility    = MSG_TYPE_STRING;
        pmsg->dli         = DLI_REG;
        pmsg->drv_id      = 0; /* id 0 - DIMAINT */
        pmsg->di_cpu      = 0;
        pmsg->data_length = len+1;

        memcpy (&pmsg[1], tmp, len+1);
                    queueCompleteMsg (pmsg);
        diva_maint_wakeup_read();
      }

      break;
    }
  }

  diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "read_ack");
  diva_os_leave_spin_lock (&dbg_adapter_lock, &old_irql1, "read_ack");

  if (pmem) {
    diva_os_free (0, pmem);
  }
}

/* ----------------------------------------------------------------
     Low level interface for management interface client
   ---------------------------------------------------------------- */
/*
  Return handle to client structure
  */
void* SuperTraceOpenAdapter   (int AdapterNumber) {
  int i;

  for (i = 1; i < ARRAY_SIZE(clients); i++) {
    if (clients[i].hDbg && clients[i].request && (clients[i].logical == AdapterNumber)) {
      return (&clients[i]);
    }
  }

  return NULL;
}

int SuperTraceCloseAdapter  (void* AdapterHandle) {
  return (0);
}

int SuperTraceReadRequest (void* AdapterHandle, const char* name, byte* data) {
  diva_maint_client_t* pC = (diva_maint_client_t*)AdapterHandle;

  if (pC && pC->pIdiLib && pC->request) {
    ENTITY* e = (ENTITY*)(*(pC->pIdiLib->DivaSTraceGetHandle))(pC->pIdiLib->hLib);
    byte* xdata = (byte*)&pC->xbuffer[0];
    char tmp = 0;
    word length;

    if (!strcmp(name, "\\")) { /* Read ROOT */
      name = &tmp;
    }
    length = SuperTraceCreateReadReq (xdata, name);
    single_p (xdata, &length, 0); /* End Of Message */

    e->Req        = MAN_READ;
    e->ReqCh      = 0;
    e->X->PLength = length;
    e->X->P                          = (byte*)xdata;

    pC->request_pending = 1;

    return (0);
  }

  return (-1);
}

int SuperTraceGetNumberOfChannels (void* AdapterHandle) {
  if (AdapterHandle) {
    diva_maint_client_t* pC = (diva_maint_client_t*)AdapterHandle;

    return (pC->channels);
  }

  return (0);
}

int SuperTraceASSIGN (void* AdapterHandle, byte* data) {
  diva_maint_client_t* pC = (diva_maint_client_t*)AdapterHandle;

  if (pC && pC->pIdiLib && pC->request) {
    ENTITY* e = (ENTITY*)(*(pC->pIdiLib->DivaSTraceGetHandle))(pC->pIdiLib->hLib);
    IDI_SYNC_REQ* preq;
    char buffer[((sizeof(preq->xdi_extended_features)+4) > sizeof(ENTITY)) ? (sizeof(preq->xdi_extended_features)+4) : sizeof(ENTITY)];
    char features[4];
    word assign_data_length = 1;

    features[0] = 0;
    pC->xbuffer[0] = 0;
    preq = (IDI_SYNC_REQ*)&buffer[0];
    preq->xdi_extended_features.Req = 0;
    preq->xdi_extended_features.Rc  = IDI_SYNC_REQ_XDI_GET_EXTENDED_FEATURES;
    preq->xdi_extended_features.info.buffer_length_in_bytes = sizeof(features);
    preq->xdi_extended_features.info.features = &features[0];

    (*(pC->request))((ENTITY*)preq);

    if ((features[0] & DIVA_XDI_EXTENDED_FEATURES_VALID) &&
        (features[0] & DIVA_XDI_EXTENDED_FEATURE_MANAGEMENT_DMA)) {
      dword uninitialized_var(rx_dma_magic);
      if ((pC->dma_handle = diva_get_dma_descriptor (pC->request, &rx_dma_magic)) >= 0) {
        pC->xbuffer[0] = LLI;
        pC->xbuffer[1] = 8;
        pC->xbuffer[2] = 0x40;
        pC->xbuffer[3] = (byte)pC->dma_handle;
        pC->xbuffer[4] = (byte)rx_dma_magic;
        pC->xbuffer[5] = (byte)(rx_dma_magic >>  8);
        pC->xbuffer[6] = (byte)(rx_dma_magic >> 16);
        pC->xbuffer[7] = (byte)(rx_dma_magic >> 24);
        pC->xbuffer[8] = (byte)DIVA_MAX_MANAGEMENT_TRANSFER_SIZE;
        pC->xbuffer[9] = (byte)(DIVA_MAX_MANAGEMENT_TRANSFER_SIZE >> 8);
        pC->xbuffer[10] = 0;

        assign_data_length = 11;
      }
    } else {
      pC->dma_handle = -1;
    }

    e->Id          = MAN_ID;
    e->callback    = diva_maint_xdi_cb;
    e->XNum        = 1;
    e->X           = &pC->XData;
    e->Req         = ASSIGN;
    e->ReqCh       = 0;
    e->X->PLength  = assign_data_length;
    e->X->P        = (byte*)&pC->xbuffer[0];

    pC->request_pending = 1;

    return (0);
  }

  return (-1);
}

int SuperTraceREMOVE (void* AdapterHandle) {
  diva_maint_client_t* pC = (diva_maint_client_t*)AdapterHandle;

  if (pC && pC->pIdiLib && pC->request) {
    ENTITY* e = (ENTITY*)(*(pC->pIdiLib->DivaSTraceGetHandle))(pC->pIdiLib->hLib);

    e->XNum        = 1;
    e->X           = &pC->XData;
    e->Req         = REMOVE;
    e->ReqCh       = 0;
    e->X->PLength  = 1;
    e->X->P        = (byte*)&pC->xbuffer[0];
    pC->xbuffer[0] = 0;

    pC->request_pending = 1;

    return (0);
  }

  return (-1);
}

int SuperTraceTraceOnRequest(void* hAdapter, const char* name, byte* data) {
  diva_maint_client_t* pC = (diva_maint_client_t*)hAdapter;

  if (pC && pC->pIdiLib && pC->request) {
    ENTITY* e = (ENTITY*)(*(pC->pIdiLib->DivaSTraceGetHandle))(pC->pIdiLib->hLib);
    byte* xdata = (byte*)&pC->xbuffer[0];
    char tmp = 0;
    word length;

    if (!strcmp(name, "\\")) { /* Read ROOT */
      name = &tmp;
    }
    length = SuperTraceCreateReadReq (xdata, name);
    single_p (xdata, &length, 0); /* End Of Message */
    e->Req          = MAN_EVENT_ON;
    e->ReqCh        = 0;
    e->X->PLength   = length;
    e->X->P                            = (byte*)xdata;

    pC->request_pending = 1;

    return (0);
  }

  return (-1);
}

int SuperTraceWriteVar (void* AdapterHandle,
                        byte* data,
                        const char* name,
                        void* var,
                        byte type,
                        byte var_length) {
  diva_maint_client_t* pC = (diva_maint_client_t*)AdapterHandle;

  if (pC && pC->pIdiLib && pC->request) {
    ENTITY* e = (ENTITY*)(*(pC->pIdiLib->DivaSTraceGetHandle))(pC->pIdiLib->hLib);
    diva_man_var_header_t* pVar = (diva_man_var_header_t*)&pC->xbuffer[0];
    word length = SuperTraceCreateReadReq ((byte*)pVar, name);

    memcpy (&pC->xbuffer[length], var, var_length);
    length += var_length;
    pVar->length += var_length;
    pVar->value_length = var_length;
    pVar->type = type;
    single_p ((byte*)pVar, &length, 0); /* End Of Message */

    e->Req          = MAN_WRITE;
    e->ReqCh                          = 0;
    e->X->PLength   = length;
    e->X->P                            = (byte*)pVar;

    pC->request_pending = 1;

    return (0);
  }

  return (-1);
}

int SuperTraceExecuteRequest (void* AdapterHandle,
                              const char* name,
                              byte* data) {
  diva_maint_client_t* pC = (diva_maint_client_t*)AdapterHandle;

  if (pC && pC->pIdiLib && pC->request) {
    ENTITY* e = (ENTITY*)(*(pC->pIdiLib->DivaSTraceGetHandle))(pC->pIdiLib->hLib);
    byte* xdata = (byte*)&pC->xbuffer[0];
    word length;

    length = SuperTraceCreateReadReq (xdata, name);
    single_p (xdata, &length, 0); /* End Of Message */

    e->Req          = MAN_EXECUTE;
    e->ReqCh                          = 0;
    e->X->PLength   = length;
    e->X->P                            = (byte*)xdata;

    pC->request_pending = 1;

    return (0);
  }

  return (-1);
}

static word SuperTraceCreateReadReq (byte* P, const char* path) {
        byte var_length;
        byte* plen;

        var_length = (byte)strlen (path);

        *P++ = ESC;
        plen = P++;
        *P++ = 0x80; /* MAN_IE */
        *P++ = 0x00; /* Type */
        *P++ = 0x00; /* Attribute */
        *P++ = 0x00; /* Status */
        *P++ = 0x00; /* Variable Length */
        *P++ = var_length;
        memcpy (P, path, var_length);
        P += var_length;
        *plen = var_length + 0x06;

        return ((word)(var_length + 0x08));
}

static void single_p (byte * P, word * PLength, byte Id) {
  P[(*PLength)++] = Id;
}

static void diva_maint_xdi_cb (ENTITY* e) {
  diva_strace_context_t* pLib = DIVAS_CONTAINING_RECORD(e,diva_strace_context_t,e);
  diva_maint_client_t* pC;
  diva_os_spin_lock_magic_t old_irql, old_irql1;


  diva_os_enter_spin_lock (&dbg_adapter_lock, &old_irql1, "xdi_cb");
  diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "xdi_cb");

  pC = (diva_maint_client_t*)pLib->hAdapter;

  if ((e->complete == 255) || (pC->dma_handle < 0)) {
    if ((*(pLib->instance.DivaSTraceMessageInput))(&pLib->instance)) {
      diva_mnt_internal_dprintf (0, DLI_ERR, "Trace internal library error");
    }
  } else {
    /*
      Process combined management interface indication
      */
    if ((*(pLib->instance.DivaSTraceMessageInput))(&pLib->instance)) {
      diva_mnt_internal_dprintf (0, DLI_ERR, "Trace internal library error (DMA mode)");
    }
  }

  diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "xdi_cb");


        if (pC->request_pending) {
    pC->request_pending = 0;
    (*(pC->request))(e);
        }

  diva_os_leave_spin_lock (&dbg_adapter_lock, &old_irql1, "xdi_cb");
}


static void diva_maint_error (void* user_context,
                              diva_strace_library_interface_t* hLib,
                              int Adapter,
                              int error,
                              const char* file,
                              int line) {
        diva_mnt_internal_dprintf (0, DLI_ERR,
                             "Trace library error(%d) A(%d) %s %d", error, Adapter, file, line);
}

static void print_ie (diva_trace_ie_t* ie, char* buffer, int length) {
        int i;

  buffer[0] = 0;

  if (length > 32) {
    for (i = 0; ((i < ie->length) && (length > 3)); i++) {
      sprintf (buffer, "%02x", ie->data[i]);
      buffer += 2;
      length -= 2;
      if (i < (ie->length-1)) {
        strcpy (buffer, " ");
        buffer++;
        length--;
      }
    }
  }
}

static void diva_maint_state_change_notify (void* user_context,
                                            diva_strace_library_interface_t* hLib,
                                            int Adapter,
                                            diva_trace_line_state_t* channel,
                                            int notify_subject) {
  diva_maint_client_t*      pC    = (diva_maint_client_t*)user_context;
  diva_trace_fax_state_t*   fax   = &channel->fax;
  diva_trace_modem_state_t* modem = &channel->modem;
  char tmp[256];

  if (!pC->hDbg) {
    return;
  }

  switch (notify_subject) {
    case DIVA_SUPER_TRACE_NOTIFY_LINE_CHANGE: {
      int view = (TraceFilter[0] == 0);
      /*
        Process selective Trace
        */
      if (channel->Line[0] == 'I' && channel->Line[1] == 'd' &&
          channel->Line[2] == 'l' && channel->Line[3] == 'e') {
        if ((TraceFilterIdent == pC->hDbg->id) && (TraceFilterChannel == (int)channel->ChannelNumber)) {
          (*(hLib->DivaSTraceSetBChannel))(hLib, (int)channel->ChannelNumber, 0);
          (*(hLib->DivaSTraceSetAudioTap))(hLib, (int)channel->ChannelNumber, 0);
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG, "Selective Trace OFF for Ch=%d",
                                     (int)channel->ChannelNumber);
          TraceFilterIdent   = -1;
          TraceFilterChannel = -1;
          view = 1;
        }
      } else if (TraceFilter[0] && (TraceFilterIdent < 0) && !(diva_mnt_cmp_nmbr (&channel->RemoteAddress[0]) &&
                                                               diva_mnt_cmp_nmbr (&channel->LocalAddress[0]))) {

        if ((pC->hDbg->dbgMask & DIVA_MGT_DBG_IFC_BCHANNEL) != 0) { /* Activate B-channel trace */
          (*(hLib->DivaSTraceSetBChannel))(hLib, (int)channel->ChannelNumber, 1);
        }
        if ((pC->hDbg->dbgMask & DIVA_MGT_DBG_IFC_AUDIO) != 0) { /* Activate AudioTap Trace */
          (*(hLib->DivaSTraceSetAudioTap))(hLib, (int)channel->ChannelNumber, 1);
        }

        TraceFilterIdent   = pC->hDbg->id;
        TraceFilterChannel = (int)channel->ChannelNumber;

        if (TraceFilterIdent >= 0) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG, "Selective Trace ON for Ch=%d",
                                     (int)channel->ChannelNumber);
          view = 1;
        }
      }
      if (view && (pC->hDbg->dbgMask & DIVA_MGT_DBG_LINE_EVENTS)) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L Ch     = %d",
                                                                     (int)channel->ChannelNumber);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L Status = <%s>", &channel->Line[0]);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L Layer1 = <%s>", &channel->Framing[0]);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L Layer2 = <%s>", &channel->Layer2[0]);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L Layer3 = <%s>", &channel->Layer3[0]);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L RAddr  = <%s>",
                                                                     &channel->RemoteAddress[0]);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L RSAddr = <%s>",
                                                                     &channel->RemoteSubAddress[0]);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L LAddr  = <%s>",
                                                                     &channel->LocalAddress[0]);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L LSAddr = <%s>",
                                                                     &channel->LocalSubAddress[0]);
        print_ie(&channel->call_BC, tmp, sizeof(tmp));
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L BC     = <%s>", tmp);
        print_ie(&channel->call_HLC, tmp, sizeof(tmp));
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L HLC    = <%s>", tmp);
        print_ie(&channel->call_LLC, tmp, sizeof(tmp));
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L LLC    = <%s>", tmp);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L CR     = 0x%x", channel->CallReference);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L Disc   = 0x%x",
                                                                    channel->LastDisconnecCause);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT, "L Owner  = <%s>", &channel->UserID[0]);
      }

                } break;

    case DIVA_SUPER_TRACE_NOTIFY_MODEM_CHANGE:
      if (pC->hDbg->dbgMask & DIVA_MGT_DBG_MDM_PROGRESS) {
                                {
                                        int ch = TraceFilterChannel;
                                        int id = TraceFilterIdent;

                                        if ((id >= 0) && (ch >= 0) && (id < ARRAY_SIZE(clients)) &&
                                                (clients[id].Dbg.id == (byte)id) && (clients[id].pIdiLib == hLib)) {
                                                if (ch != (int)modem->ChannelNumber) {
                                                        break;
                                                }
                                        } else if (TraceFilter[0] != 0) {
                                                break;
                                        }
                                }


        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM Ch    = %lu",
                                                                     (int)modem->ChannelNumber);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM Event = %lu",     modem->Event);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM Norm  = %lu",     modem->Norm);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM Opts. = 0x%08x",  modem->Options);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM Tx    = %lu Bps", modem->TxSpeed);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM Rx    = %lu Bps", modem->RxSpeed);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM RT    = %lu mSec",
                                                                     modem->RoundtripMsec);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM Sr    = %lu",     modem->SymbolRate);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM Rxl   = %d dBm",  modem->RxLeveldBm);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM El    = %d dBm",  modem->EchoLeveldBm);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM SNR   = %lu dB",  modem->SNRdb);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM MAE   = %lu",     modem->MAE);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM LRet  = %lu",
                                                                     modem->LocalRetrains);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM RRet  = %lu",
                                                                     modem->RemoteRetrains);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM LRes  = %lu",     modem->LocalResyncs);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "MDM RRes  = %lu",
                                                                     modem->RemoteResyncs);
        if (modem->Event == 3) {
          diva_mnt_internal_dprintf(pC->hDbg->id,DLI_STAT,"MDM Disc  =  %lu",    modem->DiscReason);
        }
      }
      if ((modem->Event == 3) && (pC->hDbg->dbgMask & DIVA_MGT_DBG_MDM_STATISTICS)) {
        (*(pC->pIdiLib->DivaSTraceGetModemStatistics))(pC->pIdiLib);
      }
      break;

    case DIVA_SUPER_TRACE_NOTIFY_FAX_CHANGE:
      if (pC->hDbg->dbgMask & DIVA_MGT_DBG_FAX_PROGRESS) {
                                {
                                        int ch = TraceFilterChannel;
                                        int id = TraceFilterIdent;

                                        if ((id >= 0) && (ch >= 0) && (id < ARRAY_SIZE(clients)) &&
                                                (clients[id].Dbg.id == (byte)id) && (clients[id].pIdiLib == hLib)) {
                                                if (ch != (int)fax->ChannelNumber) {
                                                        break;
                                                }
                                        } else if (TraceFilter[0] != 0) {
                                                break;
                                        }
                                }

        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Ch    = %lu",(int)fax->ChannelNumber);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Event = %lu",     fax->Event);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Pages = %lu",     fax->Page_Counter);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Feat. = 0x%08x",  fax->Features);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX ID    = <%s>",    &fax->Station_ID[0]);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Saddr = <%s>",    &fax->Subaddress[0]);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Pwd   = <%s>",    &fax->Password[0]);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Speed = %lu",     fax->Speed);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Res.  = 0x%08x",  fax->Resolution);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Width = %lu",     fax->Paper_Width);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Length= %lu",     fax->Paper_Length);
        diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX SLT   = %lu",     fax->Scanline_Time);
        if (fax->Event == 3) {
          diva_mnt_internal_dprintf(pC->hDbg->id, DLI_STAT, "FAX Disc  = %lu",     fax->Disc_Reason);
        }
      }
      if ((fax->Event == 3) && (pC->hDbg->dbgMask & DIVA_MGT_DBG_FAX_STATISTICS)) {
        (*(pC->pIdiLib->DivaSTraceGetFaxStatistics))(pC->pIdiLib);
      }
      break;

    case DIVA_SUPER_TRACE_INTERFACE_CHANGE:
      if (pC->hDbg->dbgMask & DIVA_MGT_DBG_IFC_EVENTS) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT,
                                 "Layer 1 -> [%s]", channel->pInterface->Layer1);
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_STAT,
                                 "Layer 2 -> [%s]", channel->pInterface->Layer2);
      }
      break;

    case DIVA_SUPER_TRACE_NOTIFY_STAT_CHANGE:
      if (pC->hDbg->dbgMask & DIVA_MGT_DBG_IFC_STATISTICS) {
        /*
          Incoming Statistics
          */
        if (channel->pInterfaceStat->inc.Calls) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Inc Calls                     =%lu", channel->pInterfaceStat->inc.Calls);
        }
        if (channel->pInterfaceStat->inc.Connected) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Inc Connected                 =%lu", channel->pInterfaceStat->inc.Connected);
        }
        if (channel->pInterfaceStat->inc.User_Busy) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Inc Busy                      =%lu", channel->pInterfaceStat->inc.User_Busy);
        }
        if (channel->pInterfaceStat->inc.Call_Rejected) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Inc Rejected                  =%lu", channel->pInterfaceStat->inc.Call_Rejected);
        }
        if (channel->pInterfaceStat->inc.Wrong_Number) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Inc Wrong Nr                  =%lu", channel->pInterfaceStat->inc.Wrong_Number);
        }
        if (channel->pInterfaceStat->inc.Incompatible_Dst) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Inc Incomp. Dest              =%lu", channel->pInterfaceStat->inc.Incompatible_Dst);
        }
        if (channel->pInterfaceStat->inc.Out_of_Order) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Inc Out of Order              =%lu", channel->pInterfaceStat->inc.Out_of_Order);
        }
        if (channel->pInterfaceStat->inc.Ignored) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Inc Ignored                   =%lu", channel->pInterfaceStat->inc.Ignored);
        }
        
        /*
          Outgoing Statistics
          */
        if (channel->pInterfaceStat->outg.Calls) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Outg Calls                    =%lu", channel->pInterfaceStat->outg.Calls);
        }
        if (channel->pInterfaceStat->outg.Connected) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Outg Connected                =%lu", channel->pInterfaceStat->outg.Connected);
        }
        if (channel->pInterfaceStat->outg.User_Busy) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Outg Busy                     =%lu", channel->pInterfaceStat->outg.User_Busy);
        }
        if (channel->pInterfaceStat->outg.No_Answer) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Outg No Answer                =%lu", channel->pInterfaceStat->outg.No_Answer);
        }
        if (channel->pInterfaceStat->outg.Wrong_Number) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Outg Wrong Nr                 =%lu", channel->pInterfaceStat->outg.Wrong_Number);
        }
        if (channel->pInterfaceStat->outg.Call_Rejected) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Outg Rejected                 =%lu", channel->pInterfaceStat->outg.Call_Rejected);
        }
        if (channel->pInterfaceStat->outg.Other_Failures) {
          diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
          "Outg Other Failures           =%lu", channel->pInterfaceStat->outg.Other_Failures);
        }
      }
      break;

    case DIVA_SUPER_TRACE_NOTIFY_MDM_STAT_CHANGE:
      if (channel->pInterfaceStat->mdm.Disc_Normal) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "MDM Disc Normal        = %lu", channel->pInterfaceStat->mdm.Disc_Normal);
      }
      if (channel->pInterfaceStat->mdm.Disc_Unspecified) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "MDM Disc Unsp.         = %lu", channel->pInterfaceStat->mdm.Disc_Unspecified);
      }
      if (channel->pInterfaceStat->mdm.Disc_Busy_Tone) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "MDM Disc Busy Tone     = %lu", channel->pInterfaceStat->mdm.Disc_Busy_Tone);
      }
      if (channel->pInterfaceStat->mdm.Disc_Congestion) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "MDM Disc Congestion    = %lu", channel->pInterfaceStat->mdm.Disc_Congestion);
      }
      if (channel->pInterfaceStat->mdm.Disc_Carr_Wait) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "MDM Disc Carrier Wait  = %lu", channel->pInterfaceStat->mdm.Disc_Carr_Wait);
      }
      if (channel->pInterfaceStat->mdm.Disc_Trn_Timeout) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "MDM Disc Trn. T.o.     = %lu", channel->pInterfaceStat->mdm.Disc_Trn_Timeout);
      }
      if (channel->pInterfaceStat->mdm.Disc_Incompat) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "MDM Disc Incompatible  = %lu", channel->pInterfaceStat->mdm.Disc_Incompat);
      }
      if (channel->pInterfaceStat->mdm.Disc_Frame_Rej) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "MDM Disc Frame Reject  = %lu", channel->pInterfaceStat->mdm.Disc_Frame_Rej);
      }
      if (channel->pInterfaceStat->mdm.Disc_V42bis) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "MDM Disc V.42bis       = %lu", channel->pInterfaceStat->mdm.Disc_V42bis);
      }
      break;

    case DIVA_SUPER_TRACE_NOTIFY_FAX_STAT_CHANGE:
      if (channel->pInterfaceStat->fax.Disc_Normal) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Normal        = %lu", channel->pInterfaceStat->fax.Disc_Normal);
      }
      if (channel->pInterfaceStat->fax.Disc_Not_Ident) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Not Ident.    = %lu", channel->pInterfaceStat->fax.Disc_Not_Ident);
      }
      if (channel->pInterfaceStat->fax.Disc_No_Response) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc No Response   = %lu", channel->pInterfaceStat->fax.Disc_No_Response);
      }
      if (channel->pInterfaceStat->fax.Disc_Retries) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Max Retries   = %lu", channel->pInterfaceStat->fax.Disc_Retries);
      }
      if (channel->pInterfaceStat->fax.Disc_Unexp_Msg) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Unexp. Msg.        = %lu", channel->pInterfaceStat->fax.Disc_Unexp_Msg);
      }
      if (channel->pInterfaceStat->fax.Disc_No_Polling) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc No Polling    = %lu", channel->pInterfaceStat->fax.Disc_No_Polling);
      }
      if (channel->pInterfaceStat->fax.Disc_Training) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Training      = %lu", channel->pInterfaceStat->fax.Disc_Training);
      }
      if (channel->pInterfaceStat->fax.Disc_Unexpected) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Unexpected    = %lu", channel->pInterfaceStat->fax.Disc_Unexpected);
      }
      if (channel->pInterfaceStat->fax.Disc_Application) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Application   = %lu", channel->pInterfaceStat->fax.Disc_Application);
      }
      if (channel->pInterfaceStat->fax.Disc_Incompat) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Incompatible  = %lu", channel->pInterfaceStat->fax.Disc_Incompat);
      }
      if (channel->pInterfaceStat->fax.Disc_No_Command) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc No Command    = %lu", channel->pInterfaceStat->fax.Disc_No_Command);
      }
      if (channel->pInterfaceStat->fax.Disc_Long_Msg) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Long Msg.     = %lu", channel->pInterfaceStat->fax.Disc_Long_Msg);
      }
      if (channel->pInterfaceStat->fax.Disc_Supervisor) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Supervisor    = %lu", channel->pInterfaceStat->fax.Disc_Supervisor);
      }
      if (channel->pInterfaceStat->fax.Disc_SUB_SEP_PWD) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc SUP SEP PWD   = %lu", channel->pInterfaceStat->fax.Disc_SUB_SEP_PWD);
      }
      if (channel->pInterfaceStat->fax.Disc_Invalid_Msg) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Invalid Msg.  = %lu", channel->pInterfaceStat->fax.Disc_Invalid_Msg);
      }
      if (channel->pInterfaceStat->fax.Disc_Page_Coding) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Page Coding   = %lu", channel->pInterfaceStat->fax.Disc_Page_Coding);
      }
      if (channel->pInterfaceStat->fax.Disc_App_Timeout) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Appl. T.o.    = %lu", channel->pInterfaceStat->fax.Disc_App_Timeout);
      }
      if (channel->pInterfaceStat->fax.Disc_Unspecified) {
        diva_mnt_internal_dprintf (pC->hDbg->id, DLI_LOG,
        "FAX Disc Unspec.       = %lu", channel->pInterfaceStat->fax.Disc_Unspecified);
      }
      break;
  }
}

/*
  Receive trace information from the Management Interface and store it in the
  internal trace buffer with MSG_TYPE_MLOG as is, without any filtering.
  Event Filtering and formatting is done in  Management Interface self.
  */
static void diva_maint_trace_notify (void* user_context,
                                     diva_strace_library_interface_t* hLib,
                                     int Adapter,
                                     void* xlog_buffer,
                                     int length) {
  diva_maint_client_t* pC = (diva_maint_client_t*)user_context;
  diva_dbg_entry_head_t* pmsg;
  word size;
  dword sec, usec;
  int ch = TraceFilterChannel;
  int id = TraceFilterIdent;

  /*
    Selective trace
    */
  if ((id >= 0) && (ch >= 0) && (id < ARRAY_SIZE(clients)) &&
      (clients[id].Dbg.id == (byte)id) && (clients[id].pIdiLib == hLib)) {
    const char* p = NULL;
    int ch_value = -1;
    MI_XLOG_HDR *TrcData = (MI_XLOG_HDR *)xlog_buffer;

    if (Adapter != clients[id].logical) {
      return; /* Ignore all trace messages from other adapters */
    }

    if (TrcData->code == 24) {
      p = (char*)&TrcData->code;
      p += 2;
    }

    /*
      All L1 messages start as [dsp,ch], so we can filter this information
      and filter out all messages that use different channel
      */
    if (p && p[0] == '[') {
      if (p[2] == ',') {
        p += 3;
        ch_value = *p - '0';
      } else if (p[3] == ',') {
        p += 4;
        ch_value = *p - '0';
      }
      if (ch_value >= 0) {
        if (p[2] == ']') {
          ch_value = ch_value * 10 + p[1] - '0';
        }
        if (ch_value != ch) {
          return; /* Ignore other channels */
        }
      }
    }

        } else if (TraceFilter[0] != 0) {
    return; /* Ignore trace if trace filter is activated, but idle */
  }

  diva_os_get_time (&sec, &usec);

  while (!(pmsg = (diva_dbg_entry_head_t*)queueAllocMsg (dbg_queue,
                              (word)length+sizeof(*pmsg)))) {
    if ((pmsg = (diva_dbg_entry_head_t*)queuePeekMsg (dbg_queue, &size))) {
      queueFreeMsg (dbg_queue);
    } else {
      break;
    }
  }
  if (pmsg) {
    memcpy (&pmsg[1], xlog_buffer, length);
    pmsg->sequence    = dbg_sequence++;
    pmsg->time_sec    = sec;
    pmsg->time_usec   = usec;
    pmsg->facility    = MSG_TYPE_MLOG;
    pmsg->dli         = pC->logical;
    pmsg->drv_id      = pC->hDbg->id;
    pmsg->di_cpu      = 0;
    pmsg->data_length = length;
    queueCompleteMsg (pmsg);
    if (queueCount(dbg_queue)) {
      diva_maint_wakeup_read();
    }
  }
}


/*
  Convert MAINT trace mask to management interface trace mask/work/facility and
  issue command to management interface
  */
static void diva_change_management_debug_mask (diva_maint_client_t* pC, dword old_mask) {
  if (pC->request && pC->hDbg && pC->pIdiLib) {
    dword changed = pC->hDbg->dbgMask ^ old_mask;

    if (changed & DIVA_MGT_DBG_TRACE) {
      (*(pC->pIdiLib->DivaSTraceSetInfo))(pC->pIdiLib,
                                          (pC->hDbg->dbgMask & DIVA_MGT_DBG_TRACE) != 0);
    }
    if (changed & DIVA_MGT_DBG_DCHAN) {
      (*(pC->pIdiLib->DivaSTraceSetDChannel))(pC->pIdiLib,
                                              (pC->hDbg->dbgMask & DIVA_MGT_DBG_DCHAN) != 0);
    }
    if (!TraceFilter[0]) {
      if (changed & DIVA_MGT_DBG_IFC_BCHANNEL) {
        int i, state = ((pC->hDbg->dbgMask & DIVA_MGT_DBG_IFC_BCHANNEL) != 0);

        for (i = 0; i < pC->channels; i++) {
          (*(pC->pIdiLib->DivaSTraceSetBChannel))(pC->pIdiLib, i+1, state);
        }
      }
      if (changed & DIVA_MGT_DBG_IFC_AUDIO) {
        int i, state = ((pC->hDbg->dbgMask & DIVA_MGT_DBG_IFC_AUDIO) != 0);

        for (i = 0; i < pC->channels; i++) {
          (*(pC->pIdiLib->DivaSTraceSetAudioTap))(pC->pIdiLib, i+1, state);
        }
      }
    }
  }
}


void diva_mnt_internal_dprintf (dword drv_id, dword type, char* fmt, ...) {
  va_list ap;

        va_start(ap, fmt);
  DI_format (0, (word)drv_id, (int)type, fmt, ap);
        va_end(ap);
}

/*
  Shutdown all adapters before driver removal
  */
int diva_mnt_shutdown_xdi_adapters (void) {
  diva_os_spin_lock_magic_t old_irql, old_irql1;
  int i, fret = 0;
  byte * pmem;


  for (i = 1; i < ARRAY_SIZE(clients); i++) {
    pmem = NULL;

    diva_os_enter_spin_lock (&dbg_adapter_lock, &old_irql1, "unload");
    diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "unload");

    if (clients[i].hDbg && clients[i].pIdiLib && clients[i].request) {
      if ((*(clients[i].pIdiLib->DivaSTraceLibraryStop))(clients[i].pIdiLib) == 1) {
        /*
          Adapter removal complete
          */
        if (clients[i].pIdiLib) {
          (*(clients[i].pIdiLib->DivaSTraceLibraryFinit))(clients[i].pIdiLib->hLib);
          clients[i].pIdiLib = NULL;

          pmem = clients[i].pmem;
          clients[i].pmem = NULL;
        }
        clients[i].hDbg    = NULL;
        clients[i].request_pending = 0;

        if (clients[i].dma_handle >= 0) {
          /*
            Free DMA handle
            */
          diva_free_dma_descriptor (clients[i].request, clients[i].dma_handle);
          clients[i].dma_handle = -1;
                                }
        clients[i].request = NULL;
      } else {
        fret = -1;
      }
    }

    diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "unload");
    if (clients[i].hDbg && clients[i].pIdiLib && clients[i].request && clients[i].request_pending) {
      clients[i].request_pending = 0;
      (*(clients[i].request))((ENTITY*)(*(clients[i].pIdiLib->DivaSTraceGetHandle))(clients[i].pIdiLib->hLib));
      if (clients[i].dma_handle >= 0) {
        diva_free_dma_descriptor (clients[i].request, clients[i].dma_handle);
        clients[i].dma_handle = -1;
      }
    }
    diva_os_leave_spin_lock (&dbg_adapter_lock, &old_irql1, "unload");

    if (pmem) {
      diva_os_free (0, pmem);
    }
  }

  return (fret);
}

/*
  Set/Read the trace filter used for selective tracing.
  Affects B- and Audio Tap trace mask at run time
  */
int diva_set_trace_filter (int filter_length, const char* filter) {
  diva_os_spin_lock_magic_t old_irql, old_irql1;
  int i, ch, on, client_b_on, client_atap_on;

  diva_os_enter_spin_lock (&dbg_adapter_lock, &old_irql1, "dbg mask");
  diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "write_filter");

  if (filter_length <= DIVA_MAX_SELECTIVE_FILTER_LENGTH) {
    memcpy (&TraceFilter[0], filter, filter_length);
    if (TraceFilter[filter_length]) {
      TraceFilter[filter_length] = 0;
    }
    if (TraceFilter[0] == '*') {
      TraceFilter[0] = 0;
    }
  } else {
    filter_length = -1;
  }

  TraceFilterIdent   = -1;
  TraceFilterChannel = -1;

  on = (TraceFilter[0] == 0);

  for (i = 1; i < ARRAY_SIZE(clients); i++) {
    if (clients[i].hDbg && clients[i].pIdiLib && clients[i].request) {
      client_b_on    = on && ((clients[i].hDbg->dbgMask & DIVA_MGT_DBG_IFC_BCHANNEL) != 0);
      client_atap_on = on && ((clients[i].hDbg->dbgMask & DIVA_MGT_DBG_IFC_AUDIO)    != 0);
      for (ch = 0; ch < clients[i].channels; ch++) {
        (*(clients[i].pIdiLib->DivaSTraceSetBChannel))(clients[i].pIdiLib->hLib, ch+1, client_b_on);
        (*(clients[i].pIdiLib->DivaSTraceSetAudioTap))(clients[i].pIdiLib->hLib, ch+1, client_atap_on);
      }
    }
  }

  for (i = 1; i < ARRAY_SIZE(clients); i++) {
    if (clients[i].hDbg && clients[i].pIdiLib && clients[i].request && clients[i].request_pending) {
      diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "write_filter");
      clients[i].request_pending = 0;
      (*(clients[i].request))((ENTITY*)(*(clients[i].pIdiLib->DivaSTraceGetHandle))(clients[i].pIdiLib->hLib));
      diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "write_filter");
    }
  }

  diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "write_filter");
  diva_os_leave_spin_lock (&dbg_adapter_lock, &old_irql1, "dbg mask");

  return (filter_length);
}

int diva_get_trace_filter (int max_length, char* filter) {
  diva_os_spin_lock_magic_t old_irql;
  int len;

  diva_os_enter_spin_lock (&dbg_q_lock, &old_irql, "read_filter");
  len = strlen (&TraceFilter[0]) + 1;
  if (max_length >= len) {
    memcpy (filter, &TraceFilter[0], len);
  }
  diva_os_leave_spin_lock (&dbg_q_lock, &old_irql, "read_filter");

  return (len);
}

static int diva_dbg_cmp_key (const char* ref, const char* key) {
        while (*key && (*ref++ == *key++));
  return (!*key && !*ref);
}

/*
  In case trace filter starts with "C" character then
  all following characters are interpreted as command.
  Followings commands are available:
  - single, trace single call at time, independent from CPN/CiPN
  */
static int diva_mnt_cmp_nmbr (const char* nmbr) {
  const char* ref = &TraceFilter[0];
  int ref_len = strlen(&TraceFilter[0]), nmbr_len = strlen(nmbr);

  if (ref[0] == 'C') {
    if (diva_dbg_cmp_key (&ref[1], "single")) {
      return (0);
    }
    return (-1);
  }

  if (!ref_len || (ref_len > nmbr_len)) {
    return (-1);
  }

  nmbr = nmbr + nmbr_len - 1;
  ref  = ref  + ref_len  - 1;

  while (ref_len--) {
    if (*nmbr-- != *ref--) {
      return (-1);
    }
  }

  return (0);
}

static int diva_get_dma_descriptor (IDI_CALL request, dword *dma_magic) {
  ENTITY e;
  IDI_SYNC_REQ* pReq = (IDI_SYNC_REQ*)&e;

  if (!request) {
    return (-1);
  }

  pReq->xdi_dma_descriptor_operation.Req = 0;
  pReq->xdi_dma_descriptor_operation.Rc = IDI_SYNC_REQ_DMA_DESCRIPTOR_OPERATION;

  pReq->xdi_dma_descriptor_operation.info.operation =     IDI_SYNC_REQ_DMA_DESCRIPTOR_ALLOC;
  pReq->xdi_dma_descriptor_operation.info.descriptor_number  = -1;
  pReq->xdi_dma_descriptor_operation.info.descriptor_address = NULL;
  pReq->xdi_dma_descriptor_operation.info.descriptor_magic   = 0;

  (*request)((ENTITY*)pReq);

  if (!pReq->xdi_dma_descriptor_operation.info.operation &&
      (pReq->xdi_dma_descriptor_operation.info.descriptor_number >= 0) &&
      pReq->xdi_dma_descriptor_operation.info.descriptor_magic) {
    *dma_magic = pReq->xdi_dma_descriptor_operation.info.descriptor_magic;
    return (pReq->xdi_dma_descriptor_operation.info.descriptor_number);
  } else {
    return (-1);
  }
}

static void diva_free_dma_descriptor (IDI_CALL request, int nr) {
  ENTITY e;
  IDI_SYNC_REQ* pReq = (IDI_SYNC_REQ*)&e;

  if (!request || (nr < 0)) {
    return;
  }

  pReq->xdi_dma_descriptor_operation.Req = 0;
  pReq->xdi_dma_descriptor_operation.Rc = IDI_SYNC_REQ_DMA_DESCRIPTOR_OPERATION;

  pReq->xdi_dma_descriptor_operation.info.operation = IDI_SYNC_REQ_DMA_DESCRIPTOR_FREE;
  pReq->xdi_dma_descriptor_operation.info.descriptor_number  = nr;
  pReq->xdi_dma_descriptor_operation.info.descriptor_address = NULL;
  pReq->xdi_dma_descriptor_operation.info.descriptor_magic   = 0;

  (*request)((ENTITY*)pReq);
}