Searched defs:payload (Results 1 - 20 of 20) sorted by relevance

/dovecot/src/lib-oauth2/
H A Doauth2-refresh.c86 if (response->payload == NULL) {
91 req->is = response->payload;
143 string_t *payload = str_new(req->pool, 128); local
144 str_append(payload, "client_secret=");
145 http_url_escape_param(payload, req->set->client_secret);
146 str_append(payload, "&grant_type=refresh_token&refresh_token=");
147 http_url_escape_param(payload, input->token);
148 str_append(payload, "&client_id=");
149 http_url_escape_param(payload, req->set->client_id);
151 struct istream *is = i_stream_create_from_string(payload);
[all...]
/dovecot/src/lib-http/
H A Dhttp-response.h27 struct istream *payload; member in struct:http_response
H A Dhttp-message-parser.h16 HTTP_MESSAGE_PARSE_ERROR_PAYLOAD_TOO_LARGE /* message payload is too large
56 struct istream *payload; member in struct:http_message_parser
H A Dhttp-request.h44 struct istream *payload; member in struct:http_request
H A Dtest-http-client.c21 struct istream *payload; member in struct:http_test_request
33 /* read payload */
34 while ((ret=i_stream_read_more(req->payload, &data, &size)) > 0) {
39 i_stream_skip(req->payload, size);
46 if (req->payload->stream_errno != 0) {
48 i_stream_get_error(req->payload));
52 i_stream_unref(&req->payload);
66 /* payload (if any) is skipped implicitly */
72 if (response->payload == NULL) {
77 i_info("DEBUG: REQUEST: Got payload");
[all...]
H A Dtest-http-request-parser.c30 const char *payload; member in struct:http_request_valid_parse_test
105 .payload = "Content!\r\n"
204 const char *request_text, *payload, *error; local
216 payload = NULL;
227 if (request.payload != NULL) {
230 test_out("payload receive",
231 o_stream_send_istream(output, request.payload) == OSTREAM_SEND_ISTREAM_RESULT_FINISHED);
233 payload = str_c(payload_buffer);
235 payload = NULL;
304 if (payload
[all...]
H A Dtest-http-response-parser.c19 const char *payload; member in struct:valid_parse_test_response
35 .payload = "This is a piece of stupid text.\r\n"
42 .payload = "This is a piece of stupid text.\r\n"
45 .payload = "This is a piece of even more stupid text.\r\n"
52 .payload = "Frop!"
59 .payload = "Invalid date header"
66 .payload = "Duplicate headers"
175 const char *input_text, *payload, *error; local
189 payload = NULL;
201 if (presponse.payload !
[all...]
H A Dhttp-server-connection.c209 http_server_connection_debug(conn, "Request payload stream destroyed");
212 the payload. make sure here that it's switched back. */
234 "Client sent invalid request payload");
242 /* resource stopped reading payload; update state */
256 /* response submitted, but not all payload is necessarily read */
312 struct istream *payload; local
325 if (req->req.payload != NULL) {
327 actual payload stream. */
328 conn->incoming_payload = req->req.payload =
329 i_stream_create_timeout(req->req.payload,
[all...]
H A Dhttp-server-request.c575 struct istream *payload = req->req.payload; local
582 payload->real_stream->max_buffer_size;
594 (&hsristream->istream, payload, i_stream_get_fd(payload), 0);
595 i_stream_unref(&req->req.payload);
736 i_assert(req->req.payload != NULL);
H A Dtest-http-server-errors.c189 * Hanging request payload
239 i_debug("test server: got more payload");
250 i_debug("test server: failed to read payload: %s",
316 test_begin("hanging request payload");
324 * Hanging response payload
337 "Complete payload\r\n");
372 string_t *payload; local
389 payload = t_str_new(204800);
391 str_append(payload,
397 (resp, str_data(payload), str_le
[all...]
H A Dhttp-client-connection.c587 "Expected 100-continue response timed out; sending payload anyway");
735 "Response payload stream destroyed (%u ms after initial response)",
739 the payload. make sure here that it's switched back. */
772 struct istream *payload; local
780 payload = conn->incoming_payload;
781 if (payload == NULL) {
782 /* payload already gone */
786 /* destroy the payload, so that the timeout istream is closed */
787 i_stream_ref(payload);
788 i_stream_destroy(&payload);
811 struct istream *payload; local
[all...]
H A Dtest-http-payload.c247 "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 fo
632 struct istream *payload; member in struct:test_client_request
736 struct istream *payload = tcreq->payload; local
875 struct istream *payload = resp->payload; local
973 struct istream *payload = tcreq->payload; local
[all...]
H A Dtest-http-client-errors.c925 * Broken payload
977 "GET", net_ip2addr(&bind_ip), "/broken-payload.txt",
995 test_begin("broken payload");
1081 static const char payload[] = local
1082 "This is a useless payload that only serves as a means to give the "
1083 "server the opportunity to close the connection before the payload "
1095 input = i_stream_create_from_data(payload, sizeof(payload)-1);
1213 static const char payload[] = local
1214 "This is a useless payload tha
1343 static const char payload[] = local
1451 string_t *payload; local
1963 static const char *payload = "This a test payload!"; local
[all...]
/dovecot/src/plugins/fts/
H A Dfts-parser-tika.c29 struct istream *payload; member in struct:tika_fts_parser
90 i_assert(parser->payload == NULL);
95 if (response->payload == NULL)
96 parser->payload = i_stream_create_from_data("", 0);
98 i_stream_ref(response->payload);
99 parser->payload = response->payload;
110 parser->payload = i_stream_create_from_data("", 0);
124 parser->payload = i_stream_create_from_data("", 0);
191 if (parser->payload
[all...]
/dovecot/src/lib-dcrypt/
H A Dtest-stream.c184 unsigned char payload[IO_BLOCK_SIZE]; local
187 random_fill(payload, IO_BLOCK_SIZE);
189 buffer_t *buf = buffer_create_dynamic(default_pool, sizeof(payload));
192 o_stream_nsend(os_2, payload, sizeof(payload));
216 test_assert_idx(pos + siz <= sizeof(payload), pos);
217 if (pos + siz > sizeof(payload)) break;
218 test_assert_idx(siz == 0 || memcmp(ptr, payload + pos, siz) == 0, pos);
235 unsigned char payload[1]; local
238 random_fill(payload,
328 unsigned char payload[IO_BLOCK_SIZE*10]; local
381 unsigned char payload[1]; local
[all...]
/dovecot/src/plugins/push-notification/
H A Dpush-notification-driver-ox.c337 struct istream *payload; local
395 payload = i_stream_create_from_data(str_data(str), str_len(str));
396 i_stream_add_destroy_callback(payload, str_free_i, str);
397 http_client_request_set_payload(http_req, payload, FALSE);
400 i_stream_unref(&payload);
/dovecot/src/plugins/fts-solr/
H A Dsolr-connection.c70 struct istream *payload; member in struct:solr_connection
391 /* read payload */
392 while ((ret = i_stream_read_more(conn->payload, &data, &size)) > 0) {
394 i_stream_skip(conn->payload, size);
400 if (conn->payload->stream_errno != 0) {
401 i_error("fts_solr: failed to read payload from HTTP server: %m");
405 i_stream_unref(&conn->payload);
420 if (response->payload == NULL) {
421 i_error("fts_solr: Lookup failed: Empty response payload");
426 i_stream_ref(response->payload);
[all...]
/dovecot/src/auth/
H A Dauth-policy.c49 struct istream *payload; member in struct:policy_lookup_ctx
277 if (ret == 0 && !context->payload->eof)
284 if (context->payload->stream_errno != 0) {
287 i_stream_get_error(context->payload));
288 } else if (ret == 0 && context->payload->eof) {
302 i_stream_unref(&context->payload);
341 context->payload = response->payload;
352 if (response->payload == NULL) {
362 i_stream_ref(response->payload);
[all...]
/dovecot/src/lib-smtp/
H A Dtest-smtp-payload.c154 struct istream *payload, *file; member in struct:client_transaction
165 struct istream *payload = ctrans->payload; local
171 i_debug("test server: read more payload for [%s]",
175 /* read payload */
176 while ((ret=i_stream_read_more(payload, &pdata, &psize)) > 0) {
191 ctrans->path, payload->v_offset,
203 i_stream_skip(payload, psize);
217 if (payload->stream_errno != 0) {
219 "failed to read transaction payload
646 struct istream *fstream, *payload; local
[all...]
/dovecot/src/doveadm/
H A Dclient-connection-http.c894 struct istream *payload = NULL; local
906 payload = iostream_temp_finish(&req->output,
914 if (payload != NULL) {
915 http_server_response_set_payload(http_resp, payload);
916 i_stream_unref(&payload);
1130 req->input = http_req->payload;

Completed in 5399 milliseconds