mirrors/awslabs_aws-crt-php
1
0
Fork 0
mirror of https://github.com/awslabs/aws-crt-php.git synced 2026-08-18 01:57:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

aws-crt-ffi v0.3.7 -> v0.3.8 (#112)

Browse Source 
Also: replace uses of `aws_promise` (removed in https://github.com/awslabs/aws-c-common/pull/1110) with `aws_future`
This commit is contained in:
Michael Graeb
2024-06-13 10:21:28 -07:00
committed by GitHub
parent 0ea1f04ec5
commit a63485b65b
4 changed files with 24 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ext/crt.c
+11 -11
View File
@@ -195,9 +195,9 @@ bool aws_php_thread_queue_drain(aws_php_thread_queue *queue) {
}
/* called on main thread after delivery */
static void s_thread_queue_complete_promise(void *data) {
struct aws_promise *promise = data;
aws_promise_complete(promise, NULL, NULL);
static void s_thread_queue_complete_future(void *data) {
struct aws_future_void *future = data;
aws_future_void_set_result(future);
}
/* called from worker thread to wait for the main thread to execute any queued work in PHP */
@@ -206,21 +206,21 @@ void aws_php_thread_queue_yield(aws_php_thread_queue *queue) {
if (aws_php_is_main_thread()) {
aws_php_thread_queue_drain(queue);
} else {
/* push a task onto the end of the queue, we will return once this task completes our promise */
struct aws_promise *queue_drained = aws_promise_new(aws_crt_default_allocator());
/* push a task onto the end of the queue, we will return once this task completes our future */
struct aws_future_void *queue_drained = aws_future_void_new(aws_crt_default_allocator());
aws_php_task queue_drained_task = {
.callback = s_thread_queue_complete_promise,
.callback = s_thread_queue_complete_future,
.data = queue_drained,
};
aws_php_thread_queue_push(queue, queue_drained_task);
aws_promise_wait(queue_drained);
aws_promise_release(queue_drained);
aws_future_void_wait(queue_drained, UINT64_MAX /*timeout*/);
aws_future_void_release(queue_drained);
}
}
/* called from PHP thread to wait on async queued jobs, one of which should complete the promise */
void aws_php_thread_queue_wait(aws_php_thread_queue *queue, struct aws_promise *promise) {
while (!aws_promise_is_complete(promise)) {
/* called from PHP thread to wait on async queued jobs, one of which should complete the future */
void aws_php_thread_queue_wait(aws_php_thread_queue *queue, struct aws_future_void *future) {
while (!aws_future_void_is_done(future)) {
aws_php_thread_queue_drain(queue);
}
}