Changeset 481ee28 for benchmark/io/http/worker.cfa

Timestamp:

Jan 12, 2021, 1:12:24 PM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

7dafb7b

Parents:

35285fd

Message:

Removed experiment type, server just supports both urls.
Logging is now optional.
Added done flag so spurious invalid accepts are caught.

File:

• benchmark/io/http/worker.cfa (modified) (8 diffs)

benchmark/io/http/worker.cfa

@@ -19 +19 @@
         this.pipe[0] = -1;
         this.pipe[1] = -1;
+        this.done = false;
+}
+
+extern "C" {
+extern int accept4(int sockfd, struct sockaddr *addr, socklen_t *addrlen, int flags);
 }
 
@@ -28 +33 @@
         CONNECTION:
         for() {
-                printf("=== Accepting connection ===\n");
+                if( options.log ) printf("=== Accepting connection ===\n");
                 int fd = cfa_accept4( this.[sockfd, addr, addrlen, flags], 0, -1`s, &this.cancel, 0p );
+                // int fd = accept4( this.[sockfd, addr, addrlen, flags] );
                 if(fd < 0) {
                         if( errno == ECONNABORTED ) break;
-                        if( errno == EINVAL ) break;
+                        if( errno == EINVAL && this.done ) break;
                         abort( "accept error: (%d) %s\n", (int)errno, strerror(errno) );
                 }
 
-                printf("=== New connection %d, waiting for requests ===\n", fd);
+                if( options.log ) printf("=== New connection %d, waiting for requests ===\n", fd);
                 REQUEST:
                 for() {
@@ -47 +53 @@
                         size_t len = options.socket.buflen;
                         char buffer[len];
-                        printf("=== Reading request ===\n");
+                        if( options.log ) printf("=== Reading request ===\n");
                         [code, closed, file, name_size] = http_read(fd, buffer, len, &this.cancel);
 
                         // if we are done, break out of the loop
                         if( closed ) {
-                                printf("=== Connection closed ===\n");
+                                if( options.log ) printf("=== Connection closed ===\n");
                                 continue CONNECTION;
                         }
@@ -58 +64 @@
                         // If this wasn't a request retrun 400
                         if( code != OK200 ) {
-                                printf("=== Invalid Request : %d ===\n", code_val(code));
+                                if( options.log ) printf("=== Invalid Request : %d ===\n", code_val(code));
                                 answer_error(fd, code);
                                 continue REQUEST;
@@ -64 +70 @@
 
                         if(0 == strncmp(file, "plaintext", min(name_size, sizeof("plaintext") ))) {
-                                printf("=== Request for /plaintext ===\n");
+                                if( options.log ) printf("=== Request for /plaintext ===\n");
 
                                 char text[] = "Hello, World!\n";
@@ -72 +78 @@
                         }
                         else {
-                                printf("=== Request for file %.*s ===\n", (int)name_size, file);
+                                if( options.log ) printf("=== Request for file %.*s ===\n", (int)name_size, file);
 
                                 // Get the fd from the file cache
@@ -81 +87 @@
                                 // If we can't find the file, return 404
                                 if( ans_fd < 0 ) {
-                                        printf("=== File Not Found ===\n");
+                                        if( options.log ) printf("=== File Not Found ===\n");
                                         answer_error(fd, E404);
                                         continue REQUEST;
@@ -93 +99 @@
                         }
 
-                        printf("=== Answer sent ===\n");
+                        if( options.log ) printf("=== Answer sent ===\n");
                 }
         }