bytestreamfe.cc

Go to the documentation of this file.

/*--------------------------------------------------------------------
 *
 * (C) Copyright Koninklijke Philips Electronics NV 2006. 
 * All rights reserved. This software is licensed under the terms of
 * version 2.1 of the GNU Lesser General Public License as published 
 * by the Free Software Foundation. For licensing and warranty
 * information, see the file COPYING in the main directory.
 *
 *------------------------------------------------------------------*/

#include <stdlib.h>
#include <stdio.h>
#include "bytestreamfe.h"

#define BURST_LENGTH 1024

byteStreamFE::byteStreamFE (
    const Id&            n,
    In<VYAfileName>&     fileNameF,
    In<int>&             nrBytesF,
    Out<unsigned char>&  byteStreamF)
:
    VYAprocess(n),
    fileNameP(id("fileNameP"),fileNameF),
    nrBytesP(id("nrBytesP"),nrBytesF),
    byteStreamP(id("byteStreamP"),byteStreamF)
{}

const char* byteStreamFE::type() const
{
    return "byteStreamFE";
}

void byteStreamFE::main()
{
  while(true)
  {
      FILE           *fptr;
      unsigned char  burst[BURST_LENGTH];
      int            nrBytesRead = 0;
      int            currentNrBytes;

      read(fileNameP, fileName);
      fptr=fopen(fileName, "rb");
      if (!fptr) {
          printf("\n%s: error opening input file \"%s\"\n", fullName(),(const char*)fileName);
          exit(1);
      }
      #ifdef VERBOSE
      else 
          printf("\n%s: reading data from %s\n", fullName(),(const char*)fileName);
      #endif

      read(nrBytesP, nrBytes);
      if (nrBytes < 0) {
          printf("%s: error: negative number of bytes requested (%i)\n", fullName(), nrBytes);
          exit(1);
      }

      while (!feof(fptr) && ((nrBytesRead!=nrBytes) || (nrBytes==0)))
      {
          currentNrBytes = fread(burst, sizeof(unsigned char), BURST_LENGTH, fptr);
          if ((currentNrBytes == 0) && !feof(fptr)) {
              printf("%s: error reading input file %s\n", fullName(),(const char*)fileName);
              exit(1);
          }
          else 
          {
              if ((nrBytesRead+currentNrBytes > nrBytes) && (nrBytes!=0)) {
                  currentNrBytes = nrBytes - nrBytesRead;
                  nrBytesRead    = nrBytes;
              }
              else
              {
                  nrBytesRead   += currentNrBytes;
              }
              write(byteStreamP, burst, currentNrBytes);
          }
      }

      #ifdef VERBOSE
      if (nrBytesRead != 1)
          printf("%s: finished; read %i bytes from input file\n", fullName(), nrBytesRead);
      else
          printf("%s: finished; read 1 byte from input file\n", fullName());
      #endif
      fclose(fptr);
  }
}

---