Fix typos (#546)

Author: jayvdb

awscrt/mqtt.py

@@ -228,7 +228,7 @@ class Connection(NativeResource):
             The `session_present` bool in the connection callback informs
             whether an existing session was successfully resumed.
             If an existing session is resumed, the server remembers previous subscriptions
-            and sends mesages (with QoS1 or higher) that were published while the client was offline.
+            and sends messages (with QoS1 or higher) that were published while the client was offline.
 
         on_connection_interrupted: Optional callback invoked whenever the MQTT connection is lost.
             The MQTT client will automatically attempt to reconnect.

awscrt/mqtt5.py

@@ -2015,7 +2015,7 @@ def new_connection(self, on_connection_interrupted=None, on_connection_resumed=N
             protocol_operation_timeout_ms=self.adapter_options.ack_timeout_secs * 1000,
             socket_options=self.adapter_options.socket_options,
 
-            # For the arugments below, set it to `None` will directly use the options from mqtt5 client underlying.
+            # For the arguments below, set it to `None` will directly use the options from mqtt5 client underlying.
             will=None,
             username=None,
             password=None,

codebuild/mqtt5_test_setup.sh

@@ -91,7 +91,7 @@ else
 
     return 1
 fi
-# Set the certificate and key paths (absolute paths for best compatbility)
+# Set the certificate and key paths (absolute paths for best compatibility)
 export AWS_TEST_MQTT5_CERTIFICATE_FILE="${PWD}/crt_certificate.pem"
 export AWS_TEST_MQTT5_KEY_FILE="${PWD}/crt_privatekey.pem"
 

mqtt_test.py

@@ -122,7 +122,7 @@ def on_receive_message(topic, payload, dup, qos, retain, **kwargs):
 assert(publish_results['packet_id'] == publish_packet_id)
 
 # Receive Message
-print("Waiting to receive messsage")
+print("Waiting to receive message")
 assert(receive_event.wait(TIMEOUT))
 assert(receive_results['topic'] == TOPIC)
 assert(receive_results['payload'].decode() == MESSAGE)

s3_benchmark.py

@@ -130,7 +130,7 @@ def on_body(offset, chunk, **kwargs):
     #     if not os.path.exists(file_name):
     #         open(file_name, 'a').close()
     #     with open(file_name, 'rb+') as f:
-    #         # seems like the seek here may srew up the file.
+    #         # seems like the seek here may screw up the file.
     #         f.seek(offset)
     #         f.write(chunk)
 

source/module.h

@@ -41,7 +41,7 @@ int PyObject_GetAttrAsIntEnum(PyObject *o, const char *class_name, const char *a
 
 /* Checks if the named attribute is None, converts it to the specified type, then stores
  * the value and returns a pointer to the stored value or NULL if it doesn't exist or fails.
- * If conversion cannot occur a python exception is set (check PyExc_Occured()) */
+ * If conversion cannot occur a python exception is set (check PyExc_Occurred()) */
 uint64_t *PyObject_GetAsOptionalUint64(
     PyObject *o,
     const char *class_name,

test/test_s3.py

@@ -90,7 +90,7 @@ def test_cross_proc(self):
             process = Process(target=cross_proc_task)
             process.start()
             process.join()
-            # aquiring this lock in a sub-process should fail since we
+            # acquiring this lock in a sub-process should fail since we
             # already hold the lock in this process.
             self.assertNotEqual(0, process.exitcode)