I just wanted to start updating the master project with some of the
patches I have been using in our development here.
So, this patch adds an antEnvMsg::Receive() to each incoming msg from
the Aperios callbacks. All this does is bring the current state of the
wireless more inline with the way Sony actually does it in the reference
documentation. I initially did this for more stability in the wireless
code and I was looking for differences between the Sony stuff and
Tekkotsu. This patch has been working well for us here and we are doing
some heavy dog to dog communication. I will also be submitting a helper
function later on.
Chris

--
Chris Mansley
Research Assistant
VADER Lab
Lehigh University

? msg.patch
Index: Wireless/Wireless.cc
===================================================================
RCS file: /cvs/Tekkotsu/Wireless/Wireless.cc,v
retrieving revision 1.32
diff -u -b -r1.32 Wireless.cc
--- Wireless/Wireless.cc 11 Nov 2005 21:11:02 -0000 1.32
+++ Wireless/Wireless.cc 16 Mar 2006 18:34:37 -0000
@@ -191,7 +191,7 @@

if ( sockets[sock]->trType == SOCK_STREAM )
{
- TCPEndpointListenMsg * listenMsg = ( TCPEndpointListenMsg * ) msg;
+ TCPEndpointListenMsg * listenMsg = ( TCPEndpointListenMsg * )
antEnvMsg::Receive( msg );

if ( listenMsg->error != TCP_SUCCESS )
{
@@ -227,7 +227,7 @@

if ( sockets[sock]->trType == SOCK_STREAM )
{
- TCPEndpointConnectMsg * connectMsg = ( TCPEndpointConnectMsg * ) msg;
+ TCPEndpointConnectMsg * connectMsg = ( TCPEndpointConnectMsg * )
antEnvMsg::Receive( msg );
if ( connectMsg->error != TCP_SUCCESS )
{
sockets[sock]->state = CONNECTION_ERROR;
@@ -253,7 +253,7 @@
Wireless::BindCont(void *msg)
{
try {
- UDPEndpointBindMsg* bindMsg = (UDPEndpointBindMsg*)msg;
+ UDPEndpointBindMsg* bindMsg = (UDPEndpointBindMsg*) antEnvMsg::Receive( msg );
int sock = (int)bindMsg->continuation;

if (bindMsg->error != UDP_SUCCESS) {
@@ -316,7 +316,7 @@

if ( sockets[sock]->trType == SOCK_STREAM )
{
- TCPEndpointSendMsg * sendMsg = ( TCPEndpointSendMsg * ) msg;
+ TCPEndpointSendMsg * sendMsg = ( TCPEndpointSendMsg * ) antEnvMsg::Receive(
msg );
sockets[sock]->tx = false;
if ( sendMsg->error != TCP_SUCCESS )
{
@@ -328,7 +328,7 @@

else if ( sockets[sock]->trType == SOCK_DGRAM )
{
- UDPEndpointSendMsg * sendMsg = ( UDPEndpointSendMsg * ) msg;
+ UDPEndpointSendMsg * sendMsg = ( UDPEndpointSendMsg * ) antEnvMsg::Receive(
msg );
sockets[sock]->tx = false;
if ( sendMsg->error != UDP_SUCCESS )
{
@@ -445,7 +445,7 @@

if ( sockets[sock]->trType == SOCK_STREAM )
{
- TCPEndpointReceiveMsg * receiveMsg = ( TCPEndpointReceiveMsg * ) msg;
+ TCPEndpointReceiveMsg * receiveMsg = ( TCPEndpointReceiveMsg * )
antEnvMsg::Receive( msg );
if ( receiveMsg->error != TCP_SUCCESS )
{
sockets[sock]->state = CONNECTION_ERROR;
@@ -569,7 +569,7 @@
Wireless::CloseCont(void* msg)
{
try {
- antEnvMsg * closeMsg = ( antEnvMsg * ) msg;
+ antEnvMsg * closeMsg = ( antEnvMsg * ) antEnvMsg::Receive( msg );
int sock = ( int )( closeMsg->continuation );
if ( sockets[sock] == NULL )
return;