mirrors/core-lightning
1
0
Fork 0
mirror of https://github.com/ElementsProject/lightning.git synced 2024-11-19 18:11:28 +01:00
Code Issues Projects Releases Wiki Activity

gossip: Add timer support to the io_loop

Browse Source
This commit is contained in:
Christian Decker 2017-02-04 16:28:35 +01:00
parent 1c4c874d3f
commit 83f51fe965
2 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lightningd/gossip/Makefile
View File

@ -16,7 +16,7 @@ LIGHTNINGD_GOSSIP_CONTROL_OBJS := $(LIGHTNINGD_GOSSIP_CONTROL_SRC:.c=.o)
# These should eventually be migrated to the lightningd directory, after
# deprecating the legacy daemons
LIGHTNINGD_GOSSIP_LEGACY_HEADERS := daemon/routing.h daemon/broadcast.h \
daemon/log.h daemon/pseudorand.h
daemon/log.h daemon/pseudorand.h daemon/timeout.h
# lightningd/gossip needs these:
LIGHTNINGD_GOSSIP_HEADERS := lightningd/gossip/gen_gossip_control_wire.h \

16
lightningd/gossip/gossip.c
View File

@ -11,6 +11,7 @@
#include <ccan/tal/str/str.h>
#include <daemon/broadcast.h>
#include <daemon/routing.h>
#include <daemon/timeout.h>
#include <errno.h>
#include <fcntl.h>
#include <inttypes.h>
@ -35,6 +36,8 @@ struct daemon {
/* Routing information */
struct routing_state *rstate;
struct timers timers;
};
struct peer {
@ -355,13 +358,24 @@ int main(int argc, char *argv[])
daemon = tal(NULL, struct daemon);
daemon->rstate = new_routing_state(daemon, NULL);
list_head_init(&daemon->peers);
timers_init(&daemon->timers, time_mono());
daemon->msg_in = NULL;
/* Stdout == status, stdin == requests */
status_setup(STDOUT_FILENO);
io_new_conn(NULL, STDIN_FILENO, next_req_in, daemon);
io_loop(NULL, NULL);
for (;;) {
struct timer *expired = NULL;
io_loop(&daemon->timers, &expired);
if (!expired) {
break;
} else {
timer_expired(daemon, expired);
}
}
tal_free(daemon);
return 0;