VidePub Code

#include "filecopier.h"
#include "mainwindow.h"

FileCopier::FileCopier()
{
    mFileIn = NULL;
    mFileOut = NULL;
}

FileCopier::~FileCopier()
{
    Close();
}

bool FileCopier::Open(const QString &aFileIn, const QString &aFileOut)
{
    mFileIn = fopen(aFileIn.toAscii().data(),"rb");
    if(!mFileIn) return false;

    mFileOut = fopen(aFileOut.toAscii().data(),"wb");
    if(!mFileOut) { fclose(mFileIn); mFileIn = NULL; return false; }

    print_log(QString("Open :")+aFileIn+QString(" to ")+aFileOut);

    return true;
}

bool FileCopier::Write(const VideoSegment &aSegment, QProgressDialog *aDial)
{
   size_t aBuffSize = 3000*188; // Packets MPEG
   int64_t aRestSize = aSegment.mEnd.mFilePos-aSegment.mBegin.mFilePos;
   char *aBuff = new char[aBuffSize];
   int64_t aPosition = aSegment.mBegin.mFilePos;


   fseeko64(mFileIn,aPosition,SEEK_SET);
   bool aStatus = true;

   while(aRestSize)
   {
       if(aDial)
       {
           aDial->setValue(aPosition);
           MainWindow::FlushAll();
           if(aDial->wasCanceled())
           {
               aStatus = false;
               break;
           }
       }

       if(aBuffSize > aRestSize)
           aBuffSize = aRestSize;
       size_t aReadSize = fread(aBuff,1,aBuffSize,mFileIn);
       if(aReadSize<aBuffSize)
              {
                  print_log(QString("Erreur entrée : %1/%2").arg(aReadSize).arg(aBuffSize));
                  aStatus = false;
                  break;
              }

       size_t aWrittenSize = fwrite(aBuff,1,aBuffSize,mFileOut);
       fflush(mFileOut);
       if(aWrittenSize<aBuffSize)
       {
           print_log(QString("Erreur sortie : %1/%2").arg(aWrittenSize).arg(aBuffSize));
           aStatus = false;
           break;
       }

       aPosition += aWrittenSize;
       aRestSize -= aWrittenSize;
   }

  delete aBuff;
   return aStatus;
}

void FileCopier::Close()
{
    if(mFileIn) fclose(mFileIn);
    if(mFileOut) fclose(mFileOut);

    mFileIn = NULL;
    mFileOut = NULL;
}