Databases
StackOverflow2013
Postsdbo
PORepeated calls by Restlet client to Restlet server hangs
 

Note that there are some explanatory texts on larger screens.

plurals
  1. PORepeated calls by Restlet client to Restlet server hangs
    primarykey
    data
    text
    <p>I am using Restlet to implement a web service. The client (also uses Restlet) makes many consecutive calls to the server, but after a small number of calls complete successfully, further calls hang the server, which shows the message: </p> <blockquote> <p>INFO: Stop accepting new connections and transactions. Consider increasing the maximum number of threads.</p> </blockquote> <p>I tried:</p> <pre><code>getContext().getParameters().add("maxThreads", "200"); </code></pre> <p>but that does not help. In any case, it seems like the client should be able to make an unlimited number of calls, and increasing maxThreads just ups the limit. It looks like I am not freeing up some resource or disconnecting after each client call, but I do not know how to do so. </p> <p>The following (small as I could make it) stand alone program demonstrates the problem. It starts a simple server and then a client calls it a bunch of times:</p> <pre><code>/** You may copy, modify, and re-use this code as you see fit - Jim Irrer */ import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.InputStream; import org.restlet.Application; import org.restlet.Component; import org.restlet.Request; import org.restlet.Response; import org.restlet.Restlet; import org.restlet.Server; import org.restlet.data.MediaType; import org.restlet.data.Method; import org.restlet.data.Protocol; import org.restlet.data.Status; import org.restlet.representation.InputRepresentation; import org.restlet.representation.Representation; import org.restlet.resource.ClientResource; import org.restlet.resource.Directory; public class SimpleServerPut extends Component implements Runnable { private static final int PORT = 8080; private static int readToByteArray(InputStream inputStream, byte[] buf) throws IOException { int length = 0; int b; while ((b = inputStream.read()) != -1) { buf[length++] = (byte)b; } return length; } @Override public void run() { getContext().getParameters().add("maxThreads", "200"); // Create the HTTP server and listen on port PORT SimpleServerPut simpleServer = new SimpleServerPut(); Server server = new Server(Protocol.HTTP, PORT, simpleServer); simpleServer.getClients().add(Protocol.FILE); // Create an application Application application = new Application(simpleServer.getContext()) { @Override public Restlet createRoot() { return new Directory(getContext(), "C:"); } }; // Attach the application to the component and start it simpleServer.getDefaultHost().attach("/stuff/", application); try { server.start(); } catch (Exception ex) { ex.printStackTrace(); } } @Override public void handle(Request request, Response response) { // assume the worst response.setStatus(Status.CLIENT_ERROR_METHOD_NOT_ALLOWED); response.setEntity("No no - Bad client! Only do PUTs.", MediaType.TEXT_PLAIN); try { if (request.getMethod() == Method.PUT) { InputStream inputStream = request.getEntity().getStream(); byte[] buf = new byte[64*1024]; int totalLength = readToByteArray(inputStream, buf); response.setStatus(Status.SUCCESS_OK); String msg = "Number of bytes received: " + totalLength; response.setEntity(msg, MediaType.TEXT_PLAIN); System.out.println("server: " + msg); return; } } catch (Exception ex) { ex.printStackTrace(); } } private static String callServer() throws IOException { String urlText = "http://localhost:" + PORT + "/"; ClientResource clientResource = new ClientResource(urlText); clientResource.setReferrerRef(urlText); byte[] buf = new byte[1000]; for (int i = 0; i &lt; buf.length; i++) { buf[i] = (byte)((int)'a' + (i%26)); } ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(buf); Representation representation = new InputRepresentation(byteArrayInputStream, MediaType.APPLICATION_OCTET_STREAM); Representation representation2 = clientResource.put(representation); byte[] responseBuf = new byte[16*1024]; int length = readToByteArray(representation2.getStream(), responseBuf); Response response = clientResource.getResponse(); Status status = response.getStatus(); return "status: " + status + " message: " + new String(responseBuf, 0, length); } // Start server and call it a bunch of times public static void main(String[] args) throws Exception { SimpleServerPut simpleServer = new SimpleServerPut(); new Thread(simpleServer).start(); Thread.sleep(200); // cheap trick to make sure that server is running // make a bunch of client calls for (int t = 0; t &lt; 100; t++) { System.out.println("client count: " + (t+1) + " " + callServer()); } System.exit(0); } } </code></pre>
    singulars
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. PTQuestion
    1. USDave Newton
    1. USuser1062589
    plurals
    1. This table or related slice is empty.
    1. PL
      singulars
      1. LTLinked
    1. This table or related slice is empty.
    1. PO
      singulars
      1. PTAnswer
    2. PO
      singulars
      1. PTAnswer
    3. PO
      singulars
      1. PTAnswer
    1. VO
      singulars
      1. PORepeated calls by Restlet client to Restlet server hangs
      1. This table or related slice is empty.
      1. VTUpMod
    2. VO
      singulars
      1. PORepeated calls by Restlet client to Restlet server hangs
      1. This table or related slice is empty.
      1. VTUpMod
    3. VO
      singulars
      1. PORepeated calls by Restlet client to Restlet server hangs
      1. This table or related slice is empty.
      1. VTUpMod
    1. This table or related slice is empty.
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload