ProgressPanelpublic class ProgressPanel extends AbstractWizardPanel implements TOTorrentProgressListener
| Fields Summary |
|---|
| org.eclipse.swt.widgets.Text | tasks | | org.eclipse.swt.widgets.ProgressBar | progress | | org.eclipse.swt.widgets.Display | display |
| Methods Summary |
|---|
| public void | finish()
Thread t = new AEThread("Torrent Maker") {
public void runSupport() {
makeTorrent();
}
};
t.setPriority(Thread.MIN_PRIORITY);
t.setDaemon(true);
t.start();
| | public void | makeTorrent()
NewTorrentWizard _wizard = (NewTorrentWizard)wizard;
int tracker_type = _wizard.getTrackerType();
if( tracker_type == NewTorrentWizard.TT_EXTERNAL ){
TrackersUtil.getInstance().addTracker(_wizard.trackerURL);
}
File f;
if (_wizard.create_from_dir) {
f = new File(_wizard.directoryPath);
}
else {
f = new File(_wizard.singlePath);
}
try {
URL url = new URL(_wizard.trackerURL);
final TOTorrent torrent;
if ( _wizard.getPieceSizeComputed()){
_wizard.creator =
TOTorrentFactory.createFromFileOrDirWithComputedPieceLength(
f, url, _wizard.getAddOtherHashes());
_wizard.creator.addListener( this );
torrent = _wizard.creator.create();
}else{
TOTorrentCreator c =
TOTorrentFactory.createFromFileOrDirWithFixedPieceLength(
f, url, _wizard.getAddOtherHashes(), _wizard.getPieceSizeManual());
c.addListener( this );
torrent = c.create();
}
if ( tracker_type == NewTorrentWizard.TT_DECENTRAL ){
TorrentUtils.setDecentralised( torrent );
}
torrent.setComment(_wizard.getComment());
TorrentUtils.setDHTBackupEnabled( torrent, _wizard.permitDHT );
TorrentUtils.setPrivate( torrent, _wizard.privateTorrent );
LocaleTorrentUtil.setDefaultTorrentEncoding( torrent );
// mark this newly created torrent as complete to avoid rechecking on open
final File save_dir;
if (_wizard.create_from_dir){
save_dir = f;
}else{
save_dir = f.getParentFile();
}
if(_wizard.useMultiTracker) {
this.reportCurrentTask(MessageText.getString("wizard.addingmt"));
TorrentUtils.listToAnnounceGroups(((NewTorrentWizard)wizard).trackers, torrent);
}
if (_wizard.useWebSeed && _wizard.webseeds.size() > 0 ){
this.reportCurrentTask(MessageText.getString("wizard.webseed.adding"));
Map ws = _wizard.webseeds;
List getright = (List)ws.get( "getright" );
if ( getright.size() > 0 ){
for (int i=0;i<getright.size();i++){
reportCurrentTask( " GetRight: " + getright.get(i));
}
torrent.setAdditionalListProperty( "url-list", new ArrayList( getright ));
}
List webseed = (List)ws.get( "webseed" );
if ( webseed.size() > 0 ){
for (int i=0;i<webseed.size();i++){
reportCurrentTask( " WebSeed: " + webseed.get(i));
}
torrent.setAdditionalListProperty( "httpseeds", new ArrayList( webseed ));
}
}
// must do this last as it saves a copy of the torrent state for future opening...
/*
* actually, don't need to do this as the "open-for-seeding" option used when adding the download
* does the job. Reason I stopped doing this is
* https://sourceforge.net/tracker/index.php?func=detail&aid=1721917&group_id=84122&atid=575154
*
DownloadManagerState download_manager_state =
DownloadManagerStateFactory.getDownloadState( torrent );
TorrentUtils.setResumeDataCompletelyValid( download_manager_state );
download_manager_state.save();
*/
this.reportCurrentTask(MessageText.getString("wizard.savingfile"));
final File torrent_file = new File(((NewTorrentWizard)wizard).savePath);
torrent.serialiseToBEncodedFile(torrent_file);
this.reportCurrentTask(MessageText.getString("wizard.filesaved"));
wizard.switchToClose();
if ( ((NewTorrentWizard)wizard).autoOpen ){
new AEThread("TorrentOpener::openTorrent")
{
public void
runSupport()
{
boolean default_start_stopped = COConfigurationManager.getBooleanParameter( "Default Start Torrents Stopped" );
byte[] hash = null;
try {
hash = torrent.getHash();
} catch (TOTorrentException e1) { }
DownloadManager dm = ((NewTorrentWizard)wizard).getAzureusCore().getGlobalManager().addDownloadManager(
torrent_file.toString(),
hash,
save_dir.toString(),
default_start_stopped ? DownloadManager.STATE_STOPPED
: DownloadManager.STATE_QUEUED,
true, // persistent
true, // for seeding
null ); // no adapter required
if (!default_start_stopped && dm != null) {
// We want this to move to seeding ASAP, so move it to the top
// of the download list, where it will do the quick check and
// move to the seeding list
// (the for seeding flag should really be smarter and verify
// it's a seeding torrent and set appropriately)
dm.getGlobalManager().moveTop(new DownloadManager[] { dm });
}
if ( ((NewTorrentWizard)wizard).autoHost && ((NewTorrentWizard)wizard).getTrackerType() != NewTorrentWizard.TT_EXTERNAL ){
try{
((NewTorrentWizard)wizard).getAzureusCore().getTrackerHost().hostTorrent( torrent, true, false );
}catch( TRHostException e ){
Logger.log(new LogAlert(LogAlert.REPEATABLE,
"Host operation fails", e));
}
}
}
}.start();
}
}
catch (Exception e) {
if ( e instanceof TOTorrentException ){
TOTorrentException te = (TOTorrentException)e;
if ( te.getReason() == TOTorrentException.RT_CANCELLED ){
//expected failure, don't log exception
}else{
reportCurrentTask(MessageText.getString("wizard.operationfailed"));
reportCurrentTask( TorrentUtils.exceptionToText( te ));
}
}else{
Debug.printStackTrace( e );
reportCurrentTask(MessageText.getString("wizard.operationfailed"));
reportCurrentTask(Debug.getStackTrace(e));
}
wizard.switchToClose();
}
| | public void | reportCurrentTask(java.lang.String task_description)
if (display != null && !display.isDisposed()) {
display.asyncExec(new AERunnable(){
public void runSupport() {
if (tasks != null && !tasks.isDisposed()) {
tasks.append(task_description + Text.DELIMITER);
}
}
});
}
| | public void | reportProgress(int percent_complete)
if (display != null && !display.isDisposed()) {
display.asyncExec(new AERunnable() {
public void runSupport() {
if (progress != null && !progress.isDisposed()) {
progress.setSelection(percent_complete);
}
}
});
}
| | public void | show()
display = wizard.getDisplay();
wizard.setTitle(MessageText.getString("wizard.progresstitle"));
wizard.setCurrentInfo("");
wizard.setPreviousEnabled(false);
Composite rootPanel = wizard.getPanel();
GridLayout layout = new GridLayout();
layout.numColumns = 1;
rootPanel.setLayout(layout);
Composite panel = new Composite(rootPanel, SWT.NULL);
GridData gridData = new GridData(GridData.VERTICAL_ALIGN_CENTER | GridData.FILL_HORIZONTAL);
panel.setLayoutData(gridData);
layout = new GridLayout();
layout.numColumns = 1;
panel.setLayout(layout);
tasks = new Text(panel, SWT.BORDER | SWT.MULTI | SWT.READ_ONLY);
tasks.setBackground(display.getSystemColor(SWT.COLOR_WHITE));
gridData = new GridData(GridData.FILL_BOTH);
gridData.heightHint = 120;
tasks.setLayoutData(gridData);
progress = new ProgressBar(panel, SWT.NULL);
progress.setMinimum(0);
progress.setMaximum(0);
gridData = new GridData(GridData.FILL_HORIZONTAL);
progress.setLayoutData(gridData);
|
|
