3party/protobuf-c
0
0
Fork 0
mirror of https://github.com/protobuf-c/protobuf-c.git synced 2024-12-29 23:42:12 +08:00
Code Issues Projects Releases Wiki Activity

git-svn-id: https://protobuf-c.googlecode.com/svn/trunk@117 00440858-1255-0410-a3e6-75ea37f81c3a

Browse Source
This commit is contained in:
lahiker42 2009-01-25 04:57:32 +00:00
parent 462a684323
commit e135ebd217
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/google/protobuf-c/protobuf-c-rpc.c
View File

@ -412,6 +412,7 @@ uint32_to_le (uint32_t le)
| ((le << 8) & 0xff00); | ((le << 8) & 0xff00);
#endif #endif
} }
#define uint32_from_le uint32_to_le /* make the code more readable, i guess */
static void static void
enqueue_request (ProtobufC_RPC_Client *client, enqueue_request (ProtobufC_RPC_Client *client,
@ -509,13 +510,26 @@ handle_client_fd_events (int fd,
else if (read_rv == 0) else if (read_rv == 0)
{ {
/* handle eof */ /* handle eof */
... client_failed (client,
"got end-of-file from server [%u bytes incoming, %u bytes outgoing]",
client->incoming.size, client->outgoing.size);
} }
else else
{ {
/* try processing buffer */ /* try processing buffer */
while (client->incoming.size >= 12) while (client->incoming.size >= 12)
{ {
uint32_t header[3];
unsigned service_index, message_length, request_id;
protobuf_c_data_buffer_peek (&client->incoming, header, sizeof (header));
service_index = uint32_from_le (header[0]);
message_length = uint32_from_le (header[1]);
request_id = header[2]; /* already native-endian */
if (12 + message_length > client.incoming.size)
break;
/* lookup request by id */
... ...
} }
} }