fix: reformat queue.c/queue.h after const-correctness change
CI / lint (push) Failing after 2s
CI / build-and-test (push) Has been skipped
CI / sanitizers (address) (push) Has been skipped
CI / sanitizers (thread) (push) Has been skipped
CI / lint (pull_request) Failing after 2s
CI / build-and-test (pull_request) Has been skipped
CI / sanitizers (address) (pull_request) Has been skipped
CI / sanitizers (thread) (pull_request) Has been skipped
CI / lint (push) Failing after 2s
CI / build-and-test (push) Has been skipped
CI / sanitizers (address) (push) Has been skipped
CI / sanitizers (thread) (push) Has been skipped
CI / lint (pull_request) Failing after 2s
CI / build-and-test (pull_request) Has been skipped
CI / sanitizers (address) (pull_request) Has been skipped
CI / sanitizers (thread) (pull_request) Has been skipped
This commit is contained in:
+1
-1
@@ -117,7 +117,7 @@ void* queue_dequeue(Queue* queue) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void* queue_dequeue_multithreaded(Queue* queue, mtx_t* mutex, cnd_t* condition_not_empty,
|
void* queue_dequeue_multithreaded(Queue* queue, mtx_t* mutex, cnd_t* condition_not_empty,
|
||||||
cnd_t* condition_not_full, const bool* other_thread_done) {
|
cnd_t* condition_not_full, const bool* other_thread_done) {
|
||||||
mtx_lock(mutex);
|
mtx_lock(mutex);
|
||||||
while (queue_is_empty(queue) && !*other_thread_done)
|
while (queue_is_empty(queue) && !*other_thread_done)
|
||||||
cnd_wait(condition_not_empty, mutex);
|
cnd_wait(condition_not_empty, mutex);
|
||||||
|
|||||||
+1
-1
@@ -22,6 +22,6 @@ bool queue_enqueue_multithreaded(Queue* queue, void* item, mtx_t* mutex, cnd_t*
|
|||||||
cnd_t* condition_not_full);
|
cnd_t* condition_not_full);
|
||||||
void* queue_dequeue(Queue* queue);
|
void* queue_dequeue(Queue* queue);
|
||||||
void* queue_dequeue_multithreaded(Queue* queue, mtx_t* mutex, cnd_t* condition_not_empty,
|
void* queue_dequeue_multithreaded(Queue* queue, mtx_t* mutex, cnd_t* condition_not_empty,
|
||||||
cnd_t* condition_not_full, const bool* other_thread_done);
|
cnd_t* condition_not_full, const bool* other_thread_done);
|
||||||
|
|
||||||
#endif
|
#endif
|
||||||
|
|||||||
Reference in New Issue
Block a user