dedicated_server_rpc.h

Go to the documentation of this file.

// Copyright (C) 2013-2020 iFunFactory Inc. All Rights Reserved.
//
// This work is confidential and proprietary to iFunFactory Inc. and
// must not be used, disclosed, copied, or distributed without the prior
// consent of iFunFactory Inc.

#ifndef INCLUDE_FUNAPI_DISTRIBUTION_DEDICATED_SERVER_RPC_H_
#define INCLUDE_FUNAPI_DISTRIBUTION_DEDICATED_SERVER_RPC_H_

#include <boost/asio.hpp>
#include <boost/function.hpp>
#include <boost/noncopyable.hpp>
#include <funapi/distribution/fun_dedicated_server_rpc_message.pb.h>
#include <funapi/types.h>

#include <map>


namespace fun {

class FUNAPI_DLL_VISIBILITY DedicatedServerRpc : private boost::noncopyable {
 public:
  typedef Uuid PeerId;
  typedef Uuid Xid;
  typedef boost::asio::ip::tcp::endpoint PeerEndpoint;
  typedef std::map<PeerId, PeerEndpoint> PeerMap;
  typedef string Tag;

  typedef boost::function<void(const PeerId &/*peer*/)> ConnectHandler;

  typedef boost::function<void(const PeerId &/*peer*/)> DisconnectHandler;

  typedef boost::function<
      void(const PeerId &/*peer*/, const Xid &/*xid*/,
           const Ptr<const FunDedicatedServerRpcMessage> &/*reply*/)> Callback;

  static const Xid kNullXid;
  static const PeerId kNullPeerId;

  static bool HasTag(const PeerId &peer, const Tag &tag);

  static Tag GetPeerTag(const PeerId &peer);

  static size_t GetPeers(PeerMap *ret);

  static size_t GetPeersWithTag(PeerMap *ret, const Tag &tag);

  static bool IsPeerConnected(const PeerId &peer);

  static void RegisterConnectHandler(const ConnectHandler &h);

  static void RegisterDisconnectHandler(const DisconnectHandler &h);

  static void Call(const PeerId &peer,
                   const Ptr<FunDedicatedServerRpcMessage> &msg,
                   const Callback &callback) ASSERT_NO_ROLLBACK;

  static void CallRandomly(const Ptr<FunDedicatedServerRpcMessage> &msg,
                           const Callback &callback) ASSERT_NO_ROLLBACK;
};

}  // namespace fun

#endif  // INCLUDE_FUNAPI_DISTRIBUTION_DEDICATED_SERVER_RPC_H_