Searched refs:broker_offset (Results 1 – 1 of 1) sorted by relevance
25 static size_t broker_offset; variable125 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 …]
