Changes in benchmark/io/http/worker.cfa [2cd784a:b57db73]

File:

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

benchmark/io/http/worker.cfa

@@ -17 +17 @@
 //=============================================================================================
 void ?{}( Worker & this ) {
-        size_t cli = rand() % options.clopts.cltr_cnt;
-        ((thread&)this){ "Server Worker Thread", *options.clopts.instance[cli] };
-        options.clopts.thrd_cnt[cli]++;
+        ((thread&)this){ "Server Worker Thread", *options.clopts.instance };
         this.pipe[0] = -1;
         this.pipe[1] = -1;
@@ -37 +35 @@
         for() {
                 if( options.log ) sout | "=== Accepting connection ===";
-                int fd = cfa_accept4( this.[sockfd, addr, addrlen, flags], CFA_IO_LAZY );
+                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;
@@ -43 +42 @@
                         abort( "accept error: (%d) %s\n", (int)errno, strerror(errno) );
                 }
-                if(this.done) break;
 
                 if( options.log ) sout | "=== New connection" | fd | "" | ", waiting for requests ===";
@@ -57 +55 @@
                         char buffer[len];
                         if( options.log ) sout | "=== Reading request ===";
-                        [code, closed, file, name_size] = http_read(fd, buffer, len);
+                        [code, closed, file, name_size] = http_read(fd, buffer, len, &this.cancel);
 
                         // if we are done, break out of the loop
@@ -72 +70 @@
                                 if( options.log ) sout | "=== Request for /plaintext ===";
 
-                                int ret = answer_plaintext(fd);
+                                char text[] = "Hello, World!\n";
+
+                                // Send the header
+                                int ret = answer_plain(fd, text, sizeof(text));
                                 if( ret == -ECONNRESET ) break REQUEST;