| /system/netd/server/ |
| D | NFLogListenerTest.cpp | 54 MOCK_METHOD2(subscribe, netdutils::Status(uint16_t type, const DispatchFn& fn));
63 EXPECT_CALL(*mNLListener, subscribe(kNFLogPacketMsgType, _)) in NFLogListenerTest()
65 EXPECT_CALL(*mNLListener, subscribe(kNetlinkMsgDoneType, _)) in NFLogListenerTest()
77 void subscribe(uint16_t type, const NFLogListenerInterface::DispatchFn& fn) { in subscribe() function in android::net::NFLogListenerTest
80 EXPECT_OK(mListener->subscribe(type, fn)); in subscribe()
102 TEST_F(NFLogListenerTest, subscribe) { in TEST_F() argument
105 subscribe(kType, dispatchFn); in TEST_F()
111 subscribe(kType, dispatchFn); in TEST_F()
123 subscribe(kType, dispatchFn); in TEST_F()
135 subscribe(kType, dispatchFn); in TEST_F()
|
| D | NFLogListener.h | 42 virtual netdutils::Status subscribe(uint16_t nfLogGroup, const DispatchFn& fn) = 0;
46 virtual netdutils::Status subscribe(
71 netdutils::Status subscribe(uint16_t nfLogGroup, const DispatchFn& fn) override;
73 netdutils::Status subscribe(
|
| D | NetlinkListener.h | 50 virtual netdutils::Status subscribe(uint16_t type, const DispatchFn& fn) = 0;
84 netdutils::Status subscribe(uint16_t type, const DispatchFn& fn) override EXCLUDES(mMutex);
|
| D | NFLogListener.cpp | 154 expectOk(mListener->subscribe(kNFLogPacketMsgType, rxHandler)); in NFLogListener()
163 expectOk(mListener->subscribe(kNetlinkDoneMsgType, rxDoneHandler)); in NFLogListener()
175 Status NFLogListener::subscribe(uint16_t nfLogGroup, const DispatchFn& fn) { in subscribe() function in android::net::NFLogListener
176 return subscribe(nfLogGroup, kDefaultPacketRange, fn); in subscribe()
179 Status NFLogListener::subscribe( in subscribe() function in android::net::NFLogListener
|
| D | NetlinkListener.cpp | 67 expectOk(NetlinkListener::subscribe(kNetlinkMsgErrorType, rxErrorHandler)); in NetlinkListener()
94 Status NetlinkListener::subscribe(uint16_t type, const DispatchFn& fn) { in subscribe() function in android::net::NetlinkListener
|
| D | WakeupControllerTest.cpp | 63 MOCK_METHOD2(subscribe, netdutils::Status(uint16_t nfLogGroup, const DispatchFn& fn));
64 MOCK_METHOD3(subscribe,
73 subscribe(NetlinkManager::NFLOG_WAKEUP_GROUP, kDefaultPacketCopyRange, _)) in WakeupControllerTest()
|
| D | WakeupController.cpp | 190 return mListener->subscribe(NetlinkManager::NFLOG_WAKEUP_GROUP, in init()
|
| D | TrafficController.cpp | 334 expectOk(mSkDestroyListener->subscribe(kSockDiagMsgType, rxHandler)); in start()
343 expectOk(mSkDestroyListener->subscribe(kSockDiagDoneMsgType, rxDoneHandler)); in start()
|
| /system/iorap/src/inode2filename/ |
| D | main.cc | 133 inode_results.subscribe([&return_code](const InodeResult& result) { in main()
|
| /system/iorap/src/manager/ |
| D | event_manager.cc | 259 .subscribe(/*out*/lifetime, in StartTracing()
437 .subscribe(/*out*/lifetime, [](const AppLaunchEventState& state) { in InitializeRxGraph()
|
| /system/iorap/src/perfetto/ |
| D | main.cc | 119 .subscribe(/*on_next*/[arg_output_proto] in CollectPerfettoTraceBufferViaAbstractions()
|
| D | rx_producer.cc | 805 .subscribe(/*on_next*/[&](auto state_change) { in CollectPerfettoTraceBufferImmediately()
|
| /system/iorap/tests/src/inode2filename/ |
| D | search_directories_test.cc | 2665 obs.subscribe([&vec](auto&& x) { in subscribe_drain()
|