Home
last modified time | relevance | path

Searched refs:ConsumeAll (Results 1 – 6 of 6) sorted by relevance

/packages/modules/Connectivity/service-t/native/libs/libnetworkstats/
DNetworkTracePollerTest.cpp108 EXPECT_FALSE(handler.ConsumeAll()); in TEST_F()
110 EXPECT_TRUE(handler.ConsumeAll()); in TEST_F()
112 EXPECT_FALSE(handler.ConsumeAll()); in TEST_F()
121 EXPECT_TRUE(handler.ConsumeAll()); in TEST_F()
124 EXPECT_TRUE(handler.ConsumeAll()); in TEST_F()
127 EXPECT_TRUE(handler.ConsumeAll()); in TEST_F()
130 EXPECT_FALSE(handler.ConsumeAll()); in TEST_F()
191 ASSERT_TRUE(handler.ConsumeAll()); in TEST_F()
DNetworkTracePoller.cpp147 bool NetworkTracePoller::ConsumeAll() { in ConsumeAll() function in android::bpf::internal::NetworkTracePoller
159 base::Result<int> ret = mRingBuffer->ConsumeAll( in ConsumeAllLocked()
/packages/modules/Connectivity/staticlibs/native/bpf_headers/include/bpf/
DBpfRingbuf.h67 base::Result<int> ConsumeAll(
145 base::Result<int> ConsumeAll(const MessageCallback& callback);
222 inline base::Result<int> BpfRingbufBase::ConsumeAll( in ConsumeAll() function
271 inline base::Result<int> BpfRingbuf<Value>::ConsumeAll( in ConsumeAll() function
273 return BpfRingbufBase::ConsumeAll([&](const void* value) { in ConsumeAll()
/packages/modules/Connectivity/staticlibs/native/bpf_headers/
DBpfRingbufTest.cpp98 EXPECT_THAT(result.value()->ConsumeAll(callback), HasValue(n)); in RunTestN()
127 EXPECT_THAT(result.value()->ConsumeAll(callback), in TEST_F()
134 EXPECT_THAT(result.value()->ConsumeAll(callback), HasValue(1)); in TEST_F()
147 EXPECT_THAT(result.value()->ConsumeAll([](const uint8_t&) {}), in TEST_F()
/packages/modules/UprobeStats/src/
DBpf.cpp85 result.value()->ConsumeAll(callback); in pollRingBuf()
93 result.value()->ConsumeAll(callback); in consumeRingBuf()
103 int num_consumed = result.value()->ConsumeAll(callback).value_or(-1); in printRingBuf()
/packages/modules/Connectivity/service-t/native/libs/libnetworkstats/include/netdbpf/
DNetworkTracePoller.h53 bool ConsumeAll() EXCLUDES(mMutex);