システム構成: Win XP (i7 2.1 Ghz) 外部 USB NIC。通信:マスタースレーブ通信。制約 - 通信プロトコル UDP。
ソケット構成: RecvFrom - ノンブロッキング。setsockopt を使用して、ソケット サイズが 1*1024*1024 に変更されました。
私のセットアップは、UDP を介してマスターと通信するノードで構成され、UDP フレームのペイロードで断片化されたデータを送信します。この断片化されたデータは、イーサネット フレームごとに 5 つの frament で構成されます。スレーブ ノードは、1270 バイトの断片化されたデータをマスターに送信します。スレーブは 2 ミリ秒未満で 18 ~ 20 フレームを送信します。
マスターは、このフレームをドロップせずに定期的に受信します。ただし、2 つの正しいフラグメントと残りの 3 つのフラグメントを含む UDP フレームからのランダムなペイロード データはガベージ値です。私は smae フラグメントにある Wireshark のトレースを観察しましたが、正しいデータを観察できますが、recvfrom API がこれら 3 つのフラグメントでガベージ データを収集する方法がいくつかあります。実際の情報がこのガベージ値に置き換えられているようです。この動作は、パケット数を 2 ミリ秒あたり 2 ~ 3 に減らすと低下します。
コンソールからトレースします。
_recvBuf[2]: 0x5b _recvBuf[256}: 0x5c _recvBuf[510]: 0x5d
_recvBuf[764}: 0x5e _recvBuf[1018}: 0x5f
_recvBuf[2]: 0x60 _recvBuf[256}: 0x61 _recvBuf[510]: 0x64
_recvBuf[764}: 0x0 _recvBuf[1018}: 0x0
Expected and as in the Wireshark trace:
_recvBuf[510]: 0x64 --> should be _recvBuf[510]: 0x62
_recvBuf[764}: 0x0 --> should be _recvBuf[510]: 0x63
_recvBuf[1018}: 0x0 --> should be _recvBuf[510]: 0x64
ガベージ値は、ランダムなパケット番号に対して 0xcd に頻繁に繰り返されます。
!!! パケット 200 - エラー!!! パケット 20000 - エラー!!! パケット 60000 - エラー!!! パケット 2 - エラー
なぜこの動作なのか理解できません。
コード:
receive()
{
rc = select(_sock_fd+1, &read_fd, &write_fd, &excep_fd, &to);
if (rc == 0 )
acess = 1;
else if (rc == SOCKET_ERROR)
{
closesocket(_sock_fd);
return -1;
}
else
{
if (!FD_ISSET(_sock_fd, &read_fd))
{
LogError("XCP: select() wrong socket descr");
return -1;
}
else
{
rc = recvfrom(_sock_fd, (char *)_recvBuf, UDP_RECVBUFLEN, 0, (LPSOCKADDR)&_saddr, &cli_alen);
printf("_recvBuf[3]: 0x%x _recvBuf[2]: 0x%x _recvBuf[256}: 0x%x _recvBuf[510]: 0x%x _recvBuf[764}: 0x%x _recvBuf[1018}: 0x%x\n",_recvBuf[3],_recvBuf[2],_recvBuf[256],_recvBuf[510],_recvBuf[764],_recvBuf[1018]);
_recvBuf[*(&rc)]='\0';
if(rc == SOCKET_ERROR)
{
closesocket(_sock_fd);
return -1;
}
_recvBufLen = rc;
if (_recvBufLen > 0)
{
int rc = 0;
acess = 0;
if (_rxNotification != NULL)
_rxNotification(_parent, _xhdl, _recvBuf, _recvBufLen);
RxbufferLen=*(u16*)&_recvBufLen;
/* Proto RX Queue Implementation Start */
if(!(Fullqueue(Rxbufferqueue)))
Enqueue(Rxbufferqueue,_recvBuf);
if(_recvBuf[4]==0xff)
acess = 1;
else
acess = 0;
return rc;
}
else
return 0;
}
}
関数に関する追加情報:
void XcpTransportUdp::Enqueue (Queuetype &queue, unsigned char buf[MAX_BUFFER_SIZE_QUEUE],u16 _recvBufLen) // Push Function for Queue
{
Rxbufferqueue.BackPointer=(Rxbufferqueue.BackPointer+1)%MAX_BUFFER_IN_QUEUE;
Rxbufferqueue.Recv_length[Rxbufferqueue.BackPointer]=_recvBufLen;
memcpy(Rxbufferqueue.Buffer[Rxbufferqueue.BackPointer],buf,Rxbufferqueue.Recv_length[Rxbufferqueue.BackPointer]);
}
u16 XcpTransportUdp::Dequeue (Queuetype &queue, unsigned char Output_buffer[MAX_BUFFER_SIZE_QUEUE]) // Pop Function for Queue
{
Rxbufferqueue.Frontpointer =(Rxbufferqueue.Frontpointer+1)%MAX_BUFFER_IN_QUEUE;
BufLen=Rxbufferqueue.Recv_length[Rxbufferqueue.Frontpointer];
memcpy(Output_buffer,Rxbufferqueue.Buffer[Rxbufferqueue.Frontpointer],Rxbufferqueue.Recv_length[Rxbufferqueue.Frontpointer]);
return BufLen;
}
:::Edir1::: エラーはソケットではなくメモリの初期化に関係していることがわかりました。enqueue 関数の memcpy 関数は、長さが 0cCD であるというエラーを報告します。この問題の解決策を知っている人はいますか..?