summaryrefslogtreecommitdiff
path: root/libavcodec/w32thread.c
diff options
context:
space:
mode:
Diffstat (limited to 'libavcodec/w32thread.c')
-rw-r--r--libavcodec/w32thread.c14
1 files changed, 7 insertions, 7 deletions
diff --git a/libavcodec/w32thread.c b/libavcodec/w32thread.c
index 186e302dc8..48ccf5e0b7 100644
--- a/libavcodec/w32thread.c
+++ b/libavcodec/w32thread.c
@@ -50,7 +50,7 @@ static unsigned __stdcall thread_func(void *v){
//printf("thread_func %X signal complete\n", (int)v); fflush(stdout);
ReleaseSemaphore(c->done_sem, 1, 0);
}
-
+
return 0;
}
@@ -63,7 +63,7 @@ void avcodec_thread_free(AVCodecContext *s){
int i;
for(i=0; i<s->thread_count; i++){
-
+
c[i].func= NULL;
ReleaseSemaphore(c[i].work_sem, 1, 0);
WaitForSingleObject(c[i].thread, INFINITE);
@@ -77,10 +77,10 @@ void avcodec_thread_free(AVCodecContext *s){
int avcodec_thread_execute(AVCodecContext *s, int (*func)(AVCodecContext *c2, void *arg2),void **arg, int *ret, int count){
ThreadContext *c= s->thread_opaque;
int i;
-
+
assert(s == c->avctx);
assert(count <= s->thread_count);
-
+
/* note, we can be certain that this is not called with the same AVCodecContext by different threads at the same time */
for(i=0; i<count; i++){
@@ -92,7 +92,7 @@ int avcodec_thread_execute(AVCodecContext *s, int (*func)(AVCodecContext *c2, vo
}
for(i=0; i<count; i++){
WaitForSingleObject(c[i].done_sem, INFINITE);
-
+
c[i].func= NULL;
if(ret) ret[i]= c[i].ret;
}
@@ -109,7 +109,7 @@ int avcodec_thread_init(AVCodecContext *s, int thread_count){
assert(!s->thread_opaque);
c= av_mallocz(sizeof(ThreadContext)*thread_count);
s->thread_opaque= c;
-
+
for(i=0; i<thread_count; i++){
//printf("init semaphors %d\n", i); fflush(stdout);
c[i].avctx= s;
@@ -124,7 +124,7 @@ int avcodec_thread_init(AVCodecContext *s, int thread_count){
if( !c[i].thread ) goto fail;
}
//printf("init done\n"); fflush(stdout);
-
+
s->execute= avcodec_thread_execute;
return 0;