yasnd/daemon/yasnd-ipc.c

#include <sys/ipc.h>
#include <sys/msg.h>
#include <pthread.h>

#include "yasnd.h"
#include "yasnd-gammu.h"
#include "yasnd-log.h"

pthread_t ipc_main_handle;
pthread_t ipc_sms_read_handle; // handle of thread, that checks for new incoming SMS
int qid=-1; // IPC queue id

int open_queue()
{
	key_t keyval=ftok(".",'m');
        int qid;
	if((qid = msgget( keyval, IPC_CREAT | 0660 )) == -1)
	{
		log_event("Error opening/creating IPC message queue");
		exit(EXIT_FAILURE);
	}
	return qid;
}

int send_message(int qid, mymsgbuf* qbuf)
{
	int result;
        /* The length is essentially the size of the structure minus sizeof(mtype) */
	int length = sizeof(mymsgbuf) - sizeof(long);

	if((result = msgsnd( qid, qbuf, length, 0)) == -1)
	{
		return -1;
	}

	return result;
}

int read_message(int qid, mymsgbuf* qbuf, long type)
{
	int result;
	int length = sizeof(mymsgbuf) - sizeof(long);
        if((result = msgrcv( qid, qbuf, length, type,  0)) == -1)
        {
                return -1;
        }
	return result;
}

int remove_queue( int qid )
{
        if( msgctl(qid, IPC_RMID, 0) == -1)
        {
                return -1;
        }
        return 0;
}

void* ipc_queue_loop(void* param)
{
	mymsgbuf qbuf;
	while(1)
	{
		int result=read_message(qid, &qbuf, 0);
		if (result==-1)
		{
			log_event("Error: finishing IPC loop process...");
			return (void*)1;
		}
		char dbg_txt[150];
		sprintf(dbg_txt,"Read IPC message - Type: %ld Text: %s", qbuf.mtype, qbuf.mtext);
		log_debug(dbg_txt,DEBUG_ALL);
		if (qbuf.mtype==SMS_RECEIVE_TYPE && sms_enable)
		{
			pid_t pid = fork();
			if (pid < 0) {
				log_event("Error: can not fork child :(");
		                exit(EXIT_FAILURE);
		        }
		        // If pid == 0, then we are in the child
		        if (pid == 0) {
				gammu_read_sms();
				exit(EXIT_SUCCESS);
		        }
			// wait for SMS reading thread
			// STUB: need to react on status, returned by thread
			waitpid(pid,NULL,0);
		}
		if (qbuf.mtype==SMS_SEND_TYPE && sms_enable)
		{
			log_debug(qbuf.mtext,DEBUG_BASE);
			pid_t pid = fork();
			if (pid < 0) {
				log_event("Error: can not fork child :(");
		                exit(EXIT_FAILURE);
		        }
		        // If pid == 0, then we are in the child
		        if (pid == 0) {
				gammu_send_sms(qbuf.mtext);
				exit(EXIT_SUCCESS);
		        }
			// wait for SMS sending thread
			// STUB: need to react on status, returned by thread
			waitpid(pid,NULL,0);
		}
	}
}


void* ipc_sms_reading_loop(void* param)
{
	while(1)
	{
		sleep(30); /* wait 30 seconds */
		mymsgbuf qbuf;
		qbuf.mtype=SMS_RECEIVE_TYPE;
		qbuf.mtext[0]=(char)0;
		send_message(qid,&qbuf);
	}
}

void ipc_init()
{
	qid = open_queue();
	if(pthread_create(&ipc_main_handle,NULL,ipc_queue_loop, NULL) != 0)
	{
		log_event("Main IPC event thread creation failed");
	}
	// start loop, that handles new incoming SMS
	if(pthread_create(&ipc_sms_read_handle,NULL,ipc_sms_reading_loop, NULL) != 0)
	{
		log_event("Failed to create thread for incoming SMS parsing");
	}
	//
}

void ipc_free()
{
	pthread_cancel(ipc_main_handle);
	pthread_cancel(ipc_sms_read_handle);
	remove_queue(qid);
}