mirrors/cdt
1
0
Fork 0
mirror of https://github.com/eclipse-cdt/cdt synced 2025-07-09 10:05:24 +02:00
Code Issues Wiki Activity

[175908] dstore output stream for upload

Browse source
This commit is contained in:
David McKnight 2007-02-28 21:11:13 +00:00
parent dfe4d13b53
commit 95f088ea7b
2 changed files with 106 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
rse/plugins/org.eclipse.rse.services.dstore/src/org/eclipse/rse/services/dstore/files/DStoreFileService.java
View file

@ -1300,7 +1300,18 @@ public class DStoreFileService extends AbstractDStoreService implements IFileSer
* @see org.eclipse.rse.services.files.IFileService#getOutputStream(org.eclipse.core.runtime.IProgressMonitor, java.lang.String, java.lang.String, boolean) * @see org.eclipse.rse.services.files.IFileService#getOutputStream(org.eclipse.core.runtime.IProgressMonitor, java.lang.String, java.lang.String, boolean)
*/ */
public OutputStream getOutputStream(IProgressMonitor monitor, String remoteParent, String remoteFile, boolean isBinary) throws SystemMessageException { public OutputStream getOutputStream(IProgressMonitor monitor, String remoteParent, String remoteFile, boolean isBinary) throws SystemMessageException {
// TODO Auto-generated method stub String remotePath = remoteParent + getSeparator(remoteParent) + remoteFile;
return null; int mode;
if (isBinary)
{
mode = BINARY_MODE;
}
else
{
mode = TEXT_MODE;
}
DStoreOutputStream outputStream = new DStoreOutputStream(getDataStore(), remotePath, getEncoding(monitor), mode);
return outputStream;
} }
} }

98
rse/plugins/org.eclipse.rse.services.dstore/src/org/eclipse/rse/services/dstore/files/DStoreOutputStream.java
View file

@ -16,17 +16,105 @@ package org.eclipse.rse.services.dstore.files;
import java.io.IOException; import java.io.IOException;
import java.io.OutputStream; import java.io.OutputStream;
import org.eclipse.dstore.core.model.DataStore;
import org.eclipse.rse.dstore.universal.miners.IUniversalDataStoreConstants;
import org.eclipse.rse.dstore.universal.miners.filesystem.UniversalByteStreamHandler;
public class DStoreOutputStream extends OutputStream public class DStoreOutputStream extends OutputStream
{ {
public DStoreOutputStream() private DataStore _dataStore;
{ private String _remotePath;
private String _encoding;
private int _mode;
private boolean _firstWrite = true;
private String _byteStreamHandlerId;
public DStoreOutputStream(DataStore dataStore, String remotePath, String encoding, int mode)
{
_dataStore = dataStore;
_remotePath = remotePath;
_encoding = encoding;
_mode = mode;
_byteStreamHandlerId = UniversalByteStreamHandler.class.getName();
} }
public void write(int arg0) throws IOException
public void close() throws IOException
{ {
// TODO Auto-generated method stub // TODO Auto-generated method stub
super.close();
} }
public void flush() throws IOException {
// TODO Auto-generated method stub
super.flush();
}
public void write(byte[] b, int offset, int length) throws IOException
{
if (_mode == IUniversalDataStoreConstants.TEXT_MODE)
{
String tempStr = new String(b, 0, length);
b = tempStr.getBytes(_encoding);
}
if (_firstWrite)
{
_firstWrite = false;
// send first set of bytes
_dataStore.replaceFile(_remotePath, b, length, true, _byteStreamHandlerId);
}
else
{ // append subsequent segments
_dataStore.replaceAppendFile(_remotePath, b, length, true, _byteStreamHandlerId);
}
}
public void write(byte[] b) throws IOException
{
if (_mode == IUniversalDataStoreConstants.TEXT_MODE)
{
String tempStr = new String(b, 0, b.length);
b = tempStr.getBytes(_encoding);
}
if (_firstWrite)
{
_firstWrite = false;
// send first set of bytes
_dataStore.replaceFile(_remotePath, b, b.length, true, _byteStreamHandlerId);
}
else
{ // append subsequent segments
_dataStore.replaceAppendFile(_remotePath, b, b.length, true, _byteStreamHandlerId);
}
}
public void write(int c) throws IOException
{
byte[] b = {(byte)c};
if (_mode == IUniversalDataStoreConstants.TEXT_MODE)
{
String tempStr = new String(b, 0, 1);
b = tempStr.getBytes(_encoding);
}
if (_firstWrite)
{
_firstWrite = false;
// send first set of bytes
_dataStore.replaceFile(_remotePath, b, b.length, true, _byteStreamHandlerId);
}
else
{ // append subsequent segments
_dataStore.replaceAppendFile(_remotePath, b, b.length, true, _byteStreamHandlerId);
}
}
} }