RpcCommunicator.cc 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109
  1. #include <boost/bind.hpp>
  2. #include <boost/asio.hpp>
  3. #include <boost/lexical_cast.hpp>
  4. #include <glog/logging.h>
  5. #include "Rpc/RpcCommunicator.h"
  6. namespace Egametang {
  7. RpcCommunicator::RpcCommunicator(boost::asio::io_service& service):
  8. io_service(service), socket(service)
  9. {
  10. }
  11. RpcCommunicator::~RpcCommunicator()
  12. {
  13. }
  14. boost::asio::ip::tcp::socket& RpcCommunicator::Socket()
  15. {
  16. return socket;
  17. }
  18. void RpcCommunicator::Stop()
  19. {
  20. socket.close();
  21. }
  22. void RpcCommunicator::RecvMeta(RpcMetaPtr meta, StringPtr message)
  23. {
  24. boost::asio::async_read(socket,
  25. boost::asio::buffer(reinterpret_cast<char*>(meta.get()), sizeof(*meta)),
  26. boost::bind(&RpcCommunicator::RecvMessage, this,
  27. meta, message, boost::asio::placeholders::error));
  28. }
  29. void RpcCommunicator::RecvMessage(RpcMetaPtr meta, StringPtr message,
  30. const boost::system::error_code& err)
  31. {
  32. if (err)
  33. {
  34. LOG(ERROR) << "receive message size failed: " << err.message();
  35. Stop();
  36. return;
  37. }
  38. message->resize(meta->size, '\0');
  39. boost::asio::async_read(socket,
  40. boost::asio::buffer(reinterpret_cast<char*>(&message->at(0)), meta->size),
  41. boost::bind(&RpcCommunicator::RecvDone, this,
  42. meta, message, boost::asio::placeholders::error));
  43. }
  44. void RpcCommunicator::RecvDone(RpcMetaPtr meta, StringPtr message,
  45. const boost::system::error_code& err)
  46. {
  47. if (err)
  48. {
  49. LOG(ERROR) << "receive message failed: " << err.message();
  50. Stop();
  51. return;
  52. }
  53. OnRecvMessage(meta, message);
  54. }
  55. void RpcCommunicator::OnRecvMessage(RpcMetaPtr meta, StringPtr message)
  56. {
  57. }
  58. void RpcCommunicator::SendMeta(RpcMetaPtr meta, StringPtr message)
  59. {
  60. CHECK_EQ(meta->size, message->size()) << "meta and message size not match!";
  61. boost::asio::async_write(socket,
  62. boost::asio::buffer(reinterpret_cast<char*>(meta.get()), sizeof(*meta)),
  63. boost::bind(&RpcCommunicator::SendMessage, this,
  64. meta, message, boost::asio::placeholders::error));
  65. }
  66. void RpcCommunicator::SendMessage(RpcMetaPtr meta, StringPtr message,
  67. const boost::system::error_code& err)
  68. {
  69. if (err)
  70. {
  71. LOG(ERROR) << "send message size failed: " << err.message();
  72. Stop();
  73. return;
  74. }
  75. boost::asio::async_write(socket, boost::asio::buffer(*message),
  76. boost::bind(&RpcCommunicator::SendDone, this,
  77. meta, message, boost::asio::placeholders::error));
  78. }
  79. void RpcCommunicator::SendDone(RpcMetaPtr meta, StringPtr message,
  80. const boost::system::error_code& err)
  81. {
  82. if (err)
  83. {
  84. LOG(ERROR) << "send message failed: " << err.message();
  85. Stop();
  86. return;
  87. }
  88. OnSendMessage(meta, message);
  89. }
  90. void RpcCommunicator::OnSendMessage(RpcMetaPtr meta, StringPtr message)
  91. {
  92. }
  93. } // namespace Egametang