X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=tests%2Funit_tests%2Fipc%2Fut-ipc.cpp;h=679f3df7bf7a2977162b8c0ee9b46e1efe5db391;hb=316605cca8c654878acfc67deb5a62103be2822b;hp=b8b9e9524f4049bd8b9fd2a95b1d688a354de08e;hpb=b550c251c29c804983f019305b6e7574b2f7b585;p=platform%2Fcore%2Fsecurity%2Fvasum.git diff --git a/tests/unit_tests/ipc/ut-ipc.cpp b/tests/unit_tests/ipc/ut-ipc.cpp index b8b9e95..679f3df 100644 --- a/tests/unit_tests/ipc/ut-ipc.cpp +++ b/tests/unit_tests/ipc/ut-ipc.cpp @@ -111,38 +111,38 @@ struct ThrowOnAcceptData { } }; -std::shared_ptr returnEmptyCallback(const PeerID, std::shared_ptr&) +std::shared_ptr returnEmptyCallback(const FileDescriptor, std::shared_ptr&) { return std::shared_ptr(new EmptyData()); } -std::shared_ptr returnDataCallback(const PeerID, std::shared_ptr&) +std::shared_ptr returnDataCallback(const FileDescriptor, std::shared_ptr&) { return std::shared_ptr(new SendData(1)); } -std::shared_ptr echoCallback(const PeerID, std::shared_ptr& data) +std::shared_ptr echoCallback(const FileDescriptor, std::shared_ptr& data) { return data; } -std::shared_ptr longEchoCallback(const PeerID, std::shared_ptr& data) +std::shared_ptr longEchoCallback(const FileDescriptor, std::shared_ptr& data) { std::this_thread::sleep_for(std::chrono::seconds(1)); return data; } -PeerID connect(Service& s, Client& c) +FileDescriptor connect(Service& s, Client& c) { - // Connects the Client to the Service and returns Clients PeerID + // Connects the Client to the Service and returns Clients FileDescriptor std::mutex mutex; std::condition_variable cv; - PeerID peerID = 0; - auto newPeerCallback = [&cv, &peerID, &mutex](const PeerID newPeerID) { + FileDescriptor peerFD = 0; + auto newPeerCallback = [&cv, &peerFD, &mutex](const FileDescriptor newFileDescriptor) { std::unique_lock lock(mutex); - peerID = newPeerID; + peerFD = newFileDescriptor; cv.notify_one(); }; @@ -155,11 +155,11 @@ PeerID connect(Service& s, Client& c) c.start(); std::unique_lock lock(mutex); - BOOST_CHECK(cv.wait_for(lock, std::chrono::milliseconds(1000), [&peerID]() { - return peerID != 0; + BOOST_CHECK(cv.wait_for(lock, std::chrono::milliseconds(1000), [&peerFD]() { + return peerFD != 0; })); - return peerID; + return peerFD; } void testEcho(Client& c, const MethodID methodID) @@ -169,10 +169,10 @@ void testEcho(Client& c, const MethodID methodID) BOOST_CHECK_EQUAL(recvData->intVal, sentData->intVal); } -void testEcho(Service& s, const MethodID methodID, const PeerID peerID) +void testEcho(Service& s, const MethodID methodID, const FileDescriptor peerFD) { std::shared_ptr sentData(new SendData(56)); - std::shared_ptr recvData = s.callSync(methodID, peerID, sentData); + std::shared_ptr recvData = s.callSync(methodID, peerFD, sentData); BOOST_CHECK_EQUAL(recvData->intVal, sentData->intVal); } @@ -216,17 +216,17 @@ BOOST_AUTO_TEST_CASE(ClientAddRemoveMethod) c.addMethodHandler(1, returnEmptyCallback); c.addMethodHandler(1, returnDataCallback); - PeerID peerID = connect(s, c); + FileDescriptor peerFD = connect(s, c); c.addMethodHandler(1, echoCallback); c.addMethodHandler(2, returnDataCallback); - testEcho(s, 1, peerID); + testEcho(s, 1, peerFD); c.removeMethod(1); c.removeMethod(2); - BOOST_CHECK_THROW(testEcho(s, 1, peerID), IPCException); + BOOST_CHECK_THROW(testEcho(s, 1, peerFD), IPCException); } BOOST_AUTO_TEST_CASE(ServiceStartStop) @@ -305,10 +305,10 @@ BOOST_AUTO_TEST_CASE(SyncServiceToClientEcho) Service s(socketPath); Client c(socketPath); c.addMethodHandler(1, echoCallback); - PeerID peerID = connect(s, c); + FileDescriptor peerFD = connect(s, c); std::shared_ptr sentData(new SendData(56)); - std::shared_ptr recvData = s.callSync(1, peerID, sentData); + std::shared_ptr recvData = s.callSync(1, peerFD, sentData); BOOST_CHECK_EQUAL(recvData->intVal, sentData->intVal); } @@ -349,7 +349,7 @@ BOOST_AUTO_TEST_CASE(AsyncServiceToClientEcho) Service s(socketPath); Client c(socketPath); c.addMethodHandler(1, echoCallback); - PeerID peerID = connect(s, c); + FileDescriptor peerFD = connect(s, c); // Async call std::shared_ptr sentData(new SendData(56)); @@ -364,7 +364,7 @@ BOOST_AUTO_TEST_CASE(AsyncServiceToClientEcho) cv.notify_one(); }; - s.callAsync(1, peerID, sentData, dataBack); + s.callAsync(1, peerFD, sentData, dataBack); // Wait for the response std::unique_lock lock(mutex); @@ -422,7 +422,7 @@ BOOST_AUTO_TEST_CASE(DisconnectedPeerError) { Service s(socketPath); - auto method = [](const PeerID, std::shared_ptr&) { + auto method = [](const FileDescriptor, std::shared_ptr&) { return std::shared_ptr(new SendData(1)); }; @@ -458,7 +458,7 @@ BOOST_AUTO_TEST_CASE(DisconnectedPeerError) BOOST_AUTO_TEST_CASE(ReadTimeout) { Service s(socketPath); - auto longEchoCallback = [](const PeerID, std::shared_ptr& data) { + auto longEchoCallback = [](const FileDescriptor, std::shared_ptr& data) { return std::shared_ptr(new LongSendData(data->intVal)); }; s.addMethodHandler(1, longEchoCallback); @@ -500,12 +500,12 @@ BOOST_AUTO_TEST_CASE(AddSignalInRuntime) connect(s, c); std::atomic_bool isHandlerACalled(false); - auto handlerA = [&isHandlerACalled](const PeerID, std::shared_ptr&) { + auto handlerA = [&isHandlerACalled](const FileDescriptor, std::shared_ptr&) { isHandlerACalled = true; }; std::atomic_bool isHandlerBCalled(false); - auto handlerB = [&isHandlerBCalled](const PeerID, std::shared_ptr&) { + auto handlerB = [&isHandlerBCalled](const FileDescriptor, std::shared_ptr&) { isHandlerBCalled = true; }; @@ -528,12 +528,12 @@ BOOST_AUTO_TEST_CASE(AddSignalOffline) Client c(socketPath); std::atomic_bool isHandlerACalled(false); - auto handlerA = [&isHandlerACalled](const PeerID, std::shared_ptr&) { + auto handlerA = [&isHandlerACalled](const FileDescriptor, std::shared_ptr&) { isHandlerACalled = true; }; std::atomic_bool isHandlerBCalled(false); - auto handlerB = [&isHandlerBCalled](const PeerID, std::shared_ptr&) { + auto handlerB = [&isHandlerBCalled](const FileDescriptor, std::shared_ptr&) { isHandlerBCalled = true; };