NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::RequestProcessor::Experimental Namespace Reference

Classes

class  DummyConcatResponse
 
class  DummyConcatRequest
 
class  DummyWaitOnFutureResponse
 
class  DummyWaitOnFutureRequest
 
class  DummyWaitOnFutureSubRequest
 
class  DummyWaitOnFutureMultiRequest
 
class  DummyMultiResponse
 
class  DummySubRequest
 
class  DummyMultiRequest
 
class  AsyncRequestProcessorTest
 
class  SerialStorageHandlerTest
 
class  UnlockDeleterTest
 

Functions

 TEST_P (AsyncRequestProcessorTest, startAndDestroy)
 
 TEST_F (AsyncRequestProcessorTest, testWaitingForLock)
 
 TEST_F (AsyncRequestProcessorTest, testWaitingForLockMultiRequest)
 
 TEST_P (AsyncRequestProcessorTest, submitRequest)
 
 TEST_P (AsyncRequestProcessorTest, submitFollowUpRequest)
 
 TEST_P (AsyncRequestProcessorTest, submitMultiRequest)
 
 INSTANTIATE_TEST_CASE_P (AsyncRequestExecutorMTTest, AsyncRequestProcessorTest, ::testing::Values(1, 4, 8))
 
 TEST_F (SerialStorageHandlerTest, TestResourceAccess)
 
 TEST_F (UnlockDeleterTest, TestNoLocking)
 
 TEST_F (UnlockDeleterTest, TestBlocking)
 
 TEST_F (UnlockDeleterTest, TestLocking)
 
 TEST_F (UnlockDeleterTest, TestTakingOwnershipOfLock)
 
 TEST_F (UnlockDeleterTest, TestTakingOwnershipNotLocked)
 

Function Documentation

◆ INSTANTIATE_TEST_CASE_P()

NES::RequestProcessor::Experimental::INSTANTIATE_TEST_CASE_P ( AsyncRequestExecutorMTTest  ,
AsyncRequestProcessorTest  ,
::testing::Values(1, 4, 8)   
)

◆ TEST_F() [1/8]

NES::RequestProcessor::Experimental::TEST_F ( AsyncRequestProcessorTest  ,
testWaitingForLock   
)

◆ TEST_F() [2/8]

NES::RequestProcessor::Experimental::TEST_F ( AsyncRequestProcessorTest  ,
testWaitingForLockMultiRequest   
)

References backward::details::move(), NES_DEBUG, NES::RequestProcessor::QueryCatalogService, and NES::RequestProcessor::Topology.

Here is the call graph for this function:

◆ TEST_F() [3/8]

NES::RequestProcessor::Experimental::TEST_F ( SerialStorageHandlerTest  ,
TestResourceAccess   
)

References NES::RequestProcessor::SerialStorageHandler::create().

Here is the call graph for this function:

◆ TEST_F() [4/8]

NES::RequestProcessor::Experimental::TEST_F ( UnlockDeleterTest  ,
TestBlocking   
)

◆ TEST_F() [5/8]

NES::RequestProcessor::Experimental::TEST_F ( UnlockDeleterTest  ,
TestLocking   
)

◆ TEST_F() [6/8]

NES::RequestProcessor::Experimental::TEST_F ( UnlockDeleterTest  ,
TestNoLocking   
)

◆ TEST_F() [7/8]

NES::RequestProcessor::Experimental::TEST_F ( UnlockDeleterTest  ,
TestTakingOwnershipNotLocked   
)

◆ TEST_F() [8/8]

NES::RequestProcessor::Experimental::TEST_F ( UnlockDeleterTest  ,
TestTakingOwnershipOfLock   
)

◆ TEST_P() [1/4]

NES::RequestProcessor::Experimental::TEST_P ( AsyncRequestProcessorTest  ,
startAndDestroy   
)

◆ TEST_P() [2/4]

NES::RequestProcessor::Experimental::TEST_P ( AsyncRequestProcessorTest  ,
submitFollowUpRequest   
)

References NES_DEBUG.

◆ TEST_P() [3/4]

NES::RequestProcessor::Experimental::TEST_P ( AsyncRequestProcessorTest  ,
submitMultiRequest   
)

References NES_DEBUG.

◆ TEST_P() [4/4]

NES::RequestProcessor::Experimental::TEST_P ( AsyncRequestProcessorTest  ,
submitRequest   
)

References NES_DEBUG.