serf/buckets/ssl_buckets.c

149     serf_ssl_stream_t encrypt;
176     /* Status of a fatal error, returned on subsequent encrypt or decrypt
269     if (ctx->encrypt.status == SERF_ERROR_WAIT_CONN
276         ctx->encrypt.exhausted_reset = 1;
311     if (ctx->encrypt.status == SERF_ERROR_WAIT_CONN
318         ctx->encrypt.exhausted_reset = 1;
323                                          ctx->encrypt.pending->allocator);
325     serf_bucket_aggregate_append(ctx->encrypt.pending, tmp);
874     status = serf_bucket_read(ctx->encrypt.pending, bufsize, &data, len);
903                   status, ctx->encrypt.status,
907         ctx->encrypt.status = APR_SUCCESS;
908         ctx->encrypt.exhausted_reset = 0;
916         if (!ctx->encrypt.status) {
920             status = serf_bucket_read_iovec(ctx->encrypt.stream,
955                 ctx->encrypt.status = status;
973                     serf_bucket_aggregate_prepend(ctx->encrypt.stream,
984                         status = ctx->encrypt.status;
1012             status = ctx->encrypt.status;
1024         agg_status = serf_bucket_read_iovec(ctx->encrypt.pending, bufsize,
1034             ctx->encrypt.status, *len);
1043         ctx->encrypt.exhausted = ctx->encrypt.status;
1044         ctx->encrypt.status = SERF_ERROR_WAIT_CONN;
1441     ssl_ctx->encrypt.stream = NULL;
1442     ssl_ctx->encrypt.stream_next = NULL;
1443     ssl_ctx->encrypt.pending = serf_bucket_aggregate_create(allocator);
1444     ssl_ctx->encrypt.status = APR_SUCCESS;
1445     serf_databuf_init(&ssl_ctx->encrypt.databuf);
1446     ssl_ctx->encrypt.databuf.read = ssl_encrypt;
1447     ssl_ctx->encrypt.databuf.read_baton = ssl_ctx;
1466     if (ssl_ctx->encrypt.pending != NULL) {
1467         serf_bucket_destroy(ssl_ctx->encrypt.pending);
1599     ctx->databuf = &ctx->ssl_ctx->encrypt.databuf;
1600     ctx->our_stream = &ctx->ssl_ctx->encrypt.stream;
1601     if (ctx->ssl_ctx->encrypt.stream == NULL) {
1604         ctx->ssl_ctx->encrypt.stream = tmp;
1613         if (ctx->ssl_ctx->encrypt.stream_next == NULL) {
1614             ctx->ssl_ctx->encrypt.stream_next = new_list;
1617             bucket_list_t *scan = ctx->ssl_ctx->encrypt.stream_next;
1907     if (ssl_ctx->encrypt.stream == *ctx->our_stream) {
1909         serf_bucket_destroy(ssl_ctx->encrypt.pending);
1912         ssl_ctx->encrypt.status = APR_SUCCESS;
1913         ssl_ctx->encrypt.databuf.status = APR_SUCCESS;
1916         if (ssl_ctx->encrypt.stream_next == NULL) {
1917             ssl_ctx->encrypt.stream = NULL;
1918             ssl_ctx->encrypt.pending = NULL;
1923             cur = ssl_ctx->encrypt.stream_next;
1924             ssl_ctx->encrypt.stream = cur->bucket;
1925             ssl_ctx->encrypt.pending =
1927             ssl_ctx->encrypt.stream_next = cur->next;