Home
last modified time | relevance | path

Searched refs:broker_offset (Results 1 – 1 of 1) sorted by relevance

/Zephyr-latest/tests/net/lib/mqtt/v3_1_1/mqtt_client/src/
Dmain.c25 static size_t broker_offset; variable
125 broker_offset = 0; in broker_init()
330 zassert_false(broker_offset == sizeof(broker_buf), "Cannot fit full payload!"); in broker_receive()
332 ret = zsock_recv(c_sock, broker_buf + broker_offset, in broker_receive()
333 sizeof(broker_buf) - broker_offset, in broker_receive()
338 zassert_true(broker_offset > 0, "Unexpected EAGAIN in broker"); in broker_receive()
341 broker_offset += ret; in broker_receive()
344 if (broker_offset < MQTT_FIXED_HEADER_MIN_SIZE) { in broker_receive()
349 buf.end = broker_buf + broker_offset; in broker_receive()
373 broker_offset -= bytes_consumed; in broker_receive()
[all …]