Lines Matching refs:msglen
223 typedef void (*QemudSerialReceive)( void* opaque, int channel, uint8_t* msg, int msglen);
522 int msglen )
526 int avail, len = msglen;
528 if (msglen <= 0 || channel < 0)
532 __FUNCTION__, channel, msglen,
533 quote_bytes((const void*)msg, msglen));
564 int2hex(frame, FRAME_HEADER_SIZE, msglen);
717 qemud_client_recv( void* opaque, uint8_t* msg, int msglen )
724 c->clie_recv( c->clie_opaque, msg, msglen, c );
735 if (msglen > FRAME_HEADER_SIZE &&
741 if (len >= 0 && msglen == len + FRAME_HEADER_SIZE) {
745 msglen-FRAME_HEADER_SIZE, c );
751 while (msglen > 0) {
759 if (!qemud_sink_fill(c->header, (const uint8_t**)&msg, &msglen))
780 if (!qemud_sink_fill(c->payload, (const uint8_t**)&msg, &msglen))
800 _qemud_pipe_send(QemudClient* client, const uint8_t* msg, int msglen);
1301 int msglen )
1312 qemud_client_recv(c, msg, msglen);
1318 __FUNCTION__, msglen, channel);
1408 * (i.e. msg[msglen] is a valid memory read that returns '\0')
1413 int msglen,
1417 uint8_t* msgend = msg + msglen;
1424 if (msglen > 8 && !memcmp(msg, "connect:", 8))
1433 __FUNCTION__, msglen, (const char*)msg, q ? q-(char*)msg : -1);
1468 if (msglen == 13 && !memcmp(msg, "disconnect:", 11)) {
1487 if (msglen > 11 && !memcmp(msg, "ok:connect:", 11)) {
1494 __FUNCTION__, msglen, (const char*)msg, q ? q-(char*)msg : -1);
1517 __FUNCTION__, msglen, msg);
1609 _qemud_pipe_cache_buffer(QemudClient* client, const uint8_t* msg, int msglen)
1615 buf = (QemudPipeMessage*)malloc(msglen + sizeof(QemudPipeMessage));
1619 buf->size = msglen;
1620 memcpy(buf->message, msg, msglen);
1636 _qemud_pipe_send(QemudClient* client, const uint8_t* msg, int msglen)
1639 int avail, len = msglen;
1642 if (msglen <= 0)
1646 __FUNCTION__, msglen, quote_bytes((const void*)msg, msglen));
1661 int2hex(frame, FRAME_HEADER_SIZE, msglen);
1681 qemud_client_send ( QemudClient* client, const uint8_t* msg, int msglen )
1684 _qemud_pipe_send(client, msg, msglen);
1688 client->framing != 0, msg, msglen);
2327 int msglen )
2332 qemud_client_send(c, msg, msglen);
2365 _qemud_char_client_recv( void* opaque, uint8_t* msg, int msglen,
2369 qemu_chr_write(cs, msg, msglen);
