Skip to content

Commit

Permalink
amend merge
Browse files Browse the repository at this point in the history
  • Loading branch information
kazuho committed Jan 14, 2025
1 parent 02c3e4e commit e940034
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 8 deletions.
4 changes: 2 additions & 2 deletions include/quicly.h
Original file line number Diff line number Diff line change
Expand Up @@ -1441,8 +1441,8 @@ extern const quicly_stream_callbacks_t quicly_stream_noop_callbacks;
}); \
} while (0)

int quicly_qos_send(quicly_conn_t *conn, void *buf, size_t *bufsize);
int quicly_qos_receive(quicly_conn_t *conn, const void *src, size_t *len);
quicly_error_t quicly_qos_send(quicly_conn_t *conn, void *buf, size_t *bufsize);
quicly_error_t quicly_qos_receive(quicly_conn_t *conn, const void *src, size_t *len);
quicly_conn_t *quicly_qos_new(quicly_context_t *ctx, int is_client, void *appdata);

/* inline definitions */
Expand Down
13 changes: 7 additions & 6 deletions lib/quicly.c
Original file line number Diff line number Diff line change
Expand Up @@ -7932,11 +7932,11 @@ void quicly__debug_printf(quicly_conn_t *conn, const char *function, int line, c
}
}

static int emit_qs_transport_parameters(quicly_conn_t *conn, quicly_send_context_t *s)
static quicly_error_t emit_qs_transport_parameters(quicly_conn_t *conn, quicly_send_context_t *s)
{
quicly_sent_t *sent;
ptls_buffer_t buf;
int ret;
quicly_error_t ret;

if ((ret = allocate_ack_eliciting_frame(conn, s, 100, &sent, NULL)) != 0)
return ret;
Expand All @@ -7956,10 +7956,10 @@ static int emit_qs_transport_parameters(quicly_conn_t *conn, quicly_send_context
return ret;
}

int quicly_qos_send(quicly_conn_t *conn, void *buf, size_t *bufsize)
quicly_error_t quicly_qos_send(quicly_conn_t *conn, void *buf, size_t *bufsize)
{
quicly_send_context_t s = {.dst = buf, .dst_end = (uint8_t *)buf + *bufsize, .max_datagrams = 1};
int ret;
quicly_error_t ret;

lock_now(conn, 0);

Expand All @@ -7986,12 +7986,13 @@ int quicly_qos_send(quicly_conn_t *conn, void *buf, size_t *bufsize)
return ret;
}

int quicly_qos_receive(quicly_conn_t *conn, const void *src, size_t *len)
quicly_error_t quicly_qos_receive(quicly_conn_t *conn, const void *src, size_t *len)
{
size_t epoch = conn->super.stats.num_frames_received.qs_transport_parameters == 0 ? QUICLY_EPOCH_ON_STREAMS_TP
: QUICLY_EPOCH_ON_STREAMS_OTHER;
uint64_t offending_frame_type = QUICLY_FRAME_TYPE_PADDING;
int is_ack_only, is_probe_only, ret = 0;
int is_ack_only, is_probe_only;
quicly_error_t ret = 0;

lock_now(conn, 0);

Expand Down

0 comments on commit e940034

Please sign in to comment.