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.java44 private EventReceiverThread mEventReceiver; field in StreamProtoReceiver
154 mEventReceiver = new EventReceiverThread(); in StreamProtoReceiver()
155 mEventReceiver.start(); in StreamProtoReceiver()
206 if (mEventReceiver != null) { in getSocketServerPort()
207 return mEventReceiver.getLocalPort(); in getSocketServerPort()
219 if (mEventReceiver != null) { in close()
220 mEventReceiver.cancel(); in close()
225 if (mEventReceiver != null) { in joinReceiver()
232 if (!mEventReceiver.getCountDown().await(waitTime, TimeUnit.MILLISECONDS)) { in joinReceiver()
234 mEventReceiver.interrupt(); in joinReceiver()
/tools/tradefederation/core/src/com/android/tradefed/util/
DSubprocessTestResultsParser.java96 private EventReceiverThread mEventReceiver = null; field in SubprocessTestResultsParser
218 if (mEventReceiver != null) { in joinReceiver()
221 if (!mEventReceiver.await(millis, waitForConnection)) { in joinReceiver()
222 mEventReceiver.stopParsing(); in joinReceiver()
238 if (mEventReceiver != null) { in getSocketServerPort()
239 return mEventReceiver.getLocalPort(); in getSocketServerPort()
251 if (mEventReceiver != null) { in close()
252 mEventReceiver.cancel(); in close()
268 mEventReceiver = new EventReceiverThread(); in SubprocessTestResultsParser()
269 mEventReceiver.start(); in SubprocessTestResultsParser()