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/io.h

@@ -14,13 +14,7 @@ AWS_PUSH_SANE_WARNING_LEVEL
 
 #define AWS_C_IO_PACKAGE_ID 1
 
-struct aws_io_handle {
-    union {
-        int fd;
-        void *handle;
-    } data;
-    void *additional_data;
-};
+struct aws_io_handle;
 
 enum aws_io_message_type {
     AWS_IO_MESSAGE_APPLICATION_DATA,

include/aws/io/private/event_loop_impl.h

@@ -18,6 +18,20 @@ AWS_PUSH_SANE_WARNING_LEVEL
 struct aws_event_loop;
 struct aws_overlapped;
 
+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;
+};
+
 typedef void(aws_event_loop_on_completion_fn)(
     struct aws_event_loop *event_loop,
     struct aws_overlapped *overlapped,
@@ -152,6 +166,16 @@ AWS_IO_API
 struct _OVERLAPPED *aws_overlapped_to_windows_overlapped(struct aws_overlapped *overlapped);
 #endif /* AWS_ENABLE_IO_COMPLETION_PORTS */
 
+/**
+ * @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);
+
 /**
  * Associates an aws_io_handle with the event loop's I/O Completion Port.
  *

include/aws/io/socket.h

@@ -7,6 +7,7 @@
 
 #include <aws/io/channel.h>
 #include <aws/io/io.h>
+#include <aws/io/private/event_loop_impl.h>
 
 AWS_PUSH_SANE_WARNING_LEVEL
 

source/darwin/dispatch_queue.h

@@ -0,0 +1,74 @@
+#ifndef AWS_IO_DARWIN_DISPATCH_QUEUE_H
+#define AWS_IO_DARWIN_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 will_schedule;
+
+    /**
+     * 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 dispatch_loop_context;
+
+struct dispatch_loop {
+    struct aws_allocator *allocator;
+    dispatch_queue_t dispatch_queue;
+    struct aws_task_scheduler scheduler;
+    struct aws_linked_list local_cross_thread_tasks;
+    struct aws_event_loop *base_loop;
+
+    /* Apple dispatch queue uses the id string to identify the dispatch queue */
+    struct aws_string *dispatch_queue_id;
+
+    /* Synced data handle cross thread tasks and events, and event loop operations*/
+    struct {
+        struct aws_linked_list cross_thread_tasks;
+        struct dispatch_loop_context *context;
+        bool suspended;
+    } synced_task_data;
+
+    /* Synced thread data handles the thread related info. `is_executing` flag and `current_thread_id` together are used
+     * to identify the executing thread id for dispatch queue. See `static bool s_is_on_callers_thread(struct
+     * aws_event_loop *event_loop)` for details.
+     */
+    struct {
+
+        struct aws_mutex thread_data_lock;
+        bool is_executing;
+        aws_thread_id_t current_thread_id;
+    } synced_thread_data;
+
+    bool is_destroying;
+};
+
+#endif /* #ifndef AWS_IO_DARWIN_DISPATCH_QUEUE_H */