update submodules (#259)

- to bring the change that hold a deep copy of publish payload, thus binding don't need to keep the buffer until complete - Proxy update
awslabs · Apr 7, 2021 · a5cddf8 · a5cddf8
1 parent c2ab683
commit a5cddf8
Show file tree

Hide file tree

Showing 7 changed files with 11 additions and 12 deletions.
diff --git a/awscrt/mqtt.py b/awscrt/mqtt.py
@@ -213,7 +213,7 @@ class Connection(NativeResource):
         protocol_operation_timeout_ms (int): Milliseconds to wait for the response to the operation
             requires response by protocol. Set to zero to disable timeout. Otherwise,
             the operation will fail if no response is received within this amount of time after
- *          the packet is written to the socket
+            the packet is written to the socket
             It applied to PUBLISH (QoS>0) and UNSUBSCRIBE now.
 
         will (Will): Will to send with CONNECT packet. The will is

diff --git a/crt/aws-c-http b/crt/aws-c-http
diff --git a/crt/aws-c-mqtt b/crt/aws-c-mqtt
diff --git a/crt/aws-c-s3 b/crt/aws-c-s3
diff --git a/source/http_connection.c b/source/http_connection.c
@@ -8,6 +8,7 @@
 
 #include <aws/common/array_list.h>
 #include <aws/http/connection.h>
+#include <aws/http/proxy.h>
 #include <aws/http/request_response.h>
 #include <aws/io/socket.h>
 

diff --git a/source/http_proxy.c b/source/http_proxy.c
@@ -7,6 +7,7 @@
 #include "io.h"
 
 #include <aws/http/connection.h>
+#include <aws/http/proxy.h>
 
 bool aws_py_http_proxy_options_init(struct aws_http_proxy_options *proxy_options, PyObject *py_proxy_options) {
     AWS_ZERO_STRUCT(*proxy_options);

diff --git a/source/mqtt_client_connection.c b/source/mqtt_client_connection.c
@@ -11,6 +11,7 @@
 #include <aws/mqtt/client.h>
 
 #include <aws/http/connection.h>
+#include <aws/http/proxy.h>
 #include <aws/http/request_response.h>
 
 #include <aws/io/channel.h>
@@ -684,8 +685,6 @@ PyObject *aws_py_mqtt_client_connection_reconnect(PyObject *self, PyObject *args
  ******************************************************************************/
 
 struct publish_complete_userdata {
-    Py_buffer topic;
-    Py_buffer payload;
     PyObject *callback;
 };
 
@@ -714,8 +713,6 @@ static void s_publish_complete(
     }
 
     Py_DECREF(metadata->callback);
-    PyBuffer_Release(&metadata->topic);
-    PyBuffer_Release(&metadata->payload);
 
     PyGILState_Release(state);
 
@@ -758,16 +755,14 @@ PyObject *aws_py_mqtt_client_connection_publish(PyObject *self, PyObject *args)
         goto metadata_alloc_failed;
     }
 
-    metadata->topic = topic_stack;
-    metadata->payload = payload_stack;
     metadata->callback = puback_callback;
     Py_INCREF(metadata->callback);
 
     struct aws_byte_cursor topic_cursor;
-    topic_cursor = aws_byte_cursor_from_array(metadata->topic.buf, metadata->topic.len);
+    topic_cursor = aws_byte_cursor_from_array(topic_stack.buf, topic_stack.len);
 
     struct aws_byte_cursor payload_cursor;
-    payload_cursor = aws_byte_cursor_from_array(metadata->payload.buf, metadata->payload.len);
+    payload_cursor = aws_byte_cursor_from_array(payload_stack.buf, payload_stack.len);
 
     enum aws_mqtt_qos qos = (enum aws_mqtt_qos)qos_val;
 
@@ -778,6 +773,8 @@ PyObject *aws_py_mqtt_client_connection_publish(PyObject *self, PyObject *args)
         PyErr_SetAwsLastError();
         goto publish_failed;
     }
+    PyBuffer_Release(&topic_stack);
+    PyBuffer_Release(&payload_stack);
 
     return PyLong_FromUnsignedLong(msg_id);
+22 −9		.github/workflows/ci.yml
+25 −0		.github/workflows/clang-asan-ubsan.yml
+25 −0		.github/workflows/clang-tsan.yml
+3 −3		CMakeLists.txt
+23 −34		README.md
+97 −0		build-deps.sh
+0 −48		continuous-delivery/build-elasticurl-manylinux-x64.yml
+0 −33		continuous-delivery/build-elasticurl-osx.sh
+0 −38		continuous-delivery/build-elasticurl-unix.sh
+0 −35		continuous-delivery/build-elasticurl-win64.bat
+6 −48		include/aws/http/connection.h
+5 −1		include/aws/http/http.h
+93 −11		include/aws/http/private/proxy_impl.h
+493 −0		include/aws/http/proxy.h
+11 −5		source/connection_manager.c
+15 −2		source/http.c
+458 −201		source/proxy_connection.c
+1,703 −0		source/proxy_strategy.c
+22 −10		tests/CMakeLists.txt
+168 −14		tests/integration_test_proxy.c
+215 −41		tests/proxy_test_helper.c
+22 −6		tests/proxy_test_helper.h
+30 −6		tests/test_connection_manager.c
+1 −1		tests/test_h1_server.c
+1 −1		tests/test_h2_client.c
+664 −77		tests/test_proxy.c
+4 −2		tests/test_tls.c
+28 −0		.github/workflows/ci.yml
+0 −25		.github/workflows/clang-asan-ubsan.yml
+0 −25		.github/workflows/clang-tsan.yml
+0 −98		build-deps.sh
+1 −8		include/aws/mqtt/private/client_impl.h
+25 −73		source/client.c
+1 −0		tests/CMakeLists.txt
+2 −0		tests/aws_iot_client_test.c
+71 −0		tests/connection_state_test.c
+2 −0		tests/paho_client_test.c
+2 −2		.github/workflows/ci.yml
+55 −1		README.md
+11 −9		benchmarks/package-lock.json
+76 −23		include/aws/s3/private/s3_client_impl.h
+47 −48		include/aws/s3/private/s3_meta_request_impl.h
+6 −2		include/aws/s3/private/s3_request.h
+7 −1		include/aws/s3/s3_client.h
+9 −21		source/s3_auto_ranged_get.c
+59 −52		source/s3_auto_ranged_put.c
+471 −270		source/s3_client.c
+15 −50		source/s3_default_meta_request.c
+267 −138		source/s3_meta_request.c
+17 −4		tests/CMakeLists.txt
+1,079 −5		tests/s3_data_plane_tests.c
+42 −44		tests/s3_retry_tests.c
+155 −49		tests/s3_tester.c
+12 −24		tests/s3_tester.h
+104 −0		tests/s3_vip_tests.c