loon: msgLog.h File Reference

00222 {
00223 
00224 #ifdef USESYSLOG
00225 #ifdef VxWorks    
00226     /* Do nothing */
00227 #else /* !VxWorks */
00228     openlog(ident, LOG_PERROR | LOG_PID, DAQ_LOG_FACILITY);
00229 #endif /* VxWorks */
00230 
00231 #else /* !USESYSLOG */
00232 
00233   const char* ip;
00234   const char* portenv;
00235   int port;
00236   int sockAddrSize;
00237   int pid;
00238 
00239   /*set last message time to 01/01/70
00240    * this way first message is always sent */
00241   lastMessageTime.tv_sec = 0; 
00242   lastMessageTime.tv_nsec = 0;
00243 
00244   sockAddrSize = sizeof(struct sockaddr_in);
00245 
00246   /* Clear socket address structure */
00247   bzero((char *)&lServerAddr, sockAddrSize);
00248 
00249   /* 
00250    * For VxWorks we pull the message server IP address directly from
00251    * the boot parameters. Otherwise, the server name/IP is resolved from
00252    * environment variables or falls back to the local host 
00253    */
00254 #ifdef VxWorks
00255   {
00256       char bootString[BOOT_LINE_SIZE];
00257       BOOT_PARAMS bootParams;
00258 
00259       /* 
00260        * Get the msgLogger IP adddress from the "other" field of the boot
00261        * parameters
00262        */
00263       sysNvRamGet(bootString, BOOT_LINE_SIZE, 0);
00264       bootStringToStruct(bootString, &bootParams);
00265       ip = (char *)&(bootParams.other);
00266       port = MSGLOG_PORT;
00267 
00268       if ((lServerAddr.sin_addr.s_addr = inet_addr(ip)) == ERROR) {
00269           NATIVE_MSG("msgLogInit: bad server name from boot params: %s", ip);
00270           return;
00271       }
00272       pid = taskIdSelf();
00273 
00274       /* Clean up any existing msgLogger task and message queue */
00275       if (lMsgLogTaskId != NULL) {
00276           NATIVE_MSG("msgLogInit: deleting existing message logger task (tid=0x%x)\n", lMsgLogTaskId);
00277           taskDelete(lMsgLogTaskId);
00278           lMsgLogTaskId = NULL;
00279       }
00280       if (lMsgLogQId != NULL) {
00281           NATIVE_MSG("msgLogInit: deleting existing message logger queue (id=0x%x)\n", lMsgLogQId);
00282           msgQDelete(lMsgLogQId);
00283           lMsgLogQId = NULL;
00284       }
00285 
00286       /* Create the message queue for the logging task */
00287       lMsgLogQId = msgQCreate(MSGQ_MAX_MSGS, sizeof(mdMsgLogBuffer), MSG_Q_FIFO);
00288       if (lMsgLogQId == NULL) {
00289           NATIVE_MSG("msgLogInit: msgQCreate failed: %s", strerror(errno));
00290           return;
00291       }
00292       /* Spawn the message logging task */
00293       lMsgLogTaskId = taskSpawn("tMsgLogger", TASK_PRIORITY_MSGLOGGER, 0, 
00294                                 TASK_SIZE_MSGLOGGER, (FUNCPTR)tMsgLogger,
00295                                 0,0,0,0,0,0,0,0,0,0);
00296       if (lMsgLogTaskId == ERROR) {
00297           NATIVE_MSG("msgLogInit: task creation failed: %s", strerror(errno));
00298           return;
00299       }
00300   }
00301 #else /* !Vxworks */
00302   {
00303       struct hostent     *host_ptr; /*the host add*/
00304 
00305       /* 
00306        * Pull the msg logger IP address and port from env vars, otherwise
00307        * take the default values
00308        */      
00309       ip = getenv(DAQ_MSG_IP);
00310       if (ip == NULL) {
00311           ip = MSGLOG_DEFAULT_IP;
00312       }
00313       portenv = getenv("DAQ_MSG_PORT");
00314       if ( portenv == NULL){
00315           port = MSGLOG_PORT;
00316       } else {
00317           sscanf(portenv, "%d", &port);
00318       }
00319   
00320       /* Resolve server hostname to address */
00321       host_ptr = gethostbyname(ip);
00322       if(!host_ptr ||host_ptr->h_addrtype != AF_INET ){
00323           NATIVE_MSG( "msgLogInit: bad server name/address: %s , %s",ip, strerror(errno));
00324           return;
00325       }
00326       memcpy(&lServerAddr.sin_addr.s_addr, host_ptr->h_addr, host_ptr->h_length);
00327       if(lServerAddr.sin_addr.s_addr == INADDR_NONE)
00328         {
00329           NATIVE_MSG( "msgLogInit: unresolved server address, unable to open msgLog socket\n");
00330           return;
00331         }
00332 
00333       /* Get current process ID */ 
00334       pid = getpid();
00335   
00336       /* Open syslog connection for fallback (native) messages */
00337       openlog(ident, LOG_PERROR | LOG_PID, DAQ_LOG_FACILITY);
00338   }
00339 #endif /* VxWorks */
00340 
00341   /* Fill in port and type in socket address structure */
00342   /* lServerAddr.sin_len    = (unsigned char)sockAddrSize; */
00343   lServerAddr.sin_family = AF_INET;
00344   lServerAddr.sin_port   = htons(port);
00345 
00346   /* Close the old socket if it exists */
00347   if (lSocket != 0) {
00348     NATIVE_MSG("msgLogInit: closing existing message logger socket (id=0x%x)\n", lSocket);
00349     close(lSocket);
00350     lSocket = 0;
00351   }
00352 
00353   /* Create the UDP datagram socket */
00354   lSocket = socket(AF_INET, SOCK_DGRAM, 0);
00355   if(lSocket == -1) {
00356       NATIVE_MSG("msgLogInit: socket() failed: %s", strerror(errno));
00357       return;
00358   }
00359     
00360   /* Initialise message header */
00361   lBuffer.hdr.pid = pid;
00362   lBuffer.hdr.count = 0;
00363   lBuffer.hdr.nodeFrom = MINOS_UNIDENTIFIED_CLIENT;
00364   strncpy(lBuffer.hdr.prcName, ident, MSGLOG_MAXNAME);
00365 
00366   /* Set local message echoing off by default */
00367   lMsgLocalEcho = 0;
00368 
00369 #endif /* USESYSLOG */
00370   
00371   /* Set default debug level to zero */
00372   lDebugLevel = 0;
00373 
00374   return;
00375 
00376 } /* msgLogInit */

Functions
void	msgLogInit (const char *ident)
void	msgLogCleanup (void)
void	msgLogNodeIdSet (long nodeid)
void	msgLogPidSet (long pid)
void	msgLogLocalEchoSet (int enable)
void	msgLogResetMsgCount (long count)
long	msgLogGetMsgCount ()
void	logDebugLevelSet (unsigned int level)
void	logMaxRepRateSet (long max_dt_ns)
void	logCritical (const char *fmt,...)
void	logError (const char *fmt,...)
void	logWarn (const char *fmt,...)
void	logNotice (const char *fmt,...)
void	logInfo (const char *fmt,...)
void	logDebug (unsigned int level, const char *fmt,...)
msgLog.h File Reference

Functions

Function Documentation
