serf/buckets/ssl_buckets.c

156     serf_ssl_stream_t encrypt;
183     /* Status of a fatal error, returned on subsequent encrypt or decrypt
258     if (ctx->encrypt.status == SERF_ERROR_WAIT_CONN
265         ctx->encrypt.exhausted_reset = 1;
300     if (ctx->encrypt.status == SERF_ERROR_WAIT_CONN
307         ctx->encrypt.exhausted_reset = 1;
312                                          ctx->encrypt.pending->allocator);
314     serf_bucket_aggregate_append(ctx->encrypt.pending, tmp);
799     status = serf_bucket_read(ctx->encrypt.pending, bufsize, &data, len);
828                   status, ctx->encrypt.status,
832         ctx->encrypt.status = APR_SUCCESS;
833         ctx->encrypt.exhausted_reset = 0;
841         if (!ctx->encrypt.status) {
845             status = serf_bucket_read_iovec(ctx->encrypt.stream,
880                 ctx->encrypt.status = status;
898                     serf_bucket_aggregate_prepend(ctx->encrypt.stream,
909                         status = ctx->encrypt.status;
937             status = ctx->encrypt.status;
949         agg_status = serf_bucket_read_iovec(ctx->encrypt.pending, bufsize,
959             ctx->encrypt.status, *len);
968         ctx->encrypt.exhausted = ctx->encrypt.status;
969         ctx->encrypt.status = SERF_ERROR_WAIT_CONN;
1353     ssl_ctx->encrypt.stream = NULL;
1354     ssl_ctx->encrypt.stream_next = NULL;
1355     ssl_ctx->encrypt.pending = serf_bucket_aggregate_create(allocator);
1356     ssl_ctx->encrypt.status = APR_SUCCESS;
1357     serf_databuf_init(&ssl_ctx->encrypt.databuf);
1358     ssl_ctx->encrypt.databuf.read = ssl_encrypt;
1359     ssl_ctx->encrypt.databuf.read_baton = ssl_ctx;
1378     if (ssl_ctx->encrypt.pending != NULL) {
1379         serf_bucket_destroy(ssl_ctx->encrypt.pending);
1510     ctx->databuf = &ctx->ssl_ctx->encrypt.databuf;
1511     ctx->our_stream = &ctx->ssl_ctx->encrypt.stream;
1512     if (ctx->ssl_ctx->encrypt.stream == NULL) {
1515         ctx->ssl_ctx->encrypt.stream = tmp;
1524         if (ctx->ssl_ctx->encrypt.stream_next == NULL) {
1525             ctx->ssl_ctx->encrypt.stream_next = new_list;
1528             bucket_list_t *scan = ctx->ssl_ctx->encrypt.stream_next;
1818     if (ssl_ctx->encrypt.stream == *ctx->our_stream) {
1820         serf_bucket_destroy(ssl_ctx->encrypt.pending);
1823         ssl_ctx->encrypt.status = APR_SUCCESS;
1824         ssl_ctx->encrypt.databuf.status = APR_SUCCESS;
1827         if (ssl_ctx->encrypt.stream_next == NULL) {
1828             ssl_ctx->encrypt.stream = NULL;
1829             ssl_ctx->encrypt.pending = NULL;
1834             cur = ssl_ctx->encrypt.stream_next;
1835             ssl_ctx->encrypt.stream = cur->bucket;
1836             ssl_ctx->encrypt.pending =
1838             ssl_ctx->encrypt.stream_next = cur->next;