Addressing PR comments.

lib/handle_publish.c

@@ -156,8 +156,8 @@ int handle__publish(struct mosquitto *mosq)
  return MOSQ_ERR_SUCCESS;
  case 1:
  util__decrement_receive_quota(mosq);
- // Application callbacks are called before PUBACK is sent (and ownership given to the 
- // receiver). An application crash within the callback will result in retransmission.
+ /* Application callbacks should be called before PUBACK is sent (and ownership given to the 
+  receiver). An application crash within the callback will result in message retransmission. */
  callback__on_message(mosq, &message->msg, properties);
  rc = send__puback(mosq, mid, 0, NULL);
  message__cleanup(&message);
@@ -166,8 +166,8 @@ int handle__publish(struct mosquitto *mosq)
  case 2:
  message->properties = properties;
  util__decrement_receive_quota(mosq);
- // Application callbacks are called before PUBREC is sent (and ownership given to the 
- // receiver). An application crash within the callback will result in retransmission.
+ /* Application callbacks should be called before PUBREC is sent (and ownership given to the 
+  receiver). An application crash within the callback will result in message retransmission. */
  callback__on_message(mosq, &message->msg, message->properties);
  rc = send__pubrec(mosq, mid, 0, NULL);
  pthread_mutex_lock(&mosq->msgs_in.mutex);

lib/handle_pubrel.c

@@ -112,7 +112,7 @@ int handle__pubrel(struct mosquitto *mosq)
 
  rc = message__remove(mosq, mid, mosq_md_in, &message, 2);
  if(rc == MOSQ_ERR_SUCCESS){
- // Message was already passed to the application prior to PUBREC.
+ /* Message was already passed to the application prior to PUBREC. */
  message__cleanup(&message);
  }else if(rc == MOSQ_ERR_NOT_FOUND){
  return MOSQ_ERR_SUCCESS;

test/lib/c/03-publish-b2c-qos2-len.c

@@ -87,7 +87,7 @@ int main(int argc, char *argv[])
  mosquitto_loop(mosq, 100, 1);
  }
 
- // Drain the PUBREL and PUBCOMP messages.
+ /* Drain the PUBREL and PUBCOMP messages. */
  for(int i = 0; i < 2; i++){
  mosquitto_loop(mosq, 300, 1);
  }

test/lib/c/03-publish-b2c-qos2.c

@@ -76,7 +76,7 @@ int main(int argc, char *argv[])
  mosquitto_loop(mosq, 300, 1);
  }
 
- // Drain the PUBREL and PUBCOMP messages.
+ /* Drain the PUBREL and PUBCOMP messages. */
  for(int i = 0; i < 2; i++){
  mosquitto_loop(mosq, 300, 1);
  }

test/lib/c/11-prop-recv.c

@@ -83,7 +83,7 @@ int main(int argc, char *argv[])
  }
 
  if (qos > 1){
- // Drain the PUBREL and PUBCOMP messages.
+ /* Drain the PUBREL and PUBCOMP messages. */
  for(int i = 0; i < 2; i++){
  mosquitto_loop(mosq, 300, 1);
  }

test/lib/cpp/03-publish-b2c-qos2-len.cpp

@@ -81,14 +81,14 @@ int main(int argc, char *argv[])
  mosq->loop(100, 1);
  }
 
- // Drain the PUBREL and PUBCOMP messages.
+ /* Drain the PUBREL and PUBCOMP messages. */
  for(int i = 0; i < 2; i++){
  mosq->loop();
  }
 
  run = -1;
  mosq->disconnect();
- // Wait for disconnect to complete.
+ /* Wait for disconnect to complete. */
  while(run == -1){
  mosq->loop(100, 1);
  }

test/lib/cpp/03-publish-b2c-qos2.cpp

@@ -75,7 +75,7 @@ int main(int argc, char *argv[])
  mosq->loop();
  }
 
- // Drain the PUBREL and PUBCOMP messages.
+ /* Drain the PUBREL and PUBCOMP messages. */
  for(int i = 0; i < 2; i++){
  mosq->loop();
  }

test/lib/cpp/11-prop-recv.cpp

@@ -78,7 +78,7 @@ int main(int argc, char *argv[])
  }
 
  if (qos > 1){
- // Drain the PUBREL and PUBCOMP messages.
+ /* Drain the PUBREL and PUBCOMP messages. */
  for(int i = 0; i < 2; i++){
  mosq->loop();
  }