summaryrefslogtreecommitdiffstats
path: root/main/common/syslog.c
diff options
context:
space:
mode:
Diffstat (limited to 'main/common/syslog.c')
-rw-r--r--main/common/syslog.c518
1 files changed, 264 insertions, 254 deletions
diff --git a/main/common/syslog.c b/main/common/syslog.c
index a6f0334..ecdc7a1 100644
--- a/main/common/syslog.c
+++ b/main/common/syslog.c
@@ -1,7 +1,7 @@
/**************************************************************************
*
* Copyright (c) 2013 Alcatel-Lucent
- *
+ *
* Alcatel Lucent licenses this file to You under the Apache License,
* Version 2.0 (the "License"); you may not use this file except in
* compliance with the License. A copy of the License is contained the
@@ -20,7 +20,7 @@
*
* syslog.c:
*
- * This code supports the monitor's SYSLOC client.
+ * This code supports the monitor's SYSLOC client.
*
* Original author: Ed Sutter (ed.sutter@alcatel-lucent.com)
*
@@ -33,304 +33,314 @@
#include "stddefs.h"
#include "cli.h"
-#define SYSLOG_PORT 514
+#define SYSLOG_PORT 514
struct nameval {
- char *name;
- int val;
+ char *name;
+ int val;
};
/* Priority codes:
*/
-#define LOG_EMERG 0 /* system is unusable */
-#define LOG_ALERT 1 /* action must be taken immediately */
-#define LOG_CRIT 2 /* critical conditions */
-#define LOG_ERR 3 /* error conditions */
-#define LOG_WARNING 4 /* warning conditions */
-#define LOG_NOTICE 5 /* normal but significant condition */
-#define LOG_INFO 6 /* informational */
-#define LOG_DEBUG 7 /* debug-level messages */
+#define LOG_EMERG 0 /* system is unusable */
+#define LOG_ALERT 1 /* action must be taken immediately */
+#define LOG_CRIT 2 /* critical conditions */
+#define LOG_ERR 3 /* error conditions */
+#define LOG_WARNING 4 /* warning conditions */
+#define LOG_NOTICE 5 /* normal but significant condition */
+#define LOG_INFO 6 /* informational */
+#define LOG_DEBUG 7 /* debug-level messages */
/* Facility codes:
*/
-#define LOG_KERN (0<<3) /* kernel messages */
-#define LOG_USER (1<<3) /* random user-level messages */
-#define LOG_MAIL (2<<3) /* mail system */
-#define LOG_DAEMON (3<<3) /* system daemons */
-#define LOG_AUTH (4<<3) /* security/authorization messages */
-#define LOG_SYSLOG (5<<3) /* messages generated internally by syslogd */
-#define LOG_LPR (6<<3) /* line printer subsystem */
-#define LOG_NEWS (7<<3) /* network news subsystem */
-#define LOG_UUCP (8<<3) /* UUCP subsystem */
-#define LOG_CRON (9<<3) /* clock daemon */
-#define LOG_AUTHPRIV (10<<3) /* security/authorization messages (private) */
-#define LOG_FTP (11<<3) /* ftp daemon */
-#define LOG_LOCAL0 (16<<3) /* reserved for local use */
-#define LOG_LOCAL1 (17<<3) /* reserved for local use */
-#define LOG_LOCAL2 (18<<3) /* reserved for local use */
-#define LOG_LOCAL3 (19<<3) /* reserved for local use */
-#define LOG_LOCAL4 (20<<3) /* reserved for local use */
-#define LOG_LOCAL5 (21<<3) /* reserved for local use */
-#define LOG_LOCAL6 (22<<3) /* reserved for local use */
-#define LOG_LOCAL7 (23<<3) /* reserved for local use */
-
-#define FACILITY_MASK 0x03f8
-#define PRIORITY_MASK 0x0007
+#define LOG_KERN (0<<3) /* kernel messages */
+#define LOG_USER (1<<3) /* random user-level messages */
+#define LOG_MAIL (2<<3) /* mail system */
+#define LOG_DAEMON (3<<3) /* system daemons */
+#define LOG_AUTH (4<<3) /* security/authorization messages */
+#define LOG_SYSLOG (5<<3) /* messages generated internally by syslogd */
+#define LOG_LPR (6<<3) /* line printer subsystem */
+#define LOG_NEWS (7<<3) /* network news subsystem */
+#define LOG_UUCP (8<<3) /* UUCP subsystem */
+#define LOG_CRON (9<<3) /* clock daemon */
+#define LOG_AUTHPRIV (10<<3) /* security/authorization messages (private) */
+#define LOG_FTP (11<<3) /* ftp daemon */
+#define LOG_LOCAL0 (16<<3) /* reserved for local use */
+#define LOG_LOCAL1 (17<<3) /* reserved for local use */
+#define LOG_LOCAL2 (18<<3) /* reserved for local use */
+#define LOG_LOCAL3 (19<<3) /* reserved for local use */
+#define LOG_LOCAL4 (20<<3) /* reserved for local use */
+#define LOG_LOCAL5 (21<<3) /* reserved for local use */
+#define LOG_LOCAL6 (22<<3) /* reserved for local use */
+#define LOG_LOCAL7 (23<<3) /* reserved for local use */
+
+#define FACILITY_MASK 0x03f8
+#define PRIORITY_MASK 0x0007
struct nameval prioritynames[] = {
- { "emerg", LOG_EMERG },
- { "alert", LOG_ALERT },
- { "critical", LOG_CRIT },
- { "error", LOG_ERR },
- { "warning", LOG_WARNING },
- { "notice", LOG_NOTICE },
- { "info", LOG_INFO },
- { "debug", LOG_DEBUG },
- { 0, 0 }
+ { "emerg", LOG_EMERG },
+ { "alert", LOG_ALERT },
+ { "critical", LOG_CRIT },
+ { "error", LOG_ERR },
+ { "warning", LOG_WARNING },
+ { "notice", LOG_NOTICE },
+ { "info", LOG_INFO },
+ { "debug", LOG_DEBUG },
+ { 0, 0 }
};
struct nameval facilitynames[] = {
- { "kernel", LOG_KERN },
- { "user", LOG_USER },
- { "mail", LOG_MAIL },
- { "daemon", LOG_DAEMON },
- { "authorize", LOG_AUTH },
- { "syslog", LOG_SYSLOG },
- { "lpr", LOG_LPR },
- { "news", LOG_NEWS },
- { "uucp", LOG_UUCP },
- { "cron", LOG_CRON },
- { "authpriv", LOG_AUTHPRIV },
- { "ftp", LOG_FTP },
- { "local0", LOG_LOCAL0 },
- { "local1", LOG_LOCAL1 },
- { "local2", LOG_LOCAL2 },
- { "local3", LOG_LOCAL3 },
- { "local4", LOG_LOCAL4 },
- { "local5", LOG_LOCAL5 },
- { "local6", LOG_LOCAL6 },
- { "local7", LOG_LOCAL7 },
- { 0, 0 }
+ { "kernel", LOG_KERN },
+ { "user", LOG_USER },
+ { "mail", LOG_MAIL },
+ { "daemon", LOG_DAEMON },
+ { "authorize", LOG_AUTH },
+ { "syslog", LOG_SYSLOG },
+ { "lpr", LOG_LPR },
+ { "news", LOG_NEWS },
+ { "uucp", LOG_UUCP },
+ { "cron", LOG_CRON },
+ { "authpriv", LOG_AUTHPRIV },
+ { "ftp", LOG_FTP },
+ { "local0", LOG_LOCAL0 },
+ { "local1", LOG_LOCAL1 },
+ { "local2", LOG_LOCAL2 },
+ { "local3", LOG_LOCAL3 },
+ { "local4", LOG_LOCAL4 },
+ { "local5", LOG_LOCAL5 },
+ { "local6", LOG_LOCAL6 },
+ { "local7", LOG_LOCAL7 },
+ { 0, 0 }
};
void
syslogInfo(void)
{
- int tot;
- struct nameval *nvp;
-
- tot = 0;
- nvp = prioritynames;
- printf("\nValid 'priority' names:\n");
- while(nvp->name) {
- printf("%12s",nvp->name);
- nvp++;
- if (++tot == 4) {
- printf("\n");
- tot = 0;
- }
- }
-
- tot = 0;
- nvp = facilitynames;
- printf("\nValid 'facility' names:\n");
- while(nvp->name) {
- printf("%12s",nvp->name);
- nvp++;
- if (++tot == 4) {
- printf("\n");
- tot = 0;
- }
- }
+ int tot;
+ struct nameval *nvp;
+
+ tot = 0;
+ nvp = prioritynames;
+ printf("\nValid 'priority' names:\n");
+ while(nvp->name) {
+ printf("%12s",nvp->name);
+ nvp++;
+ if(++tot == 4) {
+ printf("\n");
+ tot = 0;
+ }
+ }
+
+ tot = 0;
+ nvp = facilitynames;
+ printf("\nValid 'facility' names:\n");
+ while(nvp->name) {
+ printf("%12s",nvp->name);
+ nvp++;
+ if(++tot == 4) {
+ printf("\n");
+ tot = 0;
+ }
+ }
}
int
getPriorityValue(char *prio)
{
- struct nameval *nvp;
-
- if (prio == 0)
- return(0);
-
- nvp = prioritynames;
- while(nvp->name) {
- if (!strcmp(nvp->name,prio))
- return(nvp->val);
- nvp++;
- }
- return(-1);
+ struct nameval *nvp;
+
+ if(prio == 0) {
+ return(0);
+ }
+
+ nvp = prioritynames;
+ while(nvp->name) {
+ if(!strcmp(nvp->name,prio)) {
+ return(nvp->val);
+ }
+ nvp++;
+ }
+ return(-1);
}
int
getFacilityValue(char *fac)
{
- struct nameval *nvp;
-
- if (fac == 0)
- return(0);
-
- nvp = facilitynames;
- while(nvp->name) {
- if (!strcmp(nvp->name,fac))
- return(nvp->val);
- nvp++;
- }
- return(-1);
+ struct nameval *nvp;
+
+ if(fac == 0) {
+ return(0);
+ }
+
+ nvp = facilitynames;
+ while(nvp->name) {
+ if(!strcmp(nvp->name,fac)) {
+ return(nvp->val);
+ }
+ nvp++;
+ }
+ return(-1);
}
int
sendSyslog(uchar *syslogsrvr,char *msg, short port, int null)
{
- int msglen;
- uchar *syslogmsg;
- ushort ip_len, sport;
- struct ether_header *enetp;
- struct ip *ipp;
- struct Udphdr *udpp;
- uchar binip[8], binenet[8], *enetaddr;
-
- /* msglen is the length of the message, plus optionally the
- * terminating null character (-n option of syslog command)..
- */
- msglen = strlen(msg) + null;
-
- /* Convert IP address to binary:
- */
- if (IpToBin((char *)syslogsrvr,(unsigned char *)binip) < 0)
- return(0);
-
- /* Get the ethernet address for the IP:
- */
- enetaddr = ArpEther(binip,binenet,0);
- if (!enetaddr) {
- printf("ARP failed for %s\n",syslogsrvr);
- return(0);
- }
-
- /* Retrieve an ethernet buffer from the driver and populate the
- * ethernet level of packet:
- */
- enetp = (struct ether_header *) getXmitBuffer();
- memcpy((char *)&enetp->ether_shost,(char *)BinEnetAddr,6);
- memcpy((char *)&enetp->ether_dhost,(char *)binenet,6);
- enetp->ether_type = ecs(ETHERTYPE_IP);
-
- /* Move to the IP portion of the packet and populate it
- * appropriately:
- */
- ipp = (struct ip *) (enetp + 1);
- ipp->ip_vhl = IP_HDR_VER_LEN;
- ipp->ip_tos = 0;
- ip_len = sizeof(struct ip) + sizeof(struct Udphdr) + msglen;
- ipp->ip_len = ecs(ip_len);
- ipp->ip_id = ipId();
- ipp->ip_off = 0;
- ipp->ip_ttl = UDP_TTL;
- ipp->ip_p = IP_UDP;
- memcpy((char *)&ipp->ip_src.s_addr,(char *)BinIpAddr,4);
- memcpy((char *)&ipp->ip_dst.s_addr,(char *)binip,4);
-
- /* Now UDP...
- */
- sport = port+1;
- udpp = (struct Udphdr *) (ipp + 1);
- udpp->uh_sport = ecs(sport);
- udpp->uh_dport = ecs(port);
- udpp->uh_ulen = ecs((ushort)(ip_len - sizeof(struct ip)));
-
- /* Finally, the SYSLOG data ...
- */
- syslogmsg = (uchar *)(udpp+1);
- strcpy((char *)syslogmsg,(char *)msg);
-
- ipChksum(ipp); /* Compute csum of ip hdr */
- udpChksum(ipp); /* Compute UDP checksum */
-
- sendBuffer(ETHERSIZE + IPSIZE + UDPSIZE + msglen);
- return(0);
+ int msglen;
+ uchar *syslogmsg;
+ ushort ip_len, sport;
+ struct ether_header *enetp;
+ struct ip *ipp;
+ struct Udphdr *udpp;
+ uchar binip[8], binenet[8], *enetaddr;
+
+ /* msglen is the length of the message, plus optionally the
+ * terminating null character (-n option of syslog command)..
+ */
+ msglen = strlen(msg) + null;
+
+ /* Convert IP address to binary:
+ */
+ if(IpToBin((char *)syslogsrvr,(unsigned char *)binip) < 0) {
+ return(0);
+ }
+
+ /* Get the ethernet address for the IP:
+ */
+ enetaddr = ArpEther(binip,binenet,0);
+ if(!enetaddr) {
+ printf("ARP failed for %s\n",syslogsrvr);
+ return(0);
+ }
+
+ /* Retrieve an ethernet buffer from the driver and populate the
+ * ethernet level of packet:
+ */
+ enetp = (struct ether_header *) getXmitBuffer();
+ memcpy((char *)&enetp->ether_shost,(char *)BinEnetAddr,6);
+ memcpy((char *)&enetp->ether_dhost,(char *)binenet,6);
+ enetp->ether_type = ecs(ETHERTYPE_IP);
+
+ /* Move to the IP portion of the packet and populate it
+ * appropriately:
+ */
+ ipp = (struct ip *)(enetp + 1);
+ ipp->ip_vhl = IP_HDR_VER_LEN;
+ ipp->ip_tos = 0;
+ ip_len = sizeof(struct ip) + sizeof(struct Udphdr) + msglen;
+ ipp->ip_len = ecs(ip_len);
+ ipp->ip_id = ipId();
+ ipp->ip_off = 0;
+ ipp->ip_ttl = UDP_TTL;
+ ipp->ip_p = IP_UDP;
+ memcpy((char *)&ipp->ip_src.s_addr,(char *)BinIpAddr,4);
+ memcpy((char *)&ipp->ip_dst.s_addr,(char *)binip,4);
+
+ /* Now UDP...
+ */
+ sport = port+1;
+ udpp = (struct Udphdr *)(ipp + 1);
+ udpp->uh_sport = ecs(sport);
+ udpp->uh_dport = ecs(port);
+ udpp->uh_ulen = ecs((ushort)(ip_len - sizeof(struct ip)));
+
+ /* Finally, the SYSLOG data ...
+ */
+ syslogmsg = (uchar *)(udpp+1);
+ strcpy((char *)syslogmsg,(char *)msg);
+
+ ipChksum(ipp); /* Compute csum of ip hdr */
+ udpChksum(ipp); /* Compute UDP checksum */
+
+ sendBuffer(ETHERSIZE + IPSIZE + UDPSIZE + msglen);
+ return(0);
}
char *SyslogHelp[] = {
- "Syslog client",
- "-[f:lP:np:v] {srvr ip} {msg}",
+ "Syslog client",
+ "-[f:lP:np:v] {srvr ip} {msg}",
#if INCLUDE_VERBOSEHELP
- "Options:",
- " -f {fac} specify facility",
- " -l list facility & priority strings",
- " -n append null-char to message",
- " -P {##} override default port 514",
- " -p {prio} specify priority",
- " -v verbose",
+ "Options:",
+ " -f {fac} specify facility",
+ " -l list facility & priority strings",
+ " -n append null-char to message",
+ " -P {##} override default port 514",
+ " -p {prio} specify priority",
+ " -v verbose",
#endif
- 0,
+ 0,
};
int
SyslogCmd(int argc, char *argv[])
{
- char *facility, *priority, *msg;
- int opt, verbose, fac_val, prio_val, val, port, null;
-
- port = SYSLOG_PORT;
- facility = priority = 0;
- null = fac_val = prio_val = verbose = 0;
-
- while((opt=getopt(argc,argv,"f:lnP:p:v")) != -1) {
- switch(opt) {
- case 'f':
- facility = optarg;
- break;
- case 'l':
- syslogInfo();
- return(CMD_SUCCESS);
- case 'n':
- null = 1;
- break;
- case 'P':
- port = atoi(optarg);
- break;
- case 'p':
- priority = optarg;
- break;
- case 'v':
- verbose = 1;
- break;
- default:
- return(CMD_PARAM_ERROR);
- }
- }
-
- if (argc != optind+2)
- return(CMD_PARAM_ERROR);
-
- prio_val = getPriorityValue(priority);
- fac_val = getFacilityValue(facility);
-
- if ((prio_val == -1) || (fac_val == -1))
- return(CMD_PARAM_ERROR);
-
- val = (prio_val | fac_val);
-
- if ((priority != 0) || (facility != 0)) {
- msg = malloc(strlen(argv[optind+1])+16);
- if (!msg)
- return(CMD_FAILURE);
- sprintf(msg,"<%d>%s",val,argv[optind+1]);
- }
- else
- msg = argv[optind+1];
-
- if (verbose)
- printf("Syslog msg '%s' to %s\n",msg,argv[optind]);
-
- sendSyslog((unsigned char *)argv[optind],msg,port,null);
-
- if (val)
- free(msg);
-
- return(CMD_SUCCESS);
+ char *facility, *priority, *msg;
+ int opt, verbose, fac_val, prio_val, val, port, null;
+
+ port = SYSLOG_PORT;
+ facility = priority = 0;
+ null = fac_val = prio_val = verbose = 0;
+
+ while((opt=getopt(argc,argv,"f:lnP:p:v")) != -1) {
+ switch(opt) {
+ case 'f':
+ facility = optarg;
+ break;
+ case 'l':
+ syslogInfo();
+ return(CMD_SUCCESS);
+ case 'n':
+ null = 1;
+ break;
+ case 'P':
+ port = atoi(optarg);
+ break;
+ case 'p':
+ priority = optarg;
+ break;
+ case 'v':
+ verbose = 1;
+ break;
+ default:
+ return(CMD_PARAM_ERROR);
+ }
+ }
+
+ if(argc != optind+2) {
+ return(CMD_PARAM_ERROR);
+ }
+
+ prio_val = getPriorityValue(priority);
+ fac_val = getFacilityValue(facility);
+
+ if((prio_val == -1) || (fac_val == -1)) {
+ return(CMD_PARAM_ERROR);
+ }
+
+ val = (prio_val | fac_val);
+
+ if((priority != 0) || (facility != 0)) {
+ msg = malloc(strlen(argv[optind+1])+16);
+ if(!msg) {
+ return(CMD_FAILURE);
+ }
+ sprintf(msg,"<%d>%s",val,argv[optind+1]);
+ } else {
+ msg = argv[optind+1];
+ }
+
+ if(verbose) {
+ printf("Syslog msg '%s' to %s\n",msg,argv[optind]);
+ }
+
+ sendSyslog((unsigned char *)argv[optind],msg,port,null);
+
+ if(val) {
+ free(msg);
+ }
+
+ return(CMD_SUCCESS);
}
#endif
generated by cgit v1.2.3 (git 2.25.1) at 2024-05-05 08:25:25 +0000