• Home
  • Raw
  • Download

Lines Matching refs:msglen

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