equal
deleted
inserted
replaced
150 out.println(" with duration of " + duration); |
150 out.println(" with duration of " + duration); |
151 HttpRequest request = newRequest(uri, duration, reqVersion, method); |
151 HttpRequest request = newRequest(uri, duration, reqVersion, method); |
152 if (request == null) continue; |
152 if (request == null) continue; |
153 count++; |
153 count++; |
154 try { |
154 try { |
155 HttpResponse<?> resp = client.sendAsync(request, discard(null)).join(); |
155 HttpResponse<?> resp = client.sendAsync(request, discard()).join(); |
156 out.println("Unexpected response for: " + request); |
156 out.println("Unexpected response for: " + request); |
157 out.println("\t from " + ss.getLocalSocketAddress()); |
157 out.println("\t from " + ss.getLocalSocketAddress()); |
158 out.println("Response is: " + resp); |
158 out.println("Response is: " + resp); |
159 out.println("Headers: " + resp.headers().map()); |
159 out.println("Headers: " + resp.headers().map()); |
160 out.println("Body (should be null): " + resp.body()); |
160 out.println("Body (should be null): " + resp.body()); |
175 out.println(" with duration of " + duration); |
175 out.println(" with duration of " + duration); |
176 HttpRequest request = newRequest(uri, duration, reqVersion, method); |
176 HttpRequest request = newRequest(uri, duration, reqVersion, method); |
177 if (request == null) continue; |
177 if (request == null) continue; |
178 count++; |
178 count++; |
179 try { |
179 try { |
180 client.send(request, discard(null)); |
180 client.send(request, discard()); |
181 } catch (HttpTimeoutException e) { |
181 } catch (HttpTimeoutException e) { |
182 out.println("Caught expected timeout: " + e); |
182 out.println("Caught expected timeout: " + e); |
183 } |
183 } |
184 } |
184 } |
185 assert count >= TIMEOUTS.size() -1; |
185 assert count >= TIMEOUTS.size() -1; |