42 |
|
|
43 |
#include <pthread.h> |
#include <pthread.h> |
44 |
#include <signal.h> |
#include <signal.h> |
45 |
|
|
46 |
|
#ifndef WIN32 |
47 |
#include <unistd.h> |
#include <unistd.h> |
48 |
|
#endif |
49 |
|
|
50 |
#include "../encoder.h" |
#include "../encoder.h" |
51 |
#include "../utils/mbfunctions.h" |
#include "../utils/mbfunctions.h" |
356 |
|
|
357 |
pthread_mutex_lock(&me_mutex); |
pthread_mutex_lock(&me_mutex); |
358 |
me_iIntra=0; |
me_iIntra=0; |
359 |
me_inqueue=NUMTHREADS; |
me_inqueue=pParam->num_threads; |
360 |
me_corrqueue=NUMTHREADS; |
me_corrqueue=pParam->num_threads; |
361 |
me_outqueue=NUMTHREADS; |
me_outqueue=pParam->num_threads; |
362 |
|
|
363 |
if (!threadscreated) |
if (!threadscreated) |
364 |
{ |
{ |
365 |
for (i=0;i<NUMTHREADS;i++) { /* split domain into NUMTHREADS parts */ |
for (i=0;i<pParam->num_threads;i++) { /* split domain into NUMTHREADS parts */ |
366 |
|
|
367 |
jdata[i].id = i; |
jdata[i].id = i; |
368 |
jdata[i].minx = i*iWcount/NUMTHREADS; |
jdata[i].minx = i*iWcount/pParam->num_threads; |
369 |
jdata[i].maxx = (i+1)*iWcount/NUMTHREADS; |
jdata[i].maxx = (i+1)*iWcount/pParam->num_threads; |
370 |
jdata[i].miny = 0; |
jdata[i].miny = 0; |
371 |
jdata[i].maxy = iHcount; |
jdata[i].maxy = iHcount; |
372 |
jdata[i].gdata = &gdata; |
jdata[i].gdata = &gdata; |