Grand dispatch queue

CMakeLists.txt

@@ -44,7 +44,6 @@ file(GLOB AWS_IO_TESTING_HEADERS
         "include/aws/testing/*.h"
         )
 
-
 file(GLOB AWS_IO_PRIV_HEADERS
         "include/aws/io/private/*.h"
         )

include/aws/io/event_loop.h

@@ -103,6 +103,16 @@ struct aws_event_loop_group_options {
     aws_io_clock_fn *clock_override;
 };
 
+/**
+ * @internal - Don't use outside of testing.
+ *
+ * Return the default event loop type. If the return value is `AWS_ELT_PLATFORM_DEFAULT`, the function failed to
+ * retrieve the default type value.
+ * If `aws_event_loop_override_default_type` has been called, return the override default type.
+ */
+AWS_IO_API
+enum aws_event_loop_type aws_event_loop_get_default_type(void);
+
 AWS_EXTERN_C_BEGIN
 
 /**

include/aws/io/io.h

@@ -14,12 +14,20 @@ AWS_PUSH_SANE_WARNING_LEVEL
 
 #define AWS_C_IO_PACKAGE_ID 1
 
+struct aws_io_handle;
+
+typedef void aws_io_set_queue_on_handle_fn(struct aws_io_handle *handle, void *queue);
+typedef void aws_io_clear_queue_on_handle_fn(struct aws_io_handle *handle);
+
 struct aws_io_handle {
     union {
         int fd;
+        /* on Apple systems, handle is of type nw_connection_t. On Windows, it's a SOCKET handle. */
         void *handle;
     } data;
     void *additional_data;
+    aws_io_set_queue_on_handle_fn *set_queue;
+    aws_io_clear_queue_on_handle_fn *clear_queue;
 };
 
 enum aws_io_message_type {

source/darwin/dispatch_queue.h

@@ -0,0 +1,66 @@
+#ifndef AWS_IO_PRIVATE_DISPATCH_QUEUE_H
+#define AWS_IO_PRIVATE_DISPATCH_QUEUE_H
+/**
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ */
+
+#include <Security/Security.h>
+#include <aws/common/mutex.h>
+#include <aws/common/thread.h>
+#include <aws/io/tls_channel_handler.h>
+#include <dispatch/dispatch.h>
+
+struct secure_transport_ctx {
+    struct aws_tls_ctx ctx;
+    CFAllocatorRef wrapped_allocator;
+    CFArrayRef certs;
+    SecIdentityRef secitem_identity;
+    CFArrayRef ca_cert;
+    enum aws_tls_versions minimum_version;
+    struct aws_string *alpn_list;
+    bool verify_peer;
+};
+
+struct dispatch_scheduling_state {
+    /**
+     * Let's us skip processing an iteration task if one is already in the middle of executing
+     */
+    bool is_executing_iteration;
+
+    /**
+     * List<scheduled_service_entry> in sorted order by timestamp
+     *
+     * When we go to schedule a new iteration, we check here first to see
+     * if our scheduling attempt is redundant
+     */
+    struct aws_linked_list scheduled_services;
+};
+
+struct dispatch_loop {
+    struct aws_allocator *allocator;
+    struct aws_ref_count ref_count;
+    dispatch_queue_t dispatch_queue;
+    struct aws_task_scheduler scheduler;
+    struct aws_linked_list local_cross_thread_tasks;
+
+    /* Apple dispatch queue uses the id string to identify the dispatch queue */
+    struct aws_string *dispatch_queue_id;
+
+    struct {
+        struct dispatch_scheduling_state scheduling_state;
+        struct aws_linked_list cross_thread_tasks;
+        struct aws_mutex lock;
+        bool suspended;
+        /* `is_executing` flag and `current_thread_id` together are used to identify the excuting
+         * thread id for dispatch queue. See `static bool s_is_on_callers_thread(struct aws_event_loop *event_loop)`
+         * for details.
+         */
+        bool is_executing;
+        aws_thread_id_t current_thread_id;
+    } synced_data;
+
+    bool is_destroying;
+};
+
+#endif /* #ifndef AWS_IO_PRIVATE_DISPATCH_QUEUE_H */