博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
boost::asio async_write也不能保证一次发完所有数据 一
阅读量:5235 次
发布时间:2019-06-14

本文共 2007 字,大约阅读时间需要 6 分钟。

你要是看过basic_stream_socket的文档,里面提到async_write_some不能保证将所有要发送的数据都发出去。并且提到如果想这样做,需要使用boost asio的async_write

 

RemarksThe write operation may not transmit all of the data to the peer. Consider using the async_write function if you need to ensure that all data is written before the asynchronous operation completes.

但是这几天我就遇到一个问题,以前一直都是一次发送成功的。

 

我想发送54个字节的数据,可是每次都是只发9个字节。因此只好自己写了一个重试发送的递归函数。也很简单,通过bind,每次传递想要发送的字节数木和发送开始位置给异步回调函数。

代码参考如下:

 

void Sign::AfterWriteMessage(error_code const& ec, size_t bytes_transferred, size_t expected_size,  size_t offset) {  if (ec) {    BOOSTER_ERROR("AfterWriteMessage") << "write message failed, error code:" << ec.value()				       << " category name:" << ec.category().name()				       << " id_:" << id_				       << " address:" << address  				       << " message:" << ec.message();    Close();    return;  }  BOOSTER_DEBUG("AfterWriteMessage") << "thread id: " << this_thread::get_id() << " send_buffer: " << PrintBytesAsHexString(send_buffer, bytes_transferred) << " sent size:" << bytes_transferred;  BOOSTER_DEBUG("AfterWriteMessage") << "thread id: " << this_thread::get_id() << " send_buffer: " << PrintBytesAsHexString(send_buffer, expected_size) << " expected size:" << expected_size;    size_t resend_size = expected_size - bytes_transferred;  if (resend_size > 0) {    size_t new_offset = offset + bytes_transferred;    async_write(socket, buffer((void*)&send_buffer[new_offset], resend_size),		strand_.wrap(bind(&Sign::AfterWriteMessage, shared_from_this(), _1, _2, resend_size, new_offset)));    return;  }  // do your business after send succeeds  }void Sign::SendMessage(size_t size) {  //  BOOSTER_DEBUG("SendMessage") << "thread id: " << this_thread::get_id() << " send_buffer: " << PrintBytesAsHexString(send_buffer, size) << " size:" << size;  async_write(socket, buffer(send_buffer, size),	      strand_.wrap(bind(&Sign::AfterWriteMessage, shared_from_this(), _1, _2, size, 0)));}

 

但是为什么呢?难道真的是bug. 请看下一篇。

 

 

 

转载于:https://www.cnblogs.com/jiangu66/p/3167736.html

你可能感兴趣的文章
HDU 1811 Rank of Tetris
查看>>
L - Subway - POJ 2502
查看>>
DS_Store 是什么文件
查看>>
浅析Java中的final关键字--转
查看>>
cocoaPods使用
查看>>
javascript中全屏滑动效果实现
查看>>
ABAP 实现内表自定义的F4功能
查看>>
Service
查看>>
BZOJ4542: [Hnoi2016]大数
查看>>
python2.7.3的安装
查看>>
SQL server 行转列 列转行
查看>>
Frequent Pattern挖掘之四(MapReduce框架下的FP Growth算法详解上篇)(转)
查看>>
eclipse调试(转)
查看>>
单调队列 POJ 2823
查看>>
C# string ASCII相互转换
查看>>
前端读者 | 过了30岁,人生就没有退路
查看>>
网页元素检测工具:Spy_for_InternetExplorer下载地址
查看>>
DemoBoxWeight
查看>>
uva 11752 The Super Powers 素数+大数判断大小
查看>>
css 浅析display属性
查看>>