system/utest/core/event-pair/event-pair.c

// Copyright 2016 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include <string.h>

#include <magenta/syscalls.h>
#include <magenta/syscalls/object.h>
#include <unittest/unittest.h>

static void check_signals_state(mx_handle_t h, mx_signals_t satisfied) {
    mx_signals_t pending = 0;
    EXPECT_EQ(mx_object_wait_one(h, 0u, 0u, &pending), MX_ERR_TIMED_OUT, "wrong wait result");
    EXPECT_EQ(pending, satisfied, "wrong satisfied state");
}

static bool create_test(void) {
    BEGIN_TEST;

    {
        mx_handle_t h[2] = {MX_HANDLE_INVALID, MX_HANDLE_INVALID};
        ASSERT_EQ(mx_eventpair_create(0, &h[0], &h[1]), MX_OK, "eventpair_create failed");
        ASSERT_NE(h[0], MX_HANDLE_INVALID, "invalid handle from eventpair_create");
        ASSERT_NE(h[1], MX_HANDLE_INVALID, "invalid handle from eventpair_create");

        mx_info_handle_basic_t info;
        memset(&info, 0, sizeof(info));
        mx_status_t status = mx_object_get_info(h[0], MX_INFO_HANDLE_BASIC, &info, sizeof(info), NULL, NULL);
        ASSERT_EQ(status, MX_OK, "");
        EXPECT_EQ(info.rights,
                  MX_RIGHT_DUPLICATE | MX_RIGHT_TRANSFER | MX_RIGHT_READ |
                  MX_RIGHT_WRITE | MX_RIGHT_SIGNAL | MX_RIGHT_SIGNAL_PEER,
                  "wrong rights");
        EXPECT_EQ(info.type, (uint32_t)MX_OBJ_TYPE_EVENT_PAIR, "wrong type");
        memset(&info, 0, sizeof(info));
        status = mx_object_get_info(h[1], MX_INFO_HANDLE_BASIC, &info, sizeof(info), NULL, NULL);
        ASSERT_EQ(status, MX_OK, "");
        EXPECT_EQ(info.rights,
                  MX_RIGHT_DUPLICATE | MX_RIGHT_TRANSFER | MX_RIGHT_READ |
                  MX_RIGHT_WRITE | MX_RIGHT_SIGNAL | MX_RIGHT_SIGNAL_PEER,
                  "wrong rights");
        EXPECT_EQ(info.type, (uint32_t)MX_OBJ_TYPE_EVENT_PAIR, "wrong type");

        EXPECT_EQ(mx_handle_close(h[0]), MX_OK, "failed to close event pair handle");
        EXPECT_EQ(mx_handle_close(h[1]), MX_OK, "failed to close event pair handle");
    }

    // Currently no flags are supported.
    {
        mx_handle_t h[2] = {MX_HANDLE_INVALID, MX_HANDLE_INVALID};
        EXPECT_EQ(mx_eventpair_create(1u, &h[0], &h[1]), MX_ERR_NOT_SUPPORTED, "eventpair_create failed to fail");
        EXPECT_EQ(h[0], MX_HANDLE_INVALID, "valid handle from failed eventpair_create?");
        EXPECT_EQ(h[1], MX_HANDLE_INVALID, "valid handle from failed eventpair_create?");
    }

    END_TEST;
}

