1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
/*******************************************************************************
* Copyright (c) 2014, 2015 Wind River Systems, Inc.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Markus Schorn - initial API and implementation
*******************************************************************************/
package org.eclipse.tcf.te.tcf.remote.core.operation;
import static java.text.MessageFormat.format;
import java.util.HashMap;
import java.util.Map;
import org.eclipse.tcf.services.IFileSystem;
import org.eclipse.tcf.services.IFileSystem.DoneStat;
import org.eclipse.tcf.services.IFileSystem.FileAttrs;
import org.eclipse.tcf.te.tcf.locator.interfaces.nodes.IPeerNode;
import org.eclipse.tcf.te.tcf.remote.core.TCFFileStore;
import org.eclipse.tcf.te.tcf.remote.core.nls.Messages;
import org.eclipse.tcf.te.tcf.remote.core.operation.PeerInfo.DoneGetFileSystem;
import org.eclipse.tcf.te.tcf.remote.core.operation.PeerInfo.DoneGetUser;
public abstract class TCFFileStoreOperation<T> extends TCFOperation<T> {
private static final Map<String, PeerInfo> fPeerInfos = new HashMap<String, PeerInfo>();
private final TCFFileStore fFileStore;
protected TCFFileStoreOperation(TCFFileStore fileStore) {
fFileStore = fileStore;
}
protected final TCFFileStore getFileStore() {
return fFileStore;
}
protected final String getPath() {
return fFileStore.getPath().toString();
}
protected final IPeerNode getPeerNode() {
return fFileStore.getConnection().getPeerNode();
}
private final PeerInfo getPeerInfo(IPeerNode peerNode) {
String key = peerNode.getName();
PeerInfo result = fPeerInfos.get(key);
if (result == null) {
result = new PeerInfo();
fPeerInfos.put(key, result);
}
return result;
}
protected final void getFileSystem(DoneGetFileSystem callback) {
IPeerNode peerNode = getPeerNode();
if (peerNode == null) {
setError(createStatus(format(Messages.TCFFileStoreOperation_errorNotConnected, fFileStore.getConnection().getName()), null));
} else {
getPeerInfo(peerNode).getFileSystem(peerNode, callback);
}
}
protected final void getUser(IFileSystem fileSystem, DoneGetUser callback) {
IPeerNode peerNode = getPeerNode();
if (peerNode == null) {
setError(createStatus(format(Messages.TCFFileStoreOperation_errorNotConnected, fFileStore.getConnection().getName()), null));
} else {
getPeerInfo(peerNode).getUser(fileSystem, callback);
}
}
protected final void stat(IFileSystem fileSystem, TCFFileStore fileStore, DoneStat doneStat) {
FileAttrs attrs = fileStore.getAttributes();
if (attrs != null) {
doneStat.doneStat(null, null, attrs);
} else {
fileSystem.stat(fileStore.getPath().toString(), doneStat);
}
}
}
|
