GithubStar/open62541
1
0
Fork 0
mirror of https://github.com/open62541/open62541.git synced 2026-10-29 05:11:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(tests): Add unit tests for the Cancel service

Browse Source
This commit is contained in:
Julius Pfrommer
2023-08-30 17:40:14 +02:00
committed by Julius Pfrommer
parent 91e0efc0f5
commit 7fa86dba01
1 changed files with 70 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/server/check_server_asyncop.c
+70
View File
@@ -198,6 +198,74 @@ START_TEST(Async_timeout) {
UA_Client_delete(client);
} END_TEST
START_TEST(Async_cancel) {
UA_Client *client = UA_Client_new();
UA_ClientConfig *clientConfig = UA_Client_getConfig(client);
UA_ClientConfig_setDefault(clientConfig);
UA_StatusCode retval = UA_Client_connect(client, "opc.tcp://localhost:4840");
ck_assert_uint_eq(retval, UA_STATUSCODE_GOOD);
/* Call async method, then the sync method.
* The sync method returns first. */
UA_UInt32 reqId = 0;
retval = UA_Client_call_async(client,
UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER),
UA_NODEID_STRING(1, "asyncMethod"),
0, NULL, clientReceiveCallback, NULL, &reqId);
ck_assert_uint_eq(retval, UA_STATUSCODE_GOOD);
/* Cancel the request */
UA_UInt32 cancelCount = 0;
UA_Client_cancelByRequestId(client, reqId, &cancelCount);
ck_assert_uint_eq(cancelCount, 1);
/* We expect to receive the cancelled response */
UA_Client_run_iterate(client, 0);
ck_assert_uint_eq(clientCounter, 1);
UA_Client_disconnect(client);
UA_Client_delete(client);
} END_TEST
START_TEST(Async_cancel_multiple) {
UA_Client *client = UA_Client_new();
UA_ClientConfig *clientConfig = UA_Client_getConfig(client);
UA_ClientConfig_setDefault(clientConfig);
UA_StatusCode retval = UA_Client_connect(client, "opc.tcp://localhost:4840");
ck_assert_uint_eq(retval, UA_STATUSCODE_GOOD);
UA_CallRequest creq;
UA_CallRequest_init(&creq);
creq.requestHeader.requestHandle = 1337;
UA_CallMethodRequest cmr;
UA_CallMethodRequest_init(&cmr);
cmr.objectId = UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER);
cmr.methodId = UA_NODEID_STRING(1, "asyncMethod");
creq.methodsToCall = &cmr;
creq.methodsToCallSize = 1;
__UA_Client_AsyncService(client,
&creq, &UA_TYPES[UA_TYPES_CALLREQUEST],
NULL, &UA_TYPES[UA_TYPES_CALLRESPONSE],
NULL, NULL);
__UA_Client_AsyncService(client,
&creq, &UA_TYPES[UA_TYPES_CALLREQUEST],
NULL, &UA_TYPES[UA_TYPES_CALLRESPONSE],
NULL, NULL);
/* Expect two cancelled requests */
UA_UInt32 cancelCount = 0;
UA_Client_cancelByRequestHandle(client, 1337, &cancelCount);
ck_assert_uint_eq(cancelCount, 2);
UA_Client_run_iterate(client, 0);
UA_Client_disconnect(client);
UA_Client_delete(client);
} END_TEST
/* Force a timeout when the operation is checked out with the worker */
START_TEST(Async_timeout_worker) {
UA_Client *client = UA_Client_new();
@@ -255,6 +323,8 @@ static Suite* method_async_suite(void) {
tcase_add_checked_fixture(tc_manager, setup, teardown);
tcase_add_test(tc_manager, Async_call);
tcase_add_test(tc_manager, Async_timeout);
tcase_add_test(tc_manager, Async_cancel);
tcase_add_test(tc_manager, Async_cancel_multiple);
tcase_add_test(tc_manager, Async_timeout_worker);
suite_add_tcase(s, tc_manager);