13 lines
391 B
Diff
13 lines
391 B
Diff
|
--- a/plugins/emperor_amqp/amqp.c
|
||
|
|
+++ b/plugins/emperor_amqp/amqp.c
|
||
|
|
@@ -453,7 +453,8 @@ static int amqp_wait_connection_tune(int
|
||
|
|
static char *amqp_simple_get_frame(int fd, struct amqp_frame_header *fh) {
|
||
|
|
|
||
|
|
char *ptr = (char *) fh;
|
||
|
|
- ssize_t len = 0, rlen;
|
||
|
|
+ size_t len = 0;
|
||
|
|
+ ssize_t rlen;
|
||
|
|
|
||
|
|
while(len < 7) {
|
||
|
|
rlen = recv(fd, ptr, 7-len, 0);
|