且构网

分享程序员开发的那些事...
且构网 - 分享程序员编程开发的那些事
您所在的位置：首页 > mooon-agent发送状态机代码摘要

mooon-agent发送状态机代码摘要

更新时间：2022-09-21 20:41:53

发送状态机比接收状态机相对要简单

  • send_machine.h


    

  1. #ifndef MOOON_AGENT_SEND_MACHINE_H  
    2. 

  2.  
    3. 

  3. #define MOOON_AGENT_SEND_MACHINE_H  
    4. 

  4.  
    5. 

  5. #include <agent/config.h>  
    6. 

  6.  
    7. 

  7. AGENT_NAMESPACE_BEGIN  
    8. 

  8.  
    9. 

  9.  
    10. 

  10.  
    11. 

  11. class CAgentConnector;  
    12. 

  12.  
    13. 

  13. class CSendMachine  
    14. 

  14.  
    15. 

  15. {  
    16. 

  16.  
    17. 

  17. 
public:  

    18. 

  18.  
    19. 

  19.     CSendMachine(CAgentConnector* connector);  
    20. 

  20.  
    21. 

  21.     bool is_finish() const;  
    22. 

  22.  
    23. 

  23.     util::handle_result_t continue_send();  
    24. 

  24.  
    25. 

  25. 
    util::handle_result_t send(const char* msg, size_t msg_size);  

    26. 

  26.  
    27. 

  27.     void reset();  
    28. 

  28.  
    29. 

  29.       
    30. 

  30.  
    31. 

  31. private:  
    32. 

  32.  
    33. 

  33.     CAgentConnector* _connector;  
    34. 

  34.  
    35. 

  35.       
    36. 

  36.  
    37. 

  37. private:  
    38. 

  38.  
    39. 

  39. 
    const char* _cursor;  

    40. 

  40.  
    41. 

  41.     size_t _remain_size;   
    42. 

  42.  
    43. 

  43. };  
    44. 

  44.  
    45. 

  45.  
    46. 

  46.  
    47. 

  47. AGENT_NAMESPACE_END  
    48. 

  48.  
    49. 

  49. #endif // MOOON_AGENT_SEND_MACHINE_H  
    50. 



  • send_machine.cpp




    

  1. #include "send_machine.h" 
    2. 

  2.  
    3. 

  3. 
#include "agent_connector.h" 

    4. 

  4.  
    5. 

  5. AGENT_NAMESPACE_BEGIN  
    6. 

  6.  
    7. 

  7.  
    8. 

  8.  
    9. 

  9. CSendMachine::CSendMachine(CAgentConnector* connector)  
    10. 

  10.  
    11. 

  11.  :_connector(connector)   
    12. 

  12.  
    13. 

  13. {  
    14. 

  14.  
    15. 

  15.     reset();  
    16. 

  16.  
    17. 

  17. }  
    18. 

  18.  
    19. 

  19.  
    20. 

  20.  
    21. 

  21. // 当前消息是否已经发送完  
    22. 

  22.  
    23. 

  23. bool CSendMachine::is_finish() const  
    24. 

  24.  
    25. 

  25. {  
    26. 

  26.  
    27. 

  27. 
    return 0 == _remain_size;  

    28. 

  28.  
    29. 

  29. }  
    30. 

  30.  
    31. 

  31.  
    32. 

  32.  
    33. 

  33. // 发送消息，可能是一个消息的第一次发送，也可能是一个消息的非第一次发送  
    34. 

  34.  
    35. 

  35. util::handle_result_t CSendMachine::continue_send()  
    36. 

  36.  
    37. 

  37. {  
    38. 

  38.  
    39. 

  39.     ssize_t bytes_sent = _connector->send(_cursor, _remain_size);  
    40. 

  40.  
    41. 

  41.     if (bytes_sent > -1)  
    42. 

  42.  
    43. 

  43.     {  
    44. 

  44.  
    45. 

  45.         _cursor += bytes_sent;  
    46. 

  46.  
    47. 

  47.         _remain_size -= bytes_sent;  
    48. 

  48.  
    49. 

  49.     }  
    50. 

  50.  
    51. 

  51.       
    52. 

  52.  
    53. 

  53. 
    return is_finish()   

    54. 

  54.  
    55. 

  55.          ? util::handle_finish   
    56. 

  56.  
    57. 

  57.          : util::handle_continue;  
    58. 

  58.  
    59. 

  59. }  
    60. 

  60.  
    61. 

  61.  
    62. 

  62.  
    63. 

  63. // 发送消息，总是一个消息的第一次发送  
    64. 

  64.  
    65. 

  65. // 参数说明：  
    66. 

  66.  
    67. 

  67. // msg - 需要发送的消息  
    68. 

  68.  
    69. 

  69. // msg_size - 需要发送的消息字节数  
    70. 

  70.  
    71. 

  71. 
util::handle_result_t CSendMachine::send(const char* msg, size_t msg_size)  

    72. 

  72.  
    73. 

  73. {  
    74. 

  74.  
    75. 

  75.     _cursor = msg;  
    76. 

  76.  
    77. 

  77.     _remain_size = msg_size;  
    78. 

  78.  
    79. 

  79.       
    80. 

  80.  
    81. 

  81. 
    return continue_send();  

    82. 

  82.  
    83. 

  83. }  
    84. 

  84.  
    85. 

  85.  
    86. 

  86.  
    87. 

  87. void CSendMachine::reset()  
    88. 

  88.  
    89. 

  89. {  
    90. 

  90.  
    91. 

  91. 
    _cursor = NULL;  

    92. 

  92.  
    93. 

  93.     _remain_size = 0;  
    94. 

  94.  
    95. 

  95. }  
    96. 

  96.  
    97. 

  97.  
    98. 

  98.  
    99. 

  99. AGENT_NAMESPACE_END  
    100. 










    本文转自eyjian 51CTO博客，原文链接：http://blog.51cto.com/mooon/910295，如需转载请自行联系原作者










上一篇 : ：[PYTHON] 核心编程笔记(16.Python网络编程)下一篇 : Android 相机的使用
相关阅读
推荐文章






网站首页网站地图Copyright © 2021-2022 且购网  
免责声明：本站文章部分来源于互联网,如有侵权请联系站长,我们将在72小时内删除。