Lines Matching refs:msglen
224 typedef void (*QemudSerialReceive)( void* opaque, int channel, uint8_t* msg, int msglen);
523 int msglen )
527 int avail, len = msglen;
529 if (msglen <= 0 || channel < 0)
533 __FUNCTION__, channel, msglen,
534 quote_bytes((const void*)msg, msglen));
565 int2hex(frame, FRAME_HEADER_SIZE, msglen);
718 qemud_client_recv( void* opaque, uint8_t* msg, int msglen )
725 c->clie_recv( c->clie_opaque, msg, msglen, c );
736 if (msglen > FRAME_HEADER_SIZE &&
742 if (len >= 0 && msglen == len + FRAME_HEADER_SIZE) {
746 msglen-FRAME_HEADER_SIZE, c );
752 while (msglen > 0) {
760 if (!qemud_sink_fill(c->header, (const uint8_t**)&msg, &msglen))
781 if (!qemud_sink_fill(c->payload, (const uint8_t**)&msg, &msglen))
801 _qemud_pipe_send(QemudClient* client, const uint8_t* msg, int msglen);
1302 int msglen )
1313 qemud_client_recv(c, msg, msglen);
1319 __FUNCTION__, msglen, channel);
1409 * (i.e. msg[msglen] is a valid memory read that returns '\0')
1414 int msglen,
1418 uint8_t* msgend = msg + msglen;
1425 if (msglen > 8 && !memcmp(msg, "connect:", 8))
1434 __FUNCTION__, msglen, (const char*)msg, q ? q-(char*)msg : -1);
1469 if (msglen == 13 && !memcmp(msg, "disconnect:", 11)) {
1488 if (msglen > 11 && !memcmp(msg, "ok:connect:", 11)) {
1495 __FUNCTION__, msglen, (const char*)msg, q ? q-(char*)msg : -1);
1518 __FUNCTION__, msglen, msg);
1608 _qemud_pipe_cache_buffer(QemudClient* client, const uint8_t* msg, int msglen)
1614 buf = (QemudPipeMessage*)malloc(msglen + sizeof(QemudPipeMessage));
1618 buf->size = msglen;
1619 memcpy(buf->message, msg, msglen);
1635 _qemud_pipe_send(QemudClient* client, const uint8_t* msg, int msglen)
1638 int avail, len = msglen;
1641 if (msglen <= 0)
1645 __FUNCTION__, msglen, quote_bytes((const void*)msg, msglen));
1660 int2hex(frame, FRAME_HEADER_SIZE, msglen);
1680 qemud_client_send ( QemudClient* client, const uint8_t* msg, int msglen )
1683 _qemud_pipe_send(client, msg, msglen);
1687 client->framing != 0, msg, msglen);
2331 int msglen )
2336 qemud_client_send(c, msg, msglen);
2369 _qemud_char_client_recv( void* opaque, uint8_t* msg, int msglen,
2373 qemu_chr_write(cs, msg, msglen);
