lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2019-01-19 16:28:44 +08:00
parent fea34863e3
commit a321b41699
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/org/redkale/net/http/WebSocketNode.java
View File

@@ -59,7 +59,11 @@ public abstract class WebSocketNode {
protected Semaphore semaphore; protected Semaphore semaphore;
private int tryAcquireSeconds = 12;
public void init(AnyValue conf) { public void init(AnyValue conf) {
this.tryAcquireSeconds = Integer.getInteger("WebSocketNode.tryAcquireSeconds", 12);
if (sncpNodeAddresses != null && "memory".equals(sncpNodeAddresses.getType())) { if (sncpNodeAddresses != null && "memory".equals(sncpNodeAddresses.getType())) {
sncpNodeAddresses.initValueType(InetSocketAddress.class); sncpNodeAddresses.initValueType(InetSocketAddress.class);
} }
@@ -775,7 +779,7 @@ public abstract class WebSocketNode {
protected boolean tryAcquireSemaphore() { protected boolean tryAcquireSemaphore() {
if (this.semaphore == null) return true; if (this.semaphore == null) return true;
try { try {
return this.semaphore.tryAcquire(6, TimeUnit.SECONDS); return this.semaphore.tryAcquire(tryAcquireSeconds, TimeUnit.SECONDS);
} catch (Exception e) { } catch (Exception e) {
return false; return false;
} }