Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoreutarass2010-05-13 15:27:58 -0400
committereutarass2010-05-13 15:27:58 -0400
commit9d2e2103d28862754bbb07259fa0bc32530c1312 (patch)
tree21e765710963704fc534d0c6ac652e6af6fa3c88
parentb4b1780a58ca677a1c10d954e3789ef15cd38140 (diff)
downloadorg.eclipse.tcf-9d2e2103d28862754bbb07259fa0bc32530c1312.tar.gz
org.eclipse.tcf-9d2e2103d28862754bbb07259fa0bc32530c1312.tar.xz
org.eclipse.tcf-9d2e2103d28862754bbb07259fa0bc32530c1312.zip
TCF Core: fixed: missing code to handle "command rejected" messages
-rw-r--r--plugins/org.eclipse.tm.tcf.core/src/org/eclipse/tm/internal/tcf/services/local/ChannelProxy.java10
1 files changed, 4 insertions, 6 deletions
diff --git a/plugins/org.eclipse.tm.tcf.core/src/org/eclipse/tm/internal/tcf/services/local/ChannelProxy.java b/plugins/org.eclipse.tm.tcf.core/src/org/eclipse/tm/internal/tcf/services/local/ChannelProxy.java
index 9a760cef2..da46a156b 100644
--- a/plugins/org.eclipse.tm.tcf.core/src/org/eclipse/tm/internal/tcf/services/local/ChannelProxy.java
+++ b/plugins/org.eclipse.tm.tcf.core/src/org/eclipse/tm/internal/tcf/services/local/ChannelProxy.java
@@ -90,12 +90,11 @@ class ChannelProxy {
}
public void result(IToken token, byte[] data) {
- ch_x.sendResult(tokens_x.get(token), data);
- tokens_x.remove(token);
+ ch_x.sendResult(tokens_x.remove(token), data);
}
public void terminated(IToken token, Exception error) {
- tokens_x.remove(token);
+ ch_x.rejectCommand(tokens_x.remove(token));
}
};
@@ -106,12 +105,11 @@ class ChannelProxy {
}
public void result(IToken token, byte[] data) {
- ch_y.sendResult(tokens_y.get(token), data);
- tokens_y.remove(token);
+ ch_y.sendResult(tokens_y.remove(token), data);
}
public void terminated(IToken token, Exception error) {
- tokens_y.remove(token);
+ ch_y.rejectCommand(tokens_y.remove(token));
}
};

Back to the top