为什么文件传输的最大值是256M

Allanceng · Nov 10, 2014 · c8570fa · c8570fa
1 parent b5657f1
commit c8570fa
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 1 deletion.
diff --git a/lib/util_mosq.c b/lib/util_mosq.c
@@ -67,7 +67,7 @@ int _mosquitto_packet_alloc(struct _mosquitto_packet *packet)
  }
  remaining_bytes[packet->remaining_count] = byte;
  packet->remaining_count++;
- }while(remaining_length > 0 && packet->remaining_count < 5); //the max bytes in the packeet is 128*5 = 0.625K
+ }while(remaining_length > 0 && packet->remaining_count < 5); //协议规定最多4个字节来表示长度
  if(packet->remaining_count == 5) return MOSQ_ERR_PAYLOAD_SIZE;
  packet->packet_length = packet->remaining_length + 1 + packet->remaining_count;
  packet->payload = _mosquitto_malloc(sizeof(uint8_t)*packet->packet_length);

diff --git a/src/read_handle.c b/src/read_handle.c
@@ -206,6 +206,7 @@ int mqtt3_handle_publish(struct mosquitto_db *db, struct mosquitto *context)
  _mosquitto_log_printf(NULL, MOSQ_LOG_DEBUG, "Dropped too large PUBLISH from %s (d%d, q%d, r%d, m%d, '%s', ... (%ld bytes))", context->id, dup, qos, retain, mid, topic, (long)payloadlen);
  goto process_bad_message;
  }
+ printf("recieved payload:%d\n", payloadlen);
  payload = _mosquitto_calloc(payloadlen+1, sizeof(uint8_t));
  if(!payload){
  _mosquitto_free(topic);

diff --git a/src/read_handle.o b/src/read_handle.o