Blame src/pgetJob.h

Packit Service a2489d
/*
Packit Service a2489d
 * lftp - file transfer program
Packit Service a2489d
 *
Packit Service a2489d
 * Copyright (c) 1996-2012 by Alexander V. Lukyanov (lav@yars.free.net)
Packit Service a2489d
 *
Packit Service a2489d
 * This program is free software; you can redistribute it and/or modify
Packit Service a2489d
 * it under the terms of the GNU General Public License as published by
Packit Service a2489d
 * the Free Software Foundation; either version 3 of the License, or
Packit Service a2489d
 * (at your option) any later version.
Packit Service a2489d
 *
Packit Service a2489d
 * This program is distributed in the hope that it will be useful,
Packit Service a2489d
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
Packit Service a2489d
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
Packit Service a2489d
 * GNU General Public License for more details.
Packit Service a2489d
 *
Packit Service a2489d
 * You should have received a copy of the GNU General Public License
Packit Service a2489d
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
Packit Service a2489d
 */
Packit Service a2489d
Packit Service a2489d
#ifndef PGETJOB_H
Packit Service a2489d
#define PGETJOB_H
Packit Service a2489d
Packit Service a2489d
#include "CopyJob.h"
Packit Service a2489d
Packit Service a2489d
class pgetJob : public CopyJob
Packit Service a2489d
{
Packit Service a2489d
   class ChunkXfer : public CopyJob
Packit Service a2489d
   {
Packit Service a2489d
      friend class pgetJob;
Packit Service a2489d
Packit Service a2489d
      off_t start;
Packit Service a2489d
      off_t limit;
Packit Service a2489d
Packit Service a2489d
      ChunkXfer(FileCopy *c,const char *n,off_t start,off_t limit);
Packit Service a2489d
   };
Packit Service a2489d
Packit Service a2489d
   TaskRefArray<ChunkXfer> chunks;
Packit Service a2489d
   int	 max_chunks;
Packit Service a2489d
   off_t chunks_bytes;
Packit Service a2489d
   void InitChunks(off_t offset,off_t size);
Packit Service a2489d
Packit Service a2489d
   off_t start0;
Packit Service a2489d
   off_t limit0;
Packit Service a2489d
Packit Service a2489d
   off_t total_xferred;
Packit Service a2489d
   float total_xfer_rate;
Packit Service a2489d
Packit Service a2489d
   bool	no_parallel:1;
Packit Service a2489d
   bool chunks_done:1;
Packit Service a2489d
   bool pget_cont:1;
Packit Service a2489d
Packit Service a2489d
   void free_chunks();
Packit Service a2489d
   ChunkXfer *NewChunk(const char *remote,off_t start,off_t limit);
Packit Service a2489d
Packit Service a2489d
   long total_eta;
Packit Service a2489d
Packit Service a2489d
   Timer status_timer;
Packit Service a2489d
   xstring status_file;
Packit Service a2489d
   void SaveStatus();
Packit Service a2489d
   void LoadStatus();
Packit Service a2489d
   void LoadStatus0();
Packit Service a2489d
Packit Service a2489d
protected:
Packit Service a2489d
   void NextFile();
Packit Service a2489d
Packit Service a2489d
public:
Packit Service a2489d
   int Do();
Packit Service a2489d
   void ShowRunStatus(const SMTaskRef<StatusLine>&);
Packit Service a2489d
   xstring& FormatStatus(xstring&,int,const char *);
Packit Service a2489d
   xstring& FormatJobs(xstring&,int verbose,int indent);
Packit Service a2489d
Packit Service a2489d
   pgetJob(FileCopy *c1,const char *n,int m=0);
Packit Service a2489d
   ~pgetJob();
Packit Service a2489d
   void PrepareToDie();
Packit Service a2489d
Packit Service a2489d
   void SetMaxConn(int n) { max_chunks=n; }
Packit Service a2489d
Packit Service a2489d
   off_t GetBytesCount() { return total_xferred; }
Packit Service a2489d
   double GetTransferRate() { return total_xfer_rate; }
Packit Service a2489d
};
Packit Service a2489d
Packit Service a2489d
class pCopyJobCreator : public CopyJobCreator
Packit Service a2489d
{
Packit Service a2489d
public:
Packit Service a2489d
   int max_chunks;
Packit Service a2489d
   pCopyJobCreator(int n) : max_chunks(n) {}
Packit Service a2489d
   CopyJob *New(FileCopy *c,const char *n,const char *o) const {
Packit Service a2489d
      return new pgetJob(c,n,max_chunks);
Packit Service a2489d
   }
Packit Service a2489d
};
Packit Service a2489d
Packit Service a2489d
#endif//PGETJOB_H