Home
last modified time | relevance | path

Searched refs:mEventReceiver (Results 1 – 2 of 2) sorted by relevance

/tools/tradefederation/core/src/com/android/tradefed/result/proto/
DStreamProtoReceiver.java42 private EventReceiverThread mEventReceiver; field in StreamProtoReceiver
103 mEventReceiver = new EventReceiverThread(); in StreamProtoReceiver()
104 mEventReceiver.start(); in StreamProtoReceiver()
156 if (mEventReceiver != null) { in getSocketServerPort()
157 return mEventReceiver.getLocalPort(); in getSocketServerPort()
169 if (mEventReceiver != null) { in close()
170 mEventReceiver.cancel(); in close()
175 if (mEventReceiver != null) { in joinReceiver()
181 if (!mEventReceiver.getCountDown().await(waitTime, TimeUnit.MILLISECONDS)) { in joinReceiver()
183 mEventReceiver.interrupt(); in joinReceiver()
/tools/tradefederation/core/src/com/android/tradefed/util/
DSubprocessTestResultsParser.java76 private EventReceiverThread mEventReceiver = null; field in SubprocessTestResultsParser
172 if (mEventReceiver != null) { in joinReceiver()
175 if (!mEventReceiver.getCountDown().await(millis, TimeUnit.MILLISECONDS)) { in joinReceiver()
176 mEventReceiver.stopParsing(); in joinReceiver()
192 if (mEventReceiver != null) { in getSocketServerPort()
193 return mEventReceiver.getLocalPort(); in getSocketServerPort()
200 if (mEventReceiver != null) { in close()
201 mEventReceiver.cancel(); in close()
217 mEventReceiver = new EventReceiverThread(); in SubprocessTestResultsParser()
218 mEventReceiver.start(); in SubprocessTestResultsParser()