1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
#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/condition_variable.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;
/* The certs field can be set in two different ways, and only one requires releasing individual cert objects. */
bool cleanup_cert;
sec_identity_t secitem_identity;
CFArrayRef ca_cert;
enum aws_tls_versions minimum_tls_version;
struct aws_string *alpn_list;
bool verify_peer;
};
enum aws_dispatch_loop_execution_state {
AWS_DLES_SUSPENDED,
AWS_DLES_RUNNING,
AWS_DLES_SHUTTING_DOWN,
AWS_DLES_TERMINATED
};
struct aws_dispatch_loop {
struct aws_allocator *allocator;
dispatch_queue_t dispatch_queue;
struct aws_task_scheduler scheduler;
struct aws_event_loop *base_loop;
struct aws_ref_count ref_count;
/* Synced data handle cross thread tasks and events, and event loop operations*/
struct {
/*
* This lock is used to protect synced_data across the threads. It should be acquired whenever data in the
* synced_data struct is accessed or modified.
*/
struct aws_mutex synced_data_lock;
/*
* Allows blocking waits for changes in synced data state. Currently used by the external destruction process
* to wait for the loop to enter the TERMINATED state. It is acceptable to do a blocking wait because
* event loop group destruction is done in a dedicated thread spawned only for that purpose.
*/
struct aws_condition_variable signal;
/*
* `is_executing` flag and `current_thread_id` are used together to identify the thread id of the dispatch queue
* running the current block. See dispatch queue's `s_is_on_callers_thread()` implementation for details.
*/
bool is_executing;
aws_thread_id_t current_thread_id;
/*
* Will be true if dispatch queue is in a suspended state. A dispatch queue in a suspended state will not start
* any blocks that are already enqueued but will not prevent additional blocks from being queued.
*
* Set to true when `stop()` is called on event loop.
* `run()` must be called on owning event_loop to resume processing of blocks on a suspended dispatch queue.
*
* Calling dispatch_sync() on a suspended dispatch queue will deadlock.
*/
enum aws_dispatch_loop_execution_state execution_state;
struct aws_linked_list cross_thread_tasks;
/*
* priority queue of <scheduled_iteration_entry> in sorted order by timestamp. Each scheduled_iteration_entry
* represents a block ALREADY SCHEDULED on Apple dispatch queue.
*
* When we schedule a new run iteration, scheduled_iterations is checked to see if the scheduling attempt is
* redundant.
*/
struct aws_linked_list scheduled_iterations;
} synced_data;
};
#endif /* #ifndef AWS_IO_DARWIN_DISPATCH_QUEUE_H */
|
