Fixed OpenMP implementation on fast_demo.cc

This commit is contained in:
Emil Martinec 2010-09-17 19:19:13 -05:00
parent a26284a52f
commit 173a09738b

View File

@ -36,6 +36,7 @@ void RawImageSource::fast_demo() {
float progress = 0.0; float progress = 0.0;
//allocate output arrays //allocate output arrays
red = new unsigned short*[H]; red = new unsigned short*[H];
for (int i=0; i<H; i++) { for (int i=0; i<H; i++) {
red[i] = new unsigned short[W]; red[i] = new unsigned short[W];
@ -49,25 +50,26 @@ void RawImageSource::fast_demo() {
blue[i] = new unsigned short[W]; blue[i] = new unsigned short[W];
} }
#define bord 4 #define bord 4
int i, j, i1, j1, c, sum[6];
//%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% //%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
//first, interpolate borders using bilinear //first, interpolate borders using bilinear
for (i=0; i<H; i++) { for (int i=0; i<H; i++) {
for (j=0; j<bord; j++) {//first few columns for (int j=0; j<bord; j++) {//first few columns
for (c=0; c<6; c++) sum[c]=0; unsigned int sum[6];
for (i1=i-1; i1<i+2; i1++) for (int c=0; c<6; c++) sum[c]=0;
for (j1=j-1; j1<j+2; j1++) { for (int i1=i-1; i1<i+2; i1++)
if (i1 > -1 && i1 < H && j1 > -1) { for (int j1=j-1; j1<j+2; j1++) {
c = FC(i1,j1); if ((i1 > -1) && (i1 < H) && (j1 > -1)) {
int c = FC(i1,j1);
sum[c] += ri->data[i1][j1]; sum[c] += ri->data[i1][j1];
sum[c+3]++; sum[c+3]++;
} }
} }
c=FC(i,j); int c=FC(i,j);
if (c==1) { if (c==1) {
red[i][j]=sum[0]/sum[3]; red[i][j]=sum[0]/sum[3];
green[i][j]=ri->data[i][j]; green[i][j]=ri->data[i][j];
@ -84,17 +86,18 @@ void RawImageSource::fast_demo() {
} }
}//j }//j
for (j=W-bord; j<W; j++) {//last few columns for (int j=W-bord; j<W; j++) {//last few columns
for (c=0; c<6; c++) sum[c]=0; unsigned int sum[6];
for (i1=i-1; i1<i+2; i1++) for (int c=0; c<6; c++) sum[c]=0;
for (j1=j-1; j1<j+2; j1++) { for (int i1=i-1; i1<i+2; i1++)
if (i1 > -1 && i1 < H && j1 < W) { for (int j1=j-1; j1<j+2; j1++) {
c = FC(i1,j1); if ((i1 > -1) && (i1 < H ) && (j1 < W)) {
int c = FC(i1,j1);
sum[c] += ri->data[i1][j1]; sum[c] += ri->data[i1][j1];
sum[c+3]++; sum[c+3]++;
} }
} }
c=FC(i,j); int c=FC(i,j);
if (c==1) { if (c==1) {
red[i][j]=sum[0]/sum[3]; red[i][j]=sum[0]/sum[3];
green[i][j]=ri->data[i][j]; green[i][j]=ri->data[i][j];
@ -114,18 +117,19 @@ void RawImageSource::fast_demo() {
//%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% //%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
for (j=bord; j<W-bord; j++) { for (int j=bord; j<W-bord; j++) {
for (i=0; i<bord; i++) {//first few rows for (int i=0; i<bord; i++) {//first few rows
for (c=0; c<6; c++) sum[c]=0; unsigned int sum[6];
for (i1=i-1; i1<i+2; i1++) for (int c=0; c<6; c++) sum[c]=0;
for (j1=j-1; j1<j+2; j1++) { for (int i1=i-1; i1<i+2; i1++)
if (j1 > -1 && j1 < W && i1 > -1) { for (int j1=j-1; j1<j+2; j1++) {
c = FC(i1,j1); if ((j1 > -1) && (j1 < W) && (i1 > -1)) {
int c = FC(i1,j1);
sum[c] += ri->data[i1][j1]; sum[c] += ri->data[i1][j1];
sum[c+3]++; sum[c+3]++;
} }
} }
c=FC(i,j); int c=FC(i,j);
if (c==1) { if (c==1) {
red[i][j]=sum[0]/sum[3]; red[i][j]=sum[0]/sum[3];
green[i][j]=ri->data[i][j]; green[i][j]=ri->data[i][j];
@ -142,17 +146,18 @@ void RawImageSource::fast_demo() {
} }
}//i }//i
for (i=H-bord; i<H; i++) {//last few rows for (int i=H-bord; i<H; i++) {//last few rows
for (c=0; c<6; c++) sum[c]=0; unsigned int sum[6];
for (i1=i-1; i1<i+2; i1++) for (int c=0; c<6; c++) sum[c]=0;
for (j1=j-1; j1<j+2; j1++) { for (int i1=i-1; i1<i+2; i1++)
if (j1 > -1 && j1 < W && i1 < H) { for (int j1=j-1; j1<j+2; j1++) {
c = FC(i1,j1); if ((j1 > -1) && (j1 < W) && (i1 < H)) {
int c = FC(i1,j1);
sum[c] += ri->data[i1][j1]; sum[c] += ri->data[i1][j1];
sum[c+3]++; sum[c+3]++;
} }
} }
c=FC(i,j); int c=FC(i,j);
if (c==1) { if (c==1) {
red[i][j]=sum[0]/sum[3]; red[i][j]=sum[0]/sum[3];
green[i][j]=ri->data[i][j]; green[i][j]=ri->data[i][j];
@ -173,27 +178,19 @@ void RawImageSource::fast_demo() {
if(plistener) plistener->setProgress(0.05); if(plistener) plistener->setProgress(0.05);
//%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% //%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
#pragma omp parallel private(i,j,c)
{
int rb;
float wt1, wt2, wt3, wt4;
float * dirwt = new float [0x20000]; float * dirwt = new float [0x20000];
#pragma omp for schedule(dynamic) nowait
//set up directional weight function //set up directional weight function
for (int i=0; i<0x10000; i++) for (int i=0; i<0x10000; i++)
dirwt[i] = 1.0/SQR(1.0+i); dirwt[i] = 1.0/SQR(1.0+i);
#pragma omp parallel
{
#pragma omp for schedule(dynamic) nowait #pragma omp for
// interpolate G using gradient weights // interpolate G using gradient weights
for (i=bord; i< H-bord; i++) { for (int i=bord; i< H-bord; i++) {
for (j=bord; j < W-bord; j++) { for (int j=bord; j < W-bord; j++) {
if (FC(i,j)==1) { if (FC(i,j)==1) {
green[i][j] = ri->data[i][j]; green[i][j] = ri->data[i][j];
@ -202,6 +199,7 @@ void RawImageSource::fast_demo() {
} else { } else {
//compute directional weights using image gradients //compute directional weights using image gradients
float wt1, wt2, wt3, wt4;
wt1=dirwt[(abs(ri->data[i+1][j]-ri->data[i-1][j])+abs(ri->data[i][j]-ri->data[i-2][j])+abs(ri->data[i-1][j]-ri->data[i-3][j])) >>4]; wt1=dirwt[(abs(ri->data[i+1][j]-ri->data[i-1][j])+abs(ri->data[i][j]-ri->data[i-2][j])+abs(ri->data[i-1][j]-ri->data[i-3][j])) >>4];
wt2=dirwt[(abs(ri->data[i-1][j]-ri->data[i+1][j])+abs(ri->data[i][j]-ri->data[i+2][j])+abs(ri->data[i+1][j]-ri->data[i+3][j])) >>4]; wt2=dirwt[(abs(ri->data[i-1][j]-ri->data[i+1][j])+abs(ri->data[i][j]-ri->data[i+2][j])+abs(ri->data[i+1][j]-ri->data[i+3][j])) >>4];
wt3=dirwt[(abs(ri->data[i][j+1]-ri->data[i][j-1])+abs(ri->data[i][j]-ri->data[i][j-2])+abs(ri->data[i][j-1]-ri->data[i][j-3])) >>4]; wt3=dirwt[(abs(ri->data[i][j+1]-ri->data[i][j-1])+abs(ri->data[i][j]-ri->data[i][j-2])+abs(ri->data[i][j-1]-ri->data[i][j-3])) >>4];
@ -214,20 +212,18 @@ void RawImageSource::fast_demo() {
} }
} }
progress+=(double)0.33/(H); //progress+=(double)0.33/(H);
//if(plistener) plistener->setProgress(progress); //if(plistener) plistener->setProgress(progress);
} }
if(plistener) plistener->setProgress(0.4); if(plistener) plistener->setProgress(0.4);
#pragma omp for schedule(dynamic) nowait #pragma omp for
for (int i=bord; i< H-bord; i++) {
for (int j=bord+(FC(i,2)&1), c=FC(i,j); j < W-bord; j+=2) {
for (i=bord; i< H-bord; i++) {
for (j=bord+(FC(i,2)&1); j < W-bord; j+=2) {
c=FC(i,j);
//interpolate B/R colors at R/B sites //interpolate B/R colors at R/B sites
rb = CLIP((int)(green[i][j] - 0.25*((green[i-1][j-1]-ri->data[i-1][j-1])+(green[i-1][j+1]-ri->data[i-1][j+1])+ \ unsigned int rb = CLIP((int)(green[i][j] - 0.25*((green[i-1][j-1]-ri->data[i-1][j-1])+(green[i-1][j+1]-ri->data[i-1][j+1])+ \
(green[i+1][j+1]-ri->data[i+1][j+1])+(green[i+1][j-1]-ri->data[i+1][j-1])))); (green[i+1][j+1]-ri->data[i+1][j+1])+(green[i+1][j-1]-ri->data[i+1][j-1]))));
if (c==0) {//R site if (c==0) {//R site
red[i][j] = ri->data[i][j]; red[i][j] = ri->data[i][j];
@ -237,17 +233,18 @@ void RawImageSource::fast_demo() {
blue[i][j] = ri->data[i][j]; blue[i][j] = ri->data[i][j];
} }
} }
progress+=(double)0.33/(H); //progress+=(double)0.33/(H);
//if(plistener) plistener->setProgress(progress); //if(plistener) plistener->setProgress(progress);
} }
if(plistener) plistener->setProgress(0.7); if(plistener) plistener->setProgress(0.7);
#pragma omp barrier
#pragma omp for schedule(dynamic) nowait #pragma omp for
// interpolate R/B using color differences // interpolate R/B using color differences
for (i=bord; i< H-bord; i++) { for (int i=bord; i< H-bord; i++) {
for (j=bord+1-(FC(i,2)&1); j < W-bord; j+=2) { for (int j=bord+1-(FC(i,2)&1); j < W-bord; j+=2) {
//interpolate R and B colors at G sites //interpolate R and B colors at G sites
red[i][j] = CLIP((int)(green[i][j] - 0.25*((green[i-1][j]-red[i-1][j])+(green[i+1][j]-red[i+1][j])+ \ red[i][j] = CLIP((int)(green[i][j] - 0.25*((green[i-1][j]-red[i-1][j])+(green[i+1][j]-red[i+1][j])+ \
@ -259,13 +256,8 @@ void RawImageSource::fast_demo() {
//if(plistener) plistener->setProgress(progress); //if(plistener) plistener->setProgress(progress);
} }
if(plistener) plistener->setProgress(0.99); if(plistener) plistener->setProgress(0.99);
} }
#undef bord #undef bord
}//namespace }//namespace