char *buffer_pt = NULL;
+ /* Create PID file */
+ if(CreatePID(ARGV0, getpid()) < 0)
+ {
+ ErrorExit(PID_ERROR,ARGV0);
+ }
/* Initializing some variables */
memset(buffer, '\0', OS_MAXSTR +2);
if((r_sz = OS_RecvTCPBuffer(client_socket, buffer, OS_MAXSTR -2)) < 0)
{
close(client_socket);
+ DeletePID(ARGV0);
return;
}
if(SendMSG(logr.m_queue, buffer_pt, srcip,SYSLOG_MQ) < 0)
{
merror(QUEUE_ERROR,ARGV0,DEFAULTQUEUE, strerror(errno));
- if((logr.m_queue = StartMQ(DEFAULTQUEUE,READ)) < 0)
+ if((logr.m_queue = StartMQ(DEFAULTQUEUE,WRITE)) < 0)
{
ErrorExit(QUEUE_FATAL,ARGV0,DEFAULTQUEUE);
}