path: root/main/common/syslog.c

/**************************************************************************
 *
 * 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
 * file LICENSE at the top level of this repository.
 * You may also obtain a copy of the License at:
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 **************************************************************************
 *
 * syslog.c:
 *
 *	This code supports the monitor's SYSLOC client.
 *
 * Original author:     Ed Sutter (ed.sutter@alcatel-lucent.com)
 *
 */
#include "config.h"
#if INCLUDE_SYSLOG
#include "endian.h"
#include "genlib.h"
#include "ether.h"
#include "stddefs.h"
#include "cli.h"

#define SYSLOG_PORT	514

struct nameval {
	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 */

/* 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

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 }
};

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 }
};

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
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);
}

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);
}

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);
}

char *SyslogHelp[] = {
	"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",
#endif
	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);
}

#endif