| /external/antlr/runtime/CSharp3/Sources/Antlr3.Runtime.Debug/ |
| D | DebugEventRepeater.cs | 49 IDebugEventListener _listener; field in Antlr.Runtime.Debug.DebugEventRepeater
53 _listener = listener; in DebugEventRepeater()
62 _listener.EnterRule( grammarFileName, ruleName ); in EnterRule()
66 _listener.ExitRule( grammarFileName, ruleName ); in ExitRule()
70 _listener.EnterAlt( alt ); in EnterAlt()
74 _listener.EnterSubRule( decisionNumber ); in EnterSubRule()
78 _listener.ExitSubRule( decisionNumber ); in ExitSubRule()
82 _listener.EnterDecision( decisionNumber, couldBacktrack ); in EnterDecision()
86 _listener.ExitDecision( decisionNumber ); in ExitDecision()
90 _listener.Location( line, pos ); in Location()
[all …]
|
| /external/antlr/runtime/CSharp2/Sources/Antlr3.Runtime/Antlr.Runtime.Debug/ |
| D | DebugEventRepeater.cs | 47 IDebugEventListener _listener; field in Antlr.Runtime.Debug.DebugEventRepeater
50 _listener = listener; in DebugEventRepeater()
57 _listener.EnterRule(grammarFileName, ruleName); in EnterRule()
60 _listener.ExitRule(grammarFileName, ruleName); in ExitRule()
63 _listener.EnterAlt(alt); in EnterAlt()
66 _listener.EnterSubRule(decisionNumber); in EnterSubRule()
69 _listener.ExitSubRule(decisionNumber); in ExitSubRule()
72 _listener.EnterDecision(decisionNumber, couldBacktrack); in EnterDecision()
75 _listener.ExitDecision(decisionNumber); in ExitDecision()
78 _listener.Location(line, pos); in Location()
[all …]
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | resource_sharer.py | 68 self._listener = None
104 self._listener.close()
107 self._listener = None
120 if self._listener is not None:
121 self._listener.close()
122 self._listener = None
128 assert self._listener is None, "Already have Listener"
130 self._listener = Listener(authkey=process.current_process().authkey)
131 self._address = self._listener.address
142 with self._listener.accept() as conn:
|
| D | connection.py | 446 self._listener = PipeListener(address, backlog)
448 self._listener = SocketListener(address, family, backlog)
461 if self._listener is None:
463 c = self._listener.accept()
473 listener = self._listener
475 self._listener = None
480 return self._listener._address
484 return self._listener._last_accepted
|
| /external/autotest/client/site_tests/login_LoginSuccess/ |
| D | login_LoginSuccess.py | 30 self._listener = session_manager.SessionSignalListener(
47 self._listener.listen_for_session_state_change('started')
49 self._listener.wait_for_signals(desc='Session started.',
55 self._listener.listen_for_session_state_change('stopped')
57 self._listener.wait_for_signals(desc='Session stopped.',
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | reduction.py | 92 global _lock, _listener, _cache
97 _listener = None
103 global _listener
105 if _listener is None:
108 if _listener is None:
110 _listener = Listener(authkey=current_process().authkey)
117 return _listener
124 conn = _listener.accept()
|
| D | connection.py | 130 self._listener = PipeListener(address, backlog)
132 self._listener = SocketListener(address, family, backlog)
145 c = self._listener.accept()
155 return self._listener.close()
157 address = property(lambda self: self._listener._address)
158 last_accepted = property(lambda self: self._listener._last_accepted)
|
| /external/autotest/client/site_tests/login_MultipleSessions/ |
| D | login_MultipleSessions.py | 29 self._listener = session_manager.OwnershipSignalListener(
31 self._listener.listen_for_new_key_and_policy()
42 self._listener.wait_for_signals(desc='Initial policy push complete.')
58 self._listener.wait_for_signals(desc='Re-taking of ownership complete.')
|
| /external/autotest/client/site_tests/login_CryptohomeOwnerQuery/ |
| D | login_CryptohomeOwnerQuery.py | 28 self._listener = session_manager.OwnershipSignalListener(
30 self._listener.listen_for_new_key_and_policy()
42 self._listener.wait_for_signals(desc='Device ownership complete.')
|
| /external/autotest/client/cros/ |
| D | dark_resume_xmlrpc_server.py | 30 self._listener = dark_resume_listener.DarkResumeListener()
48 self._listener.stop_resuspend(stop_resuspend)
54 return self._listener.count
|
| /external/autotest/client/common_lib/cros/ |
| D | dark_resume_xmlrpc_server.py | 30 self._listener = dark_resume_listener.DarkResumeListener()
48 self._listener.stop_resuspend(stop_resuspend)
54 return self._listener.count
|
| /external/autotest/client/cros/multimedia/ |
| D | audio_facade_native.py | 82 self._listener = None
198 if self._listener:
199 self._listener.cleanup()
363 self._listener = Listener()
364 self._listener.start(data_format)
376 self._listener.stop()
377 if file_contains_all_zeros(self._listener.file_path):
381 return self._listener.file_path
|
| /external/python/cpython3/Lib/logging/ |
| D | config.py | 49 _listener = None variable
925 global _listener
927 _listener = server
937 global _listener
940 if _listener:
941 _listener.abort = 1
942 _listener = None
|
| /external/python/cpython2/Lib/logging/ |
| D | config.py | 58 _listener = None variable
900 global _listener
902 _listener = server
912 global _listener
915 if _listener:
916 _listener.abort = 1
917 _listener = None
|
| /external/autotest/client/site_tests/network_ProxyResolver/ |
| D | network_ProxyResolver.py | 220 self._listener = SignalListener(gobject.MainLoop())
225 self._listener.listen_for_signal('PropertyChanged',
|
| /external/protobuf/python/google/protobuf/internal/ |
| D | python_message.py | 506 self._listener = message_listener_mod.NullMessageListener()
1405 self._listener = message_listener_mod.NullMessageListener()
1407 self._listener = listener
1453 self._listener.Modified()
|
| /external/crosvm/sys_util/src/ |
| D | net.rs | 484 let _listener = UnlinkUnixSeqpacketListener( in unix_seqpacket_path_exists_pass() localVariable
|
| /external/python/cpython3/Lib/test/ |
| D | _test_multiprocessing.py | 3416 def _listener(cls, conn, families): member in _TestPicklingConnections
3453 lp = self.Process(target=self._listener, args=(lconn0, families))
|