11 static bool accept_cb(meshlink_handle_t *mesh, meshlink_channel_t *channel, uint16_t port, const void *data, size_t len) {
21 int main(int argc, char *argv[]) {
25 // Start two new meshlink instance.
27 meshlink_handle_t *mesh_a;
28 meshlink_handle_t *mesh_b;
30 open_meshlink_pair(&mesh_a, &mesh_b, "channels_no_partial");
31 meshlink_set_channel_accept_cb(mesh_b, accept_cb);
32 start_meshlink_pair(mesh_a, mesh_b);
36 meshlink_node_t *b = meshlink_get_node(mesh_a, "b");
39 meshlink_channel_t *channel = meshlink_channel_open_ex(mesh_a, b, 1, NULL, NULL, 0, MESHLINK_CHANNEL_NO_PARTIAL);
42 // Verify that no partial sends succeed.
43 // If rejected sends would fit an empty send buffer, 0 should be returned, otherwise -1.
47 meshlink_set_channel_sndbuf(mesh_a, channel, 256);
48 assert(meshlink_channel_send(mesh_a, channel, buf, 257) == -1);
49 assert(meshlink_channel_send(mesh_a, channel, buf, 256) == 256);
51 meshlink_set_channel_sndbuf(mesh_a, channel, 512);
52 assert(meshlink_channel_send(mesh_a, channel, buf, 257) == 0);
53 assert(meshlink_channel_send(mesh_a, channel, buf, 128) == 128);
54 assert(meshlink_channel_send(mesh_a, channel, buf, 129) == 0);
55 assert(meshlink_channel_send(mesh_a, channel, buf, 100) == 100);
56 assert(meshlink_channel_send(mesh_a, channel, buf, 29) == 0);
57 assert(meshlink_channel_send(mesh_a, channel, buf, 513) == -1);
59 assert_after(!meshlink_channel_get_sendq(mesh_a, channel), 30);
60 assert(meshlink_channel_send(mesh_a, channel, buf, 512) == 512);
64 close_meshlink_pair(mesh_a, mesh_b, "channels_no_partial");