AndroMeta/include/AndroMeta/MCommunicator.h

Go to the documentation of this file.

/*
 * Copyright 2009-2012 AndroMeta LLC. All rights reserved.
 *
 * AndroMeta LLC retains all intellectual property and proprietary 
 * rights to this software and related documentation and any modifications 
 * thereto.  Any use, reproduction, disclosure, or distribution of this 
 * software and related documentation without an express license agreement 
 * from AndroMeta LLC is strictly prohibited.
 * 
 */

#ifndef ANDROMETA_M_COMMUNICATOR_H
#define ANDROMETA_M_COMMUNICATOR_H

#include <AndroMeta/MSocket.h>

namespace Meta{
  
  class MProcTask;
  class MMessageBuffer;
  class MMessage;
  
  class MCommunicator : public MSocket{
  public:
    
    MCommunicator(MProcTask* task,
                  MMessageBuffer* sendBuffer=0,
                  MMessageBuffer* receiveBuffer=0);
    
    virtual ~MCommunicator();
    
    MProcTask* task();
    
    MMessageBuffer* sendBuffer();
    
    MMessageBuffer* receiveBuffer();
    
    void close(bool manual=true);
    
    virtual void onClose(bool manual);
    
    virtual void onConnect();
    
    bool isConnected() const;
    
    bool send(MMessage* msg);
    
    bool send(const mvar& header, const mvar& body);
    
    bool send(const mvar& body);
    
    bool receive(mvar& header, mvar& body);
    
    bool receive(mvar& body);
    
    bool receive(mvar& header, mvar& body, const mtime& timeout);
    
    bool receive(mvar& body, const mtime& timeout);
    
  private:  
    MCommunicator(const MCommunicator&);
    MCommunicator& operator=(const MCommunicator&);
    
    class MCommunicator_* x_;
  };
  
} // end namespace Meta

#endif // ANDROMETA_M_COMMUNICATOR_H