stats.c

/*  
    Notification-Junction is an interface between multiple applications and multiple Notification Providers.
    Copyright (C) 2015      Navroop Kaur<watwanichitra@gmail.com>, 
                            Shivani Marathe<maratheshivani94@gmail.com>, 
                            Kaveri Sangale<sangale.kaveri9@gmail.com>
	All Rights Reserved.
	
    This program is free software; you can redistribute it and/or modify it under the terms of the 
    GNU General Public License as published by the Free Software Foundation; either version 3 of the
    License, or (at your option) any later version.

    This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; 
    without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  
    See the GNU General Public License for more details.
       
    You should have received a copy of the GNU General Public License along with this program; if not, write to the 
    Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*/

/*
*	The function of this command is to print the registrations and related details, as listed below -
*	NPs registered
*	For every NP, print the count of apps registered with it
* 	Table - NP - Count of Apps
*	Apps registered and the NPs they have registered with
*	Table - App - Pid - Registered with 
*
*	Add as is thought
*
*	The idea is to extract the details from the lists in the NJ.
*
*/

#include <sys/types.h>
#include <stdlib.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <stdio.h>

#define NAME "./statsock"
#define StatSocketPrint "./statsockprint"
#define QLEN 32

int main(int argc, char *argv[])
{

	int sock, retval = 0, sock_read, msgsock;
	struct sockaddr_un server, server2;
	char data[1024];
	strcpy(data, argv[0]);

	if (argc != 1) {
		printf("Usage - ./%s\n", argv[0]);
		exit(1);
	}


	sock_read = socket(AF_UNIX, SOCK_STREAM, 0);
	if (sock_read < 0) {
		perror("opening stream socket");
		exit(EXIT_FAILURE);
	}
	server2.sun_family = AF_UNIX;
	strcpy(server2.sun_path, StatSocketPrint);
	if (bind(sock_read, (struct sockaddr *)&server2, sizeof(struct sockaddr_un))) {
		perror("binding stream socket");
		exit(EXIT_FAILURE);
	}
	if(listen(sock_read, QLEN) != 0 ) {
		perror("Error in listening on stat socket");
	}



	sock = socket(AF_UNIX, SOCK_STREAM, 0);
	if (sock < 0) {
		perror("STATS : Opening Stream Socket");
		exit(1);
	}
	server.sun_family = AF_UNIX;
	strcpy(server.sun_path, NAME);

	if (connect
			(sock, (struct sockaddr *)&server,
			 sizeof(struct sockaddr_un)) < 0) {
		close(sock);
		perror("STATS : Connecting Stream Socket");
		exit(1);
	}
	if (write(sock, data, sizeof(data)) < 0)
		perror("STATS : Writing On Stream Socket");
		
		
	msgsock = accept(sock_read, 0, 0);
	if (msgsock == -1)
		perror(" Error accept on stat socket");
	else
		do {
			bzero(data, sizeof(data));
			if ((retval = read(msgsock, data, 1024)) < 0)
				perror("NJ.C   : reading stream message");
			else {	
				printf("%s", data);
			}
		} while (retval > 0);

	close(sock);
	close(sock_read);
	return 0;
}