HomeSort by relevance Sort by last modified time
    Searched full:openedsocket (Results 1 - 10 of 10) sorted by null

  /external/caliper/caliper/src/test/java/com/google/caliper/runner/
ServerSocketServiceTest.java 22 import com.google.caliper.bridge.OpenedSocket;
59 ListenableFuture<OpenedSocket> pendingServerConnection = service.getConnection(id);
61 OpenedSocket clientSocket = openConnectionAndIdentify(id);
68 OpenedSocket clientSocket = openConnectionAndIdentify(id);
70 ListenableFuture<OpenedSocket> pendingServerConnection = service.getConnection(id);
72 OpenedSocket serverSocket = pendingServerConnection.get();
83 ListenableFuture<OpenedSocket> pendingServerConnection = service.getConnection(id);
101 private OpenedSocket openClientConnection() throws IOException {
102 return OpenedSocket.fromSocket(new Socket(InetAddress.getLoopbackAddress(), port));
108 private OpenedSocket openConnectionAndIdentify(UUID id) throws IOException
    [all...]
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();
StreamServiceTest.java 25 import com.google.caliper.bridge.OpenedSocket;
237 private ListenableFuture<OpenedSocket> getSocketFuture() {
238 ListenableFutureTask<OpenedSocket> openSocketTask = ListenableFutureTask.create(
239 new Callable<OpenedSocket>() {
241 public OpenedSocket call() throws Exception {
242 return OpenedSocket.fromSocket(serverSocket.accept());
  /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) {
TrialModule.java 22 import com.google.caliper.bridge.OpenedSocket;
84 static ListenableFuture<OpenedSocket> provideTrialSocket(
  /external/caliper/caliper/src/main/java/com/google/caliper/worker/
WorkerEventLog.java 20 import com.google.caliper.bridge.OpenedSocket;
34 private final OpenedSocket.Writer writer;
35 private final OpenedSocket.Reader reader;
37 WorkerEventLog(OpenedSocket socket) {
WorkerMain.java 20 import com.google.caliper.bridge.OpenedSocket;
51 WorkerEventLog log = new WorkerEventLog(OpenedSocket.fromSocket(channel));
  /external/caliper/caliper/src/main/java/com/google/caliper/bridge/
OpenedSocket.java 34 public final class OpenedSocket {
36 * Waits for the channel to connect and returns a new {@link OpenedSocket}.
38 public static OpenedSocket fromSocket(SocketChannel socket) throws IOException {
44 * Returns a new {@link OpenedSocket} for the given connected {@link Socket} instance.
46 public static OpenedSocket fromSocket(Socket socket) throws IOException {
60 return new OpenedSocket(new Reader(input), new Writer(output));
66 private OpenedSocket(Reader reader,

Completed in 2090 milliseconds