aboutsummaryrefslogtreecommitdiff
path: root/core/command_queue_mt.cpp
diff options
context:
space:
mode:
authorRémi Verschelde2017-03-19 00:36:26 +0100
committerRémi Verschelde2017-03-19 00:36:26 +0100
commitf8db8a3faa30b71dca33ced38be16d3f93f43e8a (patch)
tree3b798318132cca7eccfbca5818ab55656a2896d7 /core/command_queue_mt.cpp
parent1d418afe863c9e553b69174ce63aef203c46d2f0 (diff)
downloadgodot-f8db8a3faa30b71dca33ced38be16d3f93f43e8a.tar.gz
godot-f8db8a3faa30b71dca33ced38be16d3f93f43e8a.tar.zst
godot-f8db8a3faa30b71dca33ced38be16d3f93f43e8a.zip
Diffstat (limited to 'core/command_queue_mt.cpp')
-rw-r--r--core/command_queue_mt.cpp36
1 files changed, 15 insertions, 21 deletions
diff --git a/core/command_queue_mt.cpp b/core/command_queue_mt.cpp
index 9b1c052eb..0bf8d0346 100644
--- a/core/command_queue_mt.cpp
+++ b/core/command_queue_mt.cpp
@@ -47,22 +47,22 @@ void CommandQueueMT::wait_for_flush() {
OS::get_singleton()->delay_usec(1000);
}
-CommandQueueMT::SyncSemaphore* CommandQueueMT::_alloc_sync_sem() {
+CommandQueueMT::SyncSemaphore *CommandQueueMT::_alloc_sync_sem() {
- int idx=-1;
+ int idx = -1;
- while(true) {
+ while (true) {
- for(int i=0;i<SYNC_SEMAPHORES;i++) {
+ for (int i = 0; i < SYNC_SEMAPHORES; i++) {
if (!sync_sems[i].in_use) {
- sync_sems[i].in_use=true;
- idx=i;
+ sync_sems[i].in_use = true;
+ idx = i;
break;
}
}
- if (idx==-1) {
+ if (idx == -1) {
wait_for_flush();
} else {
break;
@@ -72,36 +72,30 @@ CommandQueueMT::SyncSemaphore* CommandQueueMT::_alloc_sync_sem() {
return &sync_sems[idx];
}
+CommandQueueMT::CommandQueueMT(bool p_sync) {
-CommandQueueMT::CommandQueueMT(bool p_sync){
-
- read_ptr=0;
- write_ptr=0;
+ read_ptr = 0;
+ write_ptr = 0;
mutex = Mutex::create();
- for(int i=0;i<SYNC_SEMAPHORES;i++) {
-
- sync_sems[i].sem=Semaphore::create();
- sync_sems[i].in_use=false;
-
+ for (int i = 0; i < SYNC_SEMAPHORES; i++) {
+ sync_sems[i].sem = Semaphore::create();
+ sync_sems[i].in_use = false;
}
if (p_sync)
sync = Semaphore::create();
else
- sync=NULL;
+ sync = NULL;
}
-
CommandQueueMT::~CommandQueueMT() {
if (sync)
memdelete(sync);
memdelete(mutex);
- for(int i=0;i<SYNC_SEMAPHORES;i++) {
+ for (int i = 0; i < SYNC_SEMAPHORES; i++) {
memdelete(sync_sems[i].sem);
}
}
-
-