jlengrand/vert.x
1
0
Fork 0
mirror of https://github.com/jlengrand/vert.x.git synced 2026-03-10 08:51:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Set handler in synchronized block. Invoke handler outsied of synchronized block

Browse Source 
Signed-off-by: Michal Michalowski <michal.michalowski@openet.com>
This commit is contained in:
Michal Michalowski
2018-11-09 12:34:12 +01:00
parent 288c8b7962
commit 6d64e86016
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/io/vertx/core/http/impl/Http2ServerRequestImpl.java
View File

@@ -523,22 +523,26 @@ public class Http2ServerRequestImpl extends VertxHttp2Stream<Http2ServerConnecti
@Override
public HttpServerRequest streamPriorityHandler(Handler<StreamPriority> handler) {
streamPriorityHandler = handler;
synchronized (conn) {
streamPriorityHandler = handler;
}
return this;
}
@Override
void handlePriorityChange(StreamPriority streamPriority) {
System.out.println(getClass().getName() + ".handlePriorityChange(" + streamPriority + ")");
Handler<StreamPriority> handler;
boolean priorityChanged = false;
synchronized (conn) {
Handler<StreamPriority> handler = streamPriorityHandler;
if (handler != null) {
if(streamPriority != null && !streamPriority.equals(getStreamPriority())) {
handler = streamPriorityHandler;
if(streamPriority != null && !streamPriority.equals(getStreamPriority())) {
setStreamPriority(streamPriority);
handler.handle(streamPriority);
}
priorityChanged = true;
}
}
if (handler != null && priorityChanged) {
handler.handle(streamPriority);
}
}
}