X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=test%2Fecho-fork.c;h=6839c7743e43c656723464fc56645e0c851e18eb;hb=HEAD;hp=0096c9e0fb4adc5c8611a5bccd366d7863bd2445;hpb=8d4b96efb7955eaa96174af4804597f92e124041;p=meshlink

diff --git a/test/echo-fork.c b/test/echo-fork.c
index 0096c9e0..33966da1 100644
--- a/test/echo-fork.c
+++ b/test/echo-fork.c
@@ -50,16 +50,6 @@ static void b_receive_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, c
 	assert(write(1, data, len) == (ssize_t)len);
 }
 
-static bool reject_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *data, size_t len) {
-	(void)mesh;
-	(void)channel;
-	(void)port;
-	(void)data;
-	(void)len;
-
-	return false;
-}
-
 static bool accept_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *data, size_t len) {
 	if(port != 7) {
 		return false;
@@ -89,8 +79,6 @@ static int main1(void) {
 	meshlink_handle_t *mesh = meshlink_open("echo-fork_conf.1", "a", "echo-fork", DEV_CLASS_BACKBONE);
 	assert(mesh);
 
-	meshlink_set_channel_accept_cb(mesh, reject_cb);
-
 	assert(meshlink_start(mesh));
 
 	// Open a channel.
@@ -175,6 +163,10 @@ static int main2(void) {
 
 
 int main(void) {
+	init_sync_flag(&a_started);
+	init_sync_flag(&a_stopped);
+	init_sync_flag(&b_responded);
+
 	meshlink_set_log_cb(NULL, MESHLINK_WARNING, log_cb);
 
 	// Initialize and exchange configuration.