|
? 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;
|