src/PartFile.h

   1 //
   2 // This file is part of the aMule Project.
   3 //
   4 // Copyright (c) 2003-2011 aMule Team ( admin@amule.org / http://www.amule.org )
   5 // Copyright (c) 2002-2011 Merkur ( devs@emule-project.net / http://www.emule-project.net )
   6 //
   7 // Any parts of this program derived from the xMule, lMule or eMule project,
   8 // or contributed by third-party developers are copyrighted by their
   9 // respective authors.
  10 //
  11 // This program is free software; you can redistribute it and/or modify
  12 // it under the terms of the GNU General Public License as published by
  13 // the Free Software Foundation; either version 2 of the License, or
  14 // (at your option) any later version.
  15 //
  16 // This program is distributed in the hope that it will be useful,
  17 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  18 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  19 // GNU General Public License for more details.
  20 //
  21 // You should have received a copy of the GNU General Public License
  22 // along with this program; if not, write to the Free Software
  23 // Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301, USA
  24 //
  25
  26 #ifndef PARTFILE_H
  27 #define PARTFILE_H
  28
  29
  30 #include "KnownFile.h"          // Needed for CKnownFile
  31 #include "FileAutoClose.h"      // Needed for CFileAutoClose
  32
  33 #include "OtherStructs.h"       // Needed for Requested_Block_Struct
  34 #include "DeadSourceList.h"     // Needed for CDeadSourceList
  35 #include "GapList.h"
  36
  37 class CSearchFile;
  38 class CMemFile;
  39 class CFileDataIO;
  40 class CED2KFileLink;
  41
  42 //#define BUFFER_SIZE_LIMIT     500000 // Max bytes before forcing a flush
  43 #define BUFFER_TIME_LIMIT       60000   // Max milliseconds before forcing a flush
  44
  45 // Ok, eMule and aMule are building incompatible backup files because
  46 // of the different name. aMule was using ".BAK" and eMule ".bak".
  47 // This should fix it.
  48 #define   PARTMET_BAK_EXT wxT(".bak")
  49
  50 enum EPartFileFormat {
  51         PMT_UNKNOWN     = 0,
  52         PMT_DEFAULTOLD,
  53         PMT_SPLITTED,
  54         PMT_NEWOLD,
  55         PMT_SHAREAZA,
  56         PMT_BADFORMAT
  57 };
  58
  59
  60 class SFileRating
  61 {
  62 public:
  63         wxString UserName;
  64         wxString FileName;
  65         sint16   Rating;
  66         wxString Comment;
  67 public:
  68         SFileRating(const wxString &u, const wxString &f, sint16 r, const wxString &c);
  69         SFileRating(const SFileRating &fr);
  70         SFileRating(const CUpDownClient &client);
  71         ~SFileRating();
  72 };
  73
  74 typedef std::list<SFileRating> FileRatingList;
  75
  76 class SourcenameItem
  77 {
  78 public:
  79         wxString        name;
  80         int                     count;
  81 public:
  82         SourcenameItem(const wxString &n = EmptyString, int c = 0)
  83         :
  84         name(n), count(c) {}
  85 };
  86
  87 typedef std::map<uint32,SourcenameItem> SourcenameItemMap;
  88
  89 class CPartFile : public CKnownFile {
  90 public:
  91         typedef std::list<Requested_Block_Struct*> CReqBlockPtrList;
  92
  93         CPartFile();
  94 #ifdef CLIENT_GUI
  95         CPartFile(CEC_PartFile_Tag *tag);
  96 #else
  97         virtual void    SetFileName(const CPath& filename);
  98 #endif
  99         CPartFile(CSearchFile* searchresult);  //used when downloading a new file
 100         CPartFile(const CED2KFileLink* fileLink);
 101         virtual ~CPartFile();
 102
 103         virtual bool LoadFromFile(const CFileDataIO* WXUNUSED(file)) { return false; }
 104         bool    WriteToFile(CFileDataIO* WXUNUSED(file))        { return false; }
 105
 106         // virtual functions for CKnownFile and CPartFile:
 107         bool    IsPartFile() const              { return status != PS_COMPLETE; }       // true if not completed
 108         bool    IsCompleted() const             { return status == PS_COMPLETE; }       // true if completed
 109         bool    IsCPartFile() const             { return true; }                                        // true if it's a CPartFile
 110
 111         uint32  Process(uint32 reducedownload, uint8 m_icounter);
 112         uint8   LoadPartFile(const CPath& in_directory, const CPath& filename, bool from_backup = false, bool getsizeonly = false);
 113         bool    SavePartFile(bool Initial = false);
 114         void    PartFileHashFinished(CKnownFile* result);
 115         bool    HashSinglePart(uint16 partnumber); // true = ok , false = corrupted
 116
 117         bool    CheckShowItemInGivenCat(int inCategory);
 118
 119         bool    IsComplete(uint64 start, uint64 end)    { return m_gaplist.IsComplete(start, end); }
 120         bool    IsComplete(uint16 part)                 { return m_gaplist.IsComplete(part); }
 121
 122         void    UpdateCompletedInfos();
 123
 124         bool    GetNextRequestedBlock(CUpDownClient* sender, std::vector<Requested_Block_Struct*>& toadd, uint16& count);
 125         void    WritePartStatus(CMemFile* file);
 126         void    WriteCompleteSourcesCount(CMemFile* file);
 127         static bool     CanAddSource(uint32 userid, uint16 port, uint32 serverip, uint16 serverport, uint8* pdebug_lowiddropped = NULL, bool ed2kID = true);
 128         void    AddSources(CMemFile& sources, uint32 serverip, uint16 serverport, unsigned origin, bool bWithObfuscationAndHash);
 129 #ifdef CLIENT_GUI
 130         uint8   GetStatus() const { return status; }
 131         uint8   GetStatus(bool /*ignorepause = false*/) const { return status; }
 132 #else
 133         uint8   GetStatus(bool ignorepause = false) const;
 134 #endif
 135         virtual void    UpdatePartsInfo();
 136         const CPath& GetPartMetFileName() const { return m_partmetfilename; }
 137         uint16  GetPartMetNumber() const;
 138         uint64  GetTransferred() const          { return transferred; }
 139         const CPath& GetFullName() const        { return m_fullname; }
 140         float   GetKBpsDown() const                     { return kBpsDown; }
 141         double  GetPercentCompleted() const     { return percentcompleted; }
 142
 143 #ifndef CLIENT_GUI
 144         uint16  GetSourceCount() const          { return (uint16)m_SrcList.size(); }
 145         uint16  GetSrcA4AFCount() const         { return (uint16)m_A4AFsrclist.size(); }
 146 #else
 147         uint16  m_source_count, m_a4af_source_count;
 148         uint16  GetSourceCount() const          { return m_source_count; }
 149         uint16  GetSrcA4AFCount() const         { return m_a4af_source_count; }
 150 #endif
 151         uint16  GetTransferingSrcCount() const  { return transferingsrc; }
 152         uint16  GetNotCurrentSourcesCount()     const   { return m_notCurrentSources; };
 153         uint16  GetValidSourcesCount() const    { return m_validSources; };
 154
 155         uint64  GetNeededSpace();
 156
 157         virtual wxString GetFeedback() const;
 158
 159         wxString getPartfileStatus() const; //<<--9/21/02
 160         sint32  getTimeRemaining() const; //<<--9/21/02
 161         time_t  lastseencomplete;
 162         int     getPartfileStatusRang() const;
 163
 164         // Barry - Added as replacement for BlockReceived to buffer data before writing to disk
 165         uint32  WriteToBuffer(uint32 transize, byte *data, uint64 start, uint64 end, Requested_Block_Struct *block, const CUpDownClient* client);
 166         void    FlushBuffer(bool fromAICHRecoveryDataAvailable = false);
 167
 168         // Barry - Added to prevent list containing deleted blocks on shutdown
 169         void    RemoveAllRequestedBlocks(void);
 170
 171         void    RemoveBlockFromList(uint64 start,uint64 end);
 172         void    RemoveAllSources(bool bTryToSwap);
 173         void    Delete();
 174         void    StopFile(bool bCancel = false);
 175         void    PauseFile(bool bInsufficient = false);
 176         void    ResumeFile();
 177
 178         virtual CPacket* CreateSrcInfoPacket(const CUpDownClient* forClient, uint8 byRequestedVersion, uint16 nRequestedOptions);
 179         void    AddClientSources(CMemFile* sources, unsigned nSourceFrom, uint8 uClientSXVersion, bool bSourceExchange2, const CUpDownClient* pClient = NULL);
 180
 181         bool    PreviewAvailable();
 182         uint16  GetAvailablePartCount() const   { return m_availablePartsCount; }
 183         uint32  GetLastAnsweredTime() const     { return m_ClientSrcAnswered; }
 184         void    SetLastAnsweredTime();
 185         void    SetLastAnsweredTimeTimeout();
 186         uint64  GetLostDueToCorruption() const  { return m_iLostDueToCorruption; }
 187         uint64  GetGainDueToCompression() const { return m_iGainDueToCompression; }
 188         uint32  TotalPacketsSavedDueToICH()const{ return m_iTotalPacketsSavedDueToICH; }
 189         bool    IsStopped() const               { return this ? m_stopped : true; }
 190         bool    IsPaused() const                { return m_paused; }
 191         void    UpdateFileRatingCommentAvail();
 192
 193         int     GetCommonFilePenalty();
 194         void    UpdateDisplayedInfo(bool force = false);
 195
 196         uint8   GetCategory() const { return m_category; }
 197         void    SetCategory(uint8 cat);
 198         void    RemoveCategory(uint8 cat);
 199
 200         void    SetDownPriority(uint8 newDownPriority, bool bSave = true, bool bRefresh = true);
 201         bool    IsAutoDownPriority() const      { return m_bAutoDownPriority; }
 202         void    SetAutoDownPriority(bool flag)  { m_bAutoDownPriority = flag; }
 203         void    UpdateAutoDownPriority();
 204         uint8   GetDownPriority() const         { return m_iDownPriority; }
 205         void    SetActive(bool bActive);
 206         uint32  GetDlActiveTime() const;
 207         bool    GetInsufficient() const         { return m_insufficient; }
 208
 209         void    CompleteFileEnded(bool errorOccured, const CPath& newname);
 210
 211         bool    RemoveSource(CUpDownClient* toremove, bool updatewindow = true, bool bDoStatsUpdate = true);
 212
 213         void    RequestAICHRecovery(uint16 nPart);
 214         void    AICHRecoveryDataAvailable(uint16 nPart);
 215
 216         /**
 217          * This function is used to update source-counts.
 218          *
 219          * @param oldState The old state of the client, or -1 to ignore.
 220          * @param newState The new state of the client, or -1 to ignore.
 221          *
 222          * Call this function for a client belonging to this file, which has changed
 223          * its state. The value -1 can be used to make the function ignore one of
 224          * the two states.
 225          *
 226          * AddSource and DelSource takes care of calling this function when a source is
 227          * removed, so there's no need to call this function when calling either of those.
 228          */
 229         void    ClientStateChanged( int oldState, int newState );
 230
 231         bool    AddSource( CUpDownClient* client );
 232         bool    DelSource( CUpDownClient* client );
 233
 234         /**
 235          * Updates the requency of avilable parts from with the data the client provides.
 236          *
 237          * @param client The clients whoose available parts should be considered.
 238          * @param increment If true, the counts are incremented, otherwise they are decremented.
 239          *
 240          * This functions updates the frequency list of file-parts, using the clients
 241          * parts-status. This function should be called by clients every time they update their
 242          * parts-status, or when they are added or removed from the file.
 243          */
 244         void    UpdatePartsFrequency( CUpDownClient* client, bool increment );
 245
 246         ArrayOfUInts16  m_SrcpartFrequency;
 247
 248         const SourceSet& GetSourceList()        const { return m_SrcList; }
 249         const SourceSet& GetA4AFList()          const { return m_A4AFsrclist; }
 250         void    ClearA4AFList()                         { m_A4AFsrclist.clear(); }
 251
 252         const CReqBlockPtrList  GetRequestedBlockList() const { return m_requestedblocks_list; }
 253
 254         const CGapList& GetGapList() const { return m_gaplist; }
 255
 256         /**
 257          * Adds a source to the list of dead sources.
 258          *
 259          * @param client The source to be recorded as dead for this file.
 260          */
 261         void            AddDeadSource(const CUpDownClient* client);
 262
 263         /**
 264          * Checks if a source is recorded as being dead for this file.
 265          *
 266          * @param client The client to evaluate.
 267          * @return True if dead, false otherwise.
 268          *
 269          * Sources that are dead are not to be considered valid
 270          * sources and should not be added to the partfile.
 271          */
 272         bool            IsDeadSource(const CUpDownClient* client);
 273
 274         /* Kad Stuff */
 275         uint16  GetMaxSources() const;
 276         uint16  GetMaxSourcePerFileSoft() const;
 277         uint16  GetMaxSourcePerFileUDP() const;
 278
 279         void GetRatingAndComments(FileRatingList & list) const;
 280
 281         void    AllocationFinished();
 282 private:
 283 #ifndef CLIENT_GUI
 284         // partfile handle (opened on demand)
 285         CFileAutoClose  m_hpartfile;
 286         //! A local list of sources that are invalid for this file.
 287         CDeadSourceList m_deadSources;
 288
 289         class CCorruptionBlackBox* m_CorruptionBlackBox;
 290 #endif
 291
 292         uint16  m_notCurrentSources;
 293
 294         uint32  m_validSources;
 295
 296         void    AddGap(uint64 start, uint64 end);
 297         void    AddGap(uint16 part);
 298         void    FillGap(uint64 start, uint64 end);
 299         void    FillGap(uint16 part);
 300         bool    GetNextEmptyBlockInPart(uint16 partnumber,Requested_Block_Struct* result);
 301         bool    IsAlreadyRequested(uint64 start, uint64 end);
 302         void    CompleteFile(bool hashingdone);
 303         void    CreatePartFile();
 304         void    Init();
 305
 306         bool    CheckFreeDiskSpace( uint64 neededSpace = 0 );
 307
 308         bool    IsCorruptedPart(uint16 partnumber);
 309
 310         uint32  m_iLastPausePurge;
 311         uint16  m_count;
 312         uint16  transferingsrc;
 313         uint64  completedsize;
 314         uint64  transferred;
 315
 316         uint64  m_iLostDueToCorruption;
 317         uint64  m_iGainDueToCompression;
 318         uint32  m_iTotalPacketsSavedDueToICH;
 319         float   kBpsDown;
 320         CPath   m_fullname;                     // path/name of the met file
 321         CPath   m_partmetfilename;      // name of the met file
 322         CPath   m_PartPath;             // path/name of the partfile
 323         bool    m_paused;
 324         bool    m_stopped;
 325         bool    m_insufficient;
 326         uint8   m_iDownPriority;
 327         bool    m_bAutoDownPriority;
 328         uint8   status;
 329         uint32  lastpurgetime;
 330         uint32  m_LastNoNeededCheck;
 331         CGapList m_gaplist;
 332         CReqBlockPtrList m_requestedblocks_list;
 333         double  percentcompleted;
 334         std::list<uint16> m_corrupted_list;
 335         uint16  m_availablePartsCount;
 336         uint32  m_ClientSrcAnswered;
 337         bool    m_bPercentUpdated;
 338
 339         void    PerformFileComplete();
 340
 341         uint32          m_lastRefreshedDLDisplay;
 342
 343         // Buffered data to be written
 344         std::list<class PartFileBufferedData*> m_BufferedData_list;
 345
 346         uint32 m_nTotalBufferData;
 347         uint32 m_nLastBufferFlushTime;
 348
 349         uint8   m_category;
 350         uint32  m_nDlActiveTime;
 351         time_t  m_tActivated;
 352         bool    m_is_A4AF_auto;
 353
 354         SourceSet       m_SrcList;
 355         SourceSet       m_A4AFsrclist;
 356         bool            m_hashsetneeded;
 357         uint32          m_lastsearchtime;
 358         bool            m_localSrcReqQueued;
 359
 360 #ifdef CLIENT_GUI
 361         FileRatingList m_FileRatingList;
 362         const FileRatingList &GetFileRatingList() { return m_FileRatingList; }
 363         void ClearFileRatingList() { m_FileRatingList.clear(); }
 364         void AddFileRatingList(const wxString & u, const wxString & f, sint16 r, const wxString & c) {
 365                m_FileRatingList.push_back(SFileRating(u, f, r, c)); }
 366
 367         uint32  m_kbpsDown;
 368         uint8   m_iDownPriorityEC;
 369         bool    m_isShared;
 370         SourcenameItemMap m_SourcenameItemMap;
 371
 372         ListOfUInts32   m_A4AFClientIDs;
 373         ListOfUInts32 & GetA4AFClientIDs()                      { return m_A4AFClientIDs; }
 374 public:
 375         bool    IsShared() const                                        { return m_isShared; }
 376         SourcenameItemMap &GetSourcenameItemMap()       { return m_SourcenameItemMap; }
 377         PartFileEncoderData m_PartFileEncoderData;
 378 #endif
 379 public:
 380         bool IsHashSetNeeded() const                            { return m_hashsetneeded; }
 381         void SetHashSetNeeded(bool value)                       { m_hashsetneeded = value; }
 382
 383         uint64  GetCompletedSize() const                        { return completedsize; }
 384         void    SetCompletedSize(uint64 size)           { completedsize = size; }
 385
 386         bool IsLocalSrcRequestQueued() const            { return m_localSrcReqQueued; }
 387         void SetLocalSrcRequestQueued(bool value)       { m_localSrcReqQueued = value; }
 388
 389         void AddA4AFSource(CUpDownClient* src)          { m_A4AFsrclist.insert(CCLIENTREF(src, wxT("A4AFSource"))); }
 390         bool RemoveA4AFSource(CUpDownClient* src)       { return (m_A4AFsrclist.erase(CCLIENTREF(src, wxEmptyString)) > 0); }
 391
 392         uint32 GetLastSearchTime() const                        { return m_lastsearchtime; }
 393         void SetLastSearchTime(uint32 time)                     { m_lastsearchtime = time; }
 394
 395         void AddDownloadingSource(CUpDownClient* client);
 396
 397         void RemoveDownloadingSource(CUpDownClient* client);
 398         void SetStatus(uint8 in);
 399         void StopPausedFile();
 400
 401         // [sivka / Tarod] Imported from eMule 0.30c (Creteil) ...
 402         void SetA4AFAuto(bool in)               { m_is_A4AF_auto = in; }
 403         bool IsA4AFAuto() const                 { return m_is_A4AF_auto; }
 404
 405         // Kry -Sources seeds
 406         void SaveSourceSeeds();
 407         void LoadSourceSeeds();
 408
 409         // Dropping slow sources
 410         CUpDownClient* GetSlowerDownloadingClient(uint32 speed, CUpDownClient* caller);
 411
 412   // Read data for sharing
 413         bool ReadData(class CFileArea & area, uint64 offset, uint32 toread);
 414
 415 private:
 416         /* downloading sources list */
 417         CClientRefList m_downloadingSourcesList;
 418
 419         /* Kad Stuff */
 420         uint32  m_LastSearchTimeKad;
 421         uint8   m_TotalSearchesKad;
 422
 423 friend class CKnownFilesRem;
 424 friend class CPartFileConvert;
 425 };
 426
 427 #endif // PARTFILE_H
 428 // File_checked_for_headers