Miroirs/xwords
1
0
Fork 0
mirror of git://xwords.git.sourceforge.net/gitroot/xwords/xwords synced 2025-02-09 22:00:39 +01:00
Code Issues Projects Releases Packages Wiki Activity

add error message; don't assert (crash) when socket closes.

Browse source
This commit is contained in:
ehouse 2005-09-04 20:31:34 +00:00
parent 6f8b33a05b
commit aa0a9ec158
1 changed files with 26 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
xwords4/linux/linuxmain.c
View file

@ -169,6 +169,10 @@ linux_getErrString( UtilErrID id )
/* message = "Another device has joined the game"; */ /* message = "Another device has joined the game"; */
/* break; */ /* break; */
case ERR_RELAY_BASE + XWRELAY_ERROR_LOST_OTHER:
message = "XWRELAY_ERROR_LOST_OTHER";
break;
case ERR_RELAY_BASE + XWRELAY_ERROR_TIMEOUT: case ERR_RELAY_BASE + XWRELAY_ERROR_TIMEOUT:
message = "The relay timed you out; maybe the other players " message = "The relay timed you out; maybe the other players "
"didn't show."; "didn't show.";
@ -182,6 +186,7 @@ linux_getErrString( UtilErrID id )
break; break;
default: default:
XP_LOGF( "no code for error: %d", id );
message = "<unrecognized error code reported>"; message = "<unrecognized error code reported>";
} }
@ -321,6 +326,16 @@ linux_init_socket( CommonGlobals* cGlobals )
return sock; return sock;
} /* linux_init_socket */ } /* linux_init_socket */
static void
linux_close_socket( CommonGlobals* cGlobals )
{
int socket = cGlobals->socket;
cGlobals->socket = -1;
XP_LOGF( "linux_close_socket" );
close( socket );
}
int int
linux_receive( CommonGlobals* cGlobals, unsigned char* buf, int bufSize ) linux_receive( CommonGlobals* cGlobals, unsigned char* buf, int bufSize )
{ {
@ -328,13 +343,18 @@ linux_receive( CommonGlobals* cGlobals, unsigned char* buf, int bufSize )
unsigned short tmp; unsigned short tmp;
unsigned short packetSize; unsigned short packetSize;
ssize_t nRead = recv( sock, &tmp, sizeof(tmp), 0 ); ssize_t nRead = recv( sock, &tmp, sizeof(tmp), 0 );
assert( nRead == 2 ); if ( nRead != 2 ) {
XP_LOGF( "recv => %d, errno=%d", nRead, errno );
linux_close_socket( cGlobals );
nRead = -1;
} else {
packetSize = ntohs( tmp ); packetSize = ntohs( tmp );
assert( packetSize <= bufSize ); assert( packetSize <= bufSize );
nRead = recv( sock, buf, packetSize, 0 ); nRead = recv( sock, buf, packetSize, 0 );
if ( nRead < 0 ) { if ( nRead < 0 ) {
XP_WARNF( "linuxReceive: errno=%d\n", errno ); XP_WARNF( "linuxReceive: errno=%d\n", errno );
}
} }
return nRead; return nRead;
} /* linuxReceive */ } /* linuxReceive */