Skip to content

Commit

Permalink
new changes
Browse files Browse the repository at this point in the history
  • Loading branch information
@waahm7
waahm7 committed Sep 19, 2024
1 parent f4f6ea2 commit d19acc8
Show file tree
Hide file tree
Showing 11 changed files with 31 additions and 22 deletions.
2 changes: 1 addition & 1 deletion crt/aws-c-auth
Submodule aws-c-auth updated 12 files
+1 −1 .github/workflows/ci.yml
+1 −0 .gitignore
+2 −2 include/aws/auth/private/credentials_utils.h
+25 −0 source/aws_signing.c
+3 −1 source/credentials_provider_cached.c
+17 −2 source/credentials_provider_process.c
+9 −5 source/credentials_provider_profile.c
+49 −7 source/credentials_utils.c
+3 −0 tests/CMakeLists.txt
+47 −46 tests/credentials_provider_process_tests.c
+117 −83 tests/credentials_provider_sts_tests.c
+58 −0 tests/credentials_utils_tests.c
2 changes: 1 addition & 1 deletion crt/aws-c-cal
Submodule aws-c-cal updated 1 files
+70 −26 source/unix/openssl_platform_init.c
2 changes: 1 addition & 1 deletion crt/aws-c-common
Submodule aws-c-common updated 4 files
+2 −2 .github/workflows/proof_ci_resources/config.yaml
+1 −1 cmake/AwsPrebuildDependency.cmake
+7 −1 cmake/AwsSIMD.cmake
+212 −183 verification/cbmc/proofs/Makefile.common
2 changes: 1 addition & 1 deletion crt/aws-c-http
Submodule aws-c-http updated 6 files
+1 −1 .github/workflows/ci.yml
+3 −2 include/aws/http/connection_manager.h
+1 −1 integration-testing/http_client_test.py
+2 −1 source/connection_manager.c
+1 −0 tests/CMakeLists.txt
+55 −6 tests/test_connection_manager.c
2 changes: 1 addition & 1 deletion crt/aws-c-mqtt
Submodule aws-c-mqtt updated 45 files
+12 −3 .github/workflows/ci.yml
+4 −6 .github/workflows/clang-format.yml
+2 −0 CMakeLists.txt
+29 −0 bin/elastishadow/CMakeLists.txt
+1,272 −0 bin/elastishadow/main.c
+47 −0 format-check.py
+0 −24 format-check.sh
+9 −0 include/aws/mqtt/mqtt.h
+54 −0 include/aws/mqtt/private/client_impl.h
+24 −0 include/aws/mqtt/private/client_impl_shared.h
+204 −0 include/aws/mqtt/private/mqtt311_listener.h
+220 −0 include/aws/mqtt/private/request-response/protocol_adapter.h
+23 −0 include/aws/mqtt/private/request-response/request_response_client.h
+264 −0 include/aws/mqtt/private/request-response/subscription_manager.h
+2 −0 include/aws/mqtt/private/shared.h
+274 −0 include/aws/mqtt/request-response/request_response_client.h
+3 −0 include/aws/mqtt/v5/mqtt5_client.h
+176 −58 source/client.c
+6 −0 source/client_channel_handler.c
+9 −0 source/client_impl_shared.c
+25 −0 source/mqtt.c
+329 −0 source/mqtt311_listener.c
+2 −3 source/packets.c
+964 −0 source/request-response/protocol_adapter.c
+2,276 −0 source/request-response/request_response_client.c
+822 −0 source/request-response/subscription_manager.c
+1 −1 source/shared.c
+1 −1 source/v5/mqtt5_client.c
+1 −0 source/v5/mqtt5_listener.c
+14 −0 source/v5/mqtt5_to_mqtt3_adapter.c
+135 −3 tests/CMakeLists.txt
+1,784 −0 tests/request-response/protocol_adapter_tests.c
+3,151 −0 tests/request-response/request_response_client_tests.c
+2,877 −0 tests/request-response/subscription_manager_tests.c
+739 −998 tests/v3/connection_state_test.c
+488 −0 tests/v3/mqtt311_listener_test.c
+582 −0 tests/v3/mqtt311_testing_utils.c
+155 −0 tests/v3/mqtt311_testing_utils.h
+51 −2 tests/v3/mqtt_mock_server_handler.c
+18 −0 tests/v3/mqtt_mock_server_handler.h
+22 −42 tests/v5/mqtt5_client_tests.c
+26 −0 tests/v5/mqtt5_testing_utils.c
+20 −0 tests/v5/mqtt5_testing_utils.h
+0 −4 tests/v5/mqtt5_to_mqtt3_adapter_tests.c
+2 −1 tests/v5/mqtt5_topic_alias_tests.c
2 changes: 1 addition & 1 deletion crt/aws-c-s3
Submodule aws-c-s3 updated 19 files
+16 −3 .github/workflows/ci.yml
+5 −5 include/aws/s3/private/s3_meta_request_impl.h
+11 −0 include/aws/s3/private/s3_util.h
+2 −0 include/aws/s3/s3.h
+50 −0 include/aws/s3/s3_client.h
+2 −0 source/s3.c
+20 −10 source/s3_auto_ranged_get.c
+4 −10 source/s3_auto_ranged_put.c
+1 −0 source/s3_buffer_pool.c
+5 −16 source/s3_copy_object.c
+21 −10 source/s3_default_meta_request.c
+187 −184 source/s3_endpoint_resolver/aws_s3_endpoint_resolver_partition.c
+186 −158 source/s3_meta_request.c
+56 −0 source/s3_util.c
+7 −0 tests/CMakeLists.txt
+1 −0 tests/s3_buffer_pool_tests.c
+256 −7 tests/s3_data_plane_tests.c
+64 −16 tests/s3_tester.c
+7 −0 tests/s3_tester.h
2 changes: 1 addition & 1 deletion crt/aws-checksums
Submodule aws-checksums updated 26 files
+105 −15 .github/workflows/ci.yml
+4 −6 .github/workflows/clang-format.yml
+60 −49 CMakeLists.txt
+29 −0 bin/benchmark/CMakeLists.txt
+133 −0 bin/benchmark/main.c
+4 −0 builder.json
+47 −0 format-check.py
+0 −24 format-check.sh
+42 −3 include/aws/checksums/crc.h
+51 −0 include/aws/checksums/private/crc64_priv.h
+28 −11 include/aws/checksums/private/crc_priv.h
+24 −0 include/aws/checksums/private/crc_util.h
+4 −4 source/arm/crc32c_arm.c
+208 −0 source/arm/crc64_arm.c
+35 −9 source/crc.c
+131 −0 source/crc64.c
+579 −0 source/crc64_sw.c
+0 −18 source/generic/crc32c_null.c
+3 −14 source/intel/asm/crc32c_sse42_asm.c
+245 −0 source/intel/intrin/crc32c_sse42_avx512.c
+130 −0 source/intel/intrin/crc64nvme_avx512.c
+147 −0 source/intel/intrin/crc64nvme_clmul.c
+0 −77 source/intel/visualc/visualc_crc32c_sse42.c
+3 −0 tests/CMakeLists.txt
+144 −0 tests/crc64_test.c
+129 −43 tests/crc_test.c
2 changes: 1 addition & 1 deletion crt/aws-lc
Submodule aws-lc updated from 2f1879 to d3a598
2 changes: 1 addition & 1 deletion crt/s2n
Submodule s2n updated from 87f4a0 to 08d413
13 changes: 12 additions & 1 deletion source/http_stream.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -203,7 +203,18 @@ static void s_on_stream_complete(struct aws_http_stream *native_stream, int erro
}

