Changeset 4f762d3 for benchmark/io/http/protocol.cfa
- Timestamp:
- Feb 19, 2021, 1:48:14 PM (4 years ago)
- Branches:
- ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum
- Children:
- d60d30e
- Parents:
- 78da4ab
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
benchmark/io/http/protocol.cfa
r78da4ab r4f762d3 53 53 while(len > 0) { 54 54 // Call write 55 int ret = cfa_write(fd, it, len, 0, -1`s, 0p, 0p); 56 // int ret = write(fd, it, len); 55 int ret = cfa_send(fd, it, len, 0, 0); 57 56 if( ret < 0 ) { 58 57 if( errno == ECONNRESET || errno == EPIPE ) return -ECONNRESET; … … 94 93 95 94 96 [HttpCode code, bool closed, * const char file, size_t len] http_read(int fd, []char buffer, size_t len , io_cancellation * cancel) {95 [HttpCode code, bool closed, * const char file, size_t len] http_read(int fd, []char buffer, size_t len) { 97 96 char * it = buffer; 98 97 size_t count = len - 1; … … 100 99 READ: 101 100 for() { 102 int ret = cfa_re ad(fd, (void*)it, count, 0, -1`s, cancel, 0p);101 int ret = cfa_recv(fd, (void*)it, count, 0, 0); 103 102 // int ret = read(fd, (void*)it, count); 104 103 if(ret == 0 ) return [OK200, true, 0, 0]; … … 139 138 ssize_t ret; 140 139 SPLICE1: while(count > 0) { 141 ret = cfa_splice(ans_fd, &offset, pipe[1], 0p, count, sflags, 0 , -1`s, 0p, 0p);140 ret = cfa_splice(ans_fd, &offset, pipe[1], 0p, count, sflags, 0); 142 141 // ret = splice(ans_fd, &offset, pipe[1], 0p, count, sflags); 143 142 if( ret < 0 ) { … … 152 151 size_t in_pipe = ret; 153 152 SPLICE2: while(in_pipe > 0) { 154 ret = cfa_splice(pipe[0], 0p, fd, 0p, in_pipe, sflags, 0 , -1`s, 0p, 0p);153 ret = cfa_splice(pipe[0], 0p, fd, 0p, in_pipe, sflags, 0); 155 154 // ret = splice(pipe[0], 0p, fd, 0p, in_pipe, sflags); 156 155 if( ret < 0 ) {
Note: See TracChangeset
for help on using the changeset viewer.