Lines Matching refs:args
163 va_list args; in quic_raise_non_normal_error() local
175 va_start(args, fmt); in quic_raise_non_normal_error()
176 ERR_vset_error(ERR_LIB_SSL, reason, fmt, args); in quic_raise_non_normal_error()
177 va_end(args); in quic_raise_non_normal_error()
1241 const SSL_SHUTDOWN_EX_ARGS *args, in ossl_quic_conn_shutdown() argument
1318 args != NULL ? args->quic_error_code : 0, in ossl_quic_conn_shutdown()
1319 args != NULL ? args->quic_reason : NULL); in ossl_quic_conn_shutdown()
1473 struct quic_handshake_wait_args *args = arg; in quic_handshake_wait() local
1475 if (!quic_mutation_allowed(args->qc, /*req_active=*/1)) in quic_handshake_wait()
1478 if (ossl_quic_channel_is_handshake_complete(args->qc->ch)) in quic_handshake_wait()
1481 if (tls_wants_non_io_retry(args->qc)) in quic_handshake_wait()
1713 struct quic_handshake_wait_args args; in quic_do_handshake() local
1715 args.qc = qc; in quic_do_handshake()
1717 ret = block_until_pred(qc, quic_handshake_wait, &args, 0); in quic_do_handshake()
1835 struct quic_wait_for_stream_args *args = arg; in quic_wait_for_stream() local
1837 if (!quic_mutation_allowed(args->qc, /*req_active=*/1)) { in quic_wait_for_stream()
1839 QUIC_RAISE_NON_NORMAL_ERROR(args->ctx, SSL_R_PROTOCOL_IS_SHUTDOWN, NULL); in quic_wait_for_stream()
1843 args->qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(args->qc->ch), in quic_wait_for_stream()
1844 args->expect_id | QUIC_STREAM_DIR_BIDI); in quic_wait_for_stream()
1845 if (args->qs == NULL) in quic_wait_for_stream()
1846 args->qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(args->qc->ch), in quic_wait_for_stream()
1847 args->expect_id | QUIC_STREAM_DIR_UNI); in quic_wait_for_stream()
1849 if (args->qs != NULL) in quic_wait_for_stream()
1985 struct quic_new_stream_wait_args *args = arg; in quic_new_stream_wait() local
1986 QUIC_CONNECTION *qc = args->qc; in quic_new_stream_wait()
1991 if (ossl_quic_channel_is_new_local_stream_admissible(qc->ch, args->is_uni)) in quic_new_stream_wait()
2018 struct quic_new_stream_wait_args args; in quic_conn_stream_new() local
2029 args.qc = qc; in quic_conn_stream_new()
2030 args.is_uni = is_uni; in quic_conn_stream_new()
2033 ret = block_until_pred(ctx->qc, quic_new_stream_wait, &args, 0); in quic_conn_stream_new()
2269 struct quic_write_again_args *args = arg; in quic_write_again() local
2272 if (!quic_mutation_allowed(args->xso->conn, /*req_active=*/1)) in quic_write_again()
2276 if (!quic_validate_for_write(args->xso, &args->err)) in quic_write_again()
2283 args->err = ERR_R_INTERNAL_ERROR; in quic_write_again()
2284 if (!xso_sstream_append(args->xso, args->buf, args->len, &actual_written)) in quic_write_again()
2287 quic_post_write(args->xso, actual_written > 0, in quic_write_again()
2288 args->len == actual_written, args->flags, 0); in quic_write_again()
2290 args->buf += actual_written; in quic_write_again()
2291 args->len -= actual_written; in quic_write_again()
2292 args->total_written += actual_written; in quic_write_again()
2294 if (args->len == 0) in quic_write_again()
2308 struct quic_write_again_args args; in quic_write_blocking() local
2335 args.xso = xso; in quic_write_blocking()
2336 args.buf = (const unsigned char *)buf + actual_written; in quic_write_blocking()
2337 args.len = len - actual_written; in quic_write_blocking()
2338 args.total_written = 0; in quic_write_blocking()
2339 args.err = ERR_R_INTERNAL_ERROR; in quic_write_blocking()
2340 args.flags = flags; in quic_write_blocking()
2342 res = block_until_pred(xso->conn, quic_write_again, &args, 0); in quic_write_blocking()
2347 return QUIC_RAISE_NON_NORMAL_ERROR(ctx, args.err, NULL); in quic_write_blocking()
2357 *written += args.total_written; in quic_write_blocking()
2736 struct quic_read_again_args *args = arg; in quic_read_again() local
2738 if (!quic_mutation_allowed(args->ctx->qc, /*req_active=*/1)) { in quic_read_again()
2740 QUIC_RAISE_NON_NORMAL_ERROR(args->ctx, SSL_R_PROTOCOL_IS_SHUTDOWN, NULL); in quic_read_again()
2744 if (!quic_read_actual(args->ctx, args->stream, in quic_read_again()
2745 args->buf, args->len, args->bytes_read, in quic_read_again()
2746 args->peek)) in quic_read_again()
2749 if (*args->bytes_read > 0) in quic_read_again()
2761 struct quic_read_again_args args; in quic_read() local
2814 args.ctx = &ctx; in quic_read()
2815 args.stream = ctx.xso->stream; in quic_read()
2816 args.buf = buf; in quic_read()
2817 args.len = len; in quic_read()
2818 args.bytes_read = bytes_read; in quic_read()
2819 args.peek = peek; in quic_read()
2821 res = block_until_pred(ctx.qc, quic_read_again, &args, 0); in quic_read()
3547 struct wait_for_incoming_stream_args *args = arg; in wait_for_incoming_stream() local
3548 QUIC_CONNECTION *qc = args->ctx->qc; in wait_for_incoming_stream()
3553 QUIC_RAISE_NON_NORMAL_ERROR(args->ctx, SSL_R_PROTOCOL_IS_SHUTDOWN, NULL); in wait_for_incoming_stream()
3557 args->qs = ossl_quic_stream_map_peek_accept_queue(qsm); in wait_for_incoming_stream()
3558 if (args->qs != NULL) in wait_for_incoming_stream()
3592 struct wait_for_incoming_stream_args args; in ossl_quic_accept_stream() local
3594 args.ctx = &ctx; in ossl_quic_accept_stream()
3595 args.qs = NULL; in ossl_quic_accept_stream()
3597 ret = block_until_pred(ctx.qc, wait_for_incoming_stream, &args, 0); in ossl_quic_accept_stream()
3601 } else if (ret < 0 || args.qs == NULL) { in ossl_quic_accept_stream()
3605 qs = args.qs; in ossl_quic_accept_stream()
3654 const SSL_STREAM_RESET_ARGS *args, in ossl_quic_stream_reset() argument
3668 error_code = (args != NULL ? args->quic_error_code : 0); in ossl_quic_stream_reset()
