This commit is contained in:
@@ -571,7 +571,6 @@ public abstract class WebSocketNode {
|
|||||||
protected boolean tryAcquireSemaphore() {
|
protected boolean tryAcquireSemaphore() {
|
||||||
if (this.semaphore == null) return true;
|
if (this.semaphore == null) return true;
|
||||||
try {
|
try {
|
||||||
System.out.println("---------this.semaphore.tryAcquire");
|
|
||||||
return this.semaphore.tryAcquire(6, TimeUnit.SECONDS);
|
return this.semaphore.tryAcquire(6, TimeUnit.SECONDS);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
return false;
|
return false;
|
||||||
@@ -580,6 +579,5 @@ public abstract class WebSocketNode {
|
|||||||
|
|
||||||
protected void releaseSemaphore() {
|
protected void releaseSemaphore() {
|
||||||
if (this.semaphore != null) this.semaphore.release();
|
if (this.semaphore != null) this.semaphore.release();
|
||||||
System.out.println("---------this.semaphore.release: " + this.semaphore);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user