/* DECREF python self, we don't need to force it to stay alive any longer. */
Py_XDECREF(stream->self_proxy);
PyObject *self = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 /* Check if Python version is 3.13 or higher */
/* Ignore error, stream is already complete */
PyWeakref_GetRef(stream->self_proxy, &self) < 0);/* strong reference */
#else
/* PyWeakref_GetObject is deprecated since python 3.13 */
PyWeakref_GetObject(stream->self_proxy); /* borrowed reference */
#endif
Py_XDECREF(self);
#if PY_VERSION_HEX >= 0x030D0000 /* Check if Python version is 3.13 or higher */
Py_XDECREF(self);
#endif

PyGILState_Release(state);
/*************** GIL RELEASE ***************/
Expand Down
22 changes: 10 additions & 12 deletions source/mqtt_client_connection.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -141,7 +141,7 @@ static void s_on_connection_success(
}

PyObject *self = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 // Check if Python version is 3.13 or higher
#if PY_VERSION_HEX >= 0x030D0000 /* Check if Python version is 3.13 or higher */
if (PyWeakref_GetRef(py_connection->self_proxy, &self) < 0) { /* strong reference */
PyErr_WriteUnraisable(PyErr_Occurred());
goto on_done;
Expand Down Expand Up @@ -180,8 +180,8 @@ static void s_on_connection_failure(struct aws_mqtt_client_connection *connectio
return; /* Python has shut down. Nothing matters anymore, but don't crash */
}

PyObject *self = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 // Check if Python version is 3.13 or higher
PyObject *self = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 /* Check if Python version is 3.13 or higher */
if (PyWeakref_GetRef(py_connection->self_proxy, &self) < 0) { /* strong reference */
PyErr_WriteUnraisable(PyErr_Occurred());
goto on_done;
Expand Down Expand Up @@ -222,7 +222,7 @@ static void s_on_connection_interrupted(struct aws_mqtt_client_connection *conne

/* Ensure that python class is still alive */
PyObject *self = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 // Check if Python version is 3.13 or higher
#if PY_VERSION_HEX >= 0x030D0000 /* Check if Python version is 3.13 or higher */
if (PyWeakref_GetRef(py_connection->self_proxy, &self) < 0) { /* strong reference */
PyErr_WriteUnraisable(PyErr_Occurred());
goto on_done;
Expand Down Expand Up @@ -268,8 +268,8 @@ static void s_on_connection_resumed(
}

/* Ensure that python class is still alive */
PyObject *self = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 // Check if Python version is 3.13 or higher
PyObject *self = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 /* Check if Python version is 3.13 or higher */
if (PyWeakref_GetRef(py_connection->self_proxy, &self) < 0) { /* strong reference */
PyErr_WriteUnraisable(PyErr_Occurred());
goto on_done;
Expand Down Expand Up @@ -312,8 +312,8 @@ static void s_on_connection_closed(

struct mqtt_connection_binding *py_connection = userdata;
/* Ensure that python class is still alive */
PyObject *self = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 // Check if Python version is 3.13 or higher
PyObject *self = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 /* Check if Python version is 3.13 or higher */
if (PyWeakref_GetRef(py_connection->self_proxy, &self) < 0) { /* strong reference */
PyErr_WriteUnraisable(PyErr_Occurred());
goto on_done;
Expand All @@ -332,7 +332,6 @@ static void s_on_connection_closed(
}
}


on_done:
#if PY_VERSION_HEX >= 0x030D0000
Py_XDECREF(self);
Expand Down Expand Up @@ -604,8 +603,8 @@ static void s_ws_handshake_transform(
}

/* Ensure python mqtt connection object is still alive */
PyObject *connection_py = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 // Check if Python version is 3.13 or higher
PyObject *connection_py = Py_None;
#if PY_VERSION_HEX >= 0x030D0000 /* Check if Python version is 3.13 or higher */
if (PyWeakref_GetRef(connection_binding->self_proxy, &connection_py) < 0) { /* strong reference */
aws_raise_error(AWS_ERROR_INVALID_STATE);
goto done;
Expand Down Expand Up @@ -676,7 +675,6 @@ done:;
Py_XDECREF(connection_py);
#endif


if (ws_transform_capsule) {
Py_DECREF(ws_transform_capsule);
} else if (ws_transform_data) {
Expand Down

0 comments on commit d19acc8

Please sign in to comment.