Changeset c3ee5f3

Timestamp:

Jan 8, 2021, 5:20:16 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:

35fd2c4

Parents:

390fb02

Message:

Protocol now returns date in answer header

Location:

benchmark/io/http

Files:

• main.cfa (modified) (5 diffs)
• protocol.cfa (modified) (3 diffs)

benchmark/io/http/main.cfa

@@ -46 +46 @@
 }
 
+extern void init_protocol(void);
+extern void deinit_protocol(void);
+
 //=============================================================================================
 // Main
@@ -56 +59 @@
         //===================
         // Open Files
-        printf("Filling cache from %s\n", path);
-        fill_cache( path );
+        if (FileExperiment == options.experiment.type) {
+                printf("Filling cache from %s\n", path);
+                fill_cache( path );
+        }
 
         //===================
@@ -79 +84 @@
                 ret = bind( server_fd, (struct sockaddr *)&address, sizeof(address) );
                 if(ret < 0) {
-                        if(errno == 98) {
+                        if(errno == EADDRINUSE) {
                                 if(waited == 0) {
                                         printf("Waiting for port\n");
@@ -108 +113 @@
                 #endif
                 options.clopts.instance = &cl;
+
+                init_protocol();
 
                 int pipe_cnt = options.clopts.nworkers * 2;
@@ -162 +169 @@
                 }
                 free(fds);
+
+                deinit_protocol();
         }
 

benchmark/io/http/protocol.cfa

@@ -18 +18 @@
 #include "options.hfa"
 
-const char * volatile date = "Wed, 17 Apr 2013 12:00:00 GMT";
+const char * volatile date = 0p;
 
 const char * http_msgs[] = {
@@ -78 +78 @@
         for() {
                 int ret = cfa_read(fd, (void*)it, count, 0, -1`s, 0p, 0p);
+                // int ret = read(fd, (void*)it, count);
                 if(ret == 0 ) return [OK200, true, 0, 0];
                 if(ret < 0 ) {
                         if( errno == EAGAIN || errno == EWOULDBLOCK) continue READ;
+                        // if( errno == EINVAL ) return [E400, true, 0, 0];
                         abort( "read error: (%d) %s\n", (int)errno, strerror(errno) );
                 }
@@ -129 +131 @@
         }
 }
+
+//=============================================================================================
+
+#include <clock.hfa>
+#include <time.hfa>
+#include <thread.hfa>
+
+struct date_buffer {
+        char buff[100];
+};
+
+thread DateFormater {
+        int idx;
+        date_buffer buffers[2];
+};
+
+void ?{}( DateFormater & this ) {
+        ((thread&)this){ *options.clopts.instance };
+        this.idx = 0;
+        memset( this.buffers[0].buff, 0, sizeof(this.buffers[0]) );
+        memset( this.buffers[1].buff, 0, sizeof(this.buffers[1]) );
+}
+
+void main(DateFormater & this) {
+        LOOP: for() {
+                waitfor( ^?{} : this) {
+                        break LOOP;
+                }
+                or else {}
+
+                Time now = getTimeNsec();
+                // Date: Wed, 17 Apr 2013 12:00:00 GMT
+                strftime( this.buffers[this.idx].buff, 100, "%a, %d %b %Y %H:%M:%S %Z", now );
+                printf("Changing date to %s\n", this.buffers[this.idx].buff);
+
+                char * next = this.buffers[this.idx].buff;
+                __atomic_exchange_n((char * volatile *)&date, next, __ATOMIC_SEQ_CST);
+                this.idx = (this.idx + 1) % 2;
+
+                sleep(1`s);
+        }
+}
+
+//=============================================================================================
+DateFormater * the_date_formatter;
+
+void init_protocol(void) {
+        the_date_formatter = alloc();
+        (*the_date_formatter){};
+}
+
+void deinit_protocol(void) {
+        ^(*the_date_formatter){};
+        free( the_date_formatter );
+}