/home/kopmann/git-mirror/fdhwlib/fdhwlib/akutil/baseserver.h

Go to the documentation of this file.

/***************************************************************************
    baseserver.h  -  description

    begin                : Fri Sep 24 2004
    copyright            : (C) 2004 by A Kopmann
    email                : kopmann@ipe.fzk.de
    status               :
    test                 :
    history              :
 ***************************************************************************/


#ifndef BASESERVER_H
#define BASESERVER_H

#include <cstdio>
#include <cstring>
#include <ctype.h>
#include <stdexcept>
#include <sys/select.h>
#include <sys/time.h>


#ifdef __GNUC__
# include <signal.h>
# include <unistd.h>
# include <sys/types.h>
# include <sys/socket.h>
# include <netinet/in.h>
# include <netdb.h>
# include <arpa/inet.h>
# define SOCKET int
#endif // __GNUC__

#ifdef __WIN32__ // Windows
#ifndef FD_SETSIZE
//#define FD_SETSIZE 512
// For WinXP a much larger number of sockets is required!!
// 4096 is just a guess - the first socket is about 1960...
// 2004-01-29, ak
#define FD_SETSIZE 4096
#endif
#include <winsock.h>
//#include <winsock2.h> // ???
#endif // of windows defines
 // of windows defines


class BaseServer {
public:
  BaseServer(unsigned short port);
  //BaseServer(unsigned short port, SimpleServer *s);

  virtual ~BaseServer();

  void setDebugLevel(int debug);
  void setConnectionLogging(bool logging=true)
   { connLogging = logging; }
        
  int readMsg(int client, char *msg, int n);

  int writeMsg(int client, char *msg, int n=0);


  int readData(int client, unsigned long *data, int n);

  int writeData(int client, unsigned long *data, int n);

        
  int readData(int client, unsigned int *data, int n);
        
  int writeData(int client, unsigned int *data, int n);
        
  int readPacket(int client, unsigned long *data, int max);

  int writePacket(int client, unsigned long *data, int n);

  
  void monitor();

  // test features
  void display();
  virtual void show();

  void init(FILE *fout = stdout);

  void init_server(int fd1=-1, int fd2=-1);

  void kill_server();

  void displayActiveSockets();

  void displayActiveSockets(FILE *fout);
  
  void setTRef(struct timeval *time);
  
  void enableTimeout(struct timeval *timeout=0);

  void disableTimeout();
  
  
protected:
  int debug;    
        
  void setPort(unsigned short port);
        
  virtual int handle_timeout();

  void getNextTimeout(int *iSample, struct timeval *timeout);

  void displayMsg(unsigned char *msg, int len);

  virtual int read_from_client(int filedes);


  virtual int read_from_keyboard();

  virtual void displayVersion();

  FILE *fout;

  bool shutdown;

  fd_set active_fd_set; 

  fd_set change_byteorder_fd_set;  

  inline void endian_swap(unsigned short& x) {
    x = (x>>8) | (x<<8);
  }

  inline void endian_swap(uint32_t& x) {
    x = (x>>24) |
        ((x<<8) & 0x00FF0000) |
        ((x>>8) & 0x0000FF00) |
         (x<<24);
  }

  inline void endian_swap(unsigned long& x) {
    x = (x>>24) |
        ((x<<8) & 0x00FF0000) |
        ((x>>8) & 0x0000FF00) |
         (x<<24);
  }

  inline void endian_swap(unsigned long long& x) {
    x = (x>>56) |
        ((x<<40) & 0x00FF000000000000ULL) |
        ((x<<24) & 0x0000FF0000000000ULL) |
        ((x<<8) & 0x000000FF00000000ULL) |
        ((x>>8) & 0x00000000FF000000ULL) |
        ((x>>24) & 0x0000000000FF0000ULL) |
        ((x>>40) & 0x000000000000FF00ULL) |
        (x<<56);
  }


   inline void endian_prepare_string(unsigned long& x){
    x = (x>>24) |
        ((x<<8) & 0x00FF0000) |
        ((x>>8) & 0x0000FF00) |
         (x<<24);
   }   

   inline void endian_prepare_short(unsigned long& x){
    x = (x>>16) |
        (x<<16);
   }
    

#if 0

   inline void endian_swap(unsigned int& x){
     //printf("Swap: %d --> ", x);
     x = (x>>24) |
        ((x<<8) & 0x00FF0000) |
        ((x>>8) & 0x0000FF00) |
        (x<<24);
     //printf("%d \n", x);
   }
#endif

   inline void endian_swap(double& x){
     endian_swap((unsigned long long &) x);
   }



//private:
  unsigned short port;

  SOCKET sock;

  struct timeval tRef;
  
  struct timezone tZone;
  
  struct timeval tSample;

  int index;
  
  int nSamples;
  
  int lastIndex;

  //struct timeval timeout;
  
  struct timeval ttimer;

  bool useTimeout;
  
  bool connLogging;
};

#endif