---

sockeventbrokerc.h

Go to the documentation of this file.

/*
Copyright (C) 1999  Carsten Winkelholz

Address:  FGAN Forschungsgesellschaft f�r Angewandte Naturwissenschaften e. V.
      Neuenahrer Str. 20
      D - 53343 Wachtberg
      
Email:    winkelholz@fgan.de

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
*/


#ifndef SOCKEVENTBROKERC_H
#define SOCKEVENTBROKERC_H

#include "oaw/pdtk/eventbrokerc.h"
#include "oaw/misc/stringc.h"
#include "oaw/misc/arrayc.h"
#include "oaw/misc/socketc.h"


#define ESOCKTROBJC_NO_CONNECTION_TO_MASTER 0
#define ESOCKTROBJC_SYSTEM_ERROR      1
#define ESOCKTROBJC_SWAP_UNEXSPECTED      2
#define ESOCKTROBJC_LOST_CONNECTION      3
#include "../oawconfig.h"

OAW_BEGIN_NAMESPACE

const long cMsgDataLength = 3;

class OAW_DLLMAPPING ESockEventBrokerC{
public:
  ESockEventBrokerC(const long& l){m_errorCode=l;}
  ESockEventBrokerC(const StringC& s,const long&){m_errorString=s;}
public:
  StringC m_errorString;
  long m_errorCode;
};


class OAW_DLLMAPPING SockEventBrokerC : public EventBrokerC
{
public:
  SockEventBrokerC(const StringC& name, const StringC& endpoint,const char*);
  SockEventBrokerC();
  virtual ~SockEventBrokerC();

   
  virtual int AssignInterface(const StringC&,InterfaceC*);
  virtual void InitializationReady();
  virtual int ProcessEvents();

public:
  struct MsgDataStruct{
    long m_msg;
    long m_dataMinLength;
    long m_dataMaxLength;
  };

protected:
  
  void Init(const StringC& name, const StringC& endpoint,const char*);

  void SetInitData(const char*, long);
  void CalcInterfacesMaxLengths();

  virtual void Update();
  virtual void PostUpdate();
  virtual void Swap();
  virtual void SetSleep();
  virtual void SetWake();

  void ExchangeData();
  void BroadcastDataOfInterfaces(long& sockIter, long& dataIter);
  void RecvDataOfInterfaces(long& sockIter, long& dataIter);
  
  void WaitOnMaster();
  void SetDataOfInterfaces(char* data);
  void SetDataOfInterfacesTCP(char* data,char* ownData);
  void UpdateDatapackage();
  void CalcDataMinMaxLength();
  
  void WaitOnInitData(SockAddressC&);
  void InitAsSlave();
  void InitAsNormal();
  void GetInterface(StringC interfacename, StringC trobjname, long& id, long& stype);

  void ExchangeDataSlave();
  void ExchangeDataNormal();
  
  int ProcessEventsNormal();
  int ProcessEventsSlave();
  
protected:
 

  StringC m_name;
 

  SocketC m_socketToMaster;

  ByteArrayC m_data;
  ArrayC<ByteArrayC> m_tmpdata;
  
  ArrayC<InterfaceC*> m_pInterface;
  ArrayC<long> m_interfaceDataAssignedLength;
  ArrayC<long> m_interfaceDataMinLength;
  ArrayC<long> m_interfaceDataMaxLength;
    
  long m_dataAssignedLength;
  long m_dataPresentLength;
  int m_datapackageUpdated;

  long m_dataPortBase;
  long m_anzahlTrObj;
  
  int m_init;
  int m_start;
  int m_dataBroadcasted;
  long m_anzahlDataPorts;
  
  StringC m_endpoint;
  
  SockAddressC m_udpAddressToMaster;
  ArrayC<SockAddressC> m_dataBroadcastAddress;

  ArrayC<SocketC*> m_pUdpSocket;
  SocketC* m_pUdpSocketSyncSwap;
  
  long m_broadcastBase;
  StringC m_broadcastNetAddr;
  
  //Fuer die lokale Behandlung
  long m_localType;
  char* m_szLocalIP;
 
  long* m_swapMsgData;
  long m_swapMsgDataSize;

  MsgDataStruct m_msgData;

};

OAW_END_NAMESPACE

#endif

---