static bool signal_test(void) {
    BEGIN_TEST;
    mx_handle_t h[2] = {MX_HANDLE_INVALID, MX_HANDLE_INVALID};
    ASSERT_EQ(mx_eventpair_create(0, &h[0], &h[1]), MX_OK, "eventpair_create failed");
    ASSERT_NE(h[0], MX_HANDLE_INVALID, "invalid handle from eventpair_create");
    ASSERT_NE(h[1], MX_HANDLE_INVALID, "invalid handle from eventpair_create");

    check_signals_state(h[0], MX_SIGNAL_LAST_HANDLE);
    check_signals_state(h[1], MX_SIGNAL_LAST_HANDLE);

    EXPECT_EQ(mx_object_signal(h[0], 0u, MX_USER_SIGNAL_0), MX_OK, "object_signal failed");
    check_signals_state(h[1], MX_SIGNAL_LAST_HANDLE);
    check_signals_state(h[0], MX_USER_SIGNAL_0 | MX_SIGNAL_LAST_HANDLE);

    EXPECT_EQ(mx_object_signal(h[0], MX_USER_SIGNAL_0, 0u), MX_OK, "object_signal failed");
    check_signals_state(h[1], MX_SIGNAL_LAST_HANDLE);
    check_signals_state(h[0], MX_SIGNAL_LAST_HANDLE);

    EXPECT_EQ(mx_handle_close(h[0]), MX_OK, "failed to close event pair handle");
    check_signals_state(h[1], MX_EPAIR_PEER_CLOSED | MX_SIGNAL_LAST_HANDLE);
    EXPECT_EQ(mx_handle_close(h[1]), MX_OK, "failed to close event pair handle");
    END_TEST;
}

static bool signal_peer_test(void) {
    BEGIN_TEST;

    mx_handle_t h[2] = {MX_HANDLE_INVALID, MX_HANDLE_INVALID};
    ASSERT_EQ(mx_eventpair_create(0, &h[0], &h[1]), MX_OK, "eventpair_create failed");
    ASSERT_NE(h[0], MX_HANDLE_INVALID, "invalid handle from eventpair_create");
    ASSERT_NE(h[1], MX_HANDLE_INVALID, "invalid handle from eventpair_create");

    EXPECT_EQ(mx_object_signal_peer(h[0], 0u, MX_USER_SIGNAL_0), MX_OK, "object_signal failed");
    check_signals_state(h[0], MX_SIGNAL_LAST_HANDLE);
    check_signals_state(h[1], MX_USER_SIGNAL_0 | MX_SIGNAL_LAST_HANDLE);

    EXPECT_EQ(mx_object_signal_peer(h[1], 0u, MX_USER_SIGNAL_1 | MX_USER_SIGNAL_2), MX_OK,
              "object_signal failed");
    check_signals_state(h[0], MX_USER_SIGNAL_1 | MX_USER_SIGNAL_2 | MX_SIGNAL_LAST_HANDLE);
    check_signals_state(h[1], MX_USER_SIGNAL_0 | MX_SIGNAL_LAST_HANDLE);

    EXPECT_EQ(mx_object_signal_peer(h[0], MX_USER_SIGNAL_0, MX_USER_SIGNAL_3 | MX_USER_SIGNAL_4),
              MX_OK, "object_signal failed");
    check_signals_state(h[0], MX_USER_SIGNAL_1 | MX_USER_SIGNAL_2 | MX_SIGNAL_LAST_HANDLE);
    check_signals_state(h[1], MX_USER_SIGNAL_3 | MX_USER_SIGNAL_4 | MX_SIGNAL_LAST_HANDLE);

    EXPECT_EQ(mx_handle_close(h[0]), MX_OK, "failed to close event pair handle");

    // Signaled flags should remain satisfied but now should now also get peer closed (and
    // unsignaled flags should be unsatisfiable).
    check_signals_state(h[1],
        MX_EPAIR_PEER_CLOSED | MX_USER_SIGNAL_3 | MX_USER_SIGNAL_4 | MX_SIGNAL_LAST_HANDLE);

    EXPECT_EQ(mx_handle_close(h[1]), MX_OK, "failed to close event pair handle");

    END_TEST;
}

BEGIN_TEST_CASE(event_pair_tests)
RUN_TEST(create_test)
RUN_TEST(signal_test)
RUN_TEST(signal_peer_test)
END_TEST_CASE(event_pair_tests)

#ifndef BUILD_COMBINED_TESTS
int main(int argc, char** argv) {
    return unittest_run_all_tests(argc, argv) ? 0 : -1;
}
#endif