andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add missing synchronized

Browse Source
This commit is contained in:
Norman Maurer 2012-06-04 20:40:17 +02:00
parent 0e74b089c2
commit ecea558e03
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java
View File

@ -1559,6 +1559,7 @@ public class DefaultChannelPipeline implements ChannelPipeline {
public final void run() { public final void run() {
try { try {
runTask(); runTask();
} catch (Throwable t) { } catch (Throwable t) {
if (t instanceof ChannelException) { if (t instanceof ChannelException) {
cause = (ChannelException) t; cause = (ChannelException) t;
@ -1577,7 +1578,9 @@ public class DefaultChannelPipeline implements ChannelPipeline {
void await() { void await() {
try { try {
synchronized (ChannelPipelineModificationRunnable.this) {
wait(); wait();
}
if (cause != null) { if (cause != null) {
throw cause; throw cause;
} }