NI6008.h

Go to the documentation of this file.

// $Id: $
#ifndef INC_NI6008_H
#define INC_NI6008_H 1

// #include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h> 

// Include files
#include "StatusCode.h"
#include "Element.h"

class NI6008 : public Element {
public: 

  NI6008( );

  virtual ~NI6008( ); 

  void help() { info("NI6008 "+name()+". No help.","NI6008::help"); };

  StatusCode init() {
    info("NI6008 "+name()+" initialization.","NI6008:init");    

    /* if (m_device==std::string("")){ */
    /*   error("Device has not been device before opening the server connection. Interrupt."); */
    /* } */

    m_sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (m_sockfd < 0) {
      error("ERROR opening socket");
      return StatusCode::FAILURE;
    }
    m_server = gethostbyname(m_host.c_str());
    if (m_server == NULL) {
      error("ERROR connecting to host "+m_host+".");
      return StatusCode::FAILURE;
    }
    bzero((char *) &m_serv_addr, sizeof(m_serv_addr));
    m_serv_addr.sin_family = AF_INET;
    bcopy((char *)m_server->h_addr, 
          (char *)&m_serv_addr.sin_addr.s_addr,
          m_server->h_length);
    m_serv_addr.sin_port = htons(m_portno);
    if (connect(m_sockfd,(struct sockaddr *) &m_serv_addr,sizeof(m_serv_addr)) < 0) {
      error("ERROR connecting to the socket.");
      return StatusCode::FAILURE;
    }
    info("Starting client, connecting to host "+m_host+" on port "+itos(m_portno));
    return StatusCode::SUCCESS;
  }

  void reset() { info("NI6008 "+name()+" reset.","NI6008::reset");};

  void update () {info("NI6008 "+name()+". Nothing to do.","NI6008::update");};

  std::string cmd(std::string, std::string);
  
  int port () { return m_portno; } 
  void setPort( int portno ) { m_portno = portno; }

  //  std::string device () { return m_device; } 
  //  void setDevice( std::string device ) { m_device = device; }
  
  std::string hostname () { return m_host; } 
  void setHostname( std::string host ) { m_host = host; }

  std::vector<double> ai();
  int di();

  StatusCode addDevice( std::string path){
    m_device.push_back( path );
    info("Device associated.");
    return StatusCode::SUCCESS;
  };

  std::string device ( unsigned int dev ) {
    if (dev>m_device.size()-1){
      warning("Device not defined.");
      return NULL;
    }
    return m_device[dev];
  }

  StatusCode clearDevice(){
    m_device.clear();
    return StatusCode::SUCCESS;
  }

  unsigned int numberOfDevices(){
    return m_device.size();
  }

protected:
  int m_portno;
  std::string m_host;
  std::vector<std::string>  m_device;
  int m_sockfd;
  struct sockaddr_in m_serv_addr;
  struct hostent *m_server;
  char buffer[256];

private:

};
#endif // INC_NI6008_H