X-Git-Url: https://git.dlugolecki.net.pl/?a=blobdiff_plain;f=src%2Fprocess1.c;h=f4a1392d84398e72d440e0d63cfb6b64690b46a7;hb=d9503d0855f3cc3b422c496dfa01b56eb6cee357;hp=9374646fb5ae6e4baf745486e96ac0fab2695425;hpb=1a182bf57e39422f23439520b40fc6007e991757;p=wsti_so.git

diff --git a/src/process1.c b/src/process1.c
index 9374646..f4a1392 100644
--- a/src/process1.c
+++ b/src/process1.c
@@ -32,14 +32,14 @@ int main(void) {
 	char * tmp = NULL;
 
 	/** Named pipe used to communnicate with process2 */
-	char * fifo = "/tmp/process1fifo";
+	char * write_pipe = "/tmp/process1pipe";
 
 	/** File descriptor of pipe */
 	int file_descriptor;
 
-	mkfifo(fifo, 0666);
+	mkfifo(write_pipe, 0666);
 
-	file_descriptor = open(fifo, O_WRONLY);
+	file_descriptor = open(write_pipe, O_WRONLY);
 	
 	do {
 		c = fgetc(stdin);
@@ -62,16 +62,17 @@ int main(void) {
 		}
 
 		/*
-		 * If there were no errors parse data.
+		 * If there were no errors or it was not just an empty newline:
+		 * parse data.
 		 */
-		if (c != EOF) {
+		if (c != EOF || ((i == 0) && (c == 10))) {
 			/* If newline has been found
 			 * return entire string and release the memory
 			 */
-			if (c == 10) {
+			if (c == 10 && (i != 0)) {
 				buffer[i] = '\n';
-				write(file_descriptor, buffer, ++buffer_length);
-				/*fprintf(stdout, "%s\n", buffer);*/
+				write(file_descriptor, buffer, strlen(buffer));
+				fprintf(stderr, "[%s] buffer: %s/%d\n", "process1", buffer, strlen(buffer));
 
 				buffer_length = 0;
 				i = 0;
@@ -96,8 +97,8 @@ int main(void) {
 		}
 	} while(c != EOF);
 
-	close(fifo);
-	unlink(fifo);
+	close(write_pipe);
+	unlink(write_pipe);
 
 	if (buffer) {
 		free(buffer);