Home
last modified time | relevance | path

Searched defs:producer (Results 1 - 18 of 18) sorted by relevance

/5.5.2/ns_server/include/
H A Dpipes.hrl31 -define(producer(), __Producer). macro
/5.5.2/ns_server/src/
H A Dmemcached_passwords.erl86 producer(State) -> function
H A Dmemcached_permissions.erl115 producer(State) -> function
/5.5.2/kv_engine/engines/ep/tests/module_tests/
H A Dcheckpoint_remover_test.cc109 auto producer = in TEST_F() local
162 auto producer = in TEST_F() local
H A Ddcp_reflection_test.cc167 std::shared_ptr<MockDcpProducer> producer; global() member in DCPLoopbackStreamTest
[all...]
H A Dephemeral_bucket_test.cc107 auto producer = std::make_shared<MockDcpProducer>( in TEST_F() local
[all...]
H A Dstats_test.cc120 DcpProducer* producer = engine->getDcpConnMap().newProducer( in TEST_F() local
H A Devp_store_test.cc62 DcpProducer* producer = engine->getDcpConnMap().newProducer( in TEST_F() local
H A Devp_store_rollback_test.cc329 DcpProducer* producer = engine->getDcpConnMap().newProducer( in TEST_P() local
689 auto producer = std::make_shared<MockDcpProducer>( in TEST_F() local
[all...]
H A Ddcp_test.cc218 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 Devp_store_single_threaded_test.cc260 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 Dpipe.h233 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 Dproducer.h264 DcpProducer& producer; member in DcpProducer::BufferLog
[all...]
H A Ddcpconnmap.cc166 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 Dstream.h606 auto producer = producerPtr.lock(); in queuePop() local
[all...]
H A Dstream.cc362 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 Devp_store_collections_dcp_test.cc187 std::shared_ptr<MockDcpProducer> producer; member in CollectionsDcpTest
[all...]
/5.5.2/kv_engine/engines/ep/src/
H A Dep_engine.cc1426 auto* producer = dynamic_cast<DcpProducer*>(conn); in EvpDcpGetFailoverLog() local
5339 auto producer = dynamic_pointer_cast<DcpProducer>(conn); in doDcpVbTakeoverStats() local

Completed in 84 milliseconds