我正在使用BOOST与串行端口进行异步通信。我无法查明我所面临的错误的原因,并希望得到一些指导。
std::string myclass::readStringUntil(const std::string& delim)
{
setupParameters=ReadSetupParameters(delim);
performReadSetup(setupParameters);
if(timeout!=posix_time::seconds(0)) timer.expires_from_now(timeout);
else timer.expires_from_now(posix_time::hours(100000));
timer.async_wait(boost::bind(&myclass::timeoutExpired,this,
asio::placeholders::error));
result=resultInProgress;
bytesTransferred=0;
for(;;)
{
io.run_one();
switch(result)
{
case resultSuccess:
{
timer.cancel();
bytesTransferred-=delim.size();//Don't count delim
istream is(&readData);
string result(bytesTransferred,'\0');//Alloc string
is.read(&result[0],bytesTransferred);//Fill values
is.ignore(delim.size());//Remove delimiter from stream
return result;
}
case resultTimeoutExpired:
port.cancel();
throw(timeout_exception("Timeout expired"));
cout<<"timeout on readuntill"<<endl;
case resultError:
timer.cancel();
port.cancel();
throw(boost::system::system_error(boost::system::error_code(),
"Error while reading"));
}
}
/////////////////////////////////////////////////////////////////////////////
void myclass::performReadSetup(const ReadSetupParameters& param)
{
if(param.fixedSize)
{
asio::async_read(port,asio::buffer(param.data,param.size),boost::bind(
&myclass::readCompleted,this,asio::placeholders::error,
asio::placeholders::bytes_transferred));
} else {
asio::async_read_until(port,readData,param.delim,boost::bind(
&myclass::readCompleted,this,asio::placeholders::error,
asio::placeholders::bytes_transferred));
}
}
/////////////////////////////////////////////////////////////////////////////
void myclass::timeoutExpired(const boost::system::error_code& error)
{
if(!error && result==resultInProgress) result=resultTimeoutExpired;
}
/////////////////////////////////////////////////////////////////////////////
void myclass::readCompleted(const boost::system::error_code& error,
const size_t bytesTransferred)
{
if(!error)
{
result=resultSuccess;
this->bytesTransferred=bytesTransferred;
return;
}
#ifdef _WIN32
if(error.value()==995) return; //Windows spits out error 995
#elif defined(__APPLE__)
if(error.value()==45)
{
//Bug on OS X, it might be necessary to repeat the setup
//http://osdir.com/ml/lib.boost.asio.user/2008-08/msg00004.html
performReadSetup(setupParameters);
return;
}
#else //Linux
if(error.value()==125) return; //Linux outputs error 125
#endif
result=resultError;
}
如果没有io.run_one(),我将进入一个无限循环,而不会进入switch case。
我怎样才能修复我的代码,使它摆脱不确定的块?我无法确认,但我认为run_one()导致了错误#125
2条答案
按热度按时间2o7dmzc51#
首先,错误125是操作中止:所以这意味着(可能)一个cancel()调用(或者IO对象的析构函数导致取消)。
这很正常
我已经煞费苦心地完成了你不完整的代码¹,并不容易看到你的问题:
Live On Coliru
注意事项:
*read_until
可以读取 * 超出 * 分隔符(它将读取 * 至少 * 直到并包括第一次看到分隔符)。你真的应该解释一下run_one()
的返回值。如果返回0
,则循环应该退出。不执行reset()
而再次运行它将不会有任何效果。为什么?
vuktfyat2#
我的解决方法是: