equal
deleted
inserted
replaced
54 for (int i = 0; ; i++) { // fill up the send buffer |
54 for (int i = 0; ; i++) { // fill up the send buffer |
55 long start = System.currentTimeMillis(); |
55 long start = System.currentTimeMillis(); |
56 System.out.printf("begin cycle #%s at %s%n", i, start); |
56 System.out.printf("begin cycle #%s at %s%n", i, start); |
57 cfText = webSocket.sendText(data, last); |
57 cfText = webSocket.sendText(data, last); |
58 try { |
58 try { |
59 cfText.get(5, TimeUnit.SECONDS); |
59 cfText.get(MAX_WAIT_SEC, TimeUnit.SECONDS); |
60 data.clear(); |
60 data.clear(); |
61 } catch (TimeoutException e) { |
61 } catch (TimeoutException e) { |
62 break; |
62 break; |
63 } finally { |
63 } finally { |
64 long stop = System.currentTimeMillis(); |
64 long stop = System.currentTimeMillis(); |