HomeSort by relevance Sort by last modified time
    Searched refs:openedSocket (Results 1 - 4 of 4) sorted by null

  /external/caliper/caliper/src/main/java/com/google/caliper/runner/
WorkerProcess.java 20 import com.google.caliper.bridge.OpenedSocket;
64 private final ListenableFuture<OpenedSocket> openedSocket;
69 ListenableFuture<OpenedSocket> openedSocket,
73 this.openedSocket = openedSocket;
78 ListenableFuture<OpenedSocket> openedSocket,
87 this.openedSocket = openedSocket
    [all...]
ServerSocketService.java 19 import com.google.caliper.bridge.OpenedSocket;
100 private final Map<UUID, SettableFuture<OpenedSocket>> halfFinishedConnections = Maps.newHashMap();
132 public ListenableFuture<OpenedSocket> getConnection(UUID id) {
150 OpenedSocket openedSocket = OpenedSocket.fromSocket(socket);
152 UUID id = ((StartupAnnounceMessage) openedSocket.reader().read()).trialId();
155 getConnectionImpl(id, Source.ACCEPT).set(openedSocket);
176 private SettableFuture<OpenedSocket> getConnectionImpl(UUID id, Source source) {
181 SettableFuture<OpenedSocket> future = halfFinishedConnections.get(id)
    [all...]
StreamService.java 21 import com.google.caliper.bridge.OpenedSocket;
110 private OpenedSocket.Writer socketWriter;
173 OpenedSocket openedSocket =
176 socketWriter = openedSocket.writer();
180 new SocketStreamReader(openedSocket.reader())));
389 * A background task that reads lines of text from a {@link OpenedSocket.Reader} and puts them
393 final OpenedSocket.Reader reader;
395 SocketStreamReader(OpenedSocket.Reader reader) {
  /external/caliper/caliper/src/test/java/com/google/caliper/runner/
FakeWorkers.java 19 import com.google.caliper.bridge.OpenedSocket;
176 OpenedSocket openedSocket = OpenedSocket.fromSocket(
178 OpenedSocket.Reader reader = openedSocket.reader();
179 OpenedSocket.Writer writer = openedSocket.writer();

Completed in 3095 milliseconds