X-Git-Url: https://git.dlugolecki.net.pl/?a=blobdiff_plain;f=src%2Fprocess1.c;h=9fdee30b55edb5020a3eb2c05201fa24154f44ca;hb=717e5b533ec94ef8f9a703bd4f019a2f45e138df;hp=b5004830f5c9c43e4aebc60df07a0cf1828e83ea;hpb=c0975e5a6af7b478563193dac7c3484b4430d3a3;p=wsti_so.git

diff --git a/src/process1.c b/src/process1.c
index b500483..9fdee30 100644
--- a/src/process1.c
+++ b/src/process1.c
@@ -11,22 +11,42 @@
 /** If buffer is too small to hold entire string, it is incremented by this value */
 #define BUFFER_STEP 16
 
+/** Buffer used to store line of characters */
+char * buffer = NULL;
+
+/** Named pipe used to communnicate with process2 */
+char * write_pipe = "/tmp/process1pipe";
+
+/** File descriptor of pipe */
+int file_descriptor;
+
 /**
  * Handler for signals.
  */
 void sig_handler(int signo)
 {
+	fprintf(stderr, "[%s] Received %s!\n", "process1", strsignal(signo));
 	if (signo == SIGUSR1) {
-		fprintf(stderr, "[%s] SIGUSR1!\n", "process1");
 	}
-	else if (signo == SIGUSR2) {
-		fprintf(stderr, "[%s] SIGUSR2!\n", "process1");
+	else if (signo == SIGTERM) {
+		fprintf(stderr, "[%s] > Releasing resources\n", "process1");
+		close(write_pipe);
+		unlink(write_pipe);
+
+		if (buffer) {
+			free(buffer);
+			buffer = NULL;
+		}
+		exit(0);
 	}
-	else if (signo == SIGINT) {
-		fprintf(stderr, "[%s] SIGINT!\n", "process1");
+	else if (signo == SIGTSTP) {
+		fprintf(stderr, "[%s] > Closing pipe\n", "process1");
+		close(write_pipe);
+		raise (SIGSTOP);
 	}
 	else if (signo == SIGCONT) {
-		fprintf(stderr, "[%s] SIGCONT!\n", "process1");
+		fprintf(stderr, "[%s] > Opening pipe\n", "process1");
+		file_descriptor = open(write_pipe, O_WRONLY);
 	}
 }
 
@@ -38,9 +58,6 @@ int main(void) {
 	/** Currently fetched from stdin character */
 	int c;
 
-	/** Buffer used to store line of characters */
-	char * buffer = NULL;
-
 	/** Current buffer length*/
 	int buffer_length = 0;
 
@@ -53,12 +70,6 @@ int main(void) {
 	 */
 	char * tmp = NULL;
 
-	/** Named pipe used to communnicate with process2 */
-	char * write_pipe = "/tmp/process1pipe";
-
-	/** File descriptor of pipe */
-	int file_descriptor;
-
 	fprintf(stderr, "[%s] Init!\n", "process1");
 
 	/**
@@ -67,11 +78,11 @@ int main(void) {
 	if (signal(SIGUSR1, sig_handler) == SIG_ERR) {
 		fprintf(stderr, "can't catch SIGUSR1\n");
 	}
-	if (signal(SIGUSR2, sig_handler) == SIG_ERR) {
-		fprintf(stderr, "can't catch SIGUSR2\n");
+	if (signal(SIGTERM, sig_handler) == SIG_ERR) {
+		fprintf(stderr, "can't catch SIGTERM\n");
 	}
-	if (signal(SIGINT, sig_handler) == SIG_ERR) {
-		fprintf(stderr, "can't catch SIGINT\n");
+	if (signal(SIGTSTP, sig_handler) == SIG_ERR) {
+		fprintf(stderr, "can't catch SIGTSTP\n");
 	}
 	if (signal(SIGCONT, sig_handler) == SIG_ERR) {
 		fprintf(stderr, "can't catch SIGCONT\n");
@@ -137,6 +148,7 @@ int main(void) {
 		}
 	} while(c != EOF);
 
+	/* Release resources in normal program flow exit. */
 	close(write_pipe);
 	unlink(write_pipe);