mirror of
https://github.com/VCMP-SqMod/SqMod.git
synced 2024-11-08 00:37:15 +01:00
56 lines
1.3 KiB
C++
56 lines
1.3 KiB
C++
/* SPDX-License-Identifier: MPL-2.0 */
|
|
|
|
#include "testutil.hpp"
|
|
#include "testutil_unity.hpp"
|
|
|
|
SETUP_TEARDOWN_TESTCONTEXT
|
|
|
|
void test (const char *address)
|
|
{
|
|
// Create a publisher
|
|
void *publisher = test_context_socket (ZMQ_PUB);
|
|
char my_endpoint[MAX_SOCKET_STRING];
|
|
|
|
// Bind publisher
|
|
test_bind (publisher, address, my_endpoint, MAX_SOCKET_STRING);
|
|
|
|
// Create a subscriber
|
|
void *subscriber = test_context_socket (ZMQ_SUB);
|
|
TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (subscriber, my_endpoint));
|
|
|
|
// Subscribe to all messages.
|
|
TEST_ASSERT_SUCCESS_ERRNO (
|
|
zmq_setsockopt (subscriber, ZMQ_SUBSCRIBE, "", 0));
|
|
|
|
// Wait a bit till the subscription gets to the publisher
|
|
msleep (SETTLE_TIME);
|
|
|
|
// Send an empty message
|
|
send_string_expect_success (publisher, "test", 0);
|
|
|
|
// Receive the message in the subscriber
|
|
recv_string_expect_success (subscriber, "test", 0);
|
|
|
|
// Clean up.
|
|
test_context_socket_close (publisher);
|
|
test_context_socket_close (subscriber);
|
|
}
|
|
|
|
void test_norm ()
|
|
{
|
|
#if defined ZMQ_HAVE_NORM
|
|
test ("norm://224.1.2.3:5556");
|
|
#else
|
|
TEST_IGNORE_MESSAGE ("libzmq without NORM, ignoring test");
|
|
#endif
|
|
}
|
|
|
|
int main ()
|
|
{
|
|
setup_test_environment ();
|
|
|
|
UNITY_BEGIN ();
|
|
RUN_TEST (test_norm);
|
|
return UNITY_END ();
|
|
}
|