Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'target_explorer/plugins/org.eclipse.tm.te.tcf.filesystem/src/org/eclipse/tm/te/tcf/filesystem/internal/url/TcfInputStream.java')
-rw-r--r--target_explorer/plugins/org.eclipse.tm.te.tcf.filesystem/src/org/eclipse/tm/te/tcf/filesystem/internal/url/TcfInputStream.java6
1 files changed, 6 insertions, 0 deletions
diff --git a/target_explorer/plugins/org.eclipse.tm.te.tcf.filesystem/src/org/eclipse/tm/te/tcf/filesystem/internal/url/TcfInputStream.java b/target_explorer/plugins/org.eclipse.tm.te.tcf.filesystem/src/org/eclipse/tm/te/tcf/filesystem/internal/url/TcfInputStream.java
index 9cd49721c..f446ef585 100644
--- a/target_explorer/plugins/org.eclipse.tm.te.tcf.filesystem/src/org/eclipse/tm/te/tcf/filesystem/internal/url/TcfInputStream.java
+++ b/target_explorer/plugins/org.eclipse.tm.te.tcf.filesystem/src/org/eclipse/tm/te/tcf/filesystem/internal/url/TcfInputStream.java
@@ -153,15 +153,18 @@ public class TcfInputStream extends InputStream {
// Open the channel
channel = peer.openChannel();
channel.addChannelListener(new IChannelListener() {
+ @Override
public void onChannelOpened() {
Assert.isTrue(Protocol.isDispatchThread());
service = channel.getRemoteService(IFileSystem.class);
rendezvous.arrive();
}
+ @Override
public void onChannelClosed(Throwable error) {
}
+ @Override
public void congestionLevel(int level) {
}
});
@@ -176,6 +179,7 @@ public class TcfInputStream extends InputStream {
final FileSystemException[] errors = new FileSystemException[1];
// Open the file.
service.open(path, IFileSystem.TCF_O_READ, null, new DoneOpen() {
+ @Override
public void doneOpen(IToken token, FileSystemException error,
IFileHandle hdl) {
errors[0] = error;
@@ -250,6 +254,7 @@ public class TcfInputStream extends InputStream {
private void readBlock() {
final Rendezvous rendezvous = new Rendezvous();
service.read(handle, position, chunk_size, new DoneRead() {
+ @Override
public void doneRead(IToken token, FileSystemException error,
byte[] data, boolean eof) {
if (error != null) {
@@ -285,6 +290,7 @@ public class TcfInputStream extends InputStream {
if (connected && !closed) {
final Rendezvous rendezvous = new Rendezvous();
service.close(handle, new DoneClose() {
+ @Override
public void doneClose(IToken token, FileSystemException error) {
rendezvous.arrive();
}

Back to the top