AndroMeta/include/AndroMeta/MPeerBroker.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_BROKER_H
#define ANDROMETA_M_PEER_BROKER_H

#include <AndroMeta/MBrokerBase.h>
#include <AndroMeta/MObject.h>

namespace Meta{
  
  class MProcTask;
  
  class MPeerBroker : public MBrokerBase{
  public:
    
    MPeerBroker(MProcTask* task);
    
    virtual ~MPeerBroker();
    
    mnode process(MObject* object, mnode n, bool block);
    
    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;
    
    long peerId() const;
    
    long submitterId() const;
    
    mvec peers() const;
    
    void close();
    
    virtual void onClose();
    
    mstr distribute(MObject* object,
                    const mstr& className,
                    const mstr& objectName="");
    
    bool revoke(MObject* object);
    
    MObject* obtain(long peerId,
                    const mstr& objectName);
    
    virtual bool onObtain(MObject* object);
    
    bool release(MObject* object, bool disconnect=false);
    
    mvar& session(MObject* object);
    
  private:
    MPeerBroker& operator=(const MPeerBroker&);
    MPeerBroker(const MPeerBroker&);
    
    class MPeerBroker_* x_;
  };
  
} // end namespace Meta

#endif // ANDROMETA_M_PEER_BROKER_H