latex
/
uv_link_t
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'netfoundry/master'

This commit is contained in:
latex 2023-02-01 15:19:24 +01:00
parent c7b869f661 07105c196d
commit 8b90c9e2ca
2 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/uv_link_source_t.c
View File

@ -143,7 +143,11 @@ static void uv_link_source_close_cb(uv_handle_t* handle) {
source = handle->data;
source->stream = NULL;
source->close_cb(source->close_source);
if (source->close_cb) {
source->close_cb(source->close_source);
}
source->close_cb = NULL;
source->close_source = NULL;
}
@ -153,10 +157,15 @@ static void uv_link_source_close(uv_link_t* link, uv_link_t* source,
s = (uv_link_source_t*) link;
s->close_cb = cb;
s->close_source = source;
uv_close((uv_handle_t*) s->stream, uv_link_source_close_cb);
if (s->stream) {
if (!uv_is_closing((const uv_handle_t *) s->stream)) {
s->close_cb = cb;
s->close_source = source;
uv_close((uv_handle_t *) s->stream, uv_link_source_close_cb);
}
} else {
cb(source);
}
}

3
src/uv_link_t.c
View File

@ -101,7 +101,8 @@ int uv_link_read_start(uv_link_t* link) {
int uv_link_read_stop(uv_link_t* link) {
if (link == NULL)
return uv_link_error(link, UV_EFAULT);
CLOSE_WRAP(link->methods->read_stop(link));
if (NULL != link->methods->read_stop)
CLOSE_WRAP(link->methods->read_stop(link));
}