对于一个计算机网络项目,我们正在用 C++ 编写一个具有不同窗口协议的 ftp 服务器。我们在实现工作超时功能时遇到问题。它的要点是在传输数据包时设置时间戳,如果“ack”在一定时间内(比如 2.5 毫秒)没有恢复,则重新传输数据包。我们目前使用该clock_gettime()
函数来获取数据包的当前时间和时间戳。
这是我们遇到问题的while循环:
while(packet_sync_array[prev].recieved ==0 && t==0)
{
clock_gettime(CLOCK_PROCESS_CPUTIME_ID,&timeout2);
currtime = timeout2.tv_nsec;
cout << "Is currtime: "<<currtime<< " - ptimeout " << ptimeout
<< " = " << (currtime - ptimeout) << " > "
<< (connection_parameters->timeoutInterval)*1000 << "?" << endl;
if((currtime - ptimeout)>((connection_parameters->timeoutInterval)*1000))
{
t = 1;
cout << "Prev PACKET TIMEDOUT" << endl;
cout << "Is currtime: "<<currtime<< " - ptimeout " << ptimeout
<< " = " << (currtime - ptimeout) << " > "
<< (connection_parameters->timeoutInterval)*1000 << "?" << endl;
}
}
哪里ptimeout
是发送数据包的时间,connection_parameters->timeoutInterval
是超时间隔。问题在于,由于ptimeout
是时间的长整数表示,有时它是一个非常大的值(例如 999715992)。这意味着它永远无法判断是否发生了超时,因为在值变得足够大之前,以纳秒为单位的当前时间将恢复为 0。
有没有其他人在 C++ 中处理过这些时间问题并有可能的解决方案?
谢谢!
编辑:
感谢您的快速回复!我能够弄清楚一些事情。修改while循环以检查超时+时间戳是否大于允许的长整数大小,让我看看clock_gettime在比较之前是否会变为零。知道这一点后,我检查了当前时间是否 >(超时间隔 - (最大长整数值 - 时间戳))。这允许最多 1 秒的超时,这对于这个问题来说应该是足够的。如果有人认为他们有更好的解决方案,请告诉我!谢谢!以下是感兴趣的人的代码:
if(((999999998-ptimeout)< (connection_parameters->timeoutInterval)*1000)&&(currtime - ptimeout)<0){
if(currtime > (((connection_parameters->timeoutInterval)*1000)-(999999998-ptimeout))){
t = 1;
cout << "this wrapped since " << currtime << " + " << (connection_parameters->timeoutInterval)*1000 << "is bigger than 999999999 and then timed out" << endl;
cout << "curr time " << currtime << "is bigger than" << endl;
cout << (connection_parameters->timeoutInterval)*1000 << endl;
cout << "-" << endl;
cout << (999999998-ptimeout) << endl;
cout << "---------------------------" << endl;
cout << (((connection_parameters->timeoutInterval)*1000)-(999999998-ptimeout)) << endl;
cout << "Prev PACKET TIMEDOUT" << endl;
cout << "Is currtime: "<<currtime<< " - ptimeout " << ptimeout << " = " << (currtime - ptimeout) << " > " << (connection_parameters->timeoutInterval)*1000 << "?" << endl;
}
}
else if((currtime - ptimeout)>((connection_parameters->timeoutInterval)*1000)){
t = 1;
cout << "Prev PACKET TIMEDOUT" << endl;
cout << "Is currtime: "<<currtime<< " - ptimeout " << ptimeout << " = " << (currtime - ptimeout) << " > " << (connection_parameters->timeoutInterval)*1000 << "?" << endl;
}