Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorUwe Stieber2014-06-13 08:14:46 +0000
committerUwe Stieber2014-06-13 08:14:46 +0000
commit337808b6a3816f68cd679af3d5bfd1e6276cf789 (patch)
treeb8d83b327f6f053f6a2ba5535e24cdd178d9b1a9
parent8a82ded6233caa706c558d3ebbb8eab71cd32753 (diff)
downloadorg.eclipse.tcf-337808b6a3816f68cd679af3d5bfd1e6276cf789.tar.gz
org.eclipse.tcf-337808b6a3816f68cd679af3d5bfd1e6276cf789.tar.xz
org.eclipse.tcf-337808b6a3816f68cd679af3d5bfd1e6276cf789.zip
Target Explorer: Review registration and removal of channel listener in channel manager
-rw-r--r--target_explorer/plugins/org.eclipse.tcf.te.tcf.core/src/org/eclipse/tcf/te/tcf/core/internal/ChannelManager.java6
1 files changed, 6 insertions, 0 deletions
diff --git a/target_explorer/plugins/org.eclipse.tcf.te.tcf.core/src/org/eclipse/tcf/te/tcf/core/internal/ChannelManager.java b/target_explorer/plugins/org.eclipse.tcf.te.tcf.core/src/org/eclipse/tcf/te/tcf/core/internal/ChannelManager.java
index 4812dea88..2ce89d842 100644
--- a/target_explorer/plugins/org.eclipse.tcf.te.tcf.core/src/org/eclipse/tcf/te/tcf/core/internal/ChannelManager.java
+++ b/target_explorer/plugins/org.eclipse.tcf.te.tcf.core/src/org/eclipse/tcf/te/tcf/core/internal/ChannelManager.java
@@ -298,11 +298,13 @@ public final class ChannelManager extends PlatformObject implements IChannelMana
@Override
public void onChannelOpened() {
+ finChannel.removeChannelListener(this);
done.doneOpenChannel(null, finChannel);
}
@Override
public void onChannelClosed(Throwable error) {
+ finChannel.removeChannelListener(this);
done.doneOpenChannel(error != null ? error : new OperationCanceledException(), finChannel);
}
@@ -992,10 +994,12 @@ public final class ChannelManager extends PlatformObject implements IChannelMana
channel.addChannelListener(new IChannel.IChannelListener() {
@Override
public void onChannelOpened() {
+ finChannel.removeChannelListener(this);
done.doneOpenChannel(null, finChannel);
}
@Override
public void onChannelClosed(Throwable error) {
+ finChannel.removeChannelListener(this);
done.doneOpenChannel(error != null ? error : new OperationCanceledException(), finChannel);
}
@Override
@@ -1250,10 +1254,12 @@ public final class ChannelManager extends PlatformObject implements IChannelMana
channel.addChannelListener(new IChannel.IChannelListener() {
@Override
public void onChannelOpened() {
+ finChannel.removeChannelListener(this);
done.doneOpenChannel(null, finChannel);
}
@Override
public void onChannelClosed(Throwable error) {
+ finChannel.removeChannelListener(this);
done.doneOpenChannel(error != null ? error : new OperationCanceledException(), finChannel);
}
@Override

Back to the top