Lines Matching defs:payload

247 			"sending payload for %s", fpath);
263 "failed to send blocking file payload");
268 "finished sending blocking payload for %s"
318 "Failed to read all echo payload [%s]", creq->path);
321 "Failed to write all echo payload [%s]", creq->path);
340 "finished receiving payload for %s", creq->path);
392 "failed to receive blocking echo payload");
400 "finished receiving blocking payload for %s", path);
409 "failed to send blocking echo payload");
414 "finished sending blocking payload for %s", path);
632 struct istream *payload;
657 i_stream_unref(&tcreq->payload);
675 if (tcreq->payload != NULL)
676 i_stream_switch_ioloop(tcreq->payload);
736 struct istream *payload = tcreq->payload;
744 /* read payload */
745 while ((ret=i_stream_read_more(payload, &pdata, &psize)) > 0) {
760 payload->v_offset, tcreq->file->v_offset);
770 i_stream_skip(payload, psize);
782 if (payload->stream_errno != 0) {
784 "failed to read request payload: %s",
785 i_stream_get_error(payload));
790 "payload ended prematurely "
798 /* dereference payload stream; finishes the request */
799 tcreq->payload = NULL;
801 i_stream_unref(&payload);
858 if (resp->payload == NULL) {
861 "no payload for %s [%u]",
871 i_stream_ref(resp->payload);
872 tcreq->payload = resp->payload;
875 struct istream *payload = resp->payload;
876 tcreq->payload = i_stream_create_limit
877 (payload, read_client_partial);
883 tcreq->io = io_add_istream(tcreq->payload,
973 struct istream *payload = tcreq->payload;
981 /* read payload */
982 while ((ret=i_stream_read_more(payload, &pdata, &psize)) > 0) {
997 payload->v_offset, tcreq->file->v_offset);
1007 i_stream_skip(payload, psize);
1019 if (payload->stream_errno != 0) {
1021 "failed to read request payload: %s",
1022 i_stream_get_error(payload));
1027 "payload ended prematurely "
1035 /* dereference payload stream; finishes the request */
1036 tcreq->payload = NULL;
1038 i_stream_unref(&payload);
1093 if (resp->payload == NULL) {
1097 "no payload for %s [%u]",
1108 i_stream_ref(resp->payload);
1109 tcreq->payload = resp->payload;
1110 tcreq->io = io_add_istream(resp->payload,
1445 test_begin("http payload download (server non-blocking)");
1459 test_begin("http payload download (server blocking)");
1472 test_begin("http payload echo (server non-blocking)");
1483 test_begin("http payload echo (server non-blocking; low-level)");
1494 test_begin("http payload echo (server non-blocking; handler)");
1508 test_begin("http payload echo (server blocking)");
1521 test_begin("http payload echo (server non-blocking; 100-continue)");
1532 test_begin("http payload echo (server non-blocking; 100-continue; low-level)");
1543 test_begin("http payload echo (server non-blocking; 100-continue; handler)");
1557 test_begin("http payload echo (server blocking; 100-continue)");
1570 test_begin("http payload echo (server non-blocking; partial short)");
1580 test_begin("http payload echo (server non-blocking; partial long)");
1587 test_begin("http payload echo (server non-blocking; partial short; low-level)");
1597 test_begin("http payload echo (server non-blocking; partial long; low-level)");
1604 test_begin("http payload echo (server non-blocking; partial short; handler)");
1614 test_begin("http payload echo (server non-blocking; partial long; handler)");
1624 test_begin("http payload echo (server blocking; partial short)");
1633 test_begin("http payload echo (server blocking; partial long)");
1643 test_begin("http payload download (client partial)");
1654 test_begin("http payload download (client partial long)");
1668 test_begin("http payload echo (client nested ioloop)");
1681 test_begin("http payload download (server non-blocking; client shared)");
1695 test_begin("http payload download (server blocking; client shared)");
1708 test_begin("http payload echo (server non-blocking; client shared)");
1722 test_begin("http payload echo (server blocking; client shared)");
1735 test_begin("http payload echo (server non-blocking; client global)");