bytestreambe.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 "bytestreambe.h"

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

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

void byteStreamBE::main()
{
  while(true)
  {
      FILE           *fptr;
      unsigned char  data;
      int            nrBytesWritten = 0;

      read(fileNameP, fileName);
      fptr=fopen(fileName, "wb");
      if (!fptr) {
          printf("%s: error opening output file \"%s\"\n", fullName(),(const char*)fileName);
          exit(1);
      }
      #ifdef VERBOSE
      else
          printf("%s: writing data to %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 ((nrBytesWritten != nrBytes) || (nrBytes == 0))
      {
          read(byteStreamP, data);
          if (!fwrite(&data, sizeof(unsigned char), 1, fptr))
          {
            printf("%s: error writing output file %s\n", fullName(),(const char*)fileName);
            exit(1);
          }
          else
          {
            nrBytesWritten++;
          }
      }

      #ifdef VERBOSE
      if (nrBytesWritten != 1)
          printf("%s: finished; wrote %i bytes to output file\n", fullName(), nrBytesWritten);
      else
          printf("%s: finished; wrote 1 byte to output file\n", fullName());
      #endif

      fclose(fptr);
  }
}

---