Function ipc_roundtrip_server

tests/test_daemon_ipc.c:2032–2066

}

static void *ipc_roundtrip_server(void *opaque) {
    static const uint8_t expected_request[] = {0x00, 'r', 'e', 'q', 0xff};
    static const uint8_t response[] = {'o', 'k', 0x00, 0x7f};
    ipc_roundtrip_server_t *server = (ipc_roundtrip_server_t *)opaque;
    cbm_daemon_ipc_connection_t *connection = NULL;
    cbm_daemon_frame_t frame = {0};
    uint8_t *payload = NULL;

    server->result = 1;
    if (cbm_daemon_ipc_accept(server->listener, 2000, &connection) != 1 || !connection) {
        goto done;
    }
    server->peer_pid = cbm_daemon_ipc_connection_peer_pid(connection);
    if (server->peer_pid == 0) {
        goto done;
    }
    if (cbm_daemon_ipc_receive_frame(connection, 2000, &frame, &payload) != 1) {
        goto done;
    }
    if (frame.type != CBM_DAEMON_FRAME_REQUEST || frame.flags != 0x1234 ||
        frame.length != sizeof(expected_request) || !payload ||
        memcmp(payload, expected_request, sizeof(expected_request)) != 0) {
        goto done;
    }
    if (!cbm_daemon_ipc_send_frame(connection, CBM_DAEMON_FRAME_RESPONSE, 0x00a5, response,
                                   (uint32_t)sizeof(response))) {
        goto done;
    }
    server->result = 0;

done:
    free(payload); /* receive_frame returns a malloc-owned payload */
    cbm_daemon_ipc_connection_close(connection);
    return NULL;
}

TEST(daemon_ipc_local_frame_roundtrip) {
    static const char key[] = "1111222233334444";