Update of /cvsroot/playerstage/code/player/client_libs/libplayerc
In directory
sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv10388/client_libs/libplayerc
Modified Files:
client.c playerc.h
Log Message:
added message to inform clients of queue overflows
fixed some of the replace rule logic so that the queue does not expand
indefinately
Index: client.c
===================================================================
RCS file: /cvsroot/playerstage/code/player/client_libs/libplayerc/client.c,v
retrieving revision 1.94
retrieving revision 1.95
diff -C2 -d -r1.94 -r1.95
*** client.c 4 Feb 2008 18:59:43 -0000 1.94
--- client.c 9 Feb 2008 02:52:29 -0000 1.95
***************
*** 641,648 ****
case PLAYER_MSGTYPE_SYNCH:
client->data_requested = 0;
if(!client->data_received)
{
PLAYERC_WARN ("No data recieved with SYNC");
! return -1;
}
else
--- 641,652 ----
case PLAYER_MSGTYPE_SYNCH:
client->data_requested = 0;
+ if (header.subtype == PLAYER_PLAYER_SYNCH_OVERFLOW)
+ {
+ client->overflow_count += *((uint32_t*)client->data);
+ }
if(!client->data_received)
{
PLAYERC_WARN ("No data recieved with SYNC");
! ret = -1;
}
else
***************
*** 650,655 ****
if (proxy)
*proxy = client->id;
! return 1;
}
case PLAYER_MSGTYPE_DATA:
client->lasttime = client->datatime;
--- 654,661 ----
if (proxy)
*proxy = client->id;
! ret = 1;
}
+ playerxdr_cleanup_message(client->data, header.addr.interf,
header.type, header.subtype);
+ return ret;
case PLAYER_MSGTYPE_DATA:
client->lasttime = client->datatime;
Index: playerc.h
===================================================================
RCS file: /cvsroot/playerstage/code/player/client_libs/libplayerc/playerc.h,v
retrieving revision 1.252
retrieving revision 1.253
diff -C2 -d -r1.252 -r1.253
*** playerc.h 7 Feb 2008 02:22:59 -0000 1.252
--- playerc.h 9 Feb 2008 02:52:29 -0000 1.253
***************
*** 459,462 ****
--- 459,466 ----
double retry_time;
+ /** How many messages were lost on the server due to overflows, incremented
by player, cleared by user. */
+ uint32_t overflow_count;
+
+
/** @internal Socket descriptor */
int sock;
-------------------------------------------------------------------------
This SF.net email is sponsored by: Microsoft
Defy all challenges. Microsoft(R) Visual Studio 2008.
http://clk.atdmt.com/MRT/go/vse0120000070mrt/direct/01/
_______________________________________________
Playerstage-commit mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/playerstage-commit
