Searched refs:openedSocket (Results 1 – 4 of 4) sorted by relevance
64 private final ListenableFuture<OpenedSocket> openedSocket; field in WorkerProcess69 ListenableFuture<OpenedSocket> openedSocket, in WorkerProcess() argument73 this.openedSocket = openedSocket; in WorkerProcess()78 ListenableFuture<OpenedSocket> openedSocket, in WorkerProcess() argument87 this.openedSocket = openedSocket; in WorkerProcess()92 return openedSocket; in socketFuture()
150 OpenedSocket openedSocket = OpenedSocket.fromSocket(socket); in run() local152 UUID id = ((StartupAnnounceMessage) openedSocket.reader().read()).trialId(); in run()155 getConnectionImpl(id, Source.ACCEPT).set(openedSocket); in run()
173 OpenedSocket openedSocket = in doStart()176 socketWriter = openedSocket.writer(); in doStart()180 new SocketStreamReader(openedSocket.reader()))); in doStart()
176 OpenedSocket openedSocket = OpenedSocket.fromSocket( in main() local178 OpenedSocket.Reader reader = openedSocket.reader(); in main()179 OpenedSocket.Writer writer = openedSocket.writer(); in main()