summaryrefslogtreecommitdiffstats
path: root/contrib/restricted/aws/aws-c-io/source/tls_channel_handler_shared.c
diff options
context:
space:
mode:
authororivej <[email protected]>2022-02-10 16:44:49 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:44:49 +0300
commit718c552901d703c502ccbefdfc3c9028d608b947 (patch)
tree46534a98bbefcd7b1f3faa5b52c138ab27db75b7 /contrib/restricted/aws/aws-c-io/source/tls_channel_handler_shared.c
parente9656aae26e0358d5378e5b63dcac5c8dbe0e4d0 (diff)
Restoring authorship annotation for <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'contrib/restricted/aws/aws-c-io/source/tls_channel_handler_shared.c')
-rw-r--r--contrib/restricted/aws/aws-c-io/source/tls_channel_handler_shared.c130
1 files changed, 65 insertions, 65 deletions
diff --git a/contrib/restricted/aws/aws-c-io/source/tls_channel_handler_shared.c b/contrib/restricted/aws/aws-c-io/source/tls_channel_handler_shared.c
index 0a35e78b671..0cdbfd8e29b 100644
--- a/contrib/restricted/aws/aws-c-io/source/tls_channel_handler_shared.c
+++ b/contrib/restricted/aws/aws-c-io/source/tls_channel_handler_shared.c
@@ -1,65 +1,65 @@
-/**
- * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
- * SPDX-License-Identifier: Apache-2.0.
- */
-
-#include <aws/io/private/tls_channel_handler_shared.h>
-
-#include <aws/common/clock.h>
-#include <aws/io/tls_channel_handler.h>
-
-static void s_tls_timeout_task_fn(struct aws_channel_task *channel_task, void *arg, enum aws_task_status status) {
- (void)channel_task;
-
- if (status != AWS_TASK_STATUS_RUN_READY) {
- return;
- }
-
- struct aws_tls_channel_handler_shared *tls_handler_shared = arg;
- if (tls_handler_shared->stats.handshake_status != AWS_TLS_NEGOTIATION_STATUS_ONGOING) {
- return;
- }
-
- struct aws_channel *channel = tls_handler_shared->handler->slot->channel;
- aws_channel_shutdown(channel, AWS_IO_TLS_NEGOTIATION_TIMEOUT);
-}
-
-void aws_tls_channel_handler_shared_init(
- struct aws_tls_channel_handler_shared *tls_handler_shared,
- struct aws_channel_handler *handler,
- struct aws_tls_connection_options *options) {
- tls_handler_shared->handler = handler;
- tls_handler_shared->tls_timeout_ms = options->timeout_ms;
- aws_crt_statistics_tls_init(&tls_handler_shared->stats);
- aws_channel_task_init(&tls_handler_shared->timeout_task, s_tls_timeout_task_fn, tls_handler_shared, "tls_timeout");
-}
-
-void aws_tls_channel_handler_shared_clean_up(struct aws_tls_channel_handler_shared *tls_handler_shared) {
- (void)tls_handler_shared;
-}
-
-void aws_on_drive_tls_negotiation(struct aws_tls_channel_handler_shared *tls_handler_shared) {
- if (tls_handler_shared->stats.handshake_status == AWS_TLS_NEGOTIATION_STATUS_NONE) {
- tls_handler_shared->stats.handshake_status = AWS_TLS_NEGOTIATION_STATUS_ONGOING;
-
- uint64_t now = 0;
- aws_channel_current_clock_time(tls_handler_shared->handler->slot->channel, &now);
- tls_handler_shared->stats.handshake_start_ns = now;
-
- if (tls_handler_shared->tls_timeout_ms > 0) {
- uint64_t timeout_ns =
- now + aws_timestamp_convert(
- tls_handler_shared->tls_timeout_ms, AWS_TIMESTAMP_MILLIS, AWS_TIMESTAMP_NANOS, NULL);
-
- aws_channel_schedule_task_future(
- tls_handler_shared->handler->slot->channel, &tls_handler_shared->timeout_task, timeout_ns);
- }
- }
-}
-
-void aws_on_tls_negotiation_completed(struct aws_tls_channel_handler_shared *tls_handler_shared, int error_code) {
- tls_handler_shared->stats.handshake_status =
- (error_code == AWS_ERROR_SUCCESS) ? AWS_TLS_NEGOTIATION_STATUS_SUCCESS : AWS_TLS_NEGOTIATION_STATUS_FAILURE;
- aws_channel_current_clock_time(
- tls_handler_shared->handler->slot->channel, &tls_handler_shared->stats.handshake_end_ns);
-}
+/**
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ */
+
+#include <aws/io/private/tls_channel_handler_shared.h>
+
+#include <aws/common/clock.h>
+#include <aws/io/tls_channel_handler.h>
+
+static void s_tls_timeout_task_fn(struct aws_channel_task *channel_task, void *arg, enum aws_task_status status) {
+ (void)channel_task;
+
+ if (status != AWS_TASK_STATUS_RUN_READY) {
+ return;
+ }
+
+ struct aws_tls_channel_handler_shared *tls_handler_shared = arg;
+ if (tls_handler_shared->stats.handshake_status != AWS_TLS_NEGOTIATION_STATUS_ONGOING) {
+ return;
+ }
+
+ struct aws_channel *channel = tls_handler_shared->handler->slot->channel;
+ aws_channel_shutdown(channel, AWS_IO_TLS_NEGOTIATION_TIMEOUT);
+}
+
+void aws_tls_channel_handler_shared_init(
+ struct aws_tls_channel_handler_shared *tls_handler_shared,
+ struct aws_channel_handler *handler,
+ struct aws_tls_connection_options *options) {
+ tls_handler_shared->handler = handler;
+ tls_handler_shared->tls_timeout_ms = options->timeout_ms;
+ aws_crt_statistics_tls_init(&tls_handler_shared->stats);
+ aws_channel_task_init(&tls_handler_shared->timeout_task, s_tls_timeout_task_fn, tls_handler_shared, "tls_timeout");
+}
+
+void aws_tls_channel_handler_shared_clean_up(struct aws_tls_channel_handler_shared *tls_handler_shared) {
+ (void)tls_handler_shared;
+}
+
+void aws_on_drive_tls_negotiation(struct aws_tls_channel_handler_shared *tls_handler_shared) {
+ if (tls_handler_shared->stats.handshake_status == AWS_TLS_NEGOTIATION_STATUS_NONE) {
+ tls_handler_shared->stats.handshake_status = AWS_TLS_NEGOTIATION_STATUS_ONGOING;
+
+ uint64_t now = 0;
+ aws_channel_current_clock_time(tls_handler_shared->handler->slot->channel, &now);
+ tls_handler_shared->stats.handshake_start_ns = now;
+
+ if (tls_handler_shared->tls_timeout_ms > 0) {
+ uint64_t timeout_ns =
+ now + aws_timestamp_convert(
+ tls_handler_shared->tls_timeout_ms, AWS_TIMESTAMP_MILLIS, AWS_TIMESTAMP_NANOS, NULL);
+
+ aws_channel_schedule_task_future(
+ tls_handler_shared->handler->slot->channel, &tls_handler_shared->timeout_task, timeout_ns);
+ }
+ }
+}
+
+void aws_on_tls_negotiation_completed(struct aws_tls_channel_handler_shared *tls_handler_shared, int error_code) {
+ tls_handler_shared->stats.handshake_status =
+ (error_code == AWS_ERROR_SUCCESS) ? AWS_TLS_NEGOTIATION_STATUS_SUCCESS : AWS_TLS_NEGOTIATION_STATUS_FAILURE;
+ aws_channel_current_clock_time(
+ tls_handler_shared->handler->slot->channel, &tls_handler_shared->stats.handshake_end_ns);
+}