From d04fc5a5b10e60528470365fd54d836268d2e01a Mon Sep 17 00:00:00 2001
From: Pengliang Yang <hugeman1986@126.com>
Date: Fri, 12 Jan 2018 21:39:43 +0100
Subject: [PATCH] the one is not in the list of SConstruct

---
 user/pyang/Mlsprtm2d.c | 265 ++++++++--------
 user/pyang/SConstruct  |   2 +-
 user/pyang/prtm2d.c    | 701 ++++++++++++++++++++++++-----------------
 3 files changed, 537 insertions(+), 431 deletions(-)

diff --git a/user/pyang/Mlsprtm2d.c b/user/pyang/Mlsprtm2d.c
index 48460f2309..103d87f918 100644
--- a/user/pyang/Mlsprtm2d.c
+++ b/user/pyang/Mlsprtm2d.c
@@ -1,5 +1,4 @@
-/* least-squares prestack RTM in 2-D
- */
+/* least-squares prestack RTM in 2-D */
 /*
   Copyright (C) 
   - 2014  Xi'an Jiaotong University, UT Austin (Pengliang Yang)
@@ -26,145 +25,145 @@
 
 int main(int argc, char* argv[])
 {   
-    bool verb, fromBoundary;
-    int nb, nz, nx, nt, ns, ng, niter, csd, sxbeg, szbeg, jsx, jsz, gxbeg, gzbeg, jgx, jgz;
-    float dz, dx, dt, fm, o1, o2, amp;
-    float **v0, *mod, *dat; 
-    int testadj;
+	bool verb, fromBoundary;
+	int nb, nz, nx, nt, ns, ng, niter, csd, sxbeg, szbeg, jsx, jsz, gxbeg, gzbeg, jgx, jgz;
+	float dz, dx, dt, fm, o1, o2, amp;
+	float **v0, *mod, *dat; 
+	int testadj;
 
-    sf_file shots, imglsm, imgrtm, velo;/* I/O files */
+	sf_file shots, imglsm, imgrtm, velo;/* I/O files */
 
-    /* initialize Madagascar */
-    sf_init(argc,argv);
+	/* initialize Madagascar */
+	sf_init(argc,argv);
 
-    shots = sf_input ("in"); /* shot records, data 	*/
-    velo = sf_input ("vel"); /* velocity */
-    imglsm = sf_output("out"); /* output LSRTM imglsme, model */
-    imgrtm = sf_output("imgrtm"); /* output RTM imglsme */
+	shots = sf_input ("in"); /* shot records, data 	*/
+	velo = sf_input ("vel"); /* velocity */
+	imglsm = sf_output("out"); /* output LSRTM imglsme, model */
+	imgrtm = sf_output("imgrtm"); /* output RTM imglsme */
     
-    if (!sf_histint(velo,"n1",&nz)) sf_error("n1");
-    /* 1st dimension size */
-    if (!sf_histint(velo,"n2",&nx)) sf_error("n2");
-    /* 2nd dimension size */
-    if (!sf_histfloat(velo,"d1",&dz)) sf_error("d1");
-    /* d1 */
-    if (!sf_histfloat(velo,"d2",&dx)) sf_error("d2");
-    /* d2 */
-    if (!sf_histfloat(velo,"o1",&o1)) sf_error("o1");
-    /* o1 */
-    if (!sf_histfloat(velo,"o2",&o2)) sf_error("o2");
-    /* o2 */
-    if (!sf_getbool("verb",&verb)) verb=true;
-    /* verbosity */
-    if (!sf_getint("niter",&niter)) niter=10;
-    /* totol number of least-squares iteration*/
-    if (!sf_getint("nb",&nb)) nb=20;
-    /* number (thickness) of ABC on each side */
-    if (!sf_getbool("fromBoundary",&fromBoundary)) fromBoundary=true;
-    /* if fromBoundary=true, reconstruct source wavefield from stored boundary */
-    if (!sf_getint("testadj",&testadj)) testadj=0;
-    /* if testadj = 1 then program only testadj without calculating */
+	if (!sf_histint(velo,"n1",&nz)) sf_error("n1");
+	/* 1st dimension size */
+	if (!sf_histint(velo,"n2",&nx)) sf_error("n2");
+	/* 2nd dimension size */
+	if (!sf_histfloat(velo,"d1",&dz)) sf_error("d1");
+	/* d1 */
+	if (!sf_histfloat(velo,"d2",&dx)) sf_error("d2");
+	/* d2 */
+	if (!sf_histfloat(velo,"o1",&o1)) sf_error("o1");
+	/* o1 */
+	if (!sf_histfloat(velo,"o2",&o2)) sf_error("o2");
+	/* o2 */
+	if (!sf_getbool("verb",&verb)) verb=true;
+	/* verbosity */
+	if (!sf_getint("niter",&niter)) niter=10;
+	/* totol number of least-squares iteration*/
+	if (!sf_getint("nb",&nb)) nb=20;
+	/* number (thickness) of ABC on each side */
+	if (!sf_getbool("fromBoundary",&fromBoundary)) fromBoundary=true;
+	/* if fromBoundary=true, reconstruct source wavefield from stored boundary */
+	if (!sf_getint("testadj",&testadj)) testadj=0;
+	/* if testadj = 1 then program only testadj without calculating */
    
-    if (!sf_histint(shots,"n1",&nt)) sf_error("no nt");
-    /* total modeling time steps */
-    if (!sf_histint(shots,"n2",&ng)) sf_error("no ng");
-    /* total receivers in each shot */
-    if (!sf_histint(shots,"n3",&ns)) sf_error("no ns");
-    /* number of shots */
-    if (!sf_histfloat(shots,"d1",&dt)) sf_error("no dt");
-    /* time sampling interval */
-    if (!sf_histfloat(shots,"amp",&amp)) sf_error("no amp");
-    /* maximum amplitude of ricker */
-    if (!sf_histfloat(shots,"fm",&fm)) sf_error("no fm");
-    /* dominant freq of ricker */
-    if (!sf_histint(shots,"sxbeg",&sxbeg)) sf_error("no sxbeg");
-    /* x-begining index of sources, starting from 0 */
-    if (!sf_histint(shots,"szbeg",&szbeg)) sf_error("no szbeg");
-    /* x-begining index of sources, starting from 0 */
-    if (!sf_histint(shots,"gxbeg",&gxbeg)) sf_error("no gxbeg");
-    /* x-begining index of receivers, starting from 0 */
-    if (!sf_histint(shots,"gzbeg",&gzbeg)) sf_error("no gzbeg");
-    /* x-begining index of receivers, starting from 0 */
-    if (!sf_histint(shots,"jsx",&jsx)) sf_error("no jsx");
-    /* source x-axis  jump interval  */
-    if (!sf_histint(shots,"jsz",&jsz)) sf_error("no jsz");
-    /* source z-axis jump interval  */
-    if (!sf_histint(shots,"jgx",&jgx)) sf_error("no jgx");
-    /* receiver x-axis jump interval  */
-    if (!sf_histint(shots,"jgz",&jgz)) sf_error("no jgz");
-    /* receiver z-axis jump interval  */
-    if (!sf_histint(shots,"csdgather",&csd)) sf_error("csdgather or not required");
-    /* default, common shot-gather; if n, record at every point*/
-
-    sf_putint(imglsm,"n1",nz);
-    sf_putint(imglsm,"n2",nx);
-    sf_putint(imglsm,"n3",1);
-    sf_putfloat(imglsm,"d1",dz);
-    sf_putfloat(imglsm,"d2",dx);
-    sf_putfloat(imglsm,"o1",o1);
-    sf_putfloat(imglsm,"o2",o2);
-    sf_putstring(imglsm,"label1","Depth");
-    sf_putstring(imglsm,"label2","Distance");
-
-    sf_putint(imgrtm,"n1",nz);
-    sf_putint(imgrtm,"n2",nx);
-    sf_putint(imgrtm,"n3",1);
-    sf_putfloat(imgrtm,"d1",dz);
-    sf_putfloat(imgrtm,"d2",dx);
-    sf_putfloat(imgrtm,"o1",o1);
-    sf_putfloat(imgrtm,"o2",o2);
-    sf_putstring(imgrtm,"label1","Depth");
-    sf_putstring(imgrtm,"label2","Distance");
-
-    /* In rtm, vv is the velocity model [modl], which is input parameter; 
-       mod is the imglsme/reflectivity [imglsm]; dat is seismogram [data]! */
-    v0=sf_floatalloc2(nz,nx);
-    mod=sf_floatalloc(nz*nx);
-    dat=sf_floatalloc(nt*ng*ns);
-
-    /* initialize velocity, model and data */
-    sf_floatread(v0[0], nz*nx, velo);
-    memset(mod, 0, nz*nx*sizeof(float));
-    sf_floatread(dat, nt*ng*ns, shots);
-    prtm2d_init(verb, csd, fromBoundary, dz, dx, dt, amp, fm, nz, nx, nb, nt, ns, ng, 
-		sxbeg, szbeg, jsx, jsz, gxbeg, gzbeg, jgx, jgz, v0, mod, dat);
-
-    // run adjoint test first.
-    sf_warning("adjoint test \n");
-    if (testadj){
-	prtm2d_adjtest();
-	sf_warning("exiting after testadj\n");
-	mod=NULL;
-	sf_floatwrite(mod,nz*nx,imgrtm);
-	sf_floatwrite(mod,nz*nx,imglsm);
+	if (!sf_histint(shots,"n1",&nt)) sf_error("no nt");
+	/* total modeling time steps */
+	if (!sf_histint(shots,"n2",&ng)) sf_error("no ng");
+	/* total receivers in each shot */
+	if (!sf_histint(shots,"n3",&ns)) sf_error("no ns");
+	/* number of shots */
+	if (!sf_histfloat(shots,"d1",&dt)) sf_error("no dt");
+	/* time sampling interval */
+	if (!sf_histfloat(shots,"amp",&amp)) sf_error("no amp");
+	/* maximum amplitude of ricker */
+	if (!sf_histfloat(shots,"fm",&fm)) sf_error("no fm");
+	/* dominant freq of ricker */
+	if (!sf_histint(shots,"sxbeg",&sxbeg)) sf_error("no sxbeg");
+	/* x-begining index of sources, starting from 0 */
+	if (!sf_histint(shots,"szbeg",&szbeg)) sf_error("no szbeg");
+	/* x-begining index of sources, starting from 0 */
+	if (!sf_histint(shots,"gxbeg",&gxbeg)) sf_error("no gxbeg");
+	/* x-begining index of receivers, starting from 0 */
+	if (!sf_histint(shots,"gzbeg",&gzbeg)) sf_error("no gzbeg");
+	/* x-begining index of receivers, starting from 0 */
+	if (!sf_histint(shots,"jsx",&jsx)) sf_error("no jsx");
+	/* source x-axis  jump interval  */
+	if (!sf_histint(shots,"jsz",&jsz)) sf_error("no jsz");
+	/* source z-axis jump interval  */
+	if (!sf_histint(shots,"jgx",&jgx)) sf_error("no jgx");
+	/* receiver x-axis jump interval  */
+	if (!sf_histint(shots,"jgz",&jgz)) sf_error("no jgz");
+	/* receiver z-axis jump interval  */
+	if (!sf_histint(shots,"csdgather",&csd)) sf_error("csdgather or not required");
+	/* default, common shot-gather; if n, record at every point*/
+
+	sf_putint(imglsm,"n1",nz);
+	sf_putint(imglsm,"n2",nx);
+	sf_putint(imglsm,"n3",1);
+	sf_putfloat(imglsm,"d1",dz);
+	sf_putfloat(imglsm,"d2",dx);
+	sf_putfloat(imglsm,"o1",o1);
+	sf_putfloat(imglsm,"o2",o2);
+	sf_putstring(imglsm,"label1","Depth");
+	sf_putstring(imglsm,"label2","Distance");
+
+	sf_putint(imgrtm,"n1",nz);
+	sf_putint(imgrtm,"n2",nx);
+	sf_putint(imgrtm,"n3",1);
+	sf_putfloat(imgrtm,"d1",dz);
+	sf_putfloat(imgrtm,"d2",dx);
+	sf_putfloat(imgrtm,"o1",o1);
+	sf_putfloat(imgrtm,"o2",o2);
+	sf_putstring(imgrtm,"label1","Depth");
+	sf_putstring(imgrtm,"label2","Distance");
+
+	/* In rtm, vv is the velocity model [modl], which is input parameter; 
+	   mod is the imglsme/reflectivity [imglsm]; dat is seismogram [data]! */
+	v0=sf_floatalloc2(nz,nx);
+	mod=sf_floatalloc(nz*nx);
+	dat=sf_floatalloc(nt*ng*ns);
+
+	/* initialize velocity, model and data */
+	sf_floatread(v0[0], nz*nx, velo);
+	memset(mod, 0, nz*nx*sizeof(float));
+	sf_floatread(dat, nt*ng*ns, shots);
+	prtm2d_init(verb, csd, fromBoundary, dz, dx, dt, amp, fm, nz, nx, nb, nt, ns, ng, 
+				sxbeg, szbeg, jsx, jsz, gxbeg, gzbeg, jgx, jgz, v0, mod, dat);
+
+	// run adjoint test first.
+	sf_warning("adjoint test \n");
+	if (testadj){
+		prtm2d_adjtest();
+		sf_warning("exiting after testadj\n");
+		mod=NULL;
+		sf_floatwrite(mod,nz*nx,imgrtm);
+		sf_floatwrite(mod,nz*nx,imglsm);
+		prtm2d_close();
+		free(*v0); free(v0);
+		free(mod);
+		free(dat); 	  
+		exit (0);
+	}
+	
+	sf_warning("start migration\n");
+	/* original RTM is simply applying adjoint of prtm2d_lop once!*/
+	prtm2d_lop(true, false, nz*nx, nt*ng*ns, mod, dat); 
+	sf_floatwrite(mod, nz*nx, imgrtm);/* output RTM image */
+	sf_warning("migration ends");
+
+	if (niter>0){
+		memset(mod, 0, nz*nx*sizeof(float));
+
+		sf_warning("inside LS loop niter= %d\n",niter);
+		/* least squares migration */
+		sf_solver(prtm2d_lop, sf_cgstep, nz*nx, nt*ng*ns, mod, dat, niter, "verb", verb, "end");
+		sf_floatwrite(mod, nz*nx, imglsm);  /* output inverted image */
+		sf_cgstep_close();
+	}
+
 	prtm2d_close();
 	free(*v0); free(v0);
 	free(mod);
-	free(dat); 	  
-	exit (0);
-    }
-	
-    sf_warning("start migration\n");
-    /* original RTM is simply applying adjoint of prtm2d_lop once!*/
-    prtm2d_lop(true, false, nz*nx, nt*ng*ns, mod, dat); 
-    sf_floatwrite(mod, nz*nx, imgrtm);/* output RTM image */
-    sf_warning("migration ends");
-
-    if (niter>0){
-	memset(mod, 0, nz*nx*sizeof(float));
-
-	sf_warning("inside LS loop niter= %d\n",niter);
-	/* least squares migration */
-	sf_solver(prtm2d_lop, sf_cgstep, nz*nx, nt*ng*ns, mod, dat, niter, "verb", verb, "end");
-	sf_floatwrite(mod, nz*nx, imglsm);  /* output inverted image */
-	sf_cgstep_close();
-    }
-
-    prtm2d_close();
-    free(*v0); free(v0);
-    free(mod);
-    free(dat); 
+	free(dat); 
 
-    exit(0);
+	exit(0);
 }
 
diff --git a/user/pyang/SConstruct b/user/pyang/SConstruct
index 45262a8578..301ad67880 100644
--- a/user/pyang/SConstruct
+++ b/user/pyang/SConstruct
@@ -6,7 +6,7 @@ import bldutil
 ######################################################################
 # 1. C main programs
 progs = '''
-cohn checkptdemo fwi2d fbrec2d istseislet lsrtm2d  
+cohn checkptdemo fwi2d fbrec2d istseislet lsrtm2d lsprtm2d 
 mythresh mshots mcaseislet modeling2d mysnr
 pocsseislet rtm2d rtmadcig rtmodcig rtmva2d
 Testfd2d Testfd3d Testeb Testelastic2d Testaniso Testspml
diff --git a/user/pyang/prtm2d.c b/user/pyang/prtm2d.c
index 262adeb404..062ad5a830 100644
--- a/user/pyang/prtm2d.c
+++ b/user/pyang/prtm2d.c
@@ -17,115 +17,156 @@
   You should have received a copy of the GNU General Public License
   along with this program; if not, write to the Free Software
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+
+  Comments: 
+  Operator modified to pass the adjoint. Added adjoint tests as well. 
+  Daniel Trad, Uinversity of Calgary, 2017
 */
 #include <rsf.h>
+#include <time.h>
+#include <sys/time.h>
 
 #ifdef _OPENMP
 #include <omp.h>
 #endif
 
 #include "prtm2d.h"
-
+static float ***sp0array;
+static bool fromBoundary;
 static bool csdgather, verb;
 static int nzpad, nxpad, nb, nz, nx, nt, ns, ng, sxbeg, szbeg, jsx, jsz, gxbeg, gzbeg, jgx, jgz, distx, distz;
 static int *sxz, *gxz;
 static float c0, c11, c21, c12, c22;
 static float *wlt, *bndr,*rwbndr, *mod, *dat;
 static float **sp0, **sp1, **gp0, **gp1, **vv, **ptr=NULL;
+int getTime(struct timeval t1, struct timeval  t2){
+  // return time in milliseconds;
+  return ((t2.tv_sec - t1.tv_sec)* 1000 + (t2.tv_usec - t1.tv_usec)/1000);
+}
+float compareWavefields(int it, float **u){
+  ///*< compare current wavefield with true wavefield saved in sp0array >*/
 
+  float sum =0;
+  for (int ix=nb;ix<nxpad-nb;ix++){
+    for (int iz=nb;iz<nzpad-nb;iz++){
+      if (gp1[ix][iz]) sum += fabs((u[ix][iz]-sp0array[it][ix][iz]));
+    }
+  }
+  return sum;
+}
+void rw_snapshot(float** p, int it, bool read){
+  // read/write snapshot completely 
+  // if read=true read, else write
+  
+  if (!read){
+    for (int ix=0;ix< nxpad;ix++){
+      for (int iz=0;iz< nzpad;iz++){
+	sp0array[it][ix][iz]=p[ix][iz];
+      }
+    }
+  }
+  else{
+    for (int ix=0;ix< nxpad;ix++){
+      for (int iz=0;iz< nzpad;iz++){
+	p[ix][iz]=sp0array[it][ix][iz];
+      }
+    }
+  }
+
+}
 
 void boundary_rw(float **p, float *spo, bool read)
 /* read/write using effective boundary saving strategy: 
    if read=true, read the boundary out; else save/write the boundary*/
 {
-    int ix,iz;
+  int ix,iz;
 
-    if (read){
+  if (read){
 #ifdef _OPENMP
 #pragma omp parallel for			\
-    private(ix,iz)				\
-    shared(p,spo,nx,nz,nb)  
+  private(ix,iz)				\
+  shared(p,spo,nx,nz,nb)  
 #endif	
-	for(ix=0; ix<nx; ix++)
-	    for(iz=0; iz<2; iz++)
-	    {
-		p[ix+nb][iz-2+nb]=spo[iz+4*ix];
-		p[ix+nb][iz+nz+nb]=spo[iz+2+4*ix];
-	    }
+    for(ix=0; ix<nx; ix++)
+      for(iz=0; iz<2; iz++)
+	{
+	  p[ix+nb][iz+nb]=spo[iz+4*ix];
+	  p[ix+nb][iz-2+nz+nb]=spo[iz+2+4*ix];
+	}
 #ifdef _OPENMP
 #pragma omp parallel for			\
-    private(ix,iz)				\
-    shared(p,spo,nx,nz,nb)  
+  private(ix,iz)				\
+  shared(p,spo,nx,nz,nb)  
 #endif	
-	for(iz=0; iz<nz; iz++)
-	    for(ix=0; ix<2; ix++)
-	    {
-		p[ix-2+nb][iz+nb]=spo[4*nx+iz+nz*ix];
-		p[ix+nx+nb][iz+nb]=spo[4*nx+iz+nz*(ix+2)];
-	    }
-    }else{
+    for(iz=0; iz<nz; iz++)
+      for(ix=0; ix<2; ix++)
+	{
+	  p[ix+nb][iz+nb]=spo[4*nx+iz+nz*ix];
+	  p[ix-2+nx+nb][iz+nb]=spo[4*nx+iz+nz*(ix+2)];
+	}
+  }else{
 #ifdef _OPENMP
 #pragma omp parallel for			\
-    private(ix,iz)				\
-    shared(p,spo,nx,nz,nb)  
+  private(ix,iz)				\
+  shared(p,spo,nx,nz,nb)  
 #endif	
-	for(ix=0; ix<nx; ix++)
-	    for(iz=0; iz<2; iz++)
-	    {
-		spo[iz+4*ix]=p[ix+nb][iz-2+nb];
-		spo[iz+2+4*ix]=p[ix+nb][iz+nz+nb];
-	    }
+    for(ix=0; ix<nx; ix++)
+      for(iz=0; iz<2; iz++)
+	{
+	  spo[iz+4*ix]=p[ix+nb][iz+nb];
+	  spo[iz+2+4*ix]=p[ix+nb][iz-2+nz+nb];
+	}
 #ifdef _OPENMP
 #pragma omp parallel for			\
-    private(ix,iz)				\
-    shared(p,spo,nx,nz,nb)  
+  private(ix,iz)				\
+  shared(p,spo,nx,nz,nb)  
 #endif	
-	for(iz=0; iz<nz; iz++)
-	    for(ix=0; ix<2; ix++)
-	    {
-		spo[4*nx+iz+nz*ix]=p[ix-2+nb][iz+nb];
-		spo[4*nx+iz+nz*(ix+2)]=p[ix+nx+nb][iz+nb];
-	    }
-    }
+    for(iz=0; iz<nz; iz++)
+      for(ix=0; ix<2; ix++)
+	{
+	  spo[4*nx+iz+nz*ix]=p[ix+nb][iz+nb];
+	  spo[4*nx+iz+nz*(ix+2)]=p[ix-2+nx+nb][iz+nb];
+	}
+  }
 }
 
 void step_forward(float **u0, float **u1, float **vv, bool adj)
 /*< forward step for wave propagation >*/
 {
-    int i1, i2;
+  int i1, i2;
 
-    if(adj){
+  if(adj){
 #ifdef _OPENMP
 #pragma omp parallel for default(none)			\
-    private(i2,i1)					\
-    shared(nzpad,nxpad,u1,vv,u0,c0,c11,c12,c21,c22)
+  private(i2,i1)					\
+  shared(nzpad,nxpad,u1,vv,u0,c0,c11,c12,c21,c22)
 #endif
-	for (i2=2; i2<nxpad-2; i2++) 
-	    for (i1=2; i1<nzpad-2; i1++) 
-	    {
-		u0[i2][i1]=2.*u1[i2][i1]-u0[i2][i1]+c0*vv[i2][i1]*u1[i2][i1]+
-		    c11*(vv[i2][i1-1]*u1[i2][i1-1]+vv[i2][i1+1]*u1[i2][i1+1])+
-		    c12*(vv[i2][i1-2]*u1[i2][i1-2]+vv[i2][i1+2]*u1[i2][i1+2])+
-		    c21*(vv[i2-1][i1]*u1[i2-1][i1]+vv[i2+1][i1]*u1[i2+1][i1])+
-		    c22*(vv[i2-2][i1]*u1[i2-2][i1]+vv[i2+2][i1]*u1[i2+2][i1]);
-	    }
-    }else{
+    for (i2=2; i2<nxpad-2; i2++) 
+      for (i1=2; i1<nzpad-2; i1++) 
+	{
+	  u0[i2][i1]=2.*u1[i2][i1]-u0[i2][i1]+c0*vv[i2][i1]*u1[i2][i1]+
+	    c11*(vv[i2][i1-1]*u1[i2][i1-1]+vv[i2][i1+1]*u1[i2][i1+1])+
+	    c12*(vv[i2][i1-2]*u1[i2][i1-2]+vv[i2][i1+2]*u1[i2][i1+2])+
+	    c21*(vv[i2-1][i1]*u1[i2-1][i1]+vv[i2+1][i1]*u1[i2+1][i1])+
+	    c22*(vv[i2-2][i1]*u1[i2-2][i1]+vv[i2+2][i1]*u1[i2+2][i1]);
+	}
+  }else{
 #ifdef _OPENMP
 #pragma omp parallel for default(none)			\
-    private(i2,i1)					\
-    shared(nzpad,nxpad,u1,vv,u0,c0,c11,c12,c21,c22)
+  private(i2,i1)					\
+  shared(nzpad,nxpad,u1,vv,u0,c0,c11,c12,c21,c22)
 #endif
-	for (i2=2; i2<nxpad-2; i2++) 
-	    for (i1=2; i1<nzpad-2; i1++) 
-	    {
-		u0[i2][i1]=2.*u1[i2][i1]-u0[i2][i1]+ 
-		    vv[i2][i1]*(c0*u1[i2][i1]+
-				c11*(u1[i2][i1-1]+u1[i2][i1+1])+
-				c12*(u1[i2][i1-2]+u1[i2][i1+2])+
-				c21*(u1[i2-1][i1]+u1[i2+1][i1])+
-				c22*(u1[i2-2][i1]+u1[i2+2][i1]));
-	    }
-    }
+    for (i2=2; i2<nxpad-2; i2++) 
+      for (i1=2; i1<nzpad-2; i1++) 
+	{
+	  u0[i2][i1]=2.*u1[i2][i1]-u0[i2][i1]+ 
+	    vv[i2][i1]*(c0*u1[i2][i1]+
+			c11*(u1[i2][i1-1]+u1[i2][i1+1])+
+			c12*(u1[i2][i1-2]+u1[i2][i1+2])+
+			c21*(u1[i2-1][i1]+u1[i2+1][i1])+
+			c22*(u1[i2-2][i1]+u1[i2+2][i1]));
+	}
+  }
 }
 
 
@@ -133,121 +174,121 @@ void apply_sponge(float **p0)
 /*< apply sponge (Gaussian taper) absorbing boundary condition
   L=Gaussian taper ABC; L=L*, L is self-adjoint operator. >*/
 {
-    int ix,iz,ib,ibx,ibz;
-    float w;
+  int ix,iz,ib,ibx,ibz;
+  float w;
 
-    for(ib=0; ib<nb; ib++) {
-	w = bndr[ib];
+  for(ib=0; ib<nb; ib++) {
+    w = bndr[ib];
 
-	ibz = nzpad-ib-1;
-	for(ix=0; ix<nxpad; ix++) {
-	    p0[ix][ib ] *= w; /*    top sponge */
-	    p0[ix][ibz] *= w; /* bottom sponge */
-	}
+    ibz = nzpad-ib-1;
+    for(ix=0; ix<nxpad; ix++) {
+      p0[ix][ib ] *= w; /*    top sponge */
+      p0[ix][ibz] *= w; /* bottom sponge */
+    }
 
-	ibx = nxpad-ib-1;
-	for(iz=0; iz<nzpad; iz++) {
-	    p0[ib ][iz] *= w; /*   left sponge */
-	    p0[ibx][iz] *= w; /*  right sponge */
-	}
+    ibx = nxpad-ib-1;
+    for(iz=0; iz<nzpad; iz++) {
+      p0[ib ][iz] *= w; /*   left sponge */
+      p0[ibx][iz] *= w; /*  right sponge */
     }
+  }
 }
 
 void sg_init(int *sxz, int szbeg, int sxbeg, int jsz, int jsx, int ns)
 /*< shot/geophone position initialize
   sxz/gxz; szbeg/gzbeg; sxbeg/gxbeg; jsz/jgz; jsx/jgx; ns/ng; >*/
 {
-    int is, sz, sx;
+  int is, sz, sx;
 
-    for(is=0; is<ns; is++)
+  for(is=0; is<ns; is++)
     {
-	sz=szbeg+is*jsz;
-	sx=sxbeg+is*jsx;
-	sxz[is]=sz+nz*sx;
+      sz=szbeg+is*jsz;
+      sx=sxbeg+is*jsx;
+      sxz[is]=sz+nz*sx;
     }
 }
 
 void add_source(int *sxz, float **p, int ns, float *source, bool add)
 /*< add seismic sources in grid >*/
 {
-    int is, sx, sz;
+  int is, sx, sz;
 
-    if(add){/* add sources*/
+  if(add){/* add sources*/
 #ifdef _OPENMP
 #pragma omp parallel for default(none)		\
-    private(is,sx,sz)				\
-    shared(p,source,sxz,nb,ns,nz)
+  private(is,sx,sz)				\
+  shared(p,source,sxz,nb,ns,nz)
 #endif
-	for(is=0;is<ns; is++){
-	    sx=sxz[is]/nz;
-	    sz=sxz[is]%nz;
-	    p[sx+nb][sz+nb]+=source[is];
-	}
-    }else{ /* subtract sources */
+    for(is=0;is<ns; is++){
+      sx=sxz[is]/nz;
+      sz=sxz[is]%nz;
+      p[sx+nb][sz+nb]+=source[is];
+    }
+  }else{ /* subtract sources */
 #ifdef _OPENMP
 #pragma omp parallel for default(none)		\
-    private(is,sx,sz)				\
-    shared(p,source,sxz,nb,ns,nz)
+  private(is,sx,sz)				\
+  shared(p,source,sxz,nb,ns,nz)
 #endif
-	for(is=0;is<ns; is++){
-	    sx=sxz[is]/nz;
-	    sz=sxz[is]%nz;
-	    p[sx+nb][sz+nb]-=source[is];
-	}
+    for(is=0;is<ns; is++){
+      sx=sxz[is]/nz;
+      sz=sxz[is]%nz;
+      p[sx+nb][sz+nb]-=source[is];
     }
+  }
 }
 
 
 void expand2d(float** b, float** a)
 /*< expand domain of 'a' to 'b': source(a)-->destination(b) >*/
 {
-    int iz,ix;
+  int iz,ix;
 
 #ifdef _OPENMP
 #pragma omp parallel for default(none)		\
-    private(ix,iz)				\
-    shared(b,a,nb,nz,nx)
+  private(ix,iz)				\
+  shared(b,a,nb,nz,nx)
 #endif
-    for     (ix=0;ix<nx;ix++) {
-	for (iz=0;iz<nz;iz++) {
-	    b[nb+ix][nb+iz] = a[ix][iz];
-	}
+  for     (ix=0;ix<nx;ix++) {
+    for (iz=0;iz<nz;iz++) {
+      b[nb+ix][nb+iz] = a[ix][iz];
     }
+  }
 
-    for     (ix=0; ix<nxpad; ix++) {
-	for (iz=0; iz<nb;    iz++) {
-	    b[ix][      iz  ] = b[ix][nb  ];
-	    b[ix][nzpad-iz-1] = b[ix][nzpad-nb-1];
-	}
+  for     (ix=0; ix<nxpad; ix++) {
+    for (iz=0; iz<nb;    iz++) {
+      b[ix][      iz  ] = b[ix][nb  ];
+      b[ix][nzpad-iz-1] = b[ix][nzpad-nb-1];
     }
+  }
 
-    for     (ix=0; ix<nb;    ix++) {
-	for (iz=0; iz<nzpad; iz++) {
-	    b[ix 	 ][iz] = b[nb  		][iz];
-	    b[nxpad-ix-1 ][iz] = b[nxpad-nb-1	][iz];
-	}
+  for     (ix=0; ix<nb;    ix++) {
+    for (iz=0; iz<nzpad; iz++) {
+      b[ix 	 ][iz] = b[nb  		][iz];
+      b[nxpad-ix-1 ][iz] = b[nxpad-nb-1	][iz];
     }
+  }
 }
 
 
 void window2d(float **a, float **b)
 /*< window 'b' to 'a': source(b)-->destination(a) >*/
 {
-    int iz,ix;
+  int iz,ix;
 
 #ifdef _OPENMP
 #pragma omp parallel for default(none)		\
-    private(ix,iz)				\
-    shared(b,a,nb,nz,nx)
+  private(ix,iz)				\
+  shared(b,a,nb,nz,nx)
 #endif
-    for     (ix=0;ix<nx;ix++) {
-	for (iz=0;iz<nz;iz++) {
-	    a[ix][iz]=b[nb+ix][nb+iz] ;
-	}
+  for     (ix=0;ix<nx;ix++) {
+    for (iz=0;iz<nz;iz++) {
+      a[ix][iz]=b[nb+ix][nb+iz] ;
     }
+  }
 }
 
-void prtm2d_init(bool verb_, bool csdgather_, float dz_, float dx_, float dt_, 
+void prtm2d_init(bool verb_, bool csdgather_, bool fromBoundary_, float dz_, float dx_, float dt_, 
 		 float amp, float fm, 
 		 int nz_, int nx_, int nb_, int nt_, int ns_, int ng_, 
 		 int sxbeg_, int szbeg_, int jsx_, int jsz_, 
@@ -256,192 +297,258 @@ void prtm2d_init(bool verb_, bool csdgather_, float dz_, float dx_, float dt_,
 /*< allocate variables and initialize parameters >*/
 {  
 #ifdef _OPENMP
-    omp_init();  /* initialize OpenMP support */ 
+  omp_init();  /* initialize OpenMP support */ 
 #endif
-    float t;
-    int i1, i2, it,ib;
-    t = 1.0/(dz_*dz_);
-    c11 = 4.0*t/3.0;
-    c12= -t/12.0;
-
-    t = 1.0/(dx_*dx_);
-    c21 = 4.0*t/3.0;
-    c22= -t/12.0;
-    c0=-2.0*(c11+c12+c21+c22);
-
-    verb=verb_;
-    csdgather=csdgather_;
-    ns=ns_;
-    ng=ng_;
-    nb=nb_;
-    nz=nz_;
-    nx=nx_;
-    nt=nt_;
-    sxbeg=sxbeg_;
-    szbeg=szbeg_;
-    jsx=jsx_;
-    jsz=jsz_;
-    gxbeg=gxbeg_;
-    gzbeg=gzbeg_;
-    jgx=jgx_;
-    jgz=jgz_;
-
-    nzpad=nz+2*nb;
-    nxpad=nx+2*nb;
-
-    /* allocate temporary arrays */
-    bndr=sf_floatalloc(nb);
-    sp0=sf_floatalloc2(nzpad,nxpad);
-    sp1=sf_floatalloc2(nzpad,nxpad);
-    gp0=sf_floatalloc2(nzpad,nxpad);
-    gp1=sf_floatalloc2(nzpad,nxpad);
-    vv=sf_floatalloc2(nzpad,nxpad);
-    wlt=sf_floatalloc(nt);
-    sxz=sf_intalloc(ns);
-    gxz=sf_intalloc(ng);
-    rwbndr=sf_floatalloc(nt*4*(nx+nz));
-
-    /* initialized sponge ABC coefficients */
-    for(ib=0;ib<nb;ib++){
-	t=0.015*(nb-1-ib);
-	bndr[ib]=expf(-t*t);
-    }
-    mod=mod_;
-    dat=dat_;
-    for (i2=0; i2<nx; i2++) 
-	for (i1=0; i1<nz; i1++) 
-	{
-	    t=v0[i2][i1]*dt_;
-	    vv[i2+nb][i1+nb] = t*t;
-	}	
-    for (i2=0; i2<nxpad; i2++)
-	for (i1=0; i1<nb; i1++) 
-	{
-	    vv[i2][   i1  ] =vv[i2][   nb  ];
-	    vv[i2][nzpad-i1-1] =vv[i2][nzpad-nb-1];
-	}
-    for (i2=0; i2<nb; i2++)
-	for (i1=0; i1<nzpad; i1++) 
-	{
-	    vv[   i2  ][i1] =vv[   nb  ][i1];
-	    vv[nxpad-i2-1][i1] =vv[nxpad-nb-1][i1];
-	}
-    for(it=0; it<nt; it++){
-	t=SF_PI*fm*(it*dt_-1.0/fm);t=t*t;
-	wlt[it]=amp*(1.0-2.0*t)*expf(-t);
-    }
-
-    /* configuration of sources and geophones */
-    if (!(sxbeg>=0 && szbeg>=0 && sxbeg+(ns-1)*jsx<nx && szbeg+(ns-1)*jsz<nz))	
+  float t;
+  int i1, i2, it,ib;
+  t = 1.0/(dz_*dz_);
+  c11 = 4.0*t/3.0;
+  c12= -t/12.0;
+
+  t = 1.0/(dx_*dx_);
+  c21 = 4.0*t/3.0;
+  c22= -t/12.0;
+  c0=-2.0*(c11+c12+c21+c22);
+
+  fromBoundary=fromBoundary_; 
+  verb=verb_;
+  csdgather=csdgather_;
+  ns=ns_;
+  ng=ng_;
+  nb=nb_;
+  nz=nz_;
+  nx=nx_;
+  nt=nt_;
+  sxbeg=sxbeg_;
+  szbeg=szbeg_;
+  jsx=jsx_;
+  jsz=jsz_;
+  gxbeg=gxbeg_;
+  gzbeg=gzbeg_;
+  jgx=jgx_;
+  jgz=jgz_;
+
+  nzpad=nz+2*nb;
+  nxpad=nx+2*nb;
+
+  /* allocate temporary arrays */
+  bndr=sf_floatalloc(nb);
+  sp0=sf_floatalloc2(nzpad,nxpad);
+  sp1=sf_floatalloc2(nzpad,nxpad);
+  gp0=sf_floatalloc2(nzpad,nxpad);
+  gp1=sf_floatalloc2(nzpad,nxpad);
+  vv=sf_floatalloc2(nzpad,nxpad);
+  wlt=sf_floatalloc(nt);
+  sxz=sf_intalloc(ns);
+  gxz=sf_intalloc(ng);
+  rwbndr=sf_floatalloc(nt*4*(nx+nz));
+  if (!fromBoundary) sp0array=sf_floatalloc3(nzpad,nxpad,nt);
+
+  /* initialized sponge ABC coefficients */
+  for(ib=0;ib<nb;ib++){
+    t=0.015*(nb-1-ib);
+    bndr[ib]=expf(-t*t);
+  }
+  mod=mod_;
+  dat=dat_;
+  for (i2=0; i2<nx; i2++) 
+    for (i1=0; i1<nz; i1++) 
+      {
+	t=v0[i2][i1]*dt_;
+	vv[i2+nb][i1+nb] = t*t;
+      }	
+  for (i2=0; i2<nxpad; i2++)
+    for (i1=0; i1<nb; i1++) 
+      {
+	vv[i2][   i1  ] =vv[i2][   nb  ];
+	vv[i2][nzpad-i1-1] =vv[i2][nzpad-nb-1];
+      }
+  for (i2=0; i2<nb; i2++)
+    for (i1=0; i1<nzpad; i1++) 
+      {
+	vv[   i2  ][i1] =vv[   nb  ][i1];
+	vv[nxpad-i2-1][i1] =vv[nxpad-nb-1][i1];
+      }
+  for(it=0; it<nt; it++){
+    t=SF_PI*fm*(it*dt_-1.0/fm);t=t*t;
+    wlt[it]=amp*(1.0-2.0*t)*expf(-t);
+  }
+
+  /* configuration of sources and geophones */
+  if (!(sxbeg>=0 && szbeg>=0 && sxbeg+(ns-1)*jsx<nx && szbeg+(ns-1)*jsz<nz))	
     { sf_warning("sources exceeds the computing zone!"); exit(1);}
-    sg_init(sxz, szbeg, sxbeg, jsz, jsx, ns);
-    distx=sxbeg-gxbeg;
-    distz=szbeg-gzbeg;
-    if (!(gxbeg>=0 && gzbeg>=0 && gxbeg+(ng-1)*jgx<nx && gzbeg+(ng-1)*jgz<nz))	
+  sg_init(sxz, szbeg, sxbeg, jsz, jsx, ns);
+  distx=sxbeg-gxbeg;
+  distz=szbeg-gzbeg;
+  if (!(gxbeg>=0 && gzbeg>=0 && gxbeg+(ng-1)*jgx<nx && gzbeg+(ng-1)*jgz<nz))	
     { sf_warning("geophones exceeds the computing zone!"); exit(1);}
-    if (csdgather && !( (sxbeg+(ns-1)*jsx)+(ng-1)*jgx-distx <nx  
-			&& (szbeg+(ns-1)*jsz)+(ng-1)*jgz-distz <nz))	{
-	sf_warning("geophones exceeds the computing zone!"); exit(1);
-    }
-    sg_init(gxz, gzbeg, gxbeg, jgz, jgx, ng);
+  if (csdgather && !( (sxbeg+(ns-1)*jsx)+(ng-1)*jgx-distx <nx  
+		      && (szbeg+(ns-1)*jsz)+(ng-1)*jgz-distz <nz))	{
+    sf_warning("geophones exceeds the computing zone!"); exit(1);
+  }
+  sg_init(gxz, gzbeg, gxbeg, jgz, jgx, ng);
 }
 
 void prtm2d_close()
 /*< free allocated variables >*/
 {
-    free(bndr);
-    free(*sp0); free(sp0);
-    free(*sp1); free(sp1);
-    free(*gp0); free(gp0);
-    free(*gp1); free(gp1);
-    free(*vv); free(vv);
-    free(wlt);
-    free(sxz);
-    free(gxz);
+  free(bndr);
+  if (!fromBoundary){ free(**sp0array);free(*sp0array);free(sp0array);}
+  free(*sp0); free(sp0);
+  free(*sp1); free(sp1);
+  free(*gp0); free(gp0);
+  free(*gp1); free(gp1);
+  free(*vv); free(vv);
+  free(wlt);
+  free(sxz);
+  free(gxz);
+}
+
+void prtm2d_shotwav(int is)
+/*< prtm2d shot wavefield generated at front >*/
+{
+  int it;
+
+  /* initialize is-th source wavefield Ps[] */
+  memset(sp0[0], 0, nzpad*nxpad*sizeof(float));
+  memset(sp1[0], 0, nzpad*nxpad*sizeof(float));
+  memset(gp0[0], 0, nzpad*nxpad*sizeof(float));
+  memset(gp1[0], 0, nzpad*nxpad*sizeof(float));
+
+  for(it=0; it<nt; it++){			
+    add_source(&sxz[is], sp1, 1, &wlt[it], true);
+    step_forward(sp0, sp1, vv, false);
+    ptr=sp0; sp0=sp1; sp1=ptr;
+    apply_sponge(sp0);
+    apply_sponge(sp1);
+    rw_snapshot(sp0,it,false);
+  }
 }
 
+
 void prtm2d_lop(bool adj, bool add, int nm, int nd, float *mod, float *dat)
 /*< prtm2d linear operator >*/
 {
-    int i1,i2,it,is,ig, gx, gz;
-    if(nm!=nx*nz) sf_error("model size mismatch: %d!=%d",nm, nx*nz);
-    if(nd!=nt*ng*ns) sf_error("data size mismatch: %d!=%d",nd,nt*ng*ns);
-    sf_adjnull(adj, add, nm, nd, mod, dat); 
-  
-    for(is=0; is<ns; is++) {/* it may be parallized using MPI */
-	/* initialize is-th source wavefield Ps[] */
-	memset(sp0[0], 0, nzpad*nxpad*sizeof(float));
-	memset(sp1[0], 0, nzpad*nxpad*sizeof(float));
-	memset(gp0[0], 0, nzpad*nxpad*sizeof(float));
-	memset(gp1[0], 0, nzpad*nxpad*sizeof(float));
-	if (csdgather){
-	    gxbeg=sxbeg+is*jsx-distx;
-	    sg_init(gxz, gzbeg, gxbeg, jgz, jgx, ng);
+  int i1,i2,it,is,ig, gx, gz;
+
+  if(nm!=nx*nz) sf_error("model size mismatch: %d!=%d",nm, nx*nz);
+  if(nd!=nt*ng*ns) sf_error("data size mismatch: %d!=%d",nd,nt*ng*ns);
+  sf_adjnull(adj, add, nm, nd, mod, dat); 
+
+  for(is=0; is<ns; is++) {/* it may be parallized using MPI */
+    /* initialize is-th source wavefield Ps[] */
+    memset(sp0[0], 0, nzpad*nxpad*sizeof(float));
+    memset(sp1[0], 0, nzpad*nxpad*sizeof(float));
+    memset(gp0[0], 0, nzpad*nxpad*sizeof(float));
+    memset(gp1[0], 0, nzpad*nxpad*sizeof(float));
+    
+    if(adj){/* migration: mm=Lt dd */
+      //==========================================================
+      for(it=0; it<nt; it++){			
+	add_source(&sxz[is], sp1, 1, &wlt[it], true);
+	step_forward(sp0, sp1, vv, false);
+	ptr=sp0; sp0=sp1; sp1=ptr;
+	apply_sponge(sp0);
+	apply_sponge(sp1);
+	if (fromBoundary){
+	  boundary_rw(sp0, &rwbndr[it*4*(nx+nz)], false);
+	  //rw_snapshot(sp0,it,false); // save for tests to compare
+	}else rw_snapshot(sp0,it,false);
+      }
+
+      for (it=nt-1; it >-1; it--) {
+	/* reverse time order, Img[]+=Ps[]* Pg[]; */
+
+	/* backpropagate receiver wavefield */
+	for(ig=0;ig<ng; ig++){
+	  gx=gxz[ig]/nz;
+	  gz=gxz[ig]%nz;
+	  gp1[gx+nb][gz+nb]+=dat[it+ig*nt+is*nt*ng];
+	}
+	if (fromBoundary){ 
+	  boundary_rw(sp0, &rwbndr[(it)*4*(nx+nz)], true);
+	  //fprintf(stderr,"it=%d, error=%f \n",it,compareWavefields(it,sp0));
+	  for(i2=0; i2<nx; i2++)
+	    for(i1=0; i1<nz; i1++)
+	      mod[i1+nz*i2]+=sp0[i2+nb][i1+nb]*gp1[i2+nb][i1+nb];
+
+	  ptr=sp0; sp0=sp1; sp1=ptr;
+	  step_forward(sp0, sp1, vv, false);
+	  add_source(&sxz[is], sp1, 1, &wlt[it], false);
+	}else{ 
+	  rw_snapshot(sp0,it,true); // read
+	  for(i2=0; i2<nx; i2++)
+	    for(i1=0; i1<nz; i1++)
+	      mod[i1+nz*i2]+=sp0[i2+nb][i1+nb]*gp1[i2+nb][i1+nb];
 	}
 
-	if(adj){/* migration: mm=Lt dd */
-	    for(it=0; it<nt; it++){			
-		add_source(&sxz[is], sp1, 1, &wlt[it], true);
-		step_forward(sp0, sp1, vv, false);
-		apply_sponge(sp0);
-		apply_sponge(sp1);
-		ptr=sp0; sp0=sp1; sp1=ptr;
-		boundary_rw(sp0, &rwbndr[it*4*(nx+nz)], false);
-	    }
-
-	    for (it=nt-1; it >-1; it--) {
-		/* reverse time order, Img[]+=Ps[]* Pg[]; */
-		if(verb) sf_warning("%d;",it);
-	
-		/* reconstruct source wavefield Ps[] */	
-		boundary_rw(sp0, &rwbndr[it*4*(nx+nz)], true);
-		ptr=sp0; sp0=sp1; sp1=ptr;
-		step_forward(sp0, sp1, vv, false);
-		add_source(&sxz[is], sp1, 1, &wlt[it], false);
-	
-		/* backpropagate receiver wavefield */
-		for(ig=0;ig<ng; ig++){
-		    gx=gxz[ig]/nz;
-		    gz=gxz[ig]%nz;
-		    gp1[gx+nb][gz+nb]+=dat[it+ig*nt+is*nt*ng];
-		}
-		step_forward(gp0, gp1, vv, false);
-		apply_sponge(gp0); 
-		apply_sponge(gp1); 
-		ptr=gp0; gp0=gp1; gp1=ptr;
-
-		/* rtm imaging condition */
-		for(i2=0; i2<nx; i2++)
-		    for(i1=0; i1<nz; i1++)
-			mod[i1+nz*i2]+=sp0[i2+nb][i1+nb]*gp1[i2+nb][i1+nb];
-	    }
-	}else{/* Born modeling/demigration: dd=L mm */	
-
-	    for(it=0; it<nt; it++){	
-		/* forward time order, Pg[]+=Ps[]* Img[]; */	
-		if(verb) sf_warning("%d;",it);	
-
-		for(i2=0; i2<nx; i2++)
-		    for(i1=0; i1<nz; i1++)
-			gp1[i2+nb][i1+nb]+=sp0[i2+nb][i1+nb]*mod[i1+nz*i2];
-	
-		ptr=gp0; gp0=gp1; gp1=ptr;
-		apply_sponge(gp0); 
-		apply_sponge(gp1); 
-		step_forward(gp0, gp1, vv, true);
-	
-		for(ig=0;ig<ng; ig++){
-		    gx=gxz[ig]/nz;
-		    gz=gxz[ig]%nz;
-		    dat[it+ig*nt+is*nt*ng]+=gp1[gx+nb][gz+nb];
-		}
-
-		add_source(&sxz[is], sp1, 1, &wlt[it], true);
-		step_forward(sp0, sp1, vv, false);
-		apply_sponge(sp0);
-		apply_sponge(sp1);
-		ptr=sp0; sp0=sp1; sp1=ptr;
-	    }	
+	step_forward(gp0, gp1, vv, false);
+	ptr=gp0; gp0=gp1; gp1=ptr;
+ 	apply_sponge(gp0); 
+	apply_sponge(gp1); 
+
+      }
+    }else{/* Born modeling/demigration: dd=L mm */	
+      //==========================================================
+      for(it=0; it<nt; it++){	
+	/* forward time order, Pg[]+=Ps[]* Img[]; */	
+	add_source(&sxz[is], sp1, 1, &wlt[it], true);
+	step_forward(sp0, sp1, vv, false);
+	ptr=sp0; sp0=sp1; sp1=ptr;
+	apply_sponge(sp0);
+	apply_sponge(sp1);
+	for(i2=0; i2<nx; i2++)
+	  for(i1=0; i1<nz; i1++)
+	    gp1[i2+nb][i1+nb]+=sp0[i2+nb][i1+nb]*mod[i1+nz*i2];
+
+	for(ig=0;ig<ng; ig++){
+	  gx=gxz[ig]/nz;
+	  gz=gxz[ig]%nz;
+	  dat[it+ig*nt+is*nt*ng]+=gp1[gx+nb][gz+nb];
 	}
-    }	 
+
+	step_forward(gp0, gp1, vv, true);	
+	ptr=gp0; gp0=gp1; gp1=ptr;
+	apply_sponge(gp0); 
+	apply_sponge(gp1); 
+	
+      }	
+    }
+
+  }	 
+}
+
+void prtm2d_adjtest()
+/*< prtm2d adjoint test >*/	  
+{
+  unsigned int i;
+  float dotdata,dotmodel;
+
+  unsigned int datasize =ng*nt*ns;
+  unsigned int modelsize=nx*nz;
+  float* m1=sf_floatalloc(modelsize);
+  float* m2=sf_floatalloc(modelsize);
+  float* d1=sf_floatalloc(datasize);
+  float* d2=sf_floatalloc(datasize);
+  
+  for (i=0;i<datasize;i++)  d1[i]=(drand48()-0.5);
+  for (i=0;i<modelsize;i++) m1[i]=(drand48()-0.5);
+
+  memset(m2,0,modelsize*sizeof(float));
+  memset(d2,0,datasize*sizeof(float));
+
+  prtm2d_lop(true,false,nx*nz,nt*ng*ns,m2,d1);
+  prtm2d_lop(false,false,nx*nz,nt*ng*ns,m1,d2);
+
+  dotdata=0;
+  for (i=0;i<datasize;i++)  dotdata+=(d1[i]*d2[i]);
+  dotmodel=0;
+  for (i=0;i<modelsize;i++) dotmodel+=(m1[i]*m2[i]);
+  
+  fprintf(stderr,"dot=%g, dotdata=%g, dotmodel=%g\n",dotdata/dotmodel,dotdata,dotmodel);
+
+  free(m1);
+  free(m2);
+  free(d1);
+  free(d2);
 }