/common/home/bel/bella/lnx/exports/build/current/all/central-services/cap/srvr/client.hh

#ifndef CLIENT_HH
#define CLIENT_HH

#include <alarm.hh>

#include "asrvr.h"
#include "ix_tools.h"


using namespace AccAlarm;

namespace Asrvr
{

class AlarmClient
{

  public:


    // constructor
    AlarmClient( ix_tcp_client_t *p );

    // destructor
    virtual ~AlarmClient();

    // name
    char *getName(void);

    // key of client
    ix_tcp_client_t *getClient(void);

    // set status of connection
    int setConnected( bool status );

    // get status of connection
    bool getConnected(void);

    // push alarm through client filters to send-queue
    void filter( Alarm *palarm );

    // add filter
    int addFilter( as_filter_t *pfilter );

    // delete filter
    int delFilter( as_filter_t *pfilter );

    // delete filter
    int setFilter( as_filter_t *pfilter, int nfilter );

    // flush the send-queue to client
    virtual void flush(void) = 0;

    // get the count of the send queue
    virtual int getQueueCount(void) = 0;

    // get the average count of the send queue
    virtual int getQueueCountAvg(void) = 0;

    // free alarm 
    void freeAlarm( Alarm *pAlarm );

    // 
    Alarm *eatAlarmQueue(void);

    // 
    int feedAlarmQueue(Alarm *pAlarm);

    // ... to be extended
    Alarm *pAlarm;

  protected:

    // outgoing alarm queue which is fed in the filter operation
    // and  eaten up in the flush operation
    ix_queue_t *palarm_queue_out;

    // connection handle to alarm client
    ix_tcp_client_t *pclient;

    bool _connected;

    bool _channelBroken;

    ix_thread_t *pSendThread;

    long long int _sendAlarms;

  private:
    // filter list of client
    ix_list_t *pfilter_list;

};


}


#endif

---