| /* |
| * |
| Copyright (c) Eicon Networks, 2000. |
| * |
| This source file is supplied for the use with |
| Eicon Networks range of DIVA Server Adapters. |
| * |
| Eicon File Revision : 1.9 |
| * |
| This program is free software; you can redistribute it and/or modify |
| it under the terms of the GNU General Public License as published by |
| the Free Software Foundation; either version 2, or (at your option) |
| any later version. |
| * |
| This program is distributed in the hope that it will be useful, |
| but WITHOUT ANY WARRANTY OF ANY KIND WHATSOEVER INCLUDING ANY |
| implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. |
| See the GNU General Public License for more details. |
| * |
| You should have received a copy of the GNU General Public License |
| along with this program; if not, write to the Free Software |
| Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. |
| * |
| */ |
| #include "platform.h" |
| #include "kst_ifc.h" |
| #include "di_defs.h" |
| #include "maintidi.h" |
| #include "pc.h" |
| #include "man_defs.h" |
| |
| |
| extern void diva_mnt_internal_dprintf (dword drv_id, dword type, char* p, ...); |
| |
| #define MODEM_PARSE_ENTRIES 16 /* amount of variables of interest */ |
| #define FAX_PARSE_ENTRIES 12 /* amount of variables of interest */ |
| #define LINE_PARSE_ENTRIES 15 /* amount of variables of interest */ |
| #define STAT_PARSE_ENTRIES 70 /* amount of variables of interest */ |
| |
| /* |
| LOCAL FUNCTIONS |
| */ |
| static int DivaSTraceLibraryStart (void* hLib); |
| static int DivaSTraceLibraryStop (void* hLib); |
| static int SuperTraceLibraryFinit (void* hLib); |
| static void* SuperTraceGetHandle (void* hLib); |
| static int SuperTraceMessageInput (void* hLib); |
| static int SuperTraceSetAudioTap (void* hLib, int Channel, int on); |
| static int SuperTraceSetBChannel (void* hLib, int Channel, int on); |
| static int SuperTraceSetDChannel (void* hLib, int on); |
| static int SuperTraceSetInfo (void* hLib, int on); |
| static int SuperTraceClearCall (void* hLib, int Channel); |
| static int SuperTraceGetOutgoingCallStatistics (void* hLib); |
| static int SuperTraceGetIncomingCallStatistics (void* hLib); |
| static int SuperTraceGetModemStatistics (void* hLib); |
| static int SuperTraceGetFaxStatistics (void* hLib); |
| static int SuperTraceGetBLayer1Statistics (void* hLib); |
| static int SuperTraceGetBLayer2Statistics (void* hLib); |
| static int SuperTraceGetDLayer1Statistics (void* hLib); |
| static int SuperTraceGetDLayer2Statistics (void* hLib); |
| |
| /* |
| LOCAL FUNCTIONS |
| */ |
| static int ScheduleNextTraceRequest (diva_strace_context_t* pLib); |
| static int process_idi_event (diva_strace_context_t* pLib, |
| diva_man_var_header_t* pVar); |
| static int process_idi_info (diva_strace_context_t* pLib, |
| diva_man_var_header_t* pVar); |
| static int diva_modem_event (diva_strace_context_t* pLib, int Channel); |
| static int diva_fax_event (diva_strace_context_t* pLib, int Channel); |
| static int diva_line_event (diva_strace_context_t* pLib, int Channel); |
| static int diva_modem_info (diva_strace_context_t* pLib, |
| int Channel, |
| diva_man_var_header_t* pVar); |
| static int diva_fax_info (diva_strace_context_t* pLib, |
| int Channel, |
| diva_man_var_header_t* pVar); |
| static int diva_line_info (diva_strace_context_t* pLib, |
| int Channel, |
| diva_man_var_header_t* pVar); |
| static int diva_ifc_statistics (diva_strace_context_t* pLib, |
| diva_man_var_header_t* pVar); |
| static diva_man_var_header_t* get_next_var (diva_man_var_header_t* pVar); |
| static diva_man_var_header_t* find_var (diva_man_var_header_t* pVar, |
| const char* name); |
| static int diva_strace_read_int (diva_man_var_header_t* pVar, int* var); |
| static int diva_strace_read_uint (diva_man_var_header_t* pVar, dword* var); |
| static int diva_strace_read_asz (diva_man_var_header_t* pVar, char* var); |
| static int diva_strace_read_asc (diva_man_var_header_t* pVar, char* var); |
| static int diva_strace_read_ie (diva_man_var_header_t* pVar, |
| diva_trace_ie_t* var); |
| static void diva_create_parse_table (diva_strace_context_t* pLib); |
| static void diva_trace_error (diva_strace_context_t* pLib, |
| int error, const char* file, int line); |
| static void diva_trace_notify_user (diva_strace_context_t* pLib, |
| int Channel, |
| int notify_subject); |
| static int diva_trace_read_variable (diva_man_var_header_t* pVar, |
| void* variable); |
| |
| /* |
| Initialize the library and return context |
| of the created trace object that will represent |
| the IDI adapter. |
| Return 0 on error. |
| */ |
| diva_strace_library_interface_t* DivaSTraceLibraryCreateInstance (int Adapter, |
| const diva_trace_library_user_interface_t* user_proc, |
| byte* pmem) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)pmem; |
| int i; |
| |
| if (!pLib) { |
| return NULL; |
| } |
| |
| pmem += sizeof(*pLib); |
| memset(pLib, 0x00, sizeof(*pLib)); |
| |
| pLib->Adapter = Adapter; |
| |
| /* |
| Set up Library Interface |
| */ |
| pLib->instance.hLib = pLib; |
| pLib->instance.DivaSTraceLibraryStart = DivaSTraceLibraryStart; |
| pLib->instance.DivaSTraceLibraryStop = DivaSTraceLibraryStop; |
| pLib->instance.DivaSTraceLibraryFinit = SuperTraceLibraryFinit; |
| pLib->instance.DivaSTraceMessageInput = SuperTraceMessageInput; |
| pLib->instance.DivaSTraceGetHandle = SuperTraceGetHandle; |
| pLib->instance.DivaSTraceSetAudioTap = SuperTraceSetAudioTap; |
| pLib->instance.DivaSTraceSetBChannel = SuperTraceSetBChannel; |
| pLib->instance.DivaSTraceSetDChannel = SuperTraceSetDChannel; |
| pLib->instance.DivaSTraceSetInfo = SuperTraceSetInfo; |
| pLib->instance.DivaSTraceGetOutgoingCallStatistics = \ |
| SuperTraceGetOutgoingCallStatistics; |
| pLib->instance.DivaSTraceGetIncomingCallStatistics = \ |
| SuperTraceGetIncomingCallStatistics; |
| pLib->instance.DivaSTraceGetModemStatistics = \ |
| SuperTraceGetModemStatistics; |
| pLib->instance.DivaSTraceGetFaxStatistics = \ |
| SuperTraceGetFaxStatistics; |
| pLib->instance.DivaSTraceGetBLayer1Statistics = \ |
| SuperTraceGetBLayer1Statistics; |
| pLib->instance.DivaSTraceGetBLayer2Statistics = \ |
| SuperTraceGetBLayer2Statistics; |
| pLib->instance.DivaSTraceGetDLayer1Statistics = \ |
| SuperTraceGetDLayer1Statistics; |
| pLib->instance.DivaSTraceGetDLayer2Statistics = \ |
| SuperTraceGetDLayer2Statistics; |
| pLib->instance.DivaSTraceClearCall = SuperTraceClearCall; |
| |
| |
| if (user_proc) { |
| pLib->user_proc_table.user_context = user_proc->user_context; |
| pLib->user_proc_table.notify_proc = user_proc->notify_proc; |
| pLib->user_proc_table.trace_proc = user_proc->trace_proc; |
| pLib->user_proc_table.error_notify_proc = user_proc->error_notify_proc; |
| } |
| |
| if (!(pLib->hAdapter = SuperTraceOpenAdapter (Adapter))) { |
| diva_mnt_internal_dprintf (0, DLI_ERR, "Can not open XDI adapter"); |
| return NULL; |
| } |
| pLib->Channels = SuperTraceGetNumberOfChannels (pLib->hAdapter); |
| |
| /* |
| Calculate amount of parte table entites necessary to translate |
| information from all events of onterest |
| */ |
| pLib->parse_entries = (MODEM_PARSE_ENTRIES + FAX_PARSE_ENTRIES + \ |
| STAT_PARSE_ENTRIES + \ |
| LINE_PARSE_ENTRIES + 1) * pLib->Channels; |
| pLib->parse_table = (diva_strace_path2action_t*)pmem; |
| |
| for (i = 0; i < 30; i++) { |
| pLib->lines[i].pInterface = &pLib->Interface; |
| pLib->lines[i].pInterfaceStat = &pLib->InterfaceStat; |
| } |
| |
| pLib->e.R = &pLib->RData; |
| |
| pLib->req_busy = 1; |
| pLib->rc_ok = ASSIGN_OK; |
| |
| diva_create_parse_table (pLib); |
| |
| return ((diva_strace_library_interface_t*)pLib); |
| } |
| |
| static int DivaSTraceLibraryStart (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| |
| return (SuperTraceASSIGN (pLib->hAdapter, pLib->buffer)); |
| } |
| |
| /* |
| Return (-1) on error |
| Return (0) if was initiated or pending |
| Return (1) if removal is complete |
| */ |
| static int DivaSTraceLibraryStop (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| |
| if (!pLib->e.Id) { /* Was never started/assigned */ |
| return (1); |
| } |
| |
| switch (pLib->removal_state) { |
| case 0: |
| pLib->removal_state = 1; |
| ScheduleNextTraceRequest(pLib); |
| break; |
| |
| case 3: |
| return (1); |
| } |
| |
| return (0); |
| } |
| |
| static int SuperTraceLibraryFinit (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| if (pLib) { |
| if (pLib->hAdapter) { |
| SuperTraceCloseAdapter (pLib->hAdapter); |
| } |
| return (0); |
| } |
| return (-1); |
| } |
| |
| static void* SuperTraceGetHandle (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| |
| return (&pLib->e); |
| } |
| |
| /* |
| After library handle object is gone in signaled state |
| this function should be called and will pick up incoming |
| IDI messages (return codes and indications). |
| */ |
| static int SuperTraceMessageInput (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| int ret = 0; |
| byte Rc, Ind; |
| |
| if (pLib->e.complete == 255) { |
| /* |
| Process return code |
| */ |
| pLib->req_busy = 0; |
| Rc = pLib->e.Rc; |
| pLib->e.Rc = 0; |
| |
| if (pLib->removal_state == 2) { |
| pLib->removal_state = 3; |
| return (0); |
| } |
| |
| if (Rc != pLib->rc_ok) { |
| int ignore = 0; |
| /* |
| Auto-detect amount of events/channels and features |
| */ |
| if (pLib->general_b_ch_event == 1) { |
| pLib->general_b_ch_event = 2; |
| ignore = 1; |
| } else if (pLib->general_fax_event == 1) { |
| pLib->general_fax_event = 2; |
| ignore = 1; |
| } else if (pLib->general_mdm_event == 1) { |
| pLib->general_mdm_event = 2; |
| ignore = 1; |
| } else if ((pLib->ChannelsTraceActive < pLib->Channels) && pLib->ChannelsTraceActive) { |
| pLib->ChannelsTraceActive = pLib->Channels; |
| ignore = 1; |
| } else if (pLib->ModemTraceActive < pLib->Channels) { |
| pLib->ModemTraceActive = pLib->Channels; |
| ignore = 1; |
| } else if (pLib->FaxTraceActive < pLib->Channels) { |
| pLib->FaxTraceActive = pLib->Channels; |
| ignore = 1; |
| } else if (pLib->audio_trace_init == 2) { |
| ignore = 1; |
| pLib->audio_trace_init = 1; |
| } else if (pLib->eye_pattern_pending) { |
| pLib->eye_pattern_pending = 0; |
| ignore = 1; |
| } else if (pLib->audio_tap_pending) { |
| pLib->audio_tap_pending = 0; |
| ignore = 1; |
| } |
| |
| if (!ignore) { |
| return (-1); /* request failed */ |
| } |
| } else { |
| if (pLib->general_b_ch_event == 1) { |
| pLib->ChannelsTraceActive = pLib->Channels; |
| pLib->general_b_ch_event = 2; |
| } else if (pLib->general_fax_event == 1) { |
| pLib->general_fax_event = 2; |
| pLib->FaxTraceActive = pLib->Channels; |
| } else if (pLib->general_mdm_event == 1) { |
| pLib->general_mdm_event = 2; |
| pLib->ModemTraceActive = pLib->Channels; |
| } |
| } |
| if (pLib->audio_trace_init == 2) { |
| pLib->audio_trace_init = 1; |
| } |
| pLib->rc_ok = 0xff; /* default OK after assign was done */ |
| if ((ret = ScheduleNextTraceRequest(pLib))) { |
| return (-1); |
| } |
| } else { |
| /* |
| Process indication |
| Always 'RNR' indication if return code is pending |
| */ |
| Ind = pLib->e.Ind; |
| pLib->e.Ind = 0; |
| if (pLib->removal_state) { |
| pLib->e.RNum = 0; |
| pLib->e.RNR = 2; |
| } else if (pLib->req_busy) { |
| pLib->e.RNum = 0; |
| pLib->e.RNR = 1; |
| } else { |
| if (pLib->e.complete != 0x02) { |
| /* |
| Look-ahead call, set up buffers |
| */ |
| pLib->e.RNum = 1; |
| pLib->e.R->P = (byte*)&pLib->buffer[0]; |
| pLib->e.R->PLength = (word)(sizeof(pLib->buffer) - 1); |
| |
| } else { |
| /* |
| Indication reception complete, process it now |
| */ |
| byte* p = (byte*)&pLib->buffer[0]; |
| pLib->buffer[pLib->e.R->PLength] = 0; /* terminate I.E. with zero */ |
| |
| switch (Ind) { |
| case MAN_COMBI_IND: { |
| int total_length = pLib->e.R->PLength; |
| word this_ind_length; |
| |
| while (total_length > 3 && *p) { |
| Ind = *p++; |
| this_ind_length = (word)p[0] | ((word)p[1] << 8); |
| p += 2; |
| |
| switch (Ind) { |
| case MAN_INFO_IND: |
| if (process_idi_info (pLib, (diva_man_var_header_t*)p)) { |
| return (-1); |
| } |
| break; |
| case MAN_EVENT_IND: |
| if (process_idi_event (pLib, (diva_man_var_header_t*)p)) { |
| return (-1); |
| } |
| break; |
| case MAN_TRACE_IND: |
| if (pLib->trace_on == 1) { |
| /* |
| Ignore first trace event that is result of |
| EVENT_ON operation |
| */ |
| pLib->trace_on++; |
| } else { |
| /* |
| Delivery XLOG buffer to application |
| */ |
| if (pLib->user_proc_table.trace_proc) { |
| (*(pLib->user_proc_table.trace_proc))(pLib->user_proc_table.user_context, |
| &pLib->instance, pLib->Adapter, |
| p, this_ind_length); |
| } |
| } |
| break; |
| default: |
| diva_mnt_internal_dprintf (0, DLI_ERR, "Unknon IDI Ind (DMA mode): %02x", Ind); |
| } |
| p += (this_ind_length+1); |
| total_length -= (4 + this_ind_length); |
| } |
| } break; |
| case MAN_INFO_IND: |
| if (process_idi_info (pLib, (diva_man_var_header_t*)p)) { |
| return (-1); |
| } |
| break; |
| case MAN_EVENT_IND: |
| if (process_idi_event (pLib, (diva_man_var_header_t*)p)) { |
| return (-1); |
| } |
| break; |
| case MAN_TRACE_IND: |
| if (pLib->trace_on == 1) { |
| /* |
| Ignore first trace event that is result of |
| EVENT_ON operation |
| */ |
| pLib->trace_on++; |
| } else { |
| /* |
| Delivery XLOG buffer to application |
| */ |
| if (pLib->user_proc_table.trace_proc) { |
| (*(pLib->user_proc_table.trace_proc))(pLib->user_proc_table.user_context, |
| &pLib->instance, pLib->Adapter, |
| p, pLib->e.R->PLength); |
| } |
| } |
| break; |
| default: |
| diva_mnt_internal_dprintf (0, DLI_ERR, "Unknon IDI Ind: %02x", Ind); |
| } |
| } |
| } |
| } |
| |
| if ((ret = ScheduleNextTraceRequest(pLib))) { |
| return (-1); |
| } |
| |
| return (ret); |
| } |
| |
| /* |
| Internal state machine responsible for scheduling of requests |
| */ |
| static int ScheduleNextTraceRequest (diva_strace_context_t* pLib) { |
| char name[64]; |
| int ret = 0; |
| int i; |
| |
| if (pLib->req_busy) { |
| return (0); |
| } |
| |
| if (pLib->removal_state == 1) { |
| if (SuperTraceREMOVE (pLib->hAdapter)) { |
| pLib->removal_state = 3; |
| } else { |
| pLib->req_busy = 1; |
| pLib->removal_state = 2; |
| } |
| return (0); |
| } |
| |
| if (pLib->removal_state) { |
| return (0); |
| } |
| |
| if (!pLib->general_b_ch_event) { |
| if ((ret = SuperTraceTraceOnRequest(pLib->hAdapter, "State\\B Event", pLib->buffer))) { |
| return (-1); |
| } |
| pLib->general_b_ch_event = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->general_fax_event) { |
| if ((ret = SuperTraceTraceOnRequest(pLib->hAdapter, "State\\FAX Event", pLib->buffer))) { |
| return (-1); |
| } |
| pLib->general_fax_event = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->general_mdm_event) { |
| if ((ret = SuperTraceTraceOnRequest(pLib->hAdapter, "State\\Modem Event", pLib->buffer))) { |
| return (-1); |
| } |
| pLib->general_mdm_event = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->ChannelsTraceActive < pLib->Channels) { |
| pLib->ChannelsTraceActive++; |
| sprintf (name, "State\\B%d\\Line", pLib->ChannelsTraceActive); |
| if ((ret = SuperTraceTraceOnRequest(pLib->hAdapter, name, pLib->buffer))) { |
| pLib->ChannelsTraceActive--; |
| return (-1); |
| } |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->ModemTraceActive < pLib->Channels) { |
| pLib->ModemTraceActive++; |
| sprintf (name, "State\\B%d\\Modem\\Event", pLib->ModemTraceActive); |
| if ((ret = SuperTraceTraceOnRequest(pLib->hAdapter, name, pLib->buffer))) { |
| pLib->ModemTraceActive--; |
| return (-1); |
| } |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->FaxTraceActive < pLib->Channels) { |
| pLib->FaxTraceActive++; |
| sprintf (name, "State\\B%d\\FAX\\Event", pLib->FaxTraceActive); |
| if ((ret = SuperTraceTraceOnRequest(pLib->hAdapter, name, pLib->buffer))) { |
| pLib->FaxTraceActive--; |
| return (-1); |
| } |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->trace_mask_init) { |
| word tmp = 0x0000; |
| if (SuperTraceWriteVar (pLib->hAdapter, |
| pLib->buffer, |
| "Trace\\Event Enable", |
| &tmp, |
| 0x87, /* MI_BITFLD */ |
| sizeof(tmp))) { |
| return (-1); |
| } |
| pLib->trace_mask_init = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->audio_trace_init) { |
| dword tmp = 0x00000000; |
| if (SuperTraceWriteVar (pLib->hAdapter, |
| pLib->buffer, |
| "Trace\\AudioCh# Enable", |
| &tmp, |
| 0x87, /* MI_BITFLD */ |
| sizeof(tmp))) { |
| return (-1); |
| } |
| pLib->audio_trace_init = 2; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->bchannel_init) { |
| dword tmp = 0x00000000; |
| if (SuperTraceWriteVar (pLib->hAdapter, |
| pLib->buffer, |
| "Trace\\B-Ch# Enable", |
| &tmp, |
| 0x87, /* MI_BITFLD */ |
| sizeof(tmp))) { |
| return (-1); |
| } |
| pLib->bchannel_init = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->trace_length_init) { |
| word tmp = 30; |
| if (SuperTraceWriteVar (pLib->hAdapter, |
| pLib->buffer, |
| "Trace\\Max Log Length", |
| &tmp, |
| 0x82, /* MI_UINT */ |
| sizeof(tmp))) { |
| return (-1); |
| } |
| pLib->trace_length_init = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->trace_on) { |
| if (SuperTraceTraceOnRequest (pLib->hAdapter, |
| "Trace\\Log Buffer", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->trace_on = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->trace_event_mask != pLib->current_trace_event_mask) { |
| if (SuperTraceWriteVar (pLib->hAdapter, |
| pLib->buffer, |
| "Trace\\Event Enable", |
| &pLib->trace_event_mask, |
| 0x87, /* MI_BITFLD */ |
| sizeof(pLib->trace_event_mask))) { |
| return (-1); |
| } |
| pLib->current_trace_event_mask = pLib->trace_event_mask; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if ((pLib->audio_tap_pending >= 0) && (pLib->audio_tap_mask != pLib->current_audio_tap_mask)) { |
| if (SuperTraceWriteVar (pLib->hAdapter, |
| pLib->buffer, |
| "Trace\\AudioCh# Enable", |
| &pLib->audio_tap_mask, |
| 0x87, /* MI_BITFLD */ |
| sizeof(pLib->audio_tap_mask))) { |
| return (-1); |
| } |
| pLib->current_audio_tap_mask = pLib->audio_tap_mask; |
| pLib->audio_tap_pending = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if ((pLib->eye_pattern_pending >= 0) && (pLib->audio_tap_mask != pLib->current_eye_pattern_mask)) { |
| if (SuperTraceWriteVar (pLib->hAdapter, |
| pLib->buffer, |
| "Trace\\EyeCh# Enable", |
| &pLib->audio_tap_mask, |
| 0x87, /* MI_BITFLD */ |
| sizeof(pLib->audio_tap_mask))) { |
| return (-1); |
| } |
| pLib->current_eye_pattern_mask = pLib->audio_tap_mask; |
| pLib->eye_pattern_pending = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->bchannel_trace_mask != pLib->current_bchannel_trace_mask) { |
| if (SuperTraceWriteVar (pLib->hAdapter, |
| pLib->buffer, |
| "Trace\\B-Ch# Enable", |
| &pLib->bchannel_trace_mask, |
| 0x87, /* MI_BITFLD */ |
| sizeof(pLib->bchannel_trace_mask))) { |
| return (-1); |
| } |
| pLib->current_bchannel_trace_mask = pLib->bchannel_trace_mask; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->trace_events_down) { |
| if (SuperTraceTraceOnRequest (pLib->hAdapter, |
| "Events Down", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->trace_events_down = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->l1_trace) { |
| if (SuperTraceTraceOnRequest (pLib->hAdapter, |
| "State\\Layer1", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->l1_trace = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->l2_trace) { |
| if (SuperTraceTraceOnRequest (pLib->hAdapter, |
| "State\\Layer2 No1", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->l2_trace = 1; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| for (i = 0; i < 30; i++) { |
| if (pLib->pending_line_status & (1L << i)) { |
| sprintf (name, "State\\B%d", i+1); |
| if (SuperTraceReadRequest (pLib->hAdapter, name, pLib->buffer)) { |
| return (-1); |
| } |
| pLib->pending_line_status &= ~(1L << i); |
| pLib->req_busy = 1; |
| return (0); |
| } |
| if (pLib->pending_modem_status & (1L << i)) { |
| sprintf (name, "State\\B%d\\Modem", i+1); |
| if (SuperTraceReadRequest (pLib->hAdapter, name, pLib->buffer)) { |
| return (-1); |
| } |
| pLib->pending_modem_status &= ~(1L << i); |
| pLib->req_busy = 1; |
| return (0); |
| } |
| if (pLib->pending_fax_status & (1L << i)) { |
| sprintf (name, "State\\B%d\\FAX", i+1); |
| if (SuperTraceReadRequest (pLib->hAdapter, name, pLib->buffer)) { |
| return (-1); |
| } |
| pLib->pending_fax_status &= ~(1L << i); |
| pLib->req_busy = 1; |
| return (0); |
| } |
| if (pLib->clear_call_command & (1L << i)) { |
| sprintf (name, "State\\B%d\\Clear Call", i+1); |
| if (SuperTraceExecuteRequest (pLib->hAdapter, name, pLib->buffer)) { |
| return (-1); |
| } |
| pLib->clear_call_command &= ~(1L << i); |
| pLib->req_busy = 1; |
| return (0); |
| } |
| } |
| |
| if (pLib->outgoing_ifc_stats) { |
| if (SuperTraceReadRequest (pLib->hAdapter, |
| "Statistics\\Outgoing Calls", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->outgoing_ifc_stats = 0; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->incoming_ifc_stats) { |
| if (SuperTraceReadRequest (pLib->hAdapter, |
| "Statistics\\Incoming Calls", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->incoming_ifc_stats = 0; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->modem_ifc_stats) { |
| if (SuperTraceReadRequest (pLib->hAdapter, |
| "Statistics\\Modem", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->modem_ifc_stats = 0; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->fax_ifc_stats) { |
| if (SuperTraceReadRequest (pLib->hAdapter, |
| "Statistics\\FAX", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->fax_ifc_stats = 0; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->b1_ifc_stats) { |
| if (SuperTraceReadRequest (pLib->hAdapter, |
| "Statistics\\B-Layer1", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->b1_ifc_stats = 0; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->b2_ifc_stats) { |
| if (SuperTraceReadRequest (pLib->hAdapter, |
| "Statistics\\B-Layer2", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->b2_ifc_stats = 0; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->d1_ifc_stats) { |
| if (SuperTraceReadRequest (pLib->hAdapter, |
| "Statistics\\D-Layer1", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->d1_ifc_stats = 0; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (pLib->d2_ifc_stats) { |
| if (SuperTraceReadRequest (pLib->hAdapter, |
| "Statistics\\D-Layer2", |
| pLib->buffer)) { |
| return (-1); |
| } |
| pLib->d2_ifc_stats = 0; |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| if (!pLib->IncomingCallsCallsActive) { |
| pLib->IncomingCallsCallsActive = 1; |
| sprintf (name, "%s", "Statistics\\Incoming Calls\\Calls"); |
| if ((ret = SuperTraceTraceOnRequest(pLib->hAdapter, name, pLib->buffer))) { |
| pLib->IncomingCallsCallsActive = 0; |
| return (-1); |
| } |
| pLib->req_busy = 1; |
| return (0); |
| } |
| if (!pLib->IncomingCallsConnectedActive) { |
| pLib->IncomingCallsConnectedActive = 1; |
| sprintf (name, "%s", "Statistics\\Incoming Calls\\Connected"); |
| if ((ret = SuperTraceTraceOnRequest(pLib->hAdapter, name, pLib->buffer))) { |
| pLib->IncomingCallsConnectedActive = 0; |
| return (-1); |
| } |
| pLib->req_busy = 1; |
| return (0); |
| } |
| if (!pLib->OutgoingCallsCallsActive) { |
| pLib->OutgoingCallsCallsActive = 1; |
| sprintf (name, "%s", "Statistics\\Outgoing Calls\\Calls"); |
| if ((ret = SuperTraceTraceOnRequest(pLib->hAdapter, name, pLib->buffer))) { |
| pLib->OutgoingCallsCallsActive = 0; |
| return (-1); |
| } |
| pLib->req_busy = 1; |
| return (0); |
| } |
| if (!pLib->OutgoingCallsConnectedActive) { |
| pLib->OutgoingCallsConnectedActive = 1; |
| sprintf (name, "%s", "Statistics\\Outgoing Calls\\Connected"); |
| if ((ret = SuperTraceTraceOnRequest(pLib->hAdapter, name, pLib->buffer))) { |
| pLib->OutgoingCallsConnectedActive = 0; |
| return (-1); |
| } |
| pLib->req_busy = 1; |
| return (0); |
| } |
| |
| return (0); |
| } |
| |
| static int process_idi_event (diva_strace_context_t* pLib, |
| diva_man_var_header_t* pVar) { |
| const char* path = (char*)&pVar->path_length+1; |
| char name[64]; |
| int i; |
| |
| if (!strncmp("State\\B Event", path, pVar->path_length)) { |
| dword ch_id; |
| if (!diva_trace_read_variable (pVar, &ch_id)) { |
| if (!pLib->line_init_event && !pLib->pending_line_status) { |
| for (i = 1; i <= pLib->Channels; i++) { |
| diva_line_event(pLib, i); |
| } |
| return (0); |
| } else if (ch_id && ch_id <= pLib->Channels) { |
| return (diva_line_event(pLib, (int)ch_id)); |
| } |
| return (0); |
| } |
| return (-1); |
| } |
| |
| if (!strncmp("State\\FAX Event", path, pVar->path_length)) { |
| dword ch_id; |
| if (!diva_trace_read_variable (pVar, &ch_id)) { |
| if (!pLib->pending_fax_status && !pLib->fax_init_event) { |
| for (i = 1; i <= pLib->Channels; i++) { |
| diva_fax_event(pLib, i); |
| } |
| return (0); |
| } else if (ch_id && ch_id <= pLib->Channels) { |
| return (diva_fax_event(pLib, (int)ch_id)); |
| } |
| return (0); |
| } |
| return (-1); |
| } |
| |
| if (!strncmp("State\\Modem Event", path, pVar->path_length)) { |
| dword ch_id; |
| if (!diva_trace_read_variable (pVar, &ch_id)) { |
| if (!pLib->pending_modem_status && !pLib->modem_init_event) { |
| for (i = 1; i <= pLib->Channels; i++) { |
| diva_modem_event(pLib, i); |
| } |
| return (0); |
| } else if (ch_id && ch_id <= pLib->Channels) { |
| return (diva_modem_event(pLib, (int)ch_id)); |
| } |
| return (0); |
| } |
| return (-1); |
| } |
| |
| /* |
| First look for Line Event |
| */ |
| for (i = 1; i <= pLib->Channels; i++) { |
| sprintf (name, "State\\B%d\\Line", i); |
| if (find_var (pVar, name)) { |
| return (diva_line_event(pLib, i)); |
| } |
| } |
| |
| /* |
| Look for Moden Progress Event |
| */ |
| for (i = 1; i <= pLib->Channels; i++) { |
| sprintf (name, "State\\B%d\\Modem\\Event", i); |
| if (find_var (pVar, name)) { |
| return (diva_modem_event (pLib, i)); |
| } |
| } |
| |
| /* |
| Look for Fax Event |
| */ |
| for (i = 1; i <= pLib->Channels; i++) { |
| sprintf (name, "State\\B%d\\FAX\\Event", i); |
| if (find_var (pVar, name)) { |
| return (diva_fax_event (pLib, i)); |
| } |
| } |
| |
| /* |
| Notification about loss of events |
| */ |
| if (!strncmp("Events Down", path, pVar->path_length)) { |
| if (pLib->trace_events_down == 1) { |
| pLib->trace_events_down = 2; |
| } else { |
| diva_trace_error (pLib, 1, "Events Down", 0); |
| } |
| return (0); |
| } |
| |
| if (!strncmp("State\\Layer1", path, pVar->path_length)) { |
| diva_strace_read_asz (pVar, &pLib->lines[0].pInterface->Layer1[0]); |
| if (pLib->l1_trace == 1) { |
| pLib->l1_trace = 2; |
| } else { |
| diva_trace_notify_user (pLib, 0, DIVA_SUPER_TRACE_INTERFACE_CHANGE); |
| } |
| return (0); |
| } |
| if (!strncmp("State\\Layer2 No1", path, pVar->path_length)) { |
| char* tmp = &pLib->lines[0].pInterface->Layer2[0]; |
| dword l2_state; |
| if (diva_strace_read_uint(pVar, &l2_state)) |
| return -1; |
| |
| switch (l2_state) { |
| case 0: |
| strcpy (tmp, "Idle"); |
| break; |
| case 1: |
| strcpy (tmp, "Layer2 UP"); |
| break; |
| case 2: |
| strcpy (tmp, "Layer2 Disconnecting"); |
| break; |
| case 3: |
| strcpy (tmp, "Layer2 Connecting"); |
| break; |
| case 4: |
| strcpy (tmp, "SPID Initializing"); |
| break; |
| case 5: |
| strcpy (tmp, "SPID Initialised"); |
| break; |
| case 6: |
| strcpy (tmp, "Layer2 Connecting"); |
| break; |
| |
| case 7: |
| strcpy (tmp, "Auto SPID Stopped"); |
| break; |
| |
| case 8: |
| strcpy (tmp, "Auto SPID Idle"); |
| break; |
| |
| case 9: |
| strcpy (tmp, "Auto SPID Requested"); |
| break; |
| |
| case 10: |
| strcpy (tmp, "Auto SPID Delivery"); |
| break; |
| |
| case 11: |
| strcpy (tmp, "Auto SPID Complete"); |
| break; |
| |
| default: |
| sprintf (tmp, "U:%d", (int)l2_state); |
| } |
| if (pLib->l2_trace == 1) { |
| pLib->l2_trace = 2; |
| } else { |
| diva_trace_notify_user (pLib, 0, DIVA_SUPER_TRACE_INTERFACE_CHANGE); |
| } |
| return (0); |
| } |
| |
| if (!strncmp("Statistics\\Incoming Calls\\Calls", path, pVar->path_length) || |
| !strncmp("Statistics\\Incoming Calls\\Connected", path, pVar->path_length)) { |
| return (SuperTraceGetIncomingCallStatistics (pLib)); |
| } |
| |
| if (!strncmp("Statistics\\Outgoing Calls\\Calls", path, pVar->path_length) || |
| !strncmp("Statistics\\Outgoing Calls\\Connected", path, pVar->path_length)) { |
| return (SuperTraceGetOutgoingCallStatistics (pLib)); |
| } |
| |
| return (-1); |
| } |
| |
| static int diva_line_event (diva_strace_context_t* pLib, int Channel) { |
| pLib->pending_line_status |= (1L << (Channel-1)); |
| return (0); |
| } |
| |
| static int diva_modem_event (diva_strace_context_t* pLib, int Channel) { |
| pLib->pending_modem_status |= (1L << (Channel-1)); |
| return (0); |
| } |
| |
| static int diva_fax_event (diva_strace_context_t* pLib, int Channel) { |
| pLib->pending_fax_status |= (1L << (Channel-1)); |
| return (0); |
| } |
| |
| /* |
| Process INFO indications that arrive from the card |
| Uses path of first I.E. to detect the source of the |
| infication |
| */ |
| static int process_idi_info (diva_strace_context_t* pLib, |
| diva_man_var_header_t* pVar) { |
| const char* path = (char*)&pVar->path_length+1; |
| char name[64]; |
| int i, len; |
| |
| /* |
| First look for Modem Status Info |
| */ |
| for (i = pLib->Channels; i > 0; i--) { |
| len = sprintf (name, "State\\B%d\\Modem", i); |
| if (!strncmp(name, path, len)) { |
| return (diva_modem_info (pLib, i, pVar)); |
| } |
| } |
| |
| /* |
| Look for Fax Status Info |
| */ |
| for (i = pLib->Channels; i > 0; i--) { |
| len = sprintf (name, "State\\B%d\\FAX", i); |
| if (!strncmp(name, path, len)) { |
| return (diva_fax_info (pLib, i, pVar)); |
| } |
| } |
| |
| /* |
| Look for Line Status Info |
| */ |
| for (i = pLib->Channels; i > 0; i--) { |
| len = sprintf (name, "State\\B%d", i); |
| if (!strncmp(name, path, len)) { |
| return (diva_line_info (pLib, i, pVar)); |
| } |
| } |
| |
| if (!diva_ifc_statistics (pLib, pVar)) { |
| return (0); |
| } |
| |
| return (-1); |
| } |
| |
| /* |
| MODEM INSTANCE STATE UPDATE |
| |
| Update Modem Status Information and issue notification to user, |
| that will inform about change in the state of modem instance, that is |
| associuated with this channel |
| */ |
| static int diva_modem_info (diva_strace_context_t* pLib, |
| int Channel, |
| diva_man_var_header_t* pVar) { |
| diva_man_var_header_t* cur; |
| int i, nr = Channel - 1; |
| |
| for (i = pLib->modem_parse_entry_first[nr]; |
| i <= pLib->modem_parse_entry_last[nr]; i++) { |
| if ((cur = find_var (pVar, pLib->parse_table[i].path))) { |
| if (diva_trace_read_variable (cur, pLib->parse_table[i].variable)) { |
| diva_trace_error (pLib, -3 , __FILE__, __LINE__); |
| return (-1); |
| } |
| } else { |
| diva_trace_error (pLib, -2 , __FILE__, __LINE__); |
| return (-1); |
| } |
| } |
| |
| /* |
| We do not use first event to notify user - this is the event that is |
| generated as result of EVENT ON operation and is used only to initialize |
| internal variables of application |
| */ |
| if (pLib->modem_init_event & (1L << nr)) { |
| diva_trace_notify_user (pLib, nr, DIVA_SUPER_TRACE_NOTIFY_MODEM_CHANGE); |
| } else { |
| pLib->modem_init_event |= (1L << nr); |
| } |
| |
| return (0); |
| } |
| |
| static int diva_fax_info (diva_strace_context_t* pLib, |
| int Channel, |
| diva_man_var_header_t* pVar) { |
| diva_man_var_header_t* cur; |
| int i, nr = Channel - 1; |
| |
| for (i = pLib->fax_parse_entry_first[nr]; |
| i <= pLib->fax_parse_entry_last[nr]; i++) { |
| if ((cur = find_var (pVar, pLib->parse_table[i].path))) { |
| if (diva_trace_read_variable (cur, pLib->parse_table[i].variable)) { |
| diva_trace_error (pLib, -3 , __FILE__, __LINE__); |
| return (-1); |
| } |
| } else { |
| diva_trace_error (pLib, -2 , __FILE__, __LINE__); |
| return (-1); |
| } |
| } |
| |
| /* |
| We do not use first event to notify user - this is the event that is |
| generated as result of EVENT ON operation and is used only to initialize |
| internal variables of application |
| */ |
| if (pLib->fax_init_event & (1L << nr)) { |
| diva_trace_notify_user (pLib, nr, DIVA_SUPER_TRACE_NOTIFY_FAX_CHANGE); |
| } else { |
| pLib->fax_init_event |= (1L << nr); |
| } |
| |
| return (0); |
| } |
| |
| /* |
| LINE STATE UPDATE |
| Update Line Status Information and issue notification to user, |
| that will inform about change in the line state. |
| */ |
| static int diva_line_info (diva_strace_context_t* pLib, |
| int Channel, |
| diva_man_var_header_t* pVar) { |
| diva_man_var_header_t* cur; |
| int i, nr = Channel - 1; |
| |
| for (i = pLib->line_parse_entry_first[nr]; |
| i <= pLib->line_parse_entry_last[nr]; i++) { |
| if ((cur = find_var (pVar, pLib->parse_table[i].path))) { |
| if (diva_trace_read_variable (cur, pLib->parse_table[i].variable)) { |
| diva_trace_error (pLib, -3 , __FILE__, __LINE__); |
| return (-1); |
| } |
| } else { |
| diva_trace_error (pLib, -2 , __FILE__, __LINE__); |
| return (-1); |
| } |
| } |
| |
| /* |
| We do not use first event to notify user - this is the event that is |
| generated as result of EVENT ON operation and is used only to initialize |
| internal variables of application |
| |
| Exception is is if the line is "online". In this case we have to notify |
| user about this confition. |
| */ |
| if (pLib->line_init_event & (1L << nr)) { |
| diva_trace_notify_user (pLib, nr, DIVA_SUPER_TRACE_NOTIFY_LINE_CHANGE); |
| } else { |
| pLib->line_init_event |= (1L << nr); |
| if (strcmp (&pLib->lines[nr].Line[0], "Idle")) { |
| diva_trace_notify_user (pLib, nr, DIVA_SUPER_TRACE_NOTIFY_LINE_CHANGE); |
| } |
| } |
| |
| return (0); |
| } |
| |
| /* |
| Move position to next vatianle in the chain |
| */ |
| static diva_man_var_header_t* get_next_var (diva_man_var_header_t* pVar) { |
| byte* msg = (byte*)pVar; |
| byte* start; |
| int msg_length; |
| |
| if (*msg != ESC) return NULL; |
| |
| start = msg + 2; |
| msg_length = *(msg+1); |
| msg = (start+msg_length); |
| |
| if (*msg != ESC) return NULL; |
| |
| return ((diva_man_var_header_t*)msg); |
| } |
| |
| /* |
| Move position to variable with given name |
| */ |
| static diva_man_var_header_t* find_var (diva_man_var_header_t* pVar, |
| const char* name) { |
| const char* path; |
| |
| do { |
| path = (char*)&pVar->path_length+1; |
| |
| if (!strncmp (name, path, pVar->path_length)) { |
| break; |
| } |
| } while ((pVar = get_next_var (pVar))); |
| |
| return (pVar); |
| } |
| |
| static void diva_create_line_parse_table (diva_strace_context_t* pLib, |
| int Channel) { |
| diva_trace_line_state_t* pLine = &pLib->lines[Channel]; |
| int nr = Channel+1; |
| |
| if ((pLib->cur_parse_entry + LINE_PARSE_ENTRIES) >= pLib->parse_entries) { |
| diva_trace_error (pLib, -1, __FILE__, __LINE__); |
| return; |
| } |
| |
| pLine->ChannelNumber = nr; |
| |
| pLib->line_parse_entry_first[Channel] = pLib->cur_parse_entry; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Framing", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pLine->Framing[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Line", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pLine->Line[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Layer2", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pLine->Layer2[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Layer3", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pLine->Layer3[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Remote Address", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLine->RemoteAddress[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Remote SubAddr", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLine->RemoteSubAddress[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Local Address", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLine->LocalAddress[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Local SubAddr", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLine->LocalSubAddress[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\BC", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pLine->call_BC; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\HLC", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pLine->call_HLC; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\LLC", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pLine->call_LLC; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Charges", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pLine->Charges; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Call Reference", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pLine->CallReference; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Last Disc Cause", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLine->LastDisconnecCause; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\User ID", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pLine->UserID[0]; |
| |
| pLib->line_parse_entry_last[Channel] = pLib->cur_parse_entry - 1; |
| } |
| |
| static void diva_create_fax_parse_table (diva_strace_context_t* pLib, |
| int Channel) { |
| diva_trace_fax_state_t* pFax = &pLib->lines[Channel].fax; |
| int nr = Channel+1; |
| |
| if ((pLib->cur_parse_entry + FAX_PARSE_ENTRIES) >= pLib->parse_entries) { |
| diva_trace_error (pLib, -1, __FILE__, __LINE__); |
| return; |
| } |
| pFax->ChannelNumber = nr; |
| |
| pLib->fax_parse_entry_first[Channel] = pLib->cur_parse_entry; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Event", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Event; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Page Counter", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Page_Counter; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Features", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Features; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Station ID", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Station_ID[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Subaddress", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Subaddress[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Password", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Password[0]; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Speed", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Speed; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Resolution", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Resolution; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Paper Width", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Paper_Width; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Paper Length", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Paper_Length; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Scanline Time", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Scanline_Time; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\FAX\\Disc Reason", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pFax->Disc_Reason; |
| |
| pLib->fax_parse_entry_last[Channel] = pLib->cur_parse_entry - 1; |
| } |
| |
| static void diva_create_modem_parse_table (diva_strace_context_t* pLib, |
| int Channel) { |
| diva_trace_modem_state_t* pModem = &pLib->lines[Channel].modem; |
| int nr = Channel+1; |
| |
| if ((pLib->cur_parse_entry + MODEM_PARSE_ENTRIES) >= pLib->parse_entries) { |
| diva_trace_error (pLib, -1, __FILE__, __LINE__); |
| return; |
| } |
| pModem->ChannelNumber = nr; |
| |
| pLib->modem_parse_entry_first[Channel] = pLib->cur_parse_entry; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Event", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->Event; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Norm", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->Norm; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Options", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->Options; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\TX Speed", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->TxSpeed; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\RX Speed", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->RxSpeed; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Roundtrip ms", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->RoundtripMsec; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Symbol Rate", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->SymbolRate; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\RX Level dBm", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->RxLeveldBm; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Echo Level dBm", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->EchoLeveldBm; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\SNR dB", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->SNRdb; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\MAE", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->MAE; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Local Retrains", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->LocalRetrains; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Remote Retrains", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->RemoteRetrains; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Local Resyncs", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->LocalResyncs; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Remote Resyncs", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->RemoteResyncs; |
| |
| sprintf (pLib->parse_table[pLib->cur_parse_entry].path, |
| "State\\B%d\\Modem\\Disc Reason", nr); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = &pModem->DiscReason; |
| |
| pLib->modem_parse_entry_last[Channel] = pLib->cur_parse_entry - 1; |
| } |
| |
| static void diva_create_parse_table (diva_strace_context_t* pLib) { |
| int i; |
| |
| for (i = 0; i < pLib->Channels; i++) { |
| diva_create_line_parse_table (pLib, i); |
| diva_create_modem_parse_table (pLib, i); |
| diva_create_fax_parse_table (pLib, i); |
| } |
| |
| pLib->statistic_parse_first = pLib->cur_parse_entry; |
| |
| /* |
| Outgoing Calls |
| */ |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Outgoing Calls\\Calls"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.outg.Calls; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Outgoing Calls\\Connected"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.outg.Connected; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Outgoing Calls\\User Busy"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.outg.User_Busy; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Outgoing Calls\\No Answer"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.outg.No_Answer; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Outgoing Calls\\Wrong Number"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.outg.Wrong_Number; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Outgoing Calls\\Call Rejected"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.outg.Call_Rejected; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Outgoing Calls\\Other Failures"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.outg.Other_Failures; |
| |
| /* |
| Incoming Calls |
| */ |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Incoming Calls\\Calls"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.inc.Calls; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Incoming Calls\\Connected"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.inc.Connected; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Incoming Calls\\User Busy"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.inc.User_Busy; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Incoming Calls\\Call Rejected"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.inc.Call_Rejected; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Incoming Calls\\Wrong Number"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.inc.Wrong_Number; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Incoming Calls\\Incompatible Dst"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.inc.Incompatible_Dst; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Incoming Calls\\Out of Order"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.inc.Out_of_Order; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Incoming Calls\\Ignored"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.inc.Ignored; |
| |
| /* |
| Modem Statistics |
| */ |
| pLib->mdm_statistic_parse_first = pLib->cur_parse_entry; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Modem\\Disc Normal"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.mdm.Disc_Normal; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Modem\\Disc Unspecified"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.mdm.Disc_Unspecified; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Modem\\Disc Busy Tone"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.mdm.Disc_Busy_Tone; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Modem\\Disc Congestion"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.mdm.Disc_Congestion; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Modem\\Disc Carr. Wait"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.mdm.Disc_Carr_Wait; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Modem\\Disc Trn Timeout"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.mdm.Disc_Trn_Timeout; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Modem\\Disc Incompat."); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.mdm.Disc_Incompat; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Modem\\Disc Frame Rej."); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.mdm.Disc_Frame_Rej; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\Modem\\Disc V42bis"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.mdm.Disc_V42bis; |
| |
| pLib->mdm_statistic_parse_last = pLib->cur_parse_entry - 1; |
| |
| /* |
| Fax Statistics |
| */ |
| pLib->fax_statistic_parse_first = pLib->cur_parse_entry; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Normal"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Normal; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Not Ident."); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Not_Ident; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc No Response"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_No_Response; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Retries"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Retries; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Unexp. Msg."); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Unexp_Msg; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc No Polling."); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_No_Polling; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Training"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Training; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Unexpected"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Unexpected; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Application"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Application; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Incompat."); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Incompat; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc No Command"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_No_Command; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Long Msg"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Long_Msg; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Supervisor"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Supervisor; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc SUB SEP PWD"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_SUB_SEP_PWD; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Invalid Msg"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Invalid_Msg; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Page Coding"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Page_Coding; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc App Timeout"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_App_Timeout; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\FAX\\Disc Unspecified"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.fax.Disc_Unspecified; |
| |
| pLib->fax_statistic_parse_last = pLib->cur_parse_entry - 1; |
| |
| /* |
| B-Layer1" |
| */ |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer1\\X-Frames"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b1.X_Frames; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer1\\X-Bytes"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b1.X_Bytes; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer1\\X-Errors"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b1.X_Errors; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer1\\R-Frames"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b1.R_Frames; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer1\\R-Bytes"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b1.R_Bytes; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer1\\R-Errors"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b1.R_Errors; |
| |
| /* |
| B-Layer2 |
| */ |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer2\\X-Frames"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b2.X_Frames; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer2\\X-Bytes"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b2.X_Bytes; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer2\\X-Errors"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b2.X_Errors; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer2\\R-Frames"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b2.R_Frames; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer2\\R-Bytes"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b2.R_Bytes; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\B-Layer2\\R-Errors"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.b2.R_Errors; |
| |
| /* |
| D-Layer1 |
| */ |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer1\\X-Frames"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d1.X_Frames; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer1\\X-Bytes"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d1.X_Bytes; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer1\\X-Errors"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d1.X_Errors; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer1\\R-Frames"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d1.R_Frames; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer1\\R-Bytes"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d1.R_Bytes; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer1\\R-Errors"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d1.R_Errors; |
| |
| /* |
| D-Layer2 |
| */ |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer2\\X-Frames"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d2.X_Frames; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer2\\X-Bytes"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d2.X_Bytes; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer2\\X-Errors"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d2.X_Errors; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer2\\R-Frames"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d2.R_Frames; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer2\\R-Bytes"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d2.R_Bytes; |
| |
| strcpy (pLib->parse_table[pLib->cur_parse_entry].path, |
| "Statistics\\D-Layer2\\R-Errors"); |
| pLib->parse_table[pLib->cur_parse_entry++].variable = \ |
| &pLib->InterfaceStat.d2.R_Errors; |
| |
| |
| pLib->statistic_parse_last = pLib->cur_parse_entry - 1; |
| } |
| |
| static void diva_trace_error (diva_strace_context_t* pLib, |
| int error, const char* file, int line) { |
| if (pLib->user_proc_table.error_notify_proc) { |
| (*(pLib->user_proc_table.error_notify_proc))(\ |
| pLib->user_proc_table.user_context, |
| &pLib->instance, pLib->Adapter, |
| error, file, line); |
| } |
| } |
| |
| /* |
| Delivery notification to user |
| */ |
| static void diva_trace_notify_user (diva_strace_context_t* pLib, |
| int Channel, |
| int notify_subject) { |
| if (pLib->user_proc_table.notify_proc) { |
| (*(pLib->user_proc_table.notify_proc))(pLib->user_proc_table.user_context, |
| &pLib->instance, |
| pLib->Adapter, |
| &pLib->lines[Channel], |
| notify_subject); |
| } |
| } |
| |
| /* |
| Read variable value to they destination based on the variable type |
| */ |
| static int diva_trace_read_variable (diva_man_var_header_t* pVar, |
| void* variable) { |
| switch (pVar->type) { |
| case 0x03: /* MI_ASCIIZ - syting */ |
| return (diva_strace_read_asz (pVar, (char*)variable)); |
| case 0x04: /* MI_ASCII - string */ |
| return (diva_strace_read_asc (pVar, (char*)variable)); |
| case 0x05: /* MI_NUMBER - counted sequence of bytes */ |
| return (diva_strace_read_ie (pVar, (diva_trace_ie_t*)variable)); |
| case 0x81: /* MI_INT - signed integer */ |
| return (diva_strace_read_int (pVar, (int*)variable)); |
| case 0x82: /* MI_UINT - unsigned integer */ |
| return (diva_strace_read_uint (pVar, (dword*)variable)); |
| case 0x83: /* MI_HINT - unsigned integer, hex representetion */ |
| return (diva_strace_read_uint (pVar, (dword*)variable)); |
| case 0x87: /* MI_BITFLD - unsigned integer, bit representation */ |
| return (diva_strace_read_uint (pVar, (dword*)variable)); |
| } |
| |
| /* |
| This type of variable is not handled, indicate error |
| Or one problem in management interface, or in application recodeing |
| table, or this application should handle it. |
| */ |
| return (-1); |
| } |
| |
| /* |
| Read signed integer to destination |
| */ |
| static int diva_strace_read_int (diva_man_var_header_t* pVar, int* var) { |
| byte* ptr = (char*)&pVar->path_length; |
| int value; |
| |
| ptr += (pVar->path_length + 1); |
| |
| switch (pVar->value_length) { |
| case 1: |
| value = *(char*)ptr; |
| break; |
| |
| case 2: |
| value = (short)GET_WORD(ptr); |
| break; |
| |
| case 4: |
| value = (int)GET_DWORD(ptr); |
| break; |
| |
| default: |
| return (-1); |
| } |
| |
| *var = value; |
| |
| return (0); |
| } |
| |
| static int diva_strace_read_uint (diva_man_var_header_t* pVar, dword* var) { |
| byte* ptr = (char*)&pVar->path_length; |
| dword value; |
| |
| ptr += (pVar->path_length + 1); |
| |
| switch (pVar->value_length) { |
| case 1: |
| value = (byte)(*ptr); |
| break; |
| |
| case 2: |
| value = (word)GET_WORD(ptr); |
| break; |
| |
| case 3: |
| value = (dword)GET_DWORD(ptr); |
| value &= 0x00ffffff; |
| break; |
| |
| case 4: |
| value = (dword)GET_DWORD(ptr); |
| break; |
| |
| default: |
| return (-1); |
| } |
| |
| *var = value; |
| |
| return (0); |
| } |
| |
| /* |
| Read zero terminated ASCII string |
| */ |
| static int diva_strace_read_asz (diva_man_var_header_t* pVar, char* var) { |
| char* ptr = (char*)&pVar->path_length; |
| int length; |
| |
| ptr += (pVar->path_length + 1); |
| |
| if (!(length = pVar->value_length)) { |
| length = strlen (ptr); |
| } |
| memcpy (var, ptr, length); |
| var[length] = 0; |
| |
| return (0); |
| } |
| |
| /* |
| Read counted (with leading length byte) ASCII string |
| */ |
| static int diva_strace_read_asc (diva_man_var_header_t* pVar, char* var) { |
| char* ptr = (char*)&pVar->path_length; |
| |
| ptr += (pVar->path_length + 1); |
| memcpy (var, ptr+1, *ptr); |
| var[(int)*ptr] = 0; |
| |
| return (0); |
| } |
| |
| /* |
| Read one information element - i.e. one string of byte values with |
| one length byte in front |
| */ |
| static int diva_strace_read_ie (diva_man_var_header_t* pVar, |
| diva_trace_ie_t* var) { |
| char* ptr = (char*)&pVar->path_length; |
| |
| ptr += (pVar->path_length + 1); |
| |
| var->length = *ptr; |
| memcpy (&var->data[0], ptr+1, *ptr); |
| |
| return (0); |
| } |
| |
| static int SuperTraceSetAudioTap (void* hLib, int Channel, int on) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| |
| if ((Channel < 1) || (Channel > pLib->Channels)) { |
| return (-1); |
| } |
| Channel--; |
| |
| if (on) { |
| pLib->audio_tap_mask |= (1L << Channel); |
| } else { |
| pLib->audio_tap_mask &= ~(1L << Channel); |
| } |
| |
| /* |
| EYE patterns have TM_M_DATA set as additional |
| condition |
| */ |
| if (pLib->audio_tap_mask) { |
| pLib->trace_event_mask |= TM_M_DATA; |
| } else { |
| pLib->trace_event_mask &= ~TM_M_DATA; |
| } |
| |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceSetBChannel (void* hLib, int Channel, int on) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| |
| if ((Channel < 1) || (Channel > pLib->Channels)) { |
| return (-1); |
| } |
| Channel--; |
| |
| if (on) { |
| pLib->bchannel_trace_mask |= (1L << Channel); |
| } else { |
| pLib->bchannel_trace_mask &= ~(1L << Channel); |
| } |
| |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceSetDChannel (void* hLib, int on) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| |
| if (on) { |
| pLib->trace_event_mask |= (TM_D_CHAN | TM_C_COMM | TM_DL_ERR | TM_LAYER1); |
| } else { |
| pLib->trace_event_mask &= ~(TM_D_CHAN | TM_C_COMM | TM_DL_ERR | TM_LAYER1); |
| } |
| |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceSetInfo (void* hLib, int on) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| |
| if (on) { |
| pLib->trace_event_mask |= TM_STRING; |
| } else { |
| pLib->trace_event_mask &= ~TM_STRING; |
| } |
| |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceClearCall (void* hLib, int Channel) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| |
| if ((Channel < 1) || (Channel > pLib->Channels)) { |
| return (-1); |
| } |
| Channel--; |
| |
| pLib->clear_call_command |= (1L << Channel); |
| |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| /* |
| Parse and update cumulative statistice |
| */ |
| static int diva_ifc_statistics (diva_strace_context_t* pLib, |
| diva_man_var_header_t* pVar) { |
| diva_man_var_header_t* cur; |
| int i, one_updated = 0, mdm_updated = 0, fax_updated = 0; |
| |
| for (i = pLib->statistic_parse_first; i <= pLib->statistic_parse_last; i++) { |
| if ((cur = find_var (pVar, pLib->parse_table[i].path))) { |
| if (diva_trace_read_variable (cur, pLib->parse_table[i].variable)) { |
| diva_trace_error (pLib, -3 , __FILE__, __LINE__); |
| return (-1); |
| } |
| one_updated = 1; |
| if ((i >= pLib->mdm_statistic_parse_first) && (i <= pLib->mdm_statistic_parse_last)) { |
| mdm_updated = 1; |
| } |
| if ((i >= pLib->fax_statistic_parse_first) && (i <= pLib->fax_statistic_parse_last)) { |
| fax_updated = 1; |
| } |
| } |
| } |
| |
| /* |
| We do not use first event to notify user - this is the event that is |
| generated as result of EVENT ON operation and is used only to initialize |
| internal variables of application |
| */ |
| if (mdm_updated) { |
| diva_trace_notify_user (pLib, 0, DIVA_SUPER_TRACE_NOTIFY_MDM_STAT_CHANGE); |
| } else if (fax_updated) { |
| diva_trace_notify_user (pLib, 0, DIVA_SUPER_TRACE_NOTIFY_FAX_STAT_CHANGE); |
| } else if (one_updated) { |
| diva_trace_notify_user (pLib, 0, DIVA_SUPER_TRACE_NOTIFY_STAT_CHANGE); |
| } |
| |
| return (one_updated ? 0 : -1); |
| } |
| |
| static int SuperTraceGetOutgoingCallStatistics (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| pLib->outgoing_ifc_stats = 1; |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceGetIncomingCallStatistics (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| pLib->incoming_ifc_stats = 1; |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceGetModemStatistics (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| pLib->modem_ifc_stats = 1; |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceGetFaxStatistics (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| pLib->fax_ifc_stats = 1; |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceGetBLayer1Statistics (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| pLib->b1_ifc_stats = 1; |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceGetBLayer2Statistics (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| pLib->b2_ifc_stats = 1; |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceGetDLayer1Statistics (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| pLib->d1_ifc_stats = 1; |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| static int SuperTraceGetDLayer2Statistics (void* hLib) { |
| diva_strace_context_t* pLib = (diva_strace_context_t*)hLib; |
| pLib->d2_ifc_stats = 1; |
| return (ScheduleNextTraceRequest (pLib)); |
| } |
| |
| dword DivaSTraceGetMemotyRequirement (int channels) { |
| dword parse_entries = (MODEM_PARSE_ENTRIES + FAX_PARSE_ENTRIES + \ |
| STAT_PARSE_ENTRIES + \ |
| LINE_PARSE_ENTRIES + 1) * channels; |
| return (sizeof(diva_strace_context_t) + \ |
| (parse_entries * sizeof(diva_strace_path2action_t))); |
| } |
| |