196197198199200201202203204205206
try { clientSocket.close(); } catch (Exception e) { log.error("", e); } sampler.threadFinished(); // Needed for HTTPSampler2 } } /** * Write output to the output stream, then flush and close the stream.
242243244245246247248249250251252
try { clientSocket.close(); } catch (Exception e) { log.error("", e); } sampler.threadFinished(); // Needed for HTTPSampler2 } } private SampleResult generateErrorResult(SampleResult result, Exception e) { if (result == null) {
281282283284285286287288289290291
clientSocket.close(); } catch (Exception e) { log.error(port + "Failed to close client socket", e); } if(sampler != null) { sampler.threadFinished(); // Needed for HTTPSampler2 } } } /**
321322323324325326327328329330331
{ te.threadStarted(); } else { te.threadFinished(); } } } public void subtractNode()
351352353354355356357358359360361
378379380381382383384385386387388
366367368369370371372373374375376
if (node instanceof TestElement) { TestElement te = (TestElement) node; if (isStart) { te.threadStarted(); } else { te.threadFinished(); } } } public void subtractNode() {
594595596597598599600601602603604
if (node instanceof ThreadListener) { ThreadListener tl = (ThreadListener) node; if (isStart) { tl.threadStarted(); } else { tl.threadFinished(); } } } @Override
466467468469470471472473474475476
if (node instanceof ThreadListener) { ThreadListener tl = (ThreadListener) node; if (isStart) { tl.threadStarted(); } else { tl.threadFinished(); } } } public void subtractNode() {
469470471472473474475476477478479