IntenseFinance/neovim
3
0
Fork 0
mirror of https://github.com/neovim/neovim.git synced 2025-02-25 18:55:25 -06:00
Code Issues Packages Projects Releases Wiki Activity

channels: cleanup channel freeing code

Browse Source
This commit is contained in:
Björn Linse 2018-03-24 09:49:31 +01:00
parent aea079a25d
commit 0865adbbc2
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/nvim/channel.c
View File

@ -237,16 +237,16 @@ void channel_create_event(Channel *chan, const char *ext_source)
#endif #endif
} }
void channel_incref(Channel *channel) void channel_incref(Channel *chan)
{ {
channel->refcount++; chan->refcount++;
} }
void channel_decref(Channel *channel) void channel_decref(Channel *chan)
{ {
if (!(--channel->refcount)) { if (!(--chan->refcount)) {
// delay free, so that libuv is done with the handles // delay free, so that libuv is done with the handles
multiqueue_put(main_loop.events, free_channel_event, 1, channel); multiqueue_put(main_loop.events, free_channel_event, 1, chan);
} }
} }
@ -268,18 +268,18 @@ void callback_reader_start(CallbackReader *reader)
static void free_channel_event(void **argv) static void free_channel_event(void **argv)
{ {
Channel *channel = argv[0]; Channel *chan = argv[0];
if (channel->is_rpc) { if (chan->is_rpc) {
rpc_free(channel); rpc_free(chan);
} }
callback_reader_free(&channel->on_stdout); callback_reader_free(&chan->on_stdout);
callback_reader_free(&channel->on_stderr); callback_reader_free(&chan->on_stderr);
callback_free(&channel->on_exit); callback_free(&chan->on_exit);
pmap_del(uint64_t)(channels, channel->id); pmap_del(uint64_t)(channels, chan->id);
multiqueue_free(channel->events); multiqueue_free(chan->events);
xfree(channel); xfree(chan);
} }
static void channel_destroy_early(Channel *chan) static void channel_destroy_early(Channel *chan)