comparison: src/server/daemon/sessionhandler.c
src/server/daemon/sessionhandler.c
- changeset 616
- 7a0a364a1d67
- parent 561
- e1c92c126557
- child 617
- 01228719b3ce
equal
deleted
inserted
replaced
| 615:1ffc6fce045d | 616:7a0a364a1d67 |
|---|---|
| 244 Connection *conn = io->request->connection; | 244 Connection *conn = io->request->connection; |
| 245 | 245 |
| 246 if(ev_pollin(h, conn->fd, io->io_event) != 0) { | 246 if(ev_pollin(h, conn->fd, io->io_event) != 0) { |
| 247 // TODO: ev_pollin should log, intercept some errors here | 247 // TODO: ev_pollin should log, intercept some errors here |
| 248 log_ereport(LOG_FAILURE, "Cannot enqueue connection"); | 248 log_ereport(LOG_FAILURE, "Cannot enqueue connection"); |
| 249 evt_request_error(h, event); | 249 event->finish = evt_request_error; |
| 250 } else { | 250 } else { |
| 251 // add request timeout | 251 // add request timeout |
| 252 io->watch.intdata = 1; | 252 io->watch.intdata = 1; |
| 253 io->watch.created = time(NULL); | 253 io->watch.created = time(NULL); |
| 254 io->watch.expire = io->watch.created + 240; // TODO: config | 254 io->watch.expire = io->watch.created + 240; // TODO: config |
| 577 | 577 |
| 578 http_request_cleanup(request); | 578 http_request_cleanup(request); |
| 579 http_parser_free(parser); | 579 http_parser_free(parser); |
| 580 | 580 |
| 581 free(io); | 581 free(io); |
| 582 free(event); | 582 free(event); // TODO: is this safe?? |
| 583 log_ereport(LOG_DEBUG, "trace reqid: %016llx free event", (unsigned long long int)reqid); | 583 log_ereport(LOG_DEBUG, "trace reqid: %016llx free event", (unsigned long long int)reqid); |
| 584 | 584 |
| 585 return 0; | 585 return 0; |
| 586 } | 586 } |
| 587 | 587 |
