| /5.5.2/ns_server/include/ |
| H A D | pipes.hrl | 31 -define(producer(), __Producer). macro
|
| /5.5.2/ns_server/src/ |
| H A D | memcached_passwords.erl | 86 producer(State) -> function
|
| H A D | memcached_permissions.erl | 115 producer(State) -> function
|
| /5.5.2/kv_engine/engines/ep/tests/module_tests/ |
| H A D | checkpoint_remover_test.cc | 109 auto producer = in TEST_F() local
162 auto producer = in TEST_F() local
|
| H A D | dcp_reflection_test.cc | 167 std::shared_ptr<MockDcpProducer> producer; global() member in DCPLoopbackStreamTest
[all...] |
| H A D | ephemeral_bucket_test.cc | 107 auto producer = std::make_shared<MockDcpProducer>( in TEST_F() local
[all...] |
| H A D | stats_test.cc | 120 DcpProducer* producer = engine->getDcpConnMap().newProducer( in TEST_F() local
|
| H A D | evp_store_test.cc | 62 DcpProducer* producer = engine->getDcpConnMap().newProducer( in TEST_F() local
|
| H A D | evp_store_rollback_test.cc | 329 DcpProducer* producer = engine->getDcpConnMap().newProducer( in TEST_P() local
689 auto producer = std::make_shared<MockDcpProducer>( in TEST_F() local
[all...] |
| H A D | dcp_test.cc | 218 std::shared_ptr<MockDcpProducer> producer; global() member in DCPTest
1792 auto producer = std::make_shared<MockDcpProducer>( TEST_P() local
1812 auto producer = std::make_shared<MockDcpProducer>( TEST_P() local
1853 auto producer = std::make_shared<MockDcpProducer>( TEST_P() local
1878 auto producer = std::make_shared<MockDcpProducer>( TEST_P() local
1923 auto producer = std::make_shared<MockDcpProducer>( TEST_P() local
1948 auto producer = std::make_shared<MockDcpProducer>( TEST_P() local
2018 DcpProducer* producer = connMap.newProducer(cookie1, TEST_P() local
2056 DcpProducer* producer = connMap.newProducer(cookie1, TEST_P() local
2110 DcpProducer* producer = connMap.newProducer(cookie, TEST_P() local
2141 auto producer = std::make_shared<MockDcpProducer>( TEST_P() local
2234 DcpProducer* producer = connMap.newProducer(cookie, TEST_P() local
2275 auto producer = std::make_shared<MockDcpProducer>( TEST_P() local
2494 DcpProducer* producer = connMap.newProducer(cookie, TEST_P() local
2524 DcpProducer* producer = connMap.newProducer(cookie, TEST_P() local
2721 DcpProducer* producer = engine.getDcpConnMap().newProducer(dummyMockCookie, TEST_F() local
2753 DcpProducer* producer = engine.getDcpConnMap().newProducer( TEST_F() local
2821 DcpProducer* producer; global() member in NotifyTest
2858 DcpProducer* producer; global() member in ConnMapNotifyTest
3382 std::shared_ptr<MockDcpProducer> producer; global() member in ActiveStreamChkptProcessorTaskTest
[all...] |
| H A D | evp_store_single_threaded_test.cc | 260 void SingleThreadedKVBucketTest::createDcpStream(MockDcpProducer& producer) { in createDcpStream() argument
209 notifyAndStepToCheckpoint( MockDcpProducer& producer, dcp_message_producers& producers, cb::mcbp::ClientOpcode expectedOp, bool fromMemory) notifyAndStepToCheckpoint() argument
243 runCheckpointProcessor( MockDcpProducer& producer, dcp_message_producers& producers) runCheckpointProcessor() argument
264 createDcpStream(MockDcpProducer& producer, uint16_t vbid) createDcpStream() argument
306 auto producer = std::make_shared<MockDcpProducer>( TEST_F() local
368 auto producer = std::make_shared<MockDcpProducer>( TEST_F() local
443 auto producer = TEST_F() local
612 auto producer = TEST_F() local
891 auto producer = std::make_shared<MockDcpProducer>( TEST_F() local
1135 auto producer = std::make_shared<MockDcpProducer>( TEST_F() local
1256 auto producer = std::make_shared<MockDcpProducer>( TEST_F() local
1371 auto producer = std::make_shared<MockDcpProducer>( TEST_F() local
2051 auto producer = std::make_shared<MockDcpProducer>( TEST_F() local
2601 auto producer = TEST_F() local
2826 std::shared_ptr<MockDcpProducer> producer; global() member in MB_29287
3105 auto producer = std::make_shared<MockDcpProducer>( TEST_F() local
3197 auto producer = std::make_shared<MockDcpProducer>( TEST_F() local
3288 auto producer = std::make_shared<MockDcpProducer>( TEST_F() local
[all...] |
| /5.5.2/platform/include/platform/ |
| H A D | pipe.h | 233 ssize_t produce(std::function<ssize_t(cb::byte_buffer)> producer) { in produce() argument
211 produce(std::function<ssize_t(void* , size_t )> producer) produce() argument
[all...] |
| /5.5.2/kv_engine/engines/ep/src/dcp/ |
| H A D | producer.h | 264 DcpProducer& producer; member in DcpProducer::BufferLog
[all...] |
| H A D | dcpconnmap.cc | 166 auto producer = std::make_shared<DcpProducer>(engine, in newProducer() local
207 auto* producer = dynamic_cast<DcpProducer*>(cookieToConn.second.get()); in vbucketStateChanged() local
220 auto* producer in closeStreamsDueToRollback() local
233 auto* producer = dynamic_cast<DcpProducer*>(connection.get()); handleSlowStream() local
243 auto producer = dynamic_pointer_cast<DcpProducer>(itr.second); closeStreams() local
307 auto producer = std::dynamic_pointer_cast<DcpProducer>(conn); disconnect() local
394 auto* producer = dynamic_cast<DcpProducer*>(connection.get()); notifyVBConnections() local
404 auto* producer = dynamic_cast<DcpProducer*>(cookieToConn.second.get()); notifyBackfillManagerTasks() local
[all...] |
| H A D | stream.h | 606 auto producer = producerPtr.lock(); in queuePop() local
[all...] |
| H A D | stream.cc | 362 auto producer = producerPtr.lock(); in next() local
506 auto producer = producerPtr.lock(); in backfillReceived() local
647 auto producer = producerPtr.lock(); in backfillPhase() local
741 auto producer = producerPtr.lock(); takeoverSendPhase() local
776 auto producer = producerPtr.lock(); isCompressionEnabled() local
919 auto producer = producerPtr.lock(); nextQueuedItem() local
948 auto producer = producerPtr.lock(); nextCheckpointItem() local
1348 auto producer = producerPtr.lock(); endStream() local
1406 auto producer = producerPtr.lock(); scheduleBackfill_UNLOCKED() local
1627 auto producer = producerPtr.lock(); handleSlowStream() local
1803 auto producer = producerPtr.lock(); log() local
1860 auto producer = producerPtr.lock(); notifyStreamReady() local
1951 auto producer = producerPtr.lock(); next() local
2006 auto producer = producerPtr.lock(); log() local
2018 auto producer = producerPtr.lock(); notifyStreamReady() local
[all...] |
| /5.5.2/kv_engine/engines/ep/tests/module_tests/collections/ |
| H A D | evp_store_collections_dcp_test.cc | 187 std::shared_ptr<MockDcpProducer> producer; member in CollectionsDcpTest
[all...] |
| /5.5.2/kv_engine/engines/ep/src/ |
| H A D | ep_engine.cc | 1426 auto* producer = dynamic_cast<DcpProducer*>(conn); in EvpDcpGetFailoverLog() local
5339 auto producer = dynamic_pointer_cast<DcpProducer>(conn); in doDcpVbTakeoverStats() local
|