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

src: more experiments

This commit is contained in:
Fedor Indutny 2016-06-03 13:06:06 -04:00
parent 1c8f4ad097
commit 106064e396
2 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
include/uv_link_t.h
View File

@ -66,7 +66,9 @@ struct uv_link_methods_s {
/* Private, used for close */ \
int close_depth; \
int close_waiting; \
uv_link_close_cb saved_close_cb;
uv_link_close_cb saved_close_cb; \
uv_link_close_cb pending_close_cb; \
uv_link_t* pending_close_source;
struct uv_link_s {
UV_LINK_FIELDS

18
src/uv_link_t.c
View File

@ -87,14 +87,17 @@ void uv_link_close(uv_link_t* link, uv_link_close_cb cb) {
void uv_link_maybe_close(uv_link_t* link) {
uv_link_close_cb cb;
uv_link_t* source;
if (link->saved_close_cb == NULL)
if (link->pending_close_cb == NULL)
return;
cb = link->saved_close_cb;
cb = link->pending_close_cb;
source = link->pending_close_source;
link->saved_close_cb = NULL;
return uv_link_propagate_close(link, link, cb);
link->pending_close_cb = NULL;
link->pending_close_source = NULL;
return uv_link_propagate_close(link, source, cb);
}
@ -139,7 +142,12 @@ void uv_link_propagate_close(uv_link_t* link, uv_link_t* source,
if (child != NULL)
CHECK_EQ(uv_link_unchain(root, child), 0, "close unchain");
root->methods->close(root, source, uv_link_close_join);
if (root->close_depth == 0) {
root->methods->close(root, source, uv_link_close_join);
} else {
root->pending_close_cb = uv_link_close_join;
root->pending_close_source = source;
}
root = child;
}
}