Update of /cvsroot/playerstage/code/player/client_libs/libplayerc
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv3772
Modified Files:
client.c
Log Message:
Changed setting of datatime and lasttime to happen for data messages instead of
sync messages.
Index: client.c
===================================================================
RCS file: /cvsroot/playerstage/code/player/client_libs/libplayerc/client.c,v
retrieving revision 1.72
retrieving revision 1.73
diff -C2 -d -r1.72 -r1.73
*** client.c 13 Sep 2006 23:59:40 -0000 1.72
--- client.c 16 Nov 2006 00:29:19 -0000 1.73
***************
*** 111,118 ****
struct pollfd ufd;
int ret;
!
ufd.fd = s;
ufd.events = POLLIN | POLLPRI | POLLERR | POLLHUP | POLLNVAL;
!
ret = poll (&ufd, 1, timeout);
if (ret <= 0)
--- 111,118 ----
struct pollfd ufd;
int ret;
!
ufd.fd = s;
ufd.events = POLLIN | POLLPRI | POLLERR | POLLHUP | POLLNVAL;
!
ret = poll (&ufd, 1, timeout);
if (ret <= 0)
***************
*** 121,125 ****
return ret;
}
!
return recv(s,buf,len,flags);
}
--- 121,125 ----
return ret;
}
!
return recv(s,buf,len,flags);
}
***************
*** 219,225 ****
return -1;
}
! /*
* INADDR_ANY indicates that any network interface (IP address)
! * for the local host may be used (presumably the OS will choose the
* right one).
*
--- 219,225 ----
return -1;
}
! /*
* INADDR_ANY indicates that any network interface (IP address)
! * for the local host may be used (presumably the OS will choose the
* right one).
*
***************
*** 230,235 ****
clientaddr.sin_port = 0;
! if(bind(client->sock,
! (struct sockaddr*)&clientaddr, sizeof(clientaddr)) < -1)
{
PLAYERC_ERR1("bind call failed with error [%s]", strerror(errno));
--- 230,235 ----
clientaddr.sin_port = 0;
! if(bind(client->sock,
! (struct sockaddr*)&clientaddr, sizeof(clientaddr)) < -1)
{
PLAYERC_ERR1("bind call failed with error [%s]", strerror(errno));
***************
*** 257,261 ****
memcpy(&client->server.sin_addr, entp->h_addr_list[0], entp->h_length);
client->server.sin_port = htons(client->port);
!
// Connect the socket
/*
--- 257,261 ----
memcpy(&client->server.sin_addr, entp->h_addr_list[0], entp->h_length);
client->server.sin_port = htons(client->port);
!
// Connect the socket
/*
***************
*** 271,275 ****
gettimeofday(&last,NULL);
puts("calling connect");
! ret = connect(client->sock, (struct sockaddr*)&client->server,
sizeof(client->server));
gettimeofday(&curr,NULL);
--- 271,275 ----
gettimeofday(&last,NULL);
puts("calling connect");
! ret = connect(client->sock, (struct sockaddr*)&client->server,
sizeof(client->server));
gettimeofday(&curr,NULL);
***************
*** 283,287 ****
timer.it_interval.tv_usec = 0;
timer.it_value.tv_sec = (int)floor(client->request_timeout);
! timer.it_value.tv_usec =
(int)rint(fmod(client->request_timeout,timer.it_value.tv_sec)*1e6);
if(setitimer(ITIMER_REAL, &timer, NULL) != 0)
--- 283,287 ----
timer.it_interval.tv_usec = 0;
timer.it_value.tv_sec = (int)floor(client->request_timeout);
! timer.it_value.tv_usec =
(int)rint(fmod(client->request_timeout,timer.it_value.tv_sec)*1e6);
if(setitimer(ITIMER_REAL, &timer, NULL) != 0)
***************
*** 304,308 ****
puts("calling connect");
! ret = connect(client->sock, (struct sockaddr*)&client->server,
sizeof(client->server));
puts("done");
--- 304,308 ----
puts("calling connect");
! ret = connect(client->sock, (struct sockaddr*)&client->server,
sizeof(client->server));
puts("done");
***************
*** 351,356 ****
return -1;
}
!
!
// Get the banner
if (timed_recv(client->sock, banner, sizeof(banner), 0, 2000) <
sizeof(banner))
--- 351,356 ----
return -1;
}
!
!
// Get the banner
if (timed_recv(client->sock, banner, sizeof(banner), 0, 2000) <
sizeof(banner))
***************
*** 387,391 ****
/* Clean out buffers */
client->read_xdrdata_len = 0;
!
/* TODO: re-establish replacement rules, delivery modes, etc. */
--- 387,391 ----
/* Clean out buffers */
client->read_xdrdata_len = 0;
!
/* TODO: re-establish replacement rules, delivery modes, etc. */
***************
*** 502,506 ****
return -1;
}
!
if (client->qlen > 0)
--- 502,506 ----
return -1;
}
!
if (client->qlen > 0)
***************
*** 558,565 ****
break;
case PLAYER_MSGTYPE_SYNCH:
- client->lasttime = client->datatime;
- client->datatime = header.timestamp;
return client->id;
case PLAYER_MSGTYPE_DATA:
if (client->mode == PLAYER_DATAMODE_PUSH)
// If in push mode, handle and return
--- 558,565 ----
break;
case PLAYER_MSGTYPE_SYNCH:
return client->id;
case PLAYER_MSGTYPE_DATA:
+ client->lasttime = client->datatime;
+ client->datatime = header.timestamp;
if (client->mode == PLAYER_DATAMODE_PUSH)
// If in push mode, handle and return
***************
*** 904,911 ****
return -1;
}
!
while(client->read_xdrdata_len < PLAYERXDR_MSGHDR_SIZE)
{
! nbytes = timed_recv(client->sock,
client->read_xdrdata + client->read_xdrdata_len,
PLAYERXDR_MAX_MESSAGE_SIZE - client->read_xdrdata_len,
--- 904,911 ----
return -1;
}
!
while(client->read_xdrdata_len < PLAYERXDR_MSGHDR_SIZE)
{
! nbytes = timed_recv(client->sock,
client->read_xdrdata + client->read_xdrdata_len,
PLAYERXDR_MAX_MESSAGE_SIZE - client->read_xdrdata_len,
***************
*** 938,942 ****
// Slide over the header
! memmove(client->read_xdrdata,
client->read_xdrdata + PLAYERXDR_MSGHDR_SIZE,
client->read_xdrdata_len - PLAYERXDR_MSGHDR_SIZE);
--- 938,942 ----
// Slide over the header
! memmove(client->read_xdrdata,
client->read_xdrdata + PLAYERXDR_MSGHDR_SIZE,
client->read_xdrdata_len - PLAYERXDR_MSGHDR_SIZE);
***************
*** 945,949 ****
while(client->read_xdrdata_len < header->size)
{
! nbytes = timed_recv(client->sock,
client->read_xdrdata + client->read_xdrdata_len,
PLAYERXDR_MAX_MESSAGE_SIZE - client->read_xdrdata_len,
--- 945,949 ----
while(client->read_xdrdata_len < header->size)
{
! nbytes = timed_recv(client->sock,
client->read_xdrdata + client->read_xdrdata_len,
PLAYERXDR_MAX_MESSAGE_SIZE - client->read_xdrdata_len,
***************
*** 986,990 ****
// Slide over the body
! memmove(client->read_xdrdata,
client->read_xdrdata + header->size,
client->read_xdrdata_len - header->size);
--- 986,990 ----
// Slide over the body
! memmove(client->read_xdrdata,
client->read_xdrdata + header->size,
client->read_xdrdata_len - header->size);
***************
*** 1056,1060 ****
length = PLAYERXDR_MSGHDR_SIZE + encode_msglen;
bytes = PLAYERXDR_MSGHDR_SIZE + encode_msglen;
! do
{
ret = send(client->sock, &client->write_xdrdata[length-bytes],
--- 1056,1060 ----
length = PLAYERXDR_MSGHDR_SIZE + encode_msglen;
bytes = PLAYERXDR_MSGHDR_SIZE + encode_msglen;
! do
{
ret = send(client->sock, &client->write_xdrdata[length-bytes],
-------------------------------------------------------------------------
Take Surveys. Earn Cash. Influence the Future of IT
Join SourceForge.net's Techsay panel and you'll get the chance to share your
opinions on IT & business topics through brief surveys - and earn cash
http://www.techsay.com/default.php?page=join.php&p=sourceforge&CID=DEVDEV
_______________________________________________
Playerstage-commit mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/playerstage-commit
