processloader.h

Go to the documentation of this file.

/*******************************************************************\

                   SESAME project software license

              Copyright (C) 2002 University of Amsterdam

    This program is free software; you can redistribute it and/or
     modify it under the terms of the GNU General Public License
    as published by the Free Software Foundation; either version 2
        of the License, or (at your option) any later version.

   This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
             GNU General Public License for more details.

  You should have received a copy of the GNU General Public License
     along with this program; if not, write to the Free Software
      Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
                           02111-1307, USA.

      For information regarding the SESAME software project see
              http://sesamesim.sourceforge.net or email
                    jcofflan@users.sourceforge.net

\*******************************************************************/

#ifndef PROCESSLOADER_H
#define PROCESSLOADER_H

#include <BasicUtils/BasicThread.h>
#include <libmanager.h>
#include <ymlnode.h>

#include <string.h>
#include <string>
#include <iostream>
#include <map>

#ifndef LTSTR
#define LTSTR
#include <string.h>
struct ltstr {
  bool operator()(const char* s1, const char* s2) const {
    return strcmp(s1, s2) < 0;
  }
};
#endif

// Forward declarations
class PNConnection;
class DataBlockClass;


class ProcessLoader : public BasicThread, public YMLNode {
  LibManager libManager;

  int pargc;

  char **pargs;

  typedef enum {S_STOPPED, S_RUNNING, S_READING, S_SENDING_READ,
                S_WRITING, S_SENDING_WRITE, S_SENDING_EXECUTE} state_t;
  state_t state;
  int stateID;

 public:
  ProcessLoader();
  virtual ~ProcessLoader();

  DataBlockClass *read(int portId);
  void write(int portId, DataBlockClass *dataBlock);
  void execute(const char *operation);
  void execute(int operation);

  LibManager *getLibManager() {return &libManager;}
  void loadLibraries();

  void loadProcessArgs();
  int getProcessArgc() {return pargc;}
  char **getProcessArgs() {return pargs;}

  virtual void init();

  virtual bool load();
  virtual void exit();

  std::string getStateString();

  friend std::ostream &operator<<(std::ostream &stream, ProcessLoader &p);
};

std::ostream &operator<<(std::ostream &stream, ProcessLoader &p);

#endif

---