crypto/ocsp/ocsp_ht.c

119     OCSP_REQ_CTX *rctx;
120     rctx = OPENSSL_malloc(sizeof(OCSP_REQ_CTX));
121     if (!rctx)
123     rctx->state = OHS_ERROR;
124     rctx->max_resp_len = OCSP_MAX_RESP_LENGTH;
125     rctx->mem = BIO_new(BIO_s_mem());
126     rctx->io = io;
127     rctx->asn1_len = 0;
129         rctx->iobuflen = maxline;
131         rctx->iobuflen = OCSP_MAX_LINE_LEN;
132     rctx->iobuf = OPENSSL_malloc(rctx->iobuflen);
133     if (!rctx->iobuf || !rctx->mem) {
134         OCSP_REQ_CTX_free(rctx);
137     return rctx;
140 void OCSP_REQ_CTX_free(OCSP_REQ_CTX *rctx)
142     if (rctx->mem)
143         BIO_free(rctx->mem);
144     if (rctx->iobuf)
145         OPENSSL_free(rctx->iobuf);
146     OPENSSL_free(rctx);
149 BIO *OCSP_REQ_CTX_get0_mem_bio(OCSP_REQ_CTX *rctx)
151     return rctx->mem;
154 void OCSP_set_max_response_length(OCSP_REQ_CTX *rctx, unsigned long len)
157         rctx->max_resp_len = OCSP_MAX_RESP_LENGTH;
159         rctx->max_resp_len = len;
162 int OCSP_REQ_CTX_i2d(OCSP_REQ_CTX *rctx, const ASN1_ITEM *it, ASN1_VALUE *val)
168     if (BIO_printf(rctx->mem, req_hdr, reqlen) <= 0)
170     if (ASN1_item_i2d_bio(it, rctx->mem, val) <= 0)
172     rctx->state = OHS_ASN1_WRITE_INIT;
176 int OCSP_REQ_CTX_nbio_d2i(OCSP_REQ_CTX *rctx,
182     rv = OCSP_REQ_CTX_nbio(rctx);
186     len = BIO_get_mem_data(rctx->mem, &p);
189         rctx->state = OHS_ERROR;
195 int OCSP_REQ_CTX_http(OCSP_REQ_CTX *rctx, const char *op, const char *path)
202     if (BIO_printf(rctx->mem, http_hdr, op, path) <= 0)
204     rctx->state = OHS_HTTP_HEADER;
208 int OCSP_REQ_CTX_set1_req(OCSP_REQ_CTX *rctx, OCSP_REQUEST *req)
210     return OCSP_REQ_CTX_i2d(rctx, ASN1_ITEM_rptr(OCSP_REQUEST),
214 int OCSP_REQ_CTX_add1_header(OCSP_REQ_CTX *rctx,
219     if (BIO_puts(rctx->mem, name) <= 0)
222         if (BIO_write(rctx->mem, ": ", 2) != 2)
224         if (BIO_puts(rctx->mem, value) <= 0)
227     if (BIO_write(rctx->mem, "\r\n", 2) != 2)
229     rctx->state = OHS_HTTP_HEADER;
237     OCSP_REQ_CTX *rctx = NULL;
238     rctx = OCSP_REQ_CTX_new(io, maxline);
239     if (!rctx)
242     if (!OCSP_REQ_CTX_http(rctx, "POST", path))
245     if (req && !OCSP_REQ_CTX_set1_req(rctx, req))
248     return rctx;
251     OCSP_REQ_CTX_free(rctx);
326 int OCSP_REQ_CTX_nbio(OCSP_REQ_CTX *rctx)
331     if (!(rctx->state & OHS_NOREAD)) {
332         n = BIO_read(rctx->io, rctx->iobuf, rctx->iobuflen);
335             if (BIO_should_retry(rctx->io))
342         if (BIO_write(rctx->mem, rctx->iobuf, n) != n)
346     switch (rctx->state) {
349         if (BIO_write(rctx->mem, "\r\n", 2) != 2) {
350             rctx->state = OHS_ERROR;
353         rctx->state = OHS_ASN1_WRITE_INIT;
356         rctx->asn1_len = BIO_get_mem_data(rctx->mem, NULL);
357         rctx->state = OHS_ASN1_WRITE;
360         n = BIO_get_mem_data(rctx->mem, &p);
362         i = BIO_write(rctx->io, p + (n - rctx->asn1_len), rctx->asn1_len);
365             if (BIO_should_retry(rctx->io))
367             rctx->state = OHS_ERROR;
371         rctx->asn1_len -= i;
373         if (rctx->asn1_len > 0)
376         rctx->state = OHS_ASN1_FLUSH;
378         (void)BIO_reset(rctx->mem);
382         i = BIO_flush(rctx->io);
385             rctx->state = OHS_FIRSTLINE;
389         if (BIO_should_retry(rctx->io))
392         rctx->state = OHS_ERROR;
409         n = BIO_get_mem_data(rctx->mem, &p);
411             if (n >= rctx->iobuflen) {
412                 rctx->state = OHS_ERROR;
417         n = BIO_gets(rctx->mem, (char *)rctx->iobuf, rctx->iobuflen);
420             if (BIO_should_retry(rctx->mem))
422             rctx->state = OHS_ERROR;
427         if (n == rctx->iobuflen) {
428             rctx->state = OHS_ERROR;
433         if (rctx->state == OHS_FIRSTLINE) {
434             if (parse_http_line1((char *)rctx->iobuf)) {
435                 rctx->state = OHS_HEADERS;
438                 rctx->state = OHS_ERROR;
443             for (p = rctx->iobuf; *p; p++) {
450             rctx->state = OHS_ASN1_HEADER;
462         n = BIO_get_mem_data(rctx->mem, &p);
468             rctx->state = OHS_ERROR;
483                 rctx->state = OHS_ERROR;
487             rctx->asn1_len = 0;
489                 rctx->asn1_len <<= 8;
490                 rctx->asn1_len |= *p++;
493             if (rctx->asn1_len > rctx->max_resp_len) {
494                 rctx->state = OHS_ERROR;
498             rctx->asn1_len += n + 2;
500             rctx->asn1_len = *p + 2;
502         rctx->state = OHS_ASN1_CONTENT;
507         n = BIO_get_mem_data(rctx->mem, NULL);
508         if (n < (int)rctx->asn1_len)
511         rctx->state = OHS_DONE;
525 int OCSP_sendreq_nbio(OCSP_RESPONSE **presp, OCSP_REQ_CTX *rctx)
527     return OCSP_REQ_CTX_nbio_d2i(rctx,