RpcSession.h 708 B

1234567891011121314151617181920212223242526272829303132
  1. #ifndef RPC_RPCSESSION_H
  2. #define RPC_RPCSESSION_H
  3. #include <boost/asio.hpp>
  4. #include <boost/enable_shared_from_this.hpp>
  5. #include "Base/Marcos.h"
  6. #include "Rpc/Typedef.h"
  7. #include "Rpc/RpcCommunicator.h"
  8. namespace Egametang {
  9. class RpcServer;
  10. class RpcSession: public RpcCommunicator, public boost::enable_shared_from_this<RpcSession>
  11. {
  12. private:
  13. RpcServer& rpcServer;
  14. bool isStopped;
  15. virtual void OnRecvMessage(RpcMetaPtr meta, StringPtr message);
  16. virtual void OnSendMessage(RpcMetaPtr meta, StringPtr message);
  17. public:
  18. RpcSession(boost::asio::io_service& ioService, RpcServer& server);
  19. ~RpcSession();
  20. void Start();
  21. virtual void Stop();
  22. };
  23. } // namespace Egametang
  24. #endif // RPC_RPCSESSION_H