Skip to content

Commit

Permalink
stream->err -> stream->error
Browse files Browse the repository at this point in the history
  • Loading branch information
kasperisager committed Sep 22, 2023
1 parent d802a6b commit 9f02eab
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion include/udx.h
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,7 @@ struct udx_stream_s {
int recovery;
int deferred_ack;
int pending_closes;
int err; // in case of error on close
int error; // in case of error on close

bool reordering_seen;
int retransmitting;
Expand Down
6 changes: 3 additions & 3 deletions src/udx.c
Original file line number Diff line number Diff line change
Expand Up @@ -161,7 +161,7 @@ trigger_stream_close (udx_stream_t *stream) {
if (--stream->pending_closes) return;

if (stream->on_close != NULL) {
stream->on_close(stream, stream->err);
stream->on_close(stream, stream->error);
}

ref_dec(stream->udx);
Expand Down Expand Up @@ -800,7 +800,7 @@ close_maybe (udx_stream_t *stream, int err) {
udx__fifo_destroy(&stream->unordered);
udx__fifo_destroy(&stream->write_queue);

stream->err = err;
stream->error = err;

stream->pending_closes++;
uv_close((uv_handle_t *) &stream->mtu_raise_timer, on_uv_stream_handle_close);
Expand Down Expand Up @@ -1722,7 +1722,7 @@ udx_stream_init (udx_t *udx, udx_stream_t *handle, uint32_t local_id, udx_stream

handle->deferred_ack = 0;
handle->pending_closes = 0;
handle->err = 0;
handle->error = 0;

handle->pkts_waiting = 0;
handle->pkts_inflight = 0;
Expand Down

0 comments on commit 9f02eab

Please sign in to comment.