ASSERT_TRUE(touch_stub_connected_event_cb_);
}
+/*
+ * @testcase rpc_port_event_connect_sync_P
+ * @description After the rpc_port_proxy_connect_sync() is called,
+ * the rambda function is called by connected events.
+ * @apicovered rpc_port_stub_add_connected_event_cb, rpc_port_stub_listen,
+ * rpc_port_proxy_add_connected_event_cb, rpc_port_proxy_connect_sync,
+ */
+TEST_F(RpcPortBase, rpc_port_event_connect_sync) {
+ int ret = rpc_port_stub_add_connected_event_cb(stub_handle_,
+ [](const char *sender, const char* instance, void *data) {
+ RpcPortBase* p = static_cast<RpcPortBase*>(data);
+
+ p->touch_stub_connected_event_cb_ = true;
+ }, this);
+ ASSERT_EQ(ret, 0);
+
+ ret = rpc_port_stub_listen(stub_handle_);
+ ASSERT_EQ(ret, 0);
+
+ ret = rpc_port_proxy_add_connected_event_cb(proxy_handle_,
+ [](const char *ep, const char *port_name, rpc_port_h port, void *data) {
+ RpcPortBase* p = static_cast<RpcPortBase*>(data);
+
+ p->touch_proxy_connected_event_cb_ = true;
+ }, this);
+ ASSERT_EQ(ret, 0);
+
+ ret = rpc_port_proxy_connect_sync(proxy_handle_, "TestApp", "test_port");
+ ASSERT_EQ(ret, 0);
+
+ ASSERT_TRUE(touch_proxy_connected_event_cb_);
+ ASSERT_TRUE(touch_stub_connected_event_cb_);
+}
+
+
/*
* @testcase rpc_port_proxy_event_reject_n
* @description After the rpc_port_proxy_connect() is called,