| 154 // read request |
154 // read request |
| 155 netbuf *buf = malloc(sizeof(netbuf)); |
155 netbuf *buf = malloc(sizeof(netbuf)); |
| 156 buf->rdtimeout = 120; |
156 buf->rdtimeout = 120; |
| 157 buf->pos = 0; |
157 buf->pos = 0; |
| 158 buf->cursize = 0; |
158 buf->cursize = 0; |
| 159 buf->maxsize = 2048; |
159 buf->maxsize = 16384; |
| 160 buf->sd = &conn->fd; |
160 buf->sd = &conn->fd; |
| 161 buf->inbuf = malloc(2048); |
161 buf->inbuf = malloc(16384); |
| 162 buf->errmsg = NULL; |
162 buf->errmsg = NULL; |
| 163 |
163 |
| 164 request->netbuf = buf; |
164 request->netbuf = buf; |
| 165 |
165 |
| 166 HttpParser *parser = http_parser_new(request); |
166 HttpParser *parser = http_parser_new(request); |
| 431 int r; |
431 int r; |
| 432 r = conn->read( |
432 r = conn->read( |
| 433 conn, |
433 conn, |
| 434 buf->inbuf + buf->pos, |
434 buf->inbuf + buf->pos, |
| 435 buf->maxsize - buf->pos); |
435 buf->maxsize - buf->pos); |
| 436 |
436 |
| 437 log_ereport(LOG_DEBUG, "trace reqid: %016llx request input | r=%d", (unsigned long long int)conn->id, r); |
437 log_ereport(LOG_DEBUG, "trace reqid: %016llx request input | r=%d", (unsigned long long int)conn->id, r); |
| 438 |
438 |
| 439 if(r <= 0) { |
439 if(r <= 0) { |
| 440 if(conn->ssl) { |
440 if(conn->ssl) { |
| 441 // SSL specific error handling |
441 // SSL specific error handling |