@Test public void testProcessIO_long_noLimit() throws Exception { System.out.println("processIOnolim"); SampleResult res = new SampleResult(); res.sampleStart(); String resp = TestJMeterUtils.getTestData(2048); instance.sockEmul.setBytesToRead(ByteBuffer.wrap(resp.getBytes())); byte[] result = instance.processIO(res); assertTrue(result.length > 1024); }
@Override protected byte[] processIO(SampleResult res) throws Exception { SocketChannel sock = getSocketChannel(); if (!getRequestData().isEmpty()) { ByteBuffer sendBuf = ByteBuffer.wrap(getRequestData().getBytes()); sock.write(sendBuf); } sendFile(getFileToSend(), sock); if (log.isDebugEnabled()) { log.debug("Sent request"); } return readResponse(sock, res); }
HTTPRawSampler extends AbstractIPSampler { @Override protected byte[] processIO(SampleResult res) throws Exception { SocketChannel sock = getSocketChannel(); if (!getRequestData().isEmpty()) { ByteBuffer sendBuf = ByteBuffer.wrap(getRequestData().getBytes()); sock.write(sendBuf); } sendFile(getFileToSend(), sock); if (log.isDebugEnabled()) { log.debug("Sent request"); } return readResponse(sock, res); } }
HTTPRawSampler extends AbstractIPSampler { @Override protected byte[] processIO(SampleResult res) throws Exception { SocketChannel sock = getSocketChannel(); if (!getRequestData().isEmpty()) { ByteBuffer sendBuf = ByteBuffer.wrap(getRequestData().getBytes()); sock.write(sendBuf); } sendFile(getFileToSend(), sock); if (log.isDebugEnabled()) { log.debug("Sent request"); } return readResponse(sock, res); } HTTPRawSampler(); }
HTTPRawSampler extends AbstractIPSampler { @Override protected byte[] processIO(SampleResult res) throws Exception { SocketChannel sock = getSocketChannel(); if (!getRequestData().isEmpty()) { ByteBuffer sendBuf = ByteBuffer.wrap(getRequestData().getBytes()); sock.write(sendBuf); } sendFile(getFileToSend(), sock); if (log.isDebugEnabled()) { log.debug("Sent request"); } return readResponse(sock, res); } HTTPRawSampler(); @Override SampleResult sample(Entry entry); boolean isUseKeepAlive(); void setUseKeepAlive(boolean selected); boolean isParseResult(); void setParseResult(boolean selected); String getFileToSend(); void setFileToSend(String text); @Override boolean interrupt(); }
HTTPRawSampler extends AbstractIPSampler { @Override protected byte[] processIO(SampleResult res) throws Exception { SocketChannel sock = getSocketChannel(); if (!getRequestData().isEmpty()) { ByteBuffer sendBuf = ByteBuffer.wrap(getRequestData().getBytes()); sock.write(sendBuf); } sendFile(getFileToSend(), sock); if (log.isDebugEnabled()) { log.debug("Sent request"); } return readResponse(sock, res); } HTTPRawSampler(); @Override SampleResult sample(Entry entry); boolean isUseKeepAlive(); void setUseKeepAlive(boolean selected); boolean isParseResult(); void setParseResult(boolean selected); String getFileToSend(); void setFileToSend(String text); @Override boolean interrupt();  }