AndroMeta/include/AndroMeta/MPeerProc.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_PEER_PROC_H
#define ANDROMETA_M_PEER_PROC_H

#include <AndroMeta/MObject.h>

namespace Meta{
  
  class MProcTask;
  
  class MPeerProc{
  public:
    
    MPeerProc(MProcTask* task);
    
    virtual ~MPeerProc();
    
    bool connect();
    
    bool connect(int localPort, long groupId,
                 const mstr& user, const mstr& key);
    
    bool isConnected() const;
    
    MProcTask* task();
    
    int localPort() const;
    
    long groupId() const;
    
    bool unicast(long peerId,
                 const mvar& msg,
                 const mvar& header=undef,
                 bool block=false);
    
    bool broadcast(const mvar& msg,
                   const mvar& header=undef,
                   bool block=false);
    
    long peerId() const;
    
    long submitterId() const;
    
    mvec peers() const;
    
    void barrier();
    
    void close();
    
    virtual void onClose();
    
    virtual void onClose(long peerId);
    
    virtual void handleMessage(mvar& msg, mvar& header) = 0;
    
  private:  
    MPeerProc& operator=(const MPeerProc&);
    MPeerProc(const MPeerProc&);
    
    class MPeerProc_* x_;
  };
  
} // end namespace Meta

#endif // ANDROMETA_M_PEER_PROC_H