| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | replay.cpp | 33 printf("[thread %s] Start task\n", get_pid().c_str());
43 [](long v){printf("[thread %s][1] OnNext: %ld\n", get_pid().c_str(), v);}, in __anon3e0ec51c0602()
44 [](){printf("[thread %s][1] OnCompleted\n", get_pid().c_str());}); in __anon3e0ec51c0602()
50 [](long v){printf("[thread %s][2] OnNext: %ld\n", get_pid().c_str(), v);}, in __anon3e0ec51c0902()
51 [](){printf("[thread %s][2] OnCompleted\n", get_pid().c_str());}); in __anon3e0ec51c0902()
61 printf("[thread %s] Finish task\n", get_pid().c_str());
90 printf("[thread %s] Start task\n", get_pid().c_str());
100 [](long v){printf("[thread %s][1] OnNext: %ld\n", get_pid().c_str(), v);}, in __anon3e0ec51c1202()
101 [](){printf("[thread %s][1] OnCompleted\n", get_pid().c_str());}); in __anon3e0ec51c1202()
107 [](long v){printf("[thread %s][2] OnNext: %ld\n", get_pid().c_str(), v);}, in __anon3e0ec51c1502()
[all …]
|
| D | merge_delay_error.cpp | 42 printf("[thread %s] Start task\n", get_pid().c_str());
44 printf("[thread %s] Timer1 fired\n", get_pid().c_str()); in __anon404e2e960b02()
49 ss << "[thread " << get_pid().c_str() << "] Timer2 failed\n"; in __anon404e2e960c02()
52 ss << "(Error from thread: " << get_pid().c_str() << ")\n"; in __anon404e2e960c02()
56 printf("[thread %s] Timer3 fired\n", get_pid().c_str()); in __anon404e2e960d02()
63 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anon404e2e960e02()
64 …[](std::exception_ptr eptr) { printf("[thread %s] OnError %s\n", get_pid().c_str(), rxu::what(eptr… in __anon404e2e960f02()
65 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon404e2e961002()
66 printf("[thread %s] Finish task\n", get_pid().c_str());
72 printf("[thread %s] Start task\n", get_pid().c_str());
[all …]
|
| D | amb.cpp | 37 printf("[thread %s] Start task\n", get_pid().c_str());
39 printf("[thread %s] Timer1 fired\n", get_pid().c_str()); in __anonbf9fecff0b02()
43 printf("[thread %s] Timer2 fired\n", get_pid().c_str()); in __anonbf9fecff0c02()
47 printf("[thread %s] Timer3 fired\n", get_pid().c_str()); in __anonbf9fecff0d02()
54 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anonbf9fecff0e02()
55 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anonbf9fecff0f02()
56 printf("[thread %s] Finish task\n", get_pid().c_str());
62 printf("[thread %s] Start task\n", get_pid().c_str());
64 printf("[thread %s] Timer1 fired\n", get_pid().c_str()); in __anonbf9fecff1002()
68 printf("[thread %s] Timer2 fired\n", get_pid().c_str()); in __anonbf9fecff1102()
[all …]
|
| D | merge.cpp | 37 printf("[thread %s] Start task\n", get_pid().c_str());
39 printf("[thread %s] Timer1 fired\n", get_pid().c_str()); in __anon8faf7d3f0b02()
43 printf("[thread %s] Timer2 fired\n", get_pid().c_str()); in __anon8faf7d3f0c02()
47 printf("[thread %s] Timer3 fired\n", get_pid().c_str()); in __anon8faf7d3f0d02()
54 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anon8faf7d3f0e02()
55 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon8faf7d3f0f02()
56 printf("[thread %s] Finish task\n", get_pid().c_str());
62 printf("[thread %s] Start task\n", get_pid().c_str());
64 printf("[thread %s] Timer1 fired\n", get_pid().c_str()); in __anon8faf7d3f1002()
68 printf("[thread %s] Timer2 fired\n", get_pid().c_str()); in __anon8faf7d3f1102()
[all …]
|
| D | take_until.cpp | 33 printf("[thread %s] Start task\n", get_pid().c_str());
35 printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v); in __anon6529427f0502()
39 printf("[thread %s] Trigger emits, value = %ld\n", get_pid().c_str(), v); in __anon6529427f0602()
46 [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);}, in __anon6529427f0702()
47 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon6529427f0802()
48 printf("[thread %s] Finish task\n", get_pid().c_str());
54 printf("[thread %s] Start task\n", get_pid().c_str());
56 printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v); in __anon6529427f0902()
64 [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);}, in __anon6529427f0a02()
65 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon6529427f0b02()
[all …]
|
| D | skip_until.cpp | 22 printf("[thread %s] Start task\n", get_pid().c_str());
24 printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v); in __anon9cb476f10302()
28 printf("[thread %s] Trigger emits, value = %ld\n", get_pid().c_str(), v); in __anon9cb476f10402()
35 [](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);}, in __anon9cb476f10502()
36 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon9cb476f10602()
37 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | observe_on.cpp | 10 printf("[thread %s] Start task\n", get_pid().c_str());
13 printf("[thread %s] Emit value %d\n", get_pid().c_str(), v); in __anon4472fa610102()
20 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anon4472fa610202()
21 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon4472fa610302()
22 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | subscribe_on.cpp | 10 printf("[thread %s] Start task\n", get_pid().c_str());
13 printf("[thread %s] Emit value %d\n", get_pid().c_str(), v); in __anon391bf38d0102()
20 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anon391bf38d0202()
21 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon391bf38d0302()
22 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | from.cpp | 20 printf("[thread %s] Start task\n", get_pid().c_str());
22 printf("[thread %s] Emit value: %d\n", get_pid().c_str(), v); in __anonf473b6030302()
28 [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, in __anonf473b6030402()
29 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anonf473b6030502()
30 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | concat_map.cpp | 29 printf("[thread %s] Start task\n", get_pid().c_str());
33 printf("[thread %s] Call CollectionSelector(v = %d)\n", get_pid().c_str(), v); in __anone3bd4d440502()
39 …printf("[thread %s] Call ResultSelector(v_main = %d, v_sub = %ld)\n", get_pid().c_str(), v_main, v… in __anone3bd4d440602()
46 …[](std::tuple<int, long> v){printf("[thread %s] OnNext: %d - %ld\n", get_pid().c_str(), std::get<0… in __anone3bd4d440702()
47 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anone3bd4d440802()
48 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | flat_map.cpp | 29 printf("[thread %s] Start task\n", get_pid().c_str());
33 printf("[thread %s] Call CollectionSelector(v = %d)\n", get_pid().c_str(), v); in __anonc1b991d30502()
39 …printf("[thread %s] Call ResultSelector(v_main = %d, v_sub = %d)\n", get_pid().c_str(), v_main, v_… in __anonc1b991d30602()
46 …[](std::tuple<int, long> v){printf("[thread %s] OnNext: %d - %ld\n", get_pid().c_str(), std::get<0… in __anonc1b991d30702()
47 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anonc1b991d30802()
48 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | combine_latest.cpp | 24 printf("[thread %s] Start task\n", get_pid().c_str());
27 printf("[thread %s] Source1 OnNext: %d\n", get_pid().c_str(), v); in __anonadd8ac180302()
31 printf("[thread %s] Source2 OnNext: %d\n", get_pid().c_str(), v); in __anonadd8ac180402()
35 printf("[thread %s] Source3 OnNext: %d\n", get_pid().c_str(), v); in __anonadd8ac180502()
43 …[](std::tuple<int, int, int> v){printf("[thread %s] OnNext: %d, %d, %d\n", get_pid().c_str(), std:… in __anonadd8ac180602()
44 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anonadd8ac180702()
45 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | with_latest_from.cpp | 24 printf("[thread %s] Start task\n", get_pid().c_str());
27 printf("[thread %s] Source1 OnNext: %d\n", get_pid().c_str(), v); in __anon6b5a404a0302()
31 printf("[thread %s] Source2 OnNext: %d\n", get_pid().c_str(), v); in __anon6b5a404a0402()
35 printf("[thread %s] Source3 OnNext: %d\n", get_pid().c_str(), v); in __anon6b5a404a0502()
43 …[](std::tuple<int, int, int> v){printf("[thread %s] OnNext: %d, %d, %d\n", get_pid().c_str(), std:… in __anon6b5a404a0602()
44 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon6b5a404a0702()
45 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | range.cpp | 20 printf("[thread %s] Start task\n", get_pid().c_str());
23 map([](int v) { return std::make_tuple(get_pid(), v);}); in __anonf12d6bbc0302()
31 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anonf12d6bbc0502()
32 printf("[thread %s] Finish task\n", get_pid().c_str());
38 printf("[thread %s] Start task\n", get_pid().c_str());
42 map([](int v) { return std::make_tuple(get_pid(), v);}); in __anonf12d6bbc0602()
50 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anonf12d6bbc0802()
51 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | zip.cpp | 24 printf("[thread %s] Start task\n", get_pid().c_str());
27 printf("[thread %s] Source1 OnNext: %d\n", get_pid().c_str(), v); in __anon3bb890620302()
31 printf("[thread %s] Source2 OnNext: %d\n", get_pid().c_str(), v); in __anon3bb890620402()
35 printf("[thread %s] Source3 OnNext: %d\n", get_pid().c_str(), v); in __anon3bb890620502()
43 …[](std::tuple<int, int, int> v){printf("[thread %s] OnNext: %d, %d, %d\n", get_pid().c_str(), std:… in __anon3bb890620602()
44 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon3bb890620702()
45 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | buffer.cpp | 42 printf("[thread %s] Start task\n", get_pid().c_str());
47 printf("[thread %s] Interval OnNext: %ld\n", get_pid().c_str(), v); in __anon4592fcc90702()
56 printf("[thread %s] OnNext:", get_pid().c_str()); in __anon4592fcc90802()
62 [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); in __anon4592fcc90a02()
63 printf("[thread %s] Finish task\n", get_pid().c_str());
|
| D | main.hpp | 3 std::string get_pid();
|
| D | main.cpp | 10 std::string get_pid() { in get_pid() function
|
| /external/autotest/client/site_tests/power_UiResume/ |
| D | power_UiResume.py | 46 pid_start = upstart.get_pid(service)
49 pid_start = upstart.get_pid(service)
61 pid_end = upstart.get_pid('powerd')
|
| /external/crosvm/devices/src/usb/xhci/ |
| D | xhci_backend_device.rs | 25 fn get_pid(&self) -> u16; in get_pid() method
|
| /external/autotest/client/cros/ |
| D | upstart.py | 48 def get_pid(service_name): function
|
| /external/python/cpython3/Lib/asyncio/ |
| D | transports.py | 195 def get_pid(self): member in SubprocessTransport
|
| D | subprocess.py | 124 self.pid = transport.get_pid()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_transports.py | 63 self.assertRaises(NotImplementedError, transport.get_pid)
|
| /external/crosvm/devices/src/usb/host_backend/ |
| D | host_backend_device_provider.rs | 240 .map(|d| (d.get_vid(), d.get_pid()))
|