AndroMeta/include/AndroMeta/MPeer.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_H
#define ANDROMETA_M_PEER_H

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

namespace Meta{
  
  class MProcTask;
  class MPeerBroker;
  class MPeerProc;
  class MPackage;
  class MAuth;
  
  class MPeer{
  public:
    
    MPeer(MProcTask* task,
          MAuth* auth,
          const mstr& scratchDir,
          size_t maxProcesses=0);
    
    MPeer(MProcTask* task);
    
    virtual ~MPeer();
    
    MProcTask* task();
    
    bool connect(mstr& hubHost, int hubPort, int localPort,
                 const mstr& user, const mstr& password,
                 bool requireRouter=false, bool isRouter=false);
    
    bool submitProcess(const MPackage& package,
                       size_t minHosts=1,
                       size_t maxHosts=1000,
                       double minUptime=100,
                       double minCPU=0,
                       double minNetwork=0);
    
    bool submitProcess(MPeerBroker* broker,
                       const MPackage& package,
                       size_t minHosts=1,
                       size_t maxHosts=1000,
                       double minUptime=100,
                       double minCPU=0,
                       double minNetwork=0);
    
    bool submitProcess(MPeerProc* peerProc,
                       const MPackage& package,
                       size_t minHosts=1,
                       size_t maxHosts=1000,
                       double minUptime=100,
                       double minCPU=0,
                       double minNetwork=0);
    
    bool attach(int localPort, const mstr& user, const mstr& password);
    
    size_t maxProcesses() const;
    
    void setMaxProcesses(size_t maxProcesses);
    
    const mstr& scratchDir() const;
    
    void setScratchDir(const mstr& scratchDir);
    
    int localPort() const;
    
    virtual void onHubDisconnect();
    
    virtual void onUpdate();
    
    mvar peerInfo() const;
    
    mvar groupInfo() const;
    
  private:  
    MPeer& operator=(const MPeer&);
    MPeer(const MPeer&);
    
    class MPeer_* x_;
  };
  
} // end namespace Meta

#endif // ANDROMETA_M_PEER_H