hds_messenger_ls.hpp

/* hds_messenger_ls.hpp */
/* $Id$ */
#ifndef __hds_messenger_ls_hpp
#define __hds_messenger_ls_hpp

#include <QObject>
#include <QLocalServer>
#include <QLocalSocket>

#include <hds_batch/defines.hpp>
#include <hds_batch/errors.hpp>
#include <hds_batch/hds_messenger.hpp>

namespace hds
{
  class MessengerLS : public QObject, public hds::Messenger
  {
    Q_OBJECT
    
  public:
    
    enum State
    {
      SERVER = 0, 
      CLIENT,     
      UNDEFINED   
    };
    
    MessengerLS(QObject *parent = 0x0);
    
    MessengerLS(const QString &sock_name,     
           State state = CLIENT,         
           int connection_time_out = 0,  
           QObject *parent = 0x0          ); 
        
    virtual ~MessengerLS();
    
    
    State init(const QString &sock_name,   
           State state = CLIENT,       
           int connection_time_out = 0  );
    

    virtual void sendMsg(const hds::Messenger::Message &msg) const;
    
    virtual hds::Messenger::Message getMsg() const;
    
    
    const QString& socketName() const {return m_socket_name;}
    
    int waitConnectionTimeOut() const{return m_connection_wait_time_out;}
    
    void setConnectionTimeOut(int dt) 
    {m_connection_wait_time_out = dt;}
    
    State state() const {return m_state;}
    
    bool hasMessages();
    
    
  protected slots:
  
    // socket / server slots
    virtual void socket_connection_error(QLocalSocket::LocalSocketError socketError);
    virtual void socket_connected();
    virtual void socket_disconnected();
    
  protected:
    
    mutable QLocalServer m_server;
    
    mutable QLocalSocket m_socket;
    
    QString m_socket_name;
    
    State m_state;
    
    int m_connection_wait_time_out;
        
  private:
    
    void get_message_from_sock(QLocalSocket *pls, hds::Messenger::Message &msg) const;
    void send_message_to_sock(const hds::Messenger::Message &msg, QLocalSocket &sock) const;
  
    void debug_to_file(const QString &fname, const QByteArray &array) const;
  };
};

#endif /* hds_messenger_ls.hpp */