"optimized" memory usage

Davidiusdadi · Davidiusdadi · commit 7b0fd6648801 · 2012-05-20T15:21:34.000+02:00
diff --git a/src/org/java_websocket/WebSocket.java b/src/org/java_websocket/WebSocket.java
@@ -16,7 +16,7 @@ public enum Role {
 		CLIENT, SERVER
 	}
 
-	public static int RCVBUF = 64;
+	public static int RCVBUF = 256;
 
 	public static/*final*/boolean DEBUG = false; // must be final in the future in order to take advantage of VM optimization
 
diff --git a/src/org/java_websocket/WebSocketServer.java b/src/org/java_websocket/WebSocketServer.java
@@ -293,11 +293,14 @@ public void run() {
 	}
 
 	protected void allocateBuffers( WebSocket c ) throws InterruptedException {
+		if( queuesize.get() >= 2 * decoders.size() + 1 ) {
+			return;
+		}
 		queuesize.incrementAndGet();
 		buffers.put( createBuffer() );
 	}
 	protected void releaseBuffers( WebSocket c ) throws InterruptedException {
-		queuesize.decrementAndGet();
+		// queuesize.decrementAndGet();
 		// takeBuffer();
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@ public enum Role {`
`16`	`16`	`CLIENT, SERVER`
`17`	`17`	`}`
`18`	`18`
`19`		`- public static int RCVBUF = 64;`
	`19`	`+ public static int RCVBUF = 256;`
`20`	`20`
`21`	`21`	`public static/final/boolean DEBUG = false; // must be final in the future in order to take advantage of VM optimization`
`22`	`22`
Original file line number	Diff line number	Diff line change
`@@ -293,11 +293,14 @@ public void run() {`
`293`	`293`	`}`
`294`	`294`
`295`	`295`	`protected void allocateBuffers( WebSocket c ) throws InterruptedException {`
	`296`	`+ if( queuesize.get() >= 2 * decoders.size() + 1 ) {`
	`297`	`+ return;`
	`298`	`+ }`
`296`	`299`	`queuesize.incrementAndGet();`
`297`	`300`	`buffers.put( createBuffer() );`
`298`	`301`	`}`
`299`	`302`	`protected void releaseBuffers( WebSocket c ) throws InterruptedException {`
`300`		`- queuesize.decrementAndGet();`
	`303`	`+ // queuesize.decrementAndGet();`
`301`	`304`	`// takeBuffer();`
`302`	`305`	`}`
`303`	`306`