static int qc_wait_for_default_xso_for_read(QCTX *ctx, int peek);
static void qctx_lock(QCTX *qctx);
static void qctx_unlock(QCTX *qctx);
-static void quic_lock_for_io(QCTX *ctx);
+static void qctx_lock_for_io(QCTX *ctx);
static int quic_do_handshake(QCTX *ctx);
static void qc_update_reject_policy(QUIC_CONNECTION *qc);
static void qc_touch_default_xso(QUIC_CONNECTION *qc);
return 0;
if (in_io)
- quic_lock_for_io(ctx);
+ qctx_lock_for_io(ctx);
else
qctx_lock(ctx);
#endif
}
-static void quic_lock_for_io(QCTX *ctx)
+static void qctx_lock_for_io(QCTX *ctx)
{
qctx_lock(ctx);
ctx->in_io = 1;
if (!expect_quic(s, &ctx))
return 0;
- quic_lock_for_io(&ctx);
+ qctx_lock_for_io(&ctx);
ret = quic_do_handshake(&ctx);
qctx_unlock(&ctx);
if (!expect_quic(s, &ctx))
return 0;
- quic_lock_for_io(&ctx);
+ qctx_lock_for_io(&ctx);
if (!quic_mutation_allowed(ctx.qc, /*req_active=*/0)) {
ret = QUIC_RAISE_NON_NORMAL_ERROR(&ctx, SSL_R_PROTOCOL_IS_SHUTDOWN, NULL);
int ret = 0;
uint64_t value_out = 0, value_in;
- quic_lock(ctx->qc);
+ qctx_lock(ctx);
switch (class_) {
case SSL_VALUE_CLASS_FEATURE_REQUEST:
ret = 1;
err:
- quic_unlock(ctx->qc);
+ qctx_unlock(ctx);
if (ret && p_value_out != NULL)
*p_value_out = value_out;
return 0;
}
- quic_lock(ctx->qc);
+ qctx_lock(ctx);
*value = is_remote
? ossl_quic_channel_get_remote_stream_count_avail(ctx->qc->ch, is_uni)
: ossl_quic_channel_get_local_stream_count_avail(ctx->qc->ch, is_uni);
ret = 1;
- quic_unlock(ctx->qc);
+ qctx_unlock(ctx);
return ret;
}
int ret = 0;
uint64_t value_out = 0;
- quic_lock(ctx->qc);
+ qctx_lock(ctx);
if (class_ != SSL_VALUE_CLASS_GENERIC) {
QUIC_RAISE_NON_NORMAL_ERROR(ctx, SSL_R_UNSUPPORTED_CONFIG_VALUE_CLASS,
ret = 1;
err:
- quic_unlock(ctx->qc);
+ qctx_unlock(ctx);
if (ret && p_value_out != NULL)
*p_value_out = value_out;
int ret = 0;
size_t value = 0;
- quic_lock(ctx->qc);
+ qctx_lock(ctx);
if (class_ != SSL_VALUE_CLASS_GENERIC) {
QUIC_RAISE_NON_NORMAL_ERROR(ctx, SSL_R_UNSUPPORTED_CONFIG_VALUE_CLASS,
ret = 1;
err:
- quic_unlock(ctx->qc);
+ qctx_unlock(ctx);
*p_value_out = (uint64_t)value;
return ret;
}
if (!expect_quic(ssl, &ctx))
return 0;
- quic_lock(ctx.qc);
+ qctx_lock(&ctx);
if (!ctx.qc->started) {
/* We can only try to write on non-started connection. */
}
end:
- quic_unlock(ctx.qc);
+ qctx_unlock(&ctx);
*p_revents = revents;
return 1;
}