Lines Matching refs:remaining_length
497 size_t remaining_length = 0; in mqttit() local
537 rc = fixedheader(fd, &byte, &remaining_length, &bytes); in mqttit()
541 if(remaining_length >= buff_size) { in mqttit()
542 buff_size = remaining_length; in mqttit()
550 if(remaining_length) { in mqttit()
552 rc = sread(fd, (char *)buffer, remaining_length); in mqttit()
560 logprotocol(FROM_CLIENT, "CONNECT", remaining_length, in mqttit()
619 logprotocol(FROM_CLIENT, "SUBSCRIBE", remaining_length, in mqttit()
633 if(topic_len != (remaining_length - 5)) { in mqttit()
635 topic_len, remaining_length - 5); in mqttit()
674 logprotocol(FROM_CLIENT, "PUBLISH", remaining_length, in mqttit()
