mirror of
https://github.com/eclipse-cdt/cdt
synced 2025-08-19 14:15:50 +02:00
removing old source
This commit is contained in:
David McKnight
parent
078d44db9d
commit
71b765ec1a
1 changed files with 0 additions and 360 deletions
|
|
@ -1,360 +0,0 @@
|
||||||
/********************************************************************************
|
|
||||||
* Copyright (c) 2006 IBM Corporation. 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
|
|
||||||
*
|
|
||||||
* Initial Contributors:
|
|
||||||
* The following IBM employees contributed to the Remote System Explorer
|
|
||||||
* component that contains this file: David McKnight, Kushal Munir,
|
|
||||||
* Michael Berger, David Dykstal, Phil Coulthard, Don Yantzi, Eric Simpson,
|
|
||||||
* Emily Bruner, Mazen Faraj, Adrian Storisteanu, Li Ding, and Kent Hawley.
|
|
||||||
*
|
|
||||||
* Contributors:
|
|
||||||
* {Name} (company) - description of contribution.
|
|
||||||
********************************************************************************/
|
|
||||||
|
|
||||||
package org.eclipse.rse.subsystems.files.dstore.old;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
import java.io.File;
|
|
||||||
|
|
||||||
import org.eclipse.core.runtime.IProgressMonitor;
|
|
||||||
import org.eclipse.dstore.core.model.DE;
|
|
||||||
import org.eclipse.dstore.core.model.DataElement;
|
|
||||||
import org.eclipse.dstore.core.model.DataStore;
|
|
||||||
import org.eclipse.dstore.extra.internal.extra.DomainEvent;
|
|
||||||
import org.eclipse.dstore.extra.internal.extra.IDomainListener;
|
|
||||||
import org.eclipse.rse.connectorservice.dstore.util.ICommunicationsDiagnosticFactory;
|
|
||||||
import org.eclipse.rse.core.subsystems.CommunicationsEvent;
|
|
||||||
import org.eclipse.rse.core.subsystems.ICommunicationsListener;
|
|
||||||
import org.eclipse.rse.core.subsystems.IConnectorService;
|
|
||||||
import org.eclipse.rse.dstore.universal.miners.IUniversalDataStoreConstants;
|
|
||||||
import org.eclipse.rse.services.clientserver.messages.SystemMessage;
|
|
||||||
import org.eclipse.rse.ui.ISystemMessages;
|
|
||||||
import org.eclipse.rse.ui.RSEUIPlugin;
|
|
||||||
import org.eclipse.swt.widgets.Display;
|
|
||||||
import org.eclipse.swt.widgets.Shell;
|
|
||||||
|
|
||||||
public class DownloadListener implements IDomainListener, ICommunicationsListener, IUniversalDataStoreConstants
|
|
||||||
{
|
|
||||||
|
|
||||||
private DataElement _status;
|
|
||||||
private Shell _shell;
|
|
||||||
private IProgressMonitor _monitor;
|
|
||||||
private DataStore _dataStore;
|
|
||||||
private File _localFile;
|
|
||||||
private Display _display;
|
|
||||||
|
|
||||||
private boolean _networkDown = false;
|
|
||||||
private boolean _isDone = false;
|
|
||||||
private boolean _isCancelled = false;
|
|
||||||
private long _totalBytesNotified = 0;
|
|
||||||
private long _totalLength;
|
|
||||||
private static SystemMessage _percentMsg = RSEUIPlugin.getPluginMessage(ISystemMessages.MSG_PERCENT_DONE);
|
|
||||||
|
|
||||||
public DownloadListener(Shell shell, IProgressMonitor monitor, IConnectorService system, DataElement status, File localFile, String remotePath, long totalLength)
|
|
||||||
{
|
|
||||||
_shell = shell;
|
|
||||||
_monitor = monitor;
|
|
||||||
_status = status;
|
|
||||||
_totalLength = totalLength;
|
|
||||||
_display = Display.getCurrent();
|
|
||||||
|
|
||||||
if (_status == null)
|
|
||||||
{
|
|
||||||
System.out.println("Status is null!");
|
|
||||||
}
|
|
||||||
|
|
||||||
_dataStore = _status.getDataStore();
|
|
||||||
system.addCommunicationsListener(this);
|
|
||||||
_dataStore.getDomainNotifier().addDomainListener(this);
|
|
||||||
|
|
||||||
_localFile = localFile;
|
|
||||||
|
|
||||||
if (monitor != null)
|
|
||||||
{
|
|
||||||
while (_display!=null && _display.readAndDispatch()) {
|
|
||||||
//Process everything on event queue
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (_status.getValue().equals("done"))
|
|
||||||
{
|
|
||||||
updateDownloadState();
|
|
||||||
setDone(true);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
public boolean isCancelled()
|
|
||||||
{
|
|
||||||
return _isCancelled;
|
|
||||||
}
|
|
||||||
|
|
||||||
public DataElement getStatus()
|
|
||||||
{
|
|
||||||
return _status;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @see IDomainListener#listeningTo(DomainEvent)
|
|
||||||
*/
|
|
||||||
public boolean listeningTo(DomainEvent event)
|
|
||||||
{
|
|
||||||
if (_status == null)
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (_status == event.getParent())
|
|
||||||
{
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @see IDomainListener#domainChanged(DomainEvent)
|
|
||||||
*/
|
|
||||||
public void domainChanged(DomainEvent event)
|
|
||||||
{
|
|
||||||
if (_status.getValue().equals("done"))
|
|
||||||
{
|
|
||||||
|
|
||||||
if (_status == event.getParent())
|
|
||||||
{
|
|
||||||
setDone(true);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
updateDownloadState();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void updateDownloadState()
|
|
||||||
{
|
|
||||||
|
|
||||||
if (_monitor != null)
|
|
||||||
{
|
|
||||||
long currentLength = _localFile.length();
|
|
||||||
long delta = currentLength - _totalBytesNotified;
|
|
||||||
if (delta > 0)
|
|
||||||
{
|
|
||||||
//System.out.println(_status.getAttribute(DE.A_SOURCE));
|
|
||||||
_monitor.worked((int)delta);
|
|
||||||
|
|
||||||
try
|
|
||||||
{
|
|
||||||
long percent = (currentLength * 100) / _totalLength;
|
|
||||||
|
|
||||||
|
|
||||||
StringBuffer current = new StringBuffer();
|
|
||||||
current.append(currentLength /KB_IN_BYTES);
|
|
||||||
current.append(" KB");
|
|
||||||
|
|
||||||
StringBuffer total = new StringBuffer();
|
|
||||||
total.append(_totalLength / KB_IN_BYTES);
|
|
||||||
total.append(" KB");
|
|
||||||
|
|
||||||
StringBuffer percentBuf = new StringBuffer();
|
|
||||||
percentBuf.append(percent);
|
|
||||||
percentBuf.append("%");
|
|
||||||
|
|
||||||
_percentMsg.makeSubstitution(current, total, percentBuf);
|
|
||||||
|
|
||||||
_monitor.subTask(_percentMsg.getLevelOneText());
|
|
||||||
|
|
||||||
while (_display!=null && _display.readAndDispatch()) {
|
|
||||||
//Process everything on event queue
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
}
|
|
||||||
_totalBytesNotified = currentLength;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!_status.getDataStore().getStatus().getName().equals("okay"))
|
|
||||||
{
|
|
||||||
_networkDown = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* setDone(boolean)
|
|
||||||
*/
|
|
||||||
public void setDone(boolean done)
|
|
||||||
{
|
|
||||||
this._isDone = done;
|
|
||||||
if (done)
|
|
||||||
{
|
|
||||||
updateDownloadState();
|
|
||||||
_status.getDataStore().getDomainNotifier().removeDomainListener(this);
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @see IDomainListener#getShell()
|
|
||||||
*/
|
|
||||||
public Shell getShell()
|
|
||||||
{
|
|
||||||
return _shell;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public boolean wasCancelled()
|
|
||||||
{
|
|
||||||
return _isCancelled;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @see ICommunicationsListener#communicationsStateChange(CommunicationsEvent)
|
|
||||||
*/
|
|
||||||
public void communicationsStateChange(CommunicationsEvent e)
|
|
||||||
{
|
|
||||||
if (e.getState() == CommunicationsEvent.CONNECTION_ERROR)
|
|
||||||
{
|
|
||||||
_networkDown = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @see ICommunicationsListener#isPassiveCommunicationsListener()
|
|
||||||
*/
|
|
||||||
public boolean isPassiveCommunicationsListener()
|
|
||||||
{
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Wait for the the status DataElement to be refreshed
|
|
||||||
*
|
|
||||||
* @param
|
|
||||||
* ICommunicationsDiagnosticFactory factory : for creating system specific diagnostic class instance
|
|
||||||
* Int wait : threshold for starting diagnostic. Default is 60 seconds; a zero means to use the default.
|
|
||||||
* -1 means to force a timeout; mainly for testing purpose.
|
|
||||||
*
|
|
||||||
* @return The status DataElement after it has been updated, or the user
|
|
||||||
* has pressed cancel
|
|
||||||
*
|
|
||||||
* @throws InterruptedException if the thread was interrupted.
|
|
||||||
*/
|
|
||||||
public DataElement waitForUpdate() throws InterruptedException
|
|
||||||
{
|
|
||||||
return waitForUpdate(null, 0); //No diagnostic
|
|
||||||
}
|
|
||||||
|
|
||||||
public DataElement waitForUpdate(ICommunicationsDiagnosticFactory factory) throws InterruptedException
|
|
||||||
{
|
|
||||||
return waitForUpdate(factory, 0); //Use the default wait threshold
|
|
||||||
}
|
|
||||||
|
|
||||||
public DataElement waitForUpdate(ICommunicationsDiagnosticFactory factory, int wait) throws InterruptedException
|
|
||||||
{
|
|
||||||
Display display = _display;
|
|
||||||
|
|
||||||
if (wait > 0)
|
|
||||||
{
|
|
||||||
}
|
|
||||||
else if (wait == -1)
|
|
||||||
{
|
|
||||||
}
|
|
||||||
|
|
||||||
if (display != null)
|
|
||||||
{
|
|
||||||
if (_shell == null || _shell.isDisposed())
|
|
||||||
{
|
|
||||||
_shell = Display.getDefault().getActiveShell();
|
|
||||||
}
|
|
||||||
// Current thread is UI thread
|
|
||||||
while (!_isDone && !_isCancelled && !_networkDown)
|
|
||||||
{
|
|
||||||
while (display.readAndDispatch()) {
|
|
||||||
//Process everything on event queue
|
|
||||||
}
|
|
||||||
|
|
||||||
if ((_monitor != null) && (_monitor.isCanceled()))
|
|
||||||
{
|
|
||||||
// cancel remote request
|
|
||||||
cancelDownload();
|
|
||||||
_isCancelled = true;
|
|
||||||
setDone(true);
|
|
||||||
}
|
|
||||||
else if (_networkDown)
|
|
||||||
{
|
|
||||||
_isCancelled = true;
|
|
||||||
setDone(true);
|
|
||||||
throw new InterruptedException();
|
|
||||||
}
|
|
||||||
|
|
||||||
if (getStatus().getAttribute(DE.A_NAME).equals("done"))
|
|
||||||
{
|
|
||||||
setDone(true);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Thread.sleep(100);
|
|
||||||
updateDownloadState();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
// Current thread is not UI thread
|
|
||||||
while (!_isDone && !_isCancelled && !_networkDown)
|
|
||||||
{
|
|
||||||
if ((_monitor != null) && (_monitor.isCanceled()))
|
|
||||||
{
|
|
||||||
cancelDownload();
|
|
||||||
_isCancelled = true;
|
|
||||||
setDone(true);
|
|
||||||
}
|
|
||||||
else if (_networkDown)
|
|
||||||
{
|
|
||||||
_isCancelled = true;
|
|
||||||
setDone(true);
|
|
||||||
throw new InterruptedException();
|
|
||||||
}
|
|
||||||
|
|
||||||
if (getStatus().getAttribute(DE.A_NAME).equals("done"))
|
|
||||||
{
|
|
||||||
setDone(true);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Thread.sleep(100);
|
|
||||||
updateDownloadState();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return _status;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void cancelDownload()
|
|
||||||
{
|
|
||||||
DataElement status = _status;
|
|
||||||
if (status != null)
|
|
||||||
{
|
|
||||||
DataElement command = status.getParent();
|
|
||||||
DataStore dataStore = command.getDataStore();
|
|
||||||
DataElement cmdDescriptor = command.getDescriptor();
|
|
||||||
DataElement cancelDescriptor = dataStore.localDescriptorQuery(cmdDescriptor, "C_CANCEL");
|
|
||||||
if (cancelDescriptor != null)
|
|
||||||
{
|
|
||||||
dataStore.command(cancelDescriptor, command);
|
|
||||||
}
|
|
||||||
_localFile.delete();
|
|
||||||
}
|
|
||||||
if (_monitor != null)
|
|
||||||
{
|
|
||||||
_monitor.done();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Add table
Reference in a new issue