while (cdm) {
DEQ_REMOVE_HEAD(out_messages);
DEQ_INSERT_TAIL(to_send, cdm);
- if (DEQ_SIZE(to_send) == link_credit)
+ if (DEQ_SIZE(to_send) == (size_t)link_credit)
break;
cdm = DEQ_HEAD(out_messages);
}
&cdm->mbuf.size)) == PN_OVERFLOW) {
DEBUG("amqp1 plugin: increasing message buffer size %zu", cdm->mbuf.size);
cdm->mbuf.size *= 2;
- cdm->mbuf.start = (char *)realloc(cdm->mbuf.start, cdm->mbuf.size);
+ cdm->mbuf.start = realloc(cdm->mbuf.start, cdm->mbuf.size);
}
if (status != 0) {