2 * Copyright (c) 2004 Michael Niedermayer <michaelni@gmx.at>
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Lesser General Public
6 * License as published by the Free Software Foundation; either
7 * version 2 of the License, or (at your option) any later version.
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Lesser General Public License for more details.
14 * You should have received a copy of the GNU Lesser General Public
15 * License along with this library; if not, write to the Free Software
16 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
21 // Ported by Vlad Stelmahovsky
29 #define INCL_DOSERRORS
30 #define INCL_DOSDEVIOCTL
33 typedef struct ThreadContext
{
34 AVCodecContext
*avctx
;
38 int (*func
)(AVCodecContext
*c
, void *arg
);
44 void thread_func(void *v
){
48 //printf("thread_func %X enter wait\n", (int)v); fflush(stdout);
49 DosWaitEventSem(c
->work_sem
, SEM_INDEFINITE_WAIT
);
50 // WaitForSingleObject(c->work_sem, INFINITE);
51 //printf("thread_func %X after wait (func=%X)\n", (int)v, (int)c->func); fflush(stdout);
53 c
->ret
= c
->func(c
->avctx
, c
->arg
);
56 //printf("thread_func %X signal complete\n", (int)v); fflush(stdout);
57 DosPostEventSem(c
->done_sem
);
58 // ReleaseSemaphore(c->done_sem, 1, 0);
65 * free what has been allocated by avcodec_thread_init().
66 * must be called after decoding has finished, especially dont call while avcodec_thread_execute() is running
68 void avcodec_thread_free(AVCodecContext
*s
){
69 ThreadContext
*c
= s
->thread_opaque
;
72 for(i
=0; i
<s
->thread_count
; i
++){
75 DosPostEventSem(c
[i
].work_sem
);
76 // ReleaseSemaphore(c[i].work_sem, 1, 0);
77 DosWaitThread((PTID
)&c
[i
].thread
,DCWW_WAIT
);
78 // WaitForSingleObject(c[i].thread, INFINITE);
79 if(c
[i
].work_sem
) DosCloseEventSem(c
[i
].work_sem
);//CloseHandle(c[i].work_sem);
80 if(c
[i
].done_sem
) DosCloseEventSem(c
[i
].done_sem
);//CloseHandle(c[i].done_sem);
83 av_freep(&s
->thread_opaque
);
86 int avcodec_thread_execute(AVCodecContext
*s
, int (*func
)(AVCodecContext
*c2
, void *arg2
),void **arg
, int *ret
, int count
){
87 ThreadContext
*c
= s
->thread_opaque
;
90 assert(s
== c
->avctx
);
91 assert(count
<= s
->thread_count
);
93 /* note, we can be certain that this is not called with the same AVCodecContext by different threads at the same time */
95 for(i
=0; i
<count
; i
++){
101 DosPostEventSem(c
[i
].work_sem
);
102 // ReleaseSemaphore(c[i].work_sem, 1, 0);
104 for(i
=0; i
<count
; i
++){
105 DosWaitEventSem(c
[i
].done_sem
,SEM_INDEFINITE_WAIT
);
106 // WaitForSingleObject(c[i].done_sem, INFINITE);
109 if(ret
) ret
[i
]= c
[i
].ret
;
114 int avcodec_thread_init(AVCodecContext
*s
, int thread_count
){
119 s
->thread_count
= thread_count
;
121 assert(!s
->thread_opaque
);
122 c
= av_mallocz(sizeof(ThreadContext
)*thread_count
);
125 for(i
=0; i
<thread_count
; i
++){
126 //printf("init semaphors %d\n", i); fflush(stdout);
129 if (DosCreateEventSem(NULL
,&c
[i
].work_sem
,DC_SEM_SHARED
,0))
131 if (DosCreateEventSem(NULL
,&c
[i
].done_sem
,DC_SEM_SHARED
,0))
134 //printf("create thread %d\n", i); fflush(stdout);
135 // c[i].thread = (HANDLE)_beginthreadex(NULL, 0, thread_func, &c[i], 0, &threadid );
136 c
[i
].thread
= _beginthread(thread_func
, NULL
, 0x10000, &c
[i
]);
137 if( c
[i
].thread
<= 0 ) goto fail
;
139 //printf("init done\n"); fflush(stdout);
141 s
->execute
= avcodec_thread_execute
;
145 avcodec_thread_free(s
);