Lines Matching defs:hsristream
467 struct http_server_istream *hsristream =
470 if (hsristream->istream.istream.blocking)
474 http_server_connection_switch_ioloop(hsristream->req->conn);
478 http_server_istream_read_any(struct http_server_istream *hsristream)
480 struct istream_private *stream = &hsristream->istream;
481 struct http_server *server = hsristream->req->server;
486 hsristream->read_status = ret;
494 struct http_server_istream *hsristream =
496 struct http_server_request *req = hsristream->req;
511 server = hsristream->req->server;
512 conn = hsristream->req->conn;
530 hsristream->read_status = 0;
532 http_server_istream_read_any, hsristream);
534 hsristream->read_status == 0) {
544 ret = hsristream->read_status;
547 hsristream->req = NULL;
557 struct http_server_istream *hsristream =
561 v_offset = hsristream->istream.parent_start_offset +
562 hsristream->istream.istream.v_offset;
563 if (hsristream->istream.parent->seekable ||
564 v_offset > hsristream->istream.parent->v_offset) {
566 i_stream_seek(hsristream->istream.parent, v_offset);
574 struct http_server_istream *hsristream;
579 hsristream = i_new(struct http_server_istream, 1);
580 hsristream->req = req;
581 hsristream->istream.max_buffer_size =
583 hsristream->istream.stream_size_passthrough = TRUE;
585 hsristream->istream.read = http_server_istream_read;
586 hsristream->istream.switch_ioloop_to = http_server_istream_switch_ioloop_to;
587 hsristream->istream.iostream.destroy = http_server_istream_destroy;
589 hsristream->istream.istream.readable_fd = FALSE;
590 hsristream->istream.istream.blocking = blocking;
591 hsristream->istream.istream.seekable = FALSE;
594 (&hsristream->istream, payload, i_stream_get_fd(payload), 0);