Lines Matching refs:remaining_length
498 size_t remaining_length = 0; in mqttit() local
538 rc = fixedheader(fd, &byte, &remaining_length, &bytes); in mqttit()
542 if(remaining_length >= buff_size) { in mqttit()
543 buff_size = remaining_length; in mqttit()
551 if(remaining_length) { in mqttit()
553 rc = sread(fd, (char *)buffer, remaining_length); in mqttit()
561 logprotocol(FROM_CLIENT, "CONNECT", remaining_length, in mqttit()
620 logprotocol(FROM_CLIENT, "SUBSCRIBE", remaining_length, in mqttit()
634 if(topic_len != (remaining_length - 5)) { in mqttit()
636 topic_len, remaining_length - 5); in mqttit()
678 logprotocol(FROM_CLIENT, "PUBLISH", remaining_length, in mqttit()
