X-Git-Url: https://gapil.gnulinux.it/gitweb/?p=gapil.git;a=blobdiff_plain;f=listati%2FFifoReporter-main.c;fp=listati%2FFifoReporter-main.c;h=dcf3901ad5d29d3b134b718d549f9787d4955bb3;hp=0000000000000000000000000000000000000000;hb=c15153bee6a516df24ebb4e7bf33ffa7ce91496d;hpb=7d224ad655c0a530877f39411d43a91e3d7318e1

diff --git a/listati/FifoReporter-main.c b/listati/FifoReporter-main.c
new file mode 100644
index 0000000..dcf3901
--- /dev/null
+++ b/listati/FifoReporter-main.c
@@ -0,0 +1,45 @@
+    /* Main body: wait something to report */
+    while (1) {
+        if ((n=epoll_wait(epfd, events, MAX_EPOLL_EV, -1)) < 0) 
+	    die("error on epoll_wait");
+	for (i=0; i<n; i++) {    // loop on ready file descriptors             
+	    if (events[i].data.fd == sigfd) {  // look if signalfd ready 
+		printf("Signal received:\n");
+		while(nread=read(sigfd, &siginf, sizeof(siginf))) {
+		    if (nread < 0) {
+			if (errno != EAGAIN) 
+			    die("signalfd read error");
+			else 
+			    break;
+		    }
+		    if (nread != sizeof(siginf)) {
+			printf("Error on signal data read, '\n");
+			continue;
+		    }
+		    printf("Got %s\n", sig_names[siginf.ssi_signo]);
+		    if(siginf.ssi_signo == SIGINT) { // SIGINT stop program
+			unlink(fifoname);
+			exit(0);
+		    }
+		}
+	    } else if (events[i].data.fd == fifofd) { // look if fifofd ready 
+		printf("Message from fifo:\n");
+		while ((nread = read(fifofd, buffer, 5000))) {
+		    if (nread < 0) {
+			if (errno != EAGAIN)
+			    die("fifo read error");
+			else 
+			    printf("end message\n");
+			break;
+		    }
+		    buffer[nread] = 0;
+		    if (fputs(buffer, stdout) == EOF)
+			die("Errore in scrittura su terminale");
+		}
+	    } else {   // anything else is an error
+		printf("epoll activity on unknown %i file descriptor\n", 
+		       epev.data.fd);
+		exit(-1);
+	    }
+	}
+    }