ngcbIFC2.hpp

Go to the documentation of this file.

#ifndef ngcbIFC2_H
#define ngcbIFC2_H
 
 
#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif
 
#include <ngc/core/ngcb.h>
#include <ngc/core/ngcbSocket.h>
#include <ngc/core/ngcbSched.h>
#include <ngc/core/ngcbIFC.hpp>

#define ngcbIFC2_DEFAULT_PORT 8010
 

class ngcbIFC2: public ngcbIFC
{ 
public:
  int fdPipe[2];

  char keeperMsg[256];

  int keeperFailure;

  ngcbIFC2();     

  explicit ngcbIFC2(const char *name);

  virtual ~ngcbIFC2();
 
  /*
   * Client interface
   */

  int Fd();

  int Sim(int level);

  int Open(const char *name);

  int Close();

  void Keeper(int seconds);

  int Reset();

  int Ping();

  int Timeout(int seconds);

  int SetTime(uint64_t sec, uint64_t nsec);

  int RPC(int mod, int target, int req, void *payload, unsigned int size,
      unsigned int *status);

  int ReadAddr(ngcb_route_t route, int addr, int *buffer, int size, 
           int *result);

  int WriteAddr(ngcb_route_t route, int addr, const int *buffer, int size, 
        int *result);

  int Status(int *devStatus);

  int Connect();

  int Disconnect(); 

  int Connected();             
 
  /***
   * Start TSU trigger at given absolute time 
   * (seconds + fractional nanoseconds)
   */
  int TsuStartAt(uint64_t sec, uint64_t nsec);

  int TsuStart();

  int TsuStop();

  int TsuTrigger();

  int TsuSnapshot();

  int TsuStatus(int *value);

  int TsuConfig(ngcb_tsu_t *cfg);
 
  /*** 
   * The function checks the TSU running status. If the status cannot be 
   * read -1 is returned and ErrMsg() contains the detailed error message. 
   * Otherwise 1 is returned if the TSU is running or zero is returned if 
   * the TSU is not running.
   */
  int TsuRunning();
 
  /*
   * Bottom end i/o
   */

  void Lock();

  void Unlock();

  int _ReadAddr(ngcb_route_t route, int addr, int *buffer, int size, 
        int *result);

  int _WriteAddr(ngcb_route_t route, int addr, const int *buffer,
         int size, int *result); 

  int _Ping(char *erms);
 
protected:
 
private:
  int fdCmd_;

  unsigned int requestId_;

  ngcb_sema_t semLock_;

  int thr_;

  ngcb_thread_t thid_;

  ngcbIFC *simulator_;

  void Init_();

  int RPC_(int mod, int target, int req, void *payload, unsigned int size,
       unsigned int *status);

  int DevRead_(int fd, void *buffer, size_t size, char *erms);

  int DevWrite_(int fd, const void *buffer, size_t size, char *erms);

  void StartKeeper_();

  void StopKeeper_();
};
 
#endif