#include "rcs_defs.hh"
#include "rcsvers.hh"
#include <string.h>
#include <stdlib.h>
#include "nml.hh"
#include "nmlmsg.hh"
#include "cms.hh"
#include "timer.hh"
#include "nml_srv.hh"
#include "cms_cfg.hh"
#include "linklist.hh"
#include "rcs_prnt.hh"
#include "dbg_mem.h"
#include "nmldiag.hh"
Include dependency graph for nml.cc:
Go to the source code of this file.
|
|
|
Definition at line 98 of file nml.cc. 00099 { 00100 if (cfg_file == NULL) 00101 { 00102 default_nml_config_file = NULL; 00103 } 00104 default_nml_config_file = (char *) DEBUG_MALLOC (strlen (cfg_file) + 1); 00105 strcpy (default_nml_config_file, cfg_file); 00106 } |
|
Definition at line 109 of file nml.cc. Referenced by NML_Main_Channel_List().
00110 { 00111 return default_nml_config_file; 00112 } |
|
Definition at line 263 of file nml.cc. 00265 { 00266 *nml = new NML (f_ptr, buf, proc, file); 00267 if (NULL == nml) 00268 { 00269 return -1; 00270 } 00271 if (!(*nml)->valid ()) 00272 { 00273 return -1; 00274 } 00275 if (NULL != (*nml)->cms) 00276 { 00277 (*nml)->cms->sizeof_message_header = (*nml)->sizeof_message_header; 00278 char *forced_type_eq = 00279 strstr ((*nml)->cms->buflineupper, "FORCE_TYPE="); 00280 if (forced_type_eq != NULL) 00281 { 00282 #ifndef UNDER_CE 00283 long temp = strtol (forced_type_eq + 11, NULL, 0); 00284 #else 00285 long temp = atol (forced_type_eq + 11); 00286 #endif 00287 if (temp > 0) 00288 { 00289 00290 (*nml)->forced_type = temp; 00291 } 00292 } 00293 } 00294 return 0; 00295 } |
|
Definition at line 298 of file nml.cc. 00299 { 00300 if (NULL != nml) 00301 { 00302 delete nml; 00303 } 00304 } |
|
Definition at line 2526 of file nml.cc. 02527 { 02528 struct sockaddr_in socket_address; 02529 /* Get the IP address of the server using it's BufferHost. */ 02530 #ifndef VXWORKS 02531 struct hostent *host_entry; 02532 dl_gethostbyname (hostname, &host_entry); 02533 if (NULL == host_entry) 02534 { 02535 return "UNKNOWN"; 02536 } 02537 #ifdef __MSDOS__ 02538 socket_address.sin_addr.s_addr = *((u_long *) host_entry->h_addr_list[0]); 02539 #else 02540 socket_address.sin_addr.s_addr = *((int *) host_entry->h_addr_list[0]); 02541 #endif 02542 socket_address.sin_family = host_entry->h_addrtype; 02543 #else 02544 socket_address.sin_addr.s_addr = hostGetByName (hostname); 02545 if (((long) socket_address.sin_addr.s_addr) == ERROR) 02546 { 02547 return "UNKNOWN"; 02548 } 02549 #endif 02550 return dl_inet_ntoa (socket_address.sin_addr); 02551 } |
|
Definition at line 2689 of file nml.cc. Referenced by NML_Main_Channel_List(), and NODE::NODE().
02690 { 02691 02692 #ifndef __MSDOS__ 02693 spawn_nml_servers (); 02694 #endif /* __MSDOS__ */ 02695 } |
|
Definition at line 2698 of file nml.cc. Referenced by NML_Main_Channel_List(), run_nml_servers(), and NODE::~NODE().
02699 { 02700 NML *nml; 02701 #if !defined(__MSDOS__) || defined(WIN32) 02702 nml_server_cleanup (); 02703 #endif /* __MSDOS__ */ 02704 02705 #ifdef VXWORKS 02706 int current_pid; 02707 current_pid = taskIdSelf (); 02708 #endif 02709 02710 #ifdef _Windows 02711 // HANDLE replaced with void RCS_FAR * 02712 void RCS_FAR *current_task_handle; 02713 #ifdef __WIN32__ 02714 current_task_handle = GetCurrentThread (); 02715 #else 02716 current_task_handle = GetCurrentTask (); 02717 #endif 02718 #endif 02719 02720 if (NULL != NML_Main_Channel_List) 02721 { 02722 rcs_print_debug (PRINT_NML_DESTRUCTORS, 02723 "Deleting %d channels from the NML_Main_Channel_List.\n", 02724 NML_Main_Channel_List->list_size); 02725 nml = (NML *) NML_Main_Channel_List->get_head (); 02726 while (NULL != nml) 02727 { 02728 #ifdef VXWORKS 02729 if (current_pid != nml->pid) 02730 { 02731 nml = (NML *) NML_Main_Channel_List->get_next (); 02732 continue; 02733 } 02734 #endif 02735 #ifdef _Windows 02736 if (current_task_handle != nml->task_handle) 02737 { 02738 nml = (NML *) NML_Main_Channel_List->get_next (); 02739 continue; 02740 } 02741 #endif 02742 if (nml->cms != NULL) 02743 { 02744 rcs_print_debug (PRINT_NML_DESTRUCTORS, 02745 "Deleting %s NML channel from NML_Main_Channel_List.\n", 02746 nml->cms->BufferName); 02747 } 02748 nml->delete_channel (); 02749 02750 rcs_print_debug (PRINT_NML_DESTRUCTORS, 02751 "NML channel deleted from NML_Main_Channel_List\n"); 02752 if (NULL == NML_Main_Channel_List) 02753 { 02754 return; 02755 } 02756 NML_Main_Channel_List->delete_current_node (); 02757 nml = (NML *) NML_Main_Channel_List->get_next (); 02758 } 02759 if (NULL != NML_Main_Channel_List) 02760 { 02761 #if defined(VXWORKS) || defined(_Windows) 02762 if (0 == NML_Main_Channel_List->list_size) 02763 { 02764 #endif 02765 delete NML_Main_Channel_List; 02766 NML_Main_Channel_List = (RCS_LINKED_LIST *) NULL; 02767 #if defined(VXWORKS) || defined(_Windows) 02768 } 02769 #endif 02770 } 02771 } 02772 #ifndef WINDOWS 02773 if (NULL != Dynamically_Allocated_NML_Objects) 02774 { 02775 nml = (NML *) Dynamically_Allocated_NML_Objects->get_head (); 02776 while (NULL != nml) 02777 { 02778 #ifdef VXWORKS 02779 if (current_pid != nml->pid) 02780 { 02781 nml = (NML *) Dynamically_Allocated_NML_Objects->get_next (); 02782 continue; 02783 } 02784 #endif 02785 #ifdef _Windows 02786 if (current_task_handle != nml->task_handle) 02787 { 02788 nml = (NML *) Dynamically_Allocated_NML_Objects->get_next (); 02789 continue; 02790 } 02791 #endif 02792 if (nml->cms != NULL) 02793 { 02794 rcs_print_debug (PRINT_NML_DESTRUCTORS, 02795 "Deleting %s NML channel from Dynamically_Allocated_NML_Objects.\n", 02796 nml->cms->BufferName); 02797 } 02798 delete nml; 02799 02800 rcs_print_debug (PRINT_NML_DESTRUCTORS, 02801 "NML channel deleted from Dynamically_Allocated_NML_Objects\n"); 02802 if (NULL == Dynamically_Allocated_NML_Objects) 02803 { 02804 return; 02805 } 02806 Dynamically_Allocated_NML_Objects->delete_current_node (); 02807 nml = (NML *) Dynamically_Allocated_NML_Objects->get_next (); 02808 } 02809 if (NULL != Dynamically_Allocated_NML_Objects) 02810 { 02811 #if defined(VXWORKS) || defined(_Windows) 02812 if (0 == Dynamically_Allocated_NML_Objects->list_size) 02813 { 02814 #endif 02815 delete Dynamically_Allocated_NML_Objects; 02816 Dynamically_Allocated_NML_Objects = (RCS_LINKED_LIST *) NULL; 02817 #if defined(VXWORKS) || defined(_Windows) 02818 } 02819 #endif 02820 } 02821 } 02822 #endif 02823 nmlClearHostAliases (); 02824 } |
|
Definition at line 2827 of file nml.cc. Referenced by NML_Main_Channel_List().
02828 { 02829 if (NULL != NML_Main_Channel_List) 02830 { 02831 delete NML_Main_Channel_List; 02832 NML_Main_Channel_List = (RCS_LINKED_LIST *) NULL; 02833 } 02834 if (NULL != Dynamically_Allocated_NML_Objects) 02835 { 02836 delete Dynamically_Allocated_NML_Objects; 02837 Dynamically_Allocated_NML_Objects = (RCS_LINKED_LIST *) NULL; 02838 } 02839 #ifndef __MSDOS__ 02840 if (NULL != NML_Default_Super_Server) 02841 { 02842 delete NML_Default_Super_Server; 02843 NML_Default_Super_Server = (NML_SUPER_SERVER *) NULL; 02844 } 02845 #endif 02846 } |
|
Definition at line 2880 of file nml.cc. 02882 { 02883 NML *nmlChannel = 0; 02884 02885 RCS_PRINT_DESTINATION_TYPE olddest = get_rcs_print_destination (); 02886 set_rcs_print_destination (RCS_PRINT_TO_NULL); 02887 nmlChannel = new NML (fPtr, buffer, name, file); 02888 while (!nmlChannel->reset ()) 02889 { 02890 esleep (sleepTime); 02891 } 02892 set_rcs_print_destination (olddest); 02893 return (nmlChannel); 02894 } |
|
Definition at line 3067 of file nml.cc. 03068 { 03069 if (NULL == cmsHostAliases) 03070 { 03071 cmsHostAliases = new RCS_LINKED_LIST; 03072 } 03073 CMS_HOST_ALIAS_ENTRY entry; 03074 strncpy (entry.host, hostName, 64); 03075 strncpy (entry.alias, hostAlias, 64); 03076 cmsHostAliases->store_at_tail (&entry, sizeof (entry), 1); 03077 } |
|
Definition at line 3080 of file nml.cc. Referenced by NML_Main_Channel_List(), and nml_cleanup().
|
|
Definition at line 3090 of file nml.cc. Referenced by NML_Main_Channel_List().
03091 { 03092 cms_connection_mode = CMS_NORMAL_CONNECTION_MODE; 03093 } |
|
Definition at line 3096 of file nml.cc. Referenced by NML_Main_Channel_List().
03097 { 03098 cms_connection_mode = CMS_FORCE_REMOTE_CONNECTION_MODE; 03099 } |
|
Definition at line 3102 of file nml.cc. Referenced by NML_Main_Channel_List().
03103 { 03104 cms_connection_mode = CMS_FORCE_LOCAL_CONNECTION_MODE; 03105 } |
|
Initial value: |
|
Initial value: |
|
|
|
|
|
Initial value: { "NML_NO_ERROR", "NML_BUFFER_NOT_READ", "NML_TIMED_OUT", "NML_INVALID_CONFIGURATION", "NML_FORMAT_ERROR", "NML_INTERNAL_CMS_ERROR", "NML_NO_MASTER_ERROR", "NML_INVALID_MESSAGE_ERROR", } |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|