update submodules to latest pre-release (#170)

update submodules to latest pre-release Co-authored-by: Dengke Tang <[email protected]>
awslabs · Aug 4, 2020 · 5f6be49 · 5f6be49
1 parent 9148622
commit 5f6be49
Show file tree

Hide file tree

Showing 7 changed files with 22 additions and 11 deletions.
diff --git a/aws-common-runtime/aws-c-auth b/aws-common-runtime/aws-c-auth
diff --git a/aws-common-runtime/aws-c-common b/aws-common-runtime/aws-c-common
diff --git a/aws-common-runtime/aws-c-http b/aws-common-runtime/aws-c-http
diff --git a/aws-common-runtime/aws-c-io b/aws-common-runtime/aws-c-io
diff --git a/aws-common-runtime/aws-c-mqtt b/aws-common-runtime/aws-c-mqtt
diff --git a/source/mqtt_client_connection.c b/source/mqtt_client_connection.c
@@ -1096,12 +1096,8 @@ PyObject *aws_py_mqtt_client_connection_resubscribe_existing_topics(PyObject *se
         /* C will not be invoking the python callback */
         Py_DECREF(suback_callback);
 
-        /* Don't raise a Python exception if error is AWS_ERROR_MQTT_NO_TOPICS_FOR_RESUBSCRIBE.
-         * This is a harmless error, we'll just return None instead of a msg_id */
         int aws_err = aws_last_error();
-        if (aws_err == AWS_ERROR_MQTT_NO_TOPICS_FOR_RESUBSCRIBE) {
-            Py_RETURN_NONE;
-        } else {
+        if (aws_err) {
             PyErr_SetAwsLastError();
             return NULL;
         }

diff --git a/test/test_mqtt.py b/test/test_mqtt.py
@@ -143,14 +143,29 @@ def on_message(**kwargs):
         connection.disconnect().result(TIMEOUT)
 
     def test_on_message(self):
-        connection = self._test_connection()
+        config = Config.get()
+        elg = EventLoopGroup()
+        resolver = DefaultHostResolver(elg)
+        bootstrap = ClientBootstrap(elg, resolver)
+
+        tls_opts = TlsContextOptions.create_client_with_mtls(config.cert, config.key)
+        tls = ClientTlsContext(tls_opts)
+
+        client = Client(bootstrap, tls)
+        connection = Connection(
+            client=client,
+            client_id=create_client_id(),
+            host_name=config.endpoint,
+            port=8883)
         received = Future()
 
         def on_message(**kwargs):
             received.set_result(kwargs)
 
+        # on_message for connection has to be set before connect, or possible race will happen
         connection.on_message(on_message)
 
+        connection.connect().result(TIMEOUT)
         # subscribe without callback
         subscribed, packet_id = connection.subscribe(self.TEST_TOPIC, QoS.AT_LEAST_ONCE)
         subscribed.result(TIMEOUT)
+0 −198		source/credentials.c
+0 −27		source/credentials_provider_cached.c
+0 −76		source/credentials_provider_chain.c
+364 −0		source/credentials_provider_default_chain.c
+1 −1		tests/CMakeLists.txt
+3 −2		tests/credentials_tests.c
+7 −6		bin/elasticurl/main.c
+61 −20		include/aws/http/connection.h
+2 −0		include/aws/http/http.h
+1 −0		include/aws/http/private/connection_impl.h
+116 −26		include/aws/http/private/h1_connection.h
+42 −41		include/aws/http/private/h1_encoder.h
+64 −16		include/aws/http/private/h1_stream.h
+1 −3		include/aws/http/private/request_response_impl.h
+45 −16		include/aws/http/request_response.h
+95 −42		source/connection.c
+482 −395		source/h1_connection.c
+355 −401		source/h1_encoder.c
+287 −82		source/h1_stream.c
+10 −4		source/http.c
+1 −1		source/request_response.c
+19 −17		tests/CMakeLists.txt
+3 −1		tests/proxy_test_helper.c
+3 −1		tests/test_connection_monitor.c
+494 −127		tests/test_h1_client.c
+42 −10		tests/test_h1_encoder.c
+8 −3		tests/test_h1_server.c
+0 −2		README.md
+1 −1		builder.json
+1 −0		include/aws/io/tls_channel_handler.h
+12 −12		source/channel.c
+6 −1		source/darwin/darwin_pki_utils.c
+4 −1		source/s2n/s2n_tls_channel_handler.c
+24 −2		source/windows/iocp/iocp_event_loop.c
+2 −2		source/windows/secure_channel_tls_handler.c
+1 −1		tests/CMakeLists.txt
+2 −2		tests/pki_utils_test.c
+4 −4		tests/tls_handler_test.c
+2 −1		NOTICE
+64 −1		README.md
+37 −29		include/aws/mqtt/client.h
+3 −13		include/aws/mqtt/exports.h
+5 −14		include/aws/mqtt/mqtt.h
+93 −78		include/aws/mqtt/private/client_impl.h
+3 −13		include/aws/mqtt/private/fixed_header.h
+5 −15		include/aws/mqtt/private/packets.h
+6 −18		include/aws/mqtt/private/topic_tree.h
+566 −260		source/client.c
+231 −221		source/client_channel_handler.c
+3 −13		source/fixed_header.c
+11 −18		source/mqtt.c
+4 −14		source/packets.c
+20 −23		source/topic_tree.c
+11 −2		tests/CMakeLists.txt
+4 −17		tests/aws_iot_client_test.c
+1,012 −323		tests/connection_state_test.c
+548 −0		tests/mqtt_mock_server_handler.c
+56 −382		tests/mqtt_mock_server_handler.h
+3 −13		tests/packet_encoding_test.c
+7 −20		tests/paho_client_test.c
+101 −31		tests/topic_tree_test.c