summaryrefslogtreecommitdiff
path: root/minecproxy/announce.c
diff options
context:
space:
mode:
authorDavid Härdeman <david@hardeman.nu>2020-06-28 14:58:32 +0200
committerDavid Härdeman <david@hardeman.nu>2020-06-28 14:58:32 +0200
commitd3352b997ca59a336a40fe6660c6e5b7079864aa (patch)
treef365d6c0304e512057223e9a3cf37357da44a443 /minecproxy/announce.c
parent99b2c70137fef05a5a18f439b9010ddba455f5cb (diff)
Run clang-format on source tree (excl igmp.c)
Diffstat (limited to 'minecproxy/announce.c')
-rw-r--r--minecproxy/announce.c31
1 files changed, 12 insertions, 19 deletions
diff --git a/minecproxy/announce.c b/minecproxy/announce.c
index 13ef423..78a7ccd 100644
--- a/minecproxy/announce.c
+++ b/minecproxy/announce.c
@@ -18,8 +18,7 @@ struct announce {
int mcast_fd;
};
-static void
-announce_cb(struct ptimer_task *ptask)
+static void announce_cb(struct ptimer_task *ptask)
{
struct announce *announce = container_of(ptask, struct announce, ptask);
struct server *server;
@@ -32,28 +31,25 @@ announce_cb(struct ptimer_task *ptask)
server_announce(server, announce->mcast_fd);
}
-static void
-announce_free(struct uring_task *task)
+static void announce_free(struct uring_task *task)
{
struct announce *announce = container_of(task, struct announce, task);
assert_return(task);
- debug(DBG_ANN, "task %p, announce 0x%p, mcast_fd: %i",
- task, announce, announce->mcast_fd);
+ debug(DBG_ANN, "task %p, announce 0x%p, mcast_fd: %i", task, announce,
+ announce->mcast_fd);
close(announce->mcast_fd);
xfree(announce);
}
-void
-announce_refdump()
+void announce_refdump()
{
assert_return_silent(cfg->announce);
uring_task_refdump(&cfg->announce->task);
}
-void
-announce_delete()
+void announce_delete()
{
assert_return_silent(cfg->announce);
@@ -63,8 +59,7 @@ announce_delete()
cfg->announce = NULL;
}
-void
-announce_stop()
+void announce_stop()
{
struct announce *announce = cfg->announce;
@@ -73,8 +68,7 @@ announce_stop()
ptimer_del_task(&announce->ptask);
}
-void
-announce_start(unsigned duration)
+void announce_start(unsigned duration)
{
struct announce *announce = cfg->announce;
unsigned times;
@@ -91,12 +85,11 @@ announce_start(unsigned duration)
ptimer_add_task(&announce->ptask);
}
-void
-announce_init()
+void announce_init()
{
struct announce *announce;
int sfd;
-
+
assert_return(!cfg->announce);
assert_return_silent(cfg->announce_interval > 0);
@@ -108,9 +101,9 @@ announce_init()
if (sfd < 0)
die("socket: %m");
- uring_task_init(&announce->task, "announce", uring_parent(), announce_free);
+ uring_task_init(&announce->task, "announce", uring_parent(),
+ announce_free);
ptask_init(&announce->ptask, cfg->announce_interval, 0, announce_cb);
announce->mcast_fd = sfd;
cfg->announce = announce;
}
-