How to deallocate the global memory allocated in the mex function if the program has to be terminated outside of the mex function.

1 次查看（过去 30 天）
Rylan
Rylan 2020-12-7
编辑： James Tursa 2020-12-8
Recently I'm confused by a question. I'm developing a numerical model based on matlab, but it runs a little slow. I try to convert part of the most time consuming part into the C version, and this time cosuming part is accelatared with OPENMP. This part is frequently called, and lots of memory has to be allocated and deallocated during each call. When the related calculation is not memory cosuming, this seems not to be the question, but when the calculation become memory consuming, the frequent memory allocation and deallocation is also time consuming. What attached in the end of this question is part of my code.
In the next phase, I want to reconfigure this part. I plan to define all the varables related in this function to be global variables, and their memory is allocated when this function is called for the first time, and is deallocated at the last call. But if I need to stop the program mannuly outside of this mex function during the computation, it seems that the memory allocated in this function can't be deallocated, and memory leak may affect the following computation if I restart the computation. So I wonder if there are any ways to deal with this.
Thanks in advance!
#include "..\..\..\..\..\NdgMath\NdgMath.h"
#include "..\..\..\..\..\NdgMath\NdgSWE.h"
void FetchBoundaryData(double *, double *, double *, double *, int);
void mexFunction(int nlhs, mxArray *plhs[], int nrhs, const mxArray *prhs[])
{
/*Properties contained in mesh2d*/
mxArray *Temprx2d = mxGetField(prhs[0], 0, "rx");
double *rx2d = mxGetPr(Temprx2d);
int Np2d = (int)mxGetM(Temprx2d);
int K2d = (int)mxGetN(Temprx2d);
mxArray *Tempsx2d = mxGetField(prhs[0], 0, "sx");
double *sx2d = mxGetPr(Tempsx2d);
mxArray *Tempry2d = mxGetField(prhs[0], 0, "ry");
double *ry2d = mxGetPr(Tempry2d);
mxArray *Tempsy2d = mxGetField(prhs[0], 0, "sy");
double *sy2d = mxGetPr(Tempsy2d);
mxArray *TempJ2d = mxGetField(prhs[0], 0, "J");
double *J2d = mxGetPr(TempJ2d);
/*Properties contained in mesh3d*/
mxArray *Temprx3d = mxGetField(prhs[1], 0, "rx");
double *rx3d = mxGetPr(Temprx3d);
int Np3d = (int)mxGetM(Temprx3d);
int K3d = (int)mxGetN(Temprx3d);
mxArray *Tempsx3d = mxGetField(prhs[1], 0, "sx");
double *sx3d = mxGetPr(Tempsx3d);
mxArray *Tempry3d = mxGetField(prhs[1], 0, "ry");
double *ry3d = mxGetPr(Tempry3d);
mxArray *Tempsy3d = mxGetField(prhs[1], 0, "sy");
double *sy3d = mxGetPr(Tempsy3d);
mxArray *TempJ3d = mxGetField(prhs[1], 0, "J");
double *J3d = mxGetPr(TempJ3d);
mxArray *TempNLayer = mxGetField(prhs[1], 0, "Nz");
int NLayer = (int)mxGetScalar(TempNLayer);
/*Properties contained in two dimensional inner edge*/
mxArray *TempIENe2d = mxGetField(prhs[2], 0, "Ne");
int IENe2d = (int)mxGetScalar(TempIENe2d);
mxArray *TempIENfp2d = mxGetField(prhs[2], 0, "Nfp");
int IENfp2d = (int)mxGetScalar(TempIENfp2d);
mxArray *TempIEFToE2d = mxGetField(prhs[2], 0, "FToE");
double *IEFToE2d = mxGetPr(TempIEFToE2d);
mxArray *TempIEFToF2d = mxGetField(prhs[2], 0, "FToF");
double *IEFToF2d = mxGetPr(TempIEFToF2d);
mxArray *TempIEFToN12d = mxGetField(prhs[2], 0, "FToN1");
double *IEFToN12d = mxGetPr(TempIEFToN12d);
mxArray *TempIEFToN22d = mxGetField(prhs[2], 0, "FToN2");
double *IEFToN22d = mxGetPr(TempIEFToN22d);
mxArray *TempIEnx2d = mxGetField(prhs[2], 0, "nx");
double *IEnx2d = mxGetPr(TempIEnx2d);
mxArray *TempIEny2d = mxGetField(prhs[2], 0, "ny");
double *IEny2d = mxGetPr(TempIEny2d);
mxArray *TempIEJs2d = mxGetField(prhs[2], 0, "Js");
double *IEJs2d = mxGetPr(TempIEJs2d);
mxArray *TempIEMb2d = mxGetField(prhs[2], 0, "M");
double *IEMb2d = mxGetPr(TempIEMb2d);
/*Properties contained in two dimensional boundary edge*/
mxArray *TempBENe2d = mxGetField(prhs[3], 0, "Ne");
int BENe2d = (int)mxGetScalar(TempBENe2d);
mxArray *TempBENfp2d = mxGetField(prhs[3], 0, "Nfp");
int BENfp2d = (int)mxGetScalar(TempBENfp2d);
mxArray *TempBEFToE2d = mxGetField(prhs[3], 0, "FToE");
double *BEFToE2d = mxGetPr(TempBEFToE2d);
mxArray *TempBEFToF2d = mxGetField(prhs[3], 0, "FToF");
double *BEFToF2d = mxGetPr(TempBEFToF2d);
mxArray *TempBEFToN12d = mxGetField(prhs[3], 0, "FToN1");
double *BEFToN12d = mxGetPr(TempBEFToN12d);
mxArray *TempBEnx2d = mxGetField(prhs[3], 0, "nx");
double *BEnx2d = mxGetPr(TempBEnx2d);
mxArray *TempBEny2d = mxGetField(prhs[3], 0, "ny");
double *BEny2d = mxGetPr(TempBEny2d);
mxArray *TempBEJs2d = mxGetField(prhs[3], 0, "Js");
double *BEJs2d = mxGetPr(TempBEJs2d);
mxArray *TempBEMb2d = mxGetField(prhs[3], 0, "M");
double *BEMb2d = mxGetPr(TempBEMb2d);
/*Properties contained in three dimensional inner edge*/
mxArray *TempIENe = mxGetField(prhs[4], 0, "Ne");
int IENe3d = (int)mxGetScalar(TempIENe);
mxArray *TempIENfp3d = mxGetField(prhs[4], 0, "Nfp");
int IENfp3d = (int)mxGetScalar(TempIENfp3d);
mxArray *TempIEFToE3d = mxGetField(prhs[4], 0, "FToE");
double *IEFToE3d = mxGetPr(TempIEFToE3d);
mxArray *TempIEFToF3d = mxGetField(prhs[4], 0, "FToF");
double *IEFToF3d = mxGetPr(TempIEFToF3d);
mxArray *TempIEFToN13d = mxGetField(prhs[4], 0, "FToN1");
double *IEFToN13d = mxGetPr(TempIEFToN13d);
mxArray *TempIEFToN23d = mxGetField(prhs[4], 0, "FToN2");
double *IEFToN23d = mxGetPr(TempIEFToN23d);
mxArray *TempIEnx3d = mxGetField(prhs[4], 0, "nx");
double *IEnx3d = mxGetPr(TempIEnx3d);
mxArray *TempIEny3d = mxGetField(prhs[4], 0, "ny");
double *IEny3d = mxGetPr(TempIEny3d);
mxArray *TempIEMb3d = mxGetField(prhs[4], 0, "M");
double *IEMb3d = mxGetPr(TempIEMb3d);
mxArray *TempIEJs3d = mxGetField(prhs[4], 0, "Js");
double *IEJs3d = mxGetPr(TempIEJs3d);
/*Properties contained in three dimensional boundary edge*/
mxArray *TempBENe3d = mxGetField(prhs[5], 0, "Ne");
int BENe3d = (int)mxGetScalar(TempBENe3d);
mxArray *TempBENfp3d = mxGetField(prhs[5], 0, "Nfp");
int BENfp3d = (int)mxGetScalar(TempBENfp3d);
mxArray *TempBEFToE3d = mxGetField(prhs[5], 0, "FToE");
double *BEFToE3d = mxGetPr(TempBEFToE3d);
mxArray *TempBEFToF3d = mxGetField(prhs[5], 0, "FToF");
double *BEFToF3d = mxGetPr(TempBEFToF3d);
mxArray *TempBEFToN13d = mxGetField(prhs[5], 0, "FToN1");
double *BEFToN13d = mxGetPr(TempBEFToN13d);
mxArray *TempBEnx3d = mxGetField(prhs[5], 0, "nx");
double *BEnx3d = mxGetPr(TempBEnx3d);
mxArray *TempBEny3d = mxGetField(prhs[5], 0, "ny");
double *BEny3d = mxGetPr(TempBEny3d);
mxArray *TempBEMb3d = mxGetField(prhs[5], 0, "M");
double *BEMb3d = mxGetPr(TempBEMb3d);
mxArray *TempBEJs3d = mxGetField(prhs[5], 0, "Js");
double *BEJs3d = mxGetPr(TempBEJs3d);
/*Data contained in two dimensional physical field and three dimensional physical field*/
double *fphys2d = mxGetPr(prhs[6]);
double *h2d = fphys2d;
double *hu2d = fphys2d + Np2d*K2d;
double *hv2d = fphys2d + 2 * Np2d*K2d;
double *z2d = fphys2d + 3 * Np2d*K2d;
double *fphys3d = mxGetPr(prhs[7]);
double *hu3d = fphys3d;
double *hv3d = fphys3d + Np3d * K3d;
double *h3d = fphys3d + 3 * Np3d*K3d;
double *z3d = fphys3d + 5 * Np3d*K3d;
/*The critical water depth*/
double Hcrit = (double)mxGetScalar(prhs[8]);
/*Data contained in two-dimensional standard cell*/
mxArray *TempDr2d = mxGetField(prhs[9], 0, "Dr");
double *Dr2d = mxGetPr(TempDr2d);
mxArray *TempDs2d = mxGetField(prhs[9], 0, "Ds");
double *Ds2d = mxGetPr(TempDs2d);
mxArray *TempNface = mxGetField(prhs[9], 0, "Nface");
int Nface = mxGetScalar(TempNface);
mxArray *TempinvM2d = mxGetField(prhs[9], 0, "invM");
double *invM2d = mxGetPr(TempinvM2d);
/*Data contained in three-dimensional standard cell*/
mxArray *TempDr3d = mxGetField(prhs[10], 0, "Dr");
double *Dr3d = mxGetPr(TempDr3d);
mxArray *TempDs3d = mxGetField(prhs[10], 0, "Ds");
double *Ds3d = mxGetPr(TempDs3d);
mxArray *TempinvM3d = mxGetField(prhs[10], 0, "invM");
double *invM3d = mxGetPr(TempinvM3d);
/*Approximation order in vertical direction*/
mxArray *TempNz = mxGetField(prhs[10], 0, "Nz");
int Nz = (int)mxGetScalar(TempNz);
double gra = mxGetScalar(prhs[11]);
/*The two-dimensional external value*/
double *fext2d = mxGetPr(prhs[12]);
/*The three-dimensional external value*/
double *fext3d = mxGetPr(prhs[13]);
/*The coefficient matrix corresponds to the right hand side of horizontal partial derivative term*/
double *RHSCoeMatrix = mxGetPr(prhs[14]);
/*The coefficient matrix corresponds to the bottom vertical velocity, this part also contributes to the right hand side*/
double *VertCoeMatrix = mxGetPr(prhs[15]);
/*The interpolation point index at the bottom most face*/
double *BotEidM = mxGetPr(prhs[16]);
/*The interpolation point index at the up most face*/
double *UpEidM = mxGetPr(prhs[17]);
signed char *ftype2d = (signed char *)mxGetData(prhs[18]);
signed char *ftype3d = (signed char *)mxGetData(prhs[19]);
plhs[0] = mxCreateDoubleMatrix(Np3d, K3d, mxREAL);
double *VerticalVelocity = mxGetPr(plhs[0]);
/********************************************************** Two Dimensional Part *******************************************************************************/
double *rhs2d = malloc(Np2d*K2d*sizeof(double));
memset(rhs2d, 0, Np2d*K2d*sizeof(double));
double *IEfm2d = malloc(IENfp2d*IENe2d*3*sizeof(double));
double *IEhuM2d = IEfm2d, *IEhvM2d = IEfm2d + IENfp2d * IENe2d, \
*IEhM2d = IEfm2d + 2 * IENfp2d*IENe2d;
double *IEfp2d = malloc(IENfp2d*IENe2d*3*sizeof(double));
double *IEhuP2d = IEfp2d, *IEhvP2d = IEfp2d + IENfp2d * IENe2d, \
*IEhP2d = IEfp2d + 2 * IENfp2d*IENe2d;
double *IEFluxM2d = malloc(IENfp2d*IENe2d*sizeof(double));
memset(IEFluxM2d, 0, IENfp2d*IENe2d*sizeof(double));
double *IEFluxP2d = malloc(IENfp2d*IENe2d*sizeof(double));
memset(IEFluxP2d, 0, IENfp2d*IENe2d*sizeof(double));
double *IEFluxS2d = malloc(IENfp2d*IENe2d*sizeof(double));
memset(IEFluxS2d, 0, IENfp2d*IENe2d*sizeof(double));
double *ERHS2d = malloc(Np2d*K2d*Nface*sizeof(double));
memset(ERHS2d, 0, Np2d*K2d*Nface*sizeof(double));
double *VolumeIntegralX = malloc(Np2d*K2d*sizeof(double));
double *TempVolumeIntegralX = malloc(Np2d*K2d*sizeof(double));
double *VolumeIntegralY = malloc(Np2d*K2d*sizeof(double));
double *TempVolumeIntegralY = malloc(Np2d*K2d*sizeof(double));
ptrdiff_t np = Np2d;
ptrdiff_t oneI = 1;
double one = 1.0, zero = 0.0;
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int k = 0; k < K2d; k++){
/*$\bold{r_x}\cdot (Dr*hu2d)+\bold{s_x}\cdot (Ds*hu2d)$*/
GetVolumnIntegral2d(VolumeIntegralX + k*Np2d, TempVolumeIntegralX + k*Np2d, &np, &oneI, &np, &one, \
Dr2d, Ds2d, &np, hu2d + k*Np2d, &np, &zero, &np, rx2d + k*Np2d, sx2d + k*Np2d);
/*$\bold{r_y}\cdot (Dr*hv2d)+\bold{s_y}\cdot (Ds*hv2d)$*/
GetVolumnIntegral2d(VolumeIntegralY + k*Np2d, TempVolumeIntegralY + k*Np2d, &np, &oneI, &np, &one, \
Dr2d, Ds2d, &np, hv2d + k*Np2d, &np, &zero, &np, ry2d + k*Np2d, sy2d + k*Np2d);
Add(rhs2d + k*Np2d, VolumeIntegralX + k*Np2d, VolumeIntegralY + k*Np2d, Np2d);
}
/*Two dimensional inner edge flux part*/
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int e = 0; e < IENe2d; e++){
FetchInnerEdgeFacialValue(IEhM2d + e*IENfp2d, IEhP2d + e*IENfp2d, h2d, IEFToE2d + 2 * e, IEFToN12d + e*IENfp2d, IEFToN22d + e*IENfp2d, Np2d, IENfp2d);
FetchInnerEdgeFacialValue(IEhuM2d + e*IENfp2d, IEhuP2d + e*IENfp2d, hu2d, IEFToE2d + 2 * e, IEFToN12d + e*IENfp2d, IEFToN22d + e*IENfp2d, Np2d, IENfp2d);
FetchInnerEdgeFacialValue(IEhvM2d + e*IENfp2d, IEhvP2d + e*IENfp2d, hv2d, IEFToE2d + 2 * e, IEFToN12d + e*IENfp2d, IEFToN22d + e*IENfp2d, Np2d, IENfp2d);
GetFacialFluxTerm2d(IEFluxM2d + e*IENfp2d, IEhuM2d + e*IENfp2d, IEhvM2d + e*IENfp2d, IEnx2d + e*IENfp2d, IEny2d + e*IENfp2d, IENfp2d);
GetFacialFluxTerm2d(IEFluxP2d + e*IENfp2d, IEhuP2d + e*IENfp2d, IEhvP2d + e*IENfp2d, IEnx2d + e*IENfp2d, IEny2d + e*IENfp2d, IENfp2d);
GetPCENumericalFluxTerm_HLLC_LAI(IEFluxS2d + e*IENfp2d, IEfm2d + e*IENfp2d, IEfp2d + e*IENfp2d, IEnx2d + e*IENfp2d, IEny2d + e*IENfp2d, &gra, Hcrit, IENfp2d, IENe2d);
}
double *BEfm2d = malloc(BENe2d * BENfp2d * 3 * sizeof(double));
double *BEhuM2d = BEfm2d, *BEhvM2d = BEfm2d + BENe2d * BENfp2d, \
*BEhM2d = BEfm2d + 2 * BENe2d * BENfp2d;
double *BEzM2d = malloc(BENe2d * BENfp2d*sizeof(double));
double *BEfp2d = malloc(BENe2d * BENfp2d * 3 * sizeof(double));
// double *BEhuP2d = BEfp2d, *BEhvP2d = BEfp2d + BENe2d * BENfp2d, \
*BEhP2d = BEfp2d + 2 * BENe2d * BENfp2d;
double *BEzP2d = malloc(BENe2d * BENfp2d*sizeof(double));
double *BEFluxS2d = malloc(BENe2d*BENfp2d*sizeof(double));
memset(BEFluxS2d, 0, BENe2d*BENfp2d*sizeof(double));
double *BEFluxM2d = malloc(BENe2d*BENfp2d*sizeof(double));
memset(BEFluxM2d, 0, BENe2d*BENfp2d*sizeof(double));
/*The number of variables is three, since we only consider hu, hv and h when adding the boundary condition*/
int Nfield = 3;
/*fetch boundary edge value h, hu, hv and z, apply hydrostatic construction at the boundary and compute the numerical flux*/
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int e = 0; e < BENe2d; e++){
NdgEdgeType type = (NdgEdgeType)ftype2d[e]; // boundary condition
FetchBoundaryEdgeFacialValue(BEhM2d + e*BENfp2d, h2d, BEFToE2d + 2 * e, BEFToN12d + e*BENfp2d, Np2d, BENfp2d);
FetchBoundaryEdgeFacialValue(BEhuM2d + e*BENfp2d, hu2d, BEFToE2d + 2 * e, BEFToN12d + e*BENfp2d, Np2d, BENfp2d);
FetchBoundaryEdgeFacialValue(BEhvM2d + e*BENfp2d, hv2d, BEFToE2d + 2 * e, BEFToN12d + e*BENfp2d, Np2d, BENfp2d);
FetchBoundaryEdgeFacialValue(BEzM2d + e*BENfp2d, z2d, BEFToE2d + 2 * e, BEFToN12d + e*BENfp2d, Np2d, BENfp2d);
ImposeBoundaryCondition(&gra, type, BEnx2d + e*BENfp2d, BEny2d + e*BENfp2d, BEfm2d + e*BENfp2d, BEfp2d + e*BENfp2d, \
BEzM2d + e*BENfp2d, BEzP2d + e*BENfp2d, fext2d + e*BENfp2d, BENfp2d, Nfield, BENe2d);
EvaluateHydroStaticReconstructValue(Hcrit, BEfm2d + e*BENfp2d, BEfp2d + e*BENfp2d, BEzM2d + e*BENfp2d, BEzP2d + e*BENfp2d, BENfp2d, Nfield, BENe2d);
GetFacialFluxTerm2d(BEFluxM2d + e*BENfp2d, BEhuM2d + e*BENfp2d, BEhvM2d + e*BENfp2d, BEnx2d + e*BENfp2d, BEny2d + e*BENfp2d, BENfp2d);
GetPCENumericalFluxTerm_HLLC_LAI(BEFluxS2d + e*BENfp2d, BEfm2d + e*BENfp2d, BEfp2d + e*BENfp2d, BEnx2d + e*BENfp2d, BEny2d + e*BENfp2d, &gra, Hcrit, BENfp2d, BENe2d);
}
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int e = 0; e < IENe2d; e++){
StrongFormInnerEdgeRHS(e, IEFToE2d, IEFToF2d, Np2d, K2d, IENfp2d, IEFToN12d, IEFToN22d, IEFluxM2d, IEFluxP2d, IEFluxS2d, IEJs2d, IEMb2d, ERHS2d);
}
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int e = 0; e < BENe2d; e++){
StrongFormBoundaryEdgeRHS(e, BEFToE2d, BEFToF2d, Np2d, K2d, BENfp2d, BEFToN12d, BEFluxM2d, BEFluxS2d, BEJs2d, BEMb2d, ERHS2d);
}
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int k=0; k < K2d; k++){
for(int face=1; face<Nface; face++){
Add( ERHS2d + k*Np2d, ERHS2d + k*Np2d, ERHS2d + face*Np2d*K2d + k*Np2d, Np2d);
}
}
double *TempFacialIntegral = malloc(Np2d*K2d*sizeof(double));
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int k = 0; k < K2d; k++) {
MultiEdgeContributionByLiftOperator(ERHS2d + k*Np2d, TempFacialIntegral + k*Np2d, &np, &oneI, &np, \
&one, invM2d, &np, &np, &zero, &np, J2d + k*Np2d, Np2d);
}
/*Add face integral and volume integral up to form the right hand side corresponding to the discretization of the depth-averaged part*/
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int k = 0; k < K2d; k++){
Minus(rhs2d + k*Np2d, ERHS2d + k*Np2d, rhs2d + k*Np2d, Np2d);
}
double *field2d = malloc(Np3d*K3d*sizeof(double));
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int k = 0; k < K2d; k++){
NdgExtend2dField(field2d, rhs2d, Np2d, k, Np3d, NLayer, Nz);
}
free(rhs2d);
free(IEfm2d);
free(IEfp2d);
free(BEfm2d);
free(BEfp2d);
free(BEzM2d);
free(BEzP2d);
free(IEFluxM2d);
free(IEFluxP2d);
free(IEFluxS2d);
free(BEFluxS2d);
free(BEFluxM2d);
free(ERHS2d);
free(VolumeIntegralX);
free(VolumeIntegralY);
free(TempVolumeIntegralX);
free(TempVolumeIntegralY);
free(TempFacialIntegral);
/********************************************************** Two Dimensional Part Finished *******************************************************************************/
/********************************************************** Three Dimensional Part *******************************************************************************/
double *rhs3d = malloc(Np3d*K3d*sizeof(double));
memset(rhs3d, 0, Np3d*K3d*sizeof(double));
double *IEfm3d = malloc(IENfp3d*IENe3d * 3 * sizeof(double));
double *IEhuM3d = IEfm3d, *IEhvM3d = IEfm3d + IENfp3d * IENe3d, \
*IEhM3d = IEfm3d + 2 * IENfp3d*IENe3d;
double *IEfp3d = malloc(IENfp3d*IENe3d * 3 * sizeof(double));
double *IEhuP3d = IEfp3d, *IEhvP3d = IEfp3d + IENfp3d * IENe3d, \
*IEhP3d = IEfp3d + 2 * IENfp3d*IENe3d;
double *IEFluxM3d = malloc(IENfp3d*IENe3d*sizeof(double));
memset(IEFluxM3d, 0, IENfp3d*IENe3d*sizeof(double));
double *IEFluxP3d = malloc(IENfp3d*IENe3d*sizeof(double));
memset(IEFluxP3d, 0, IENfp3d*IENe3d*sizeof(double));
double *IEFluxS3d = malloc(IENfp3d*IENe3d*sizeof(double));
memset(IEFluxS3d, 0, IENfp3d*IENe3d*sizeof(double));
double *ERHS3d = malloc(Np3d*K3d*Nface*sizeof(double));
memset(ERHS3d, 0, Np3d*K3d*Nface*sizeof(double));
VolumeIntegralX = malloc(Np3d*K3d*sizeof(double));
TempVolumeIntegralX = malloc(Np3d*K3d*sizeof(double));
VolumeIntegralY = malloc(Np3d*K3d*sizeof(double));
TempVolumeIntegralY = malloc(Np3d*K3d*sizeof(double));
np = Np3d;
oneI = 1;
one = 1.0, zero = 0.0;
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int k = 0; k < K3d; k++){
/*$\bold{r_x}\cdot (Dr*hu2d)+\bold{s_x}\cdot (Ds*hu2d)$*/
GetVolumnIntegral2d(VolumeIntegralX + k*Np3d, TempVolumeIntegralX + k*Np3d, &np, &oneI, &np, &one, \
Dr3d, Ds3d, &np, hu3d + k*Np3d, &np, &zero, &np, rx3d + k*Np3d, sx3d + k*Np3d);
/*$\bold{r_y}\cdot (Dr*hv)+\bold{s_y}\cdot (Ds*hv)$*/
GetVolumnIntegral2d(VolumeIntegralY + k*Np3d, TempVolumeIntegralY + k*Np3d, &np, &oneI, &np, &one, \
Dr3d, Ds3d, &np, hv3d + k*Np3d, &np, &zero, &np, ry3d + k*Np3d, sy3d + k*Np3d);
Add(rhs3d + k*Np3d, VolumeIntegralX + k*Np3d, VolumeIntegralY + k*Np3d, Np3d);
}
/*Two dimensional inner edge flux part*/
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int e = 0; e < IENe3d; e++){
FetchInnerEdgeFacialValue(IEhM3d + e*IENfp3d, IEhP3d + e*IENfp3d, h3d, IEFToE3d + 2 * e, IEFToN13d + e*IENfp3d, IEFToN23d + e*IENfp3d, Np3d, IENfp3d);
FetchInnerEdgeFacialValue(IEhuM3d + e*IENfp3d, IEhuP3d + e*IENfp3d, hu3d, IEFToE3d + 2 * e, IEFToN13d + e*IENfp3d, IEFToN23d + e*IENfp3d, Np3d, IENfp3d);
FetchInnerEdgeFacialValue(IEhvM3d + e*IENfp3d, IEhvP3d + e*IENfp3d, hv3d, IEFToE3d + 2 * e, IEFToN13d + e*IENfp3d, IEFToN23d + e*IENfp3d, Np3d, IENfp3d);
GetFacialFluxTerm2d(IEFluxM3d + e*IENfp3d, IEhuM3d + e*IENfp3d, IEhvM3d + e*IENfp3d, IEnx3d + e*IENfp3d, IEny3d + e*IENfp3d, IENfp3d);
GetFacialFluxTerm2d(IEFluxP3d + e*IENfp3d, IEhuP3d + e*IENfp3d, IEhvP3d + e*IENfp3d, IEnx3d + e*IENfp3d, IEny3d + e*IENfp3d, IENfp3d);
GetPCENumericalFluxTerm_HLLC_LAI(IEFluxS3d + e*IENfp3d, IEfm3d + e*IENfp3d, IEfp3d + e*IENfp3d, IEnx3d + e*IENfp3d, IEny3d + e*IENfp3d, &gra, Hcrit, IENfp3d, IENe3d);
}
double *BEfm3d = malloc(BENe3d * BENfp3d * 3 * sizeof(double));
double *BEhuM3d = BEfm3d, *BEhvM3d = BEfm3d + BENe3d * BENfp3d, \
*BEhM3d = BEfm3d + 2 * BENe3d * BENfp3d;
double *BEzM3d = malloc(BENe3d * BENfp3d * sizeof(double));
double *BEfp3d = malloc(BENe3d * BENfp3d * 3 * sizeof(double));
double *BEzP3d = malloc(BENe3d * BENfp3d * sizeof(double));
double *BEFluxS3d = malloc(BENe3d*BENfp3d*sizeof(double));
double *BEFluxM3d = malloc(BENe3d*BENfp3d*sizeof(double));
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int e = 0; e < BENe3d; e++){
NdgEdgeType type = (NdgEdgeType)ftype3d[e]; // boundary condition
FetchBoundaryEdgeFacialValue(BEhuM3d + e*BENfp3d, hu3d, BEFToE3d + 2 * e, BEFToN13d + e*BENfp3d, Np3d, BENfp3d);
FetchBoundaryEdgeFacialValue(BEhvM3d + e*BENfp3d, hv3d, BEFToE3d + 2 * e, BEFToN13d + e*BENfp3d, Np3d, BENfp3d);
FetchBoundaryEdgeFacialValue(BEhM3d + e*BENfp3d, h3d, BEFToE3d + 2 * e, BEFToN13d + e*BENfp3d, Np3d, BENfp3d);
FetchBoundaryEdgeFacialValue(BEzM3d + e*BENfp3d, z3d, BEFToE3d + 2 * e, BEFToN13d + e*BENfp3d, Np3d, BENfp3d);
ImposeBoundaryCondition(&gra, type, BEnx3d + e*BENfp3d, BEny3d + e*BENfp3d, BEfm3d + e*BENfp3d, BEfp3d + e*BENfp3d, \
BEzM3d + e*BENfp3d, BEzP3d + e*BENfp3d, fext3d + e*BENfp3d, BENfp3d, Nfield, BENe3d);
EvaluateHydroStaticReconstructValue(Hcrit, BEfm3d + e*BENfp3d, BEfp3d + e*BENfp3d, BEzM3d + e*BENfp3d, BEzP3d + e*BENfp3d, BENfp3d, Nfield, BENe3d);
GetFacialFluxTerm2d(BEFluxM3d + e*BENfp3d, BEhuM3d + e*BENfp3d, BEhvM3d + e*BENfp3d, BEnx3d + e*BENfp3d, BEny3d + e*BENfp3d, BENfp3d);
GetPCENumericalFluxTerm_HLLC_LAI(BEFluxS3d + e*BENfp3d, BEfm3d + e*BENfp3d, BEfp3d + e*BENfp3d, BEnx3d + e*BENfp3d, BEny3d + e*BENfp3d, &gra, Hcrit, BENfp3d, BENe3d);
}
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int e = 0; e < IENe3d; e++){
StrongFormInnerEdgeRHS(e, IEFToE3d, IEFToF3d, Np3d, K3d, IENfp3d, IEFToN13d, IEFToN23d, IEFluxM3d, IEFluxP3d, IEFluxS3d, IEJs3d, IEMb3d, ERHS3d);
}
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int e = 0; e < BENe3d; e++){
StrongFormBoundaryEdgeRHS(e, BEFToE3d, BEFToF3d, Np3d, K3d, BENfp3d, BEFToN13d, BEFluxM3d, BEFluxS3d, BEJs3d, BEMb3d, ERHS3d);
}
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int k=0; k < K3d; k++){
for(int face=1;face<Nface;face++){
Add( ERHS3d + k*Np3d, ERHS3d + k*Np3d, ERHS3d + face*Np3d*K3d + K3d*Np3d, Np3d);
}
}
TempFacialIntegral = malloc(Np3d*K3d*sizeof(double));
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int k = 0; k < K3d; k++) {
MultiEdgeContributionByLiftOperator(ERHS3d + k*Np3d, TempFacialIntegral + k*Np3d, &np, &oneI, &np, \
&one, invM3d, &np, &np, &zero, &np, J3d + k*Np3d, Np3d);
}
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int k = 0; k < K3d; k++){
Minus(rhs3d + k*Np3d, ERHS3d + k*Np3d, rhs3d + k*Np3d, Np3d);
/*Substract the field2d from rhs3d to assemble the final right hand side*/
Minus(rhs3d + k*Np3d, rhs3d + k*Np3d, field2d + k*Np3d, Np3d);
}
free(IEfm3d);
free(IEfp3d);
free(BEfm3d);
free(BEfp3d);
free(BEzM3d);
free(BEzP3d);
free(IEFluxM3d);
free(IEFluxP3d);
free(IEFluxS3d);
free(BEFluxM3d);
free(BEFluxS3d);
free(ERHS3d);
free(VolumeIntegralX);
free(VolumeIntegralY);
free(TempVolumeIntegralX);
free(TempVolumeIntegralY);
free(TempFacialIntegral);
free(field2d);
/********************************************************** Three Dimensional Part Finished *******************************************************************************/
double *TempVerticalVelocity = malloc(Np3d*K3d*sizeof(double));
double *BotVertVelocity = malloc(Np3d*K2d*sizeof(double));
memset(BotVertVelocity, 0, Np3d*K2d*sizeof(double));
#ifdef _OPENMP
#pragma omp parallel for num_threads(omp_get_max_threads())
#endif
for (int k = 0; k < K2d; k++){
dgemm("N", "N", &np, &oneI, &np, &one, RHSCoeMatrix + k*NLayer*Np3d*Np3d + (NLayer - 1)*Np3d*Np3d, \
&np, rhs3d + k*NLayer*Np3d + (NLayer - 1)*Np3d, &np, &zero, VerticalVelocity + k*NLayer*Np3d + (NLayer - 1)*Np3d, \
&np);
for (int L = 1; L < NLayer; L++){
FetchBoundaryData(BotVertVelocity + k*Np3d, VerticalVelocity + k*NLayer*Np3d + (NLayer - L)*Np3d, BotEidM, UpEidM, Np2d);
dgemm("N", "N", &np, &oneI, &np, &one, RHSCoeMatrix + k*NLayer*Np3d*Np3d + (NLayer - L-1)*Np3d*Np3d, \
&np, rhs3d + k*NLayer*Np3d + (NLayer - L - 1)*Np3d, &np, &zero, VerticalVelocity + k*NLayer*Np3d + (NLayer - L - 1)*Np3d, \
&np);
dgemm("N", "N", &np, &oneI, &np, &one, VertCoeMatrix + k*NLayer*Np3d*Np3d + (NLayer - L - 1)*Np3d*Np3d, \
&np, BotVertVelocity + k*Np3d, &np, &zero, TempVerticalVelocity + k*NLayer*Np3d + (NLayer - L - 1)*Np3d, \
&np);
Add(VerticalVelocity + k*NLayer*Np3d + (NLayer - L - 1)*Np3d, VerticalVelocity + k*NLayer*Np3d + (NLayer - L - 1)*Np3d, \
TempVerticalVelocity + k*NLayer*Np3d + (NLayer - L - 1)*Np3d, Np3d);
}
}
free(rhs3d);
free(TempVerticalVelocity);
free(BotVertVelocity);
}
void FetchBoundaryData(double *dest, double *source, double *destIndex, double *sourceIndex, int size)
{
for (int i = 0; i < size; i++)
dest[(int)destIndex[i] - 1] = source[(int)sourceIndex[i] - 1];
}

请先登录，再回答此问题。

采纳的回答

James Tursa
James Tursa 2020-12-7
编辑：James Tursa 2020-12-7
As I understand your question, the general approach would be as follows:
  • Have pointers to your allocated memory be "global", i.e. at the top level outside any functions, initialized to NULL.
  • Have a function that deallocates this memory and sets the pointers to NULL, e.g., call it cleanup( ).
  • On the first call to your mex function, set cleanup( ) as your mexAtExit function.
  • If the pointers are NULL, allocate them.
  • Have a method of calling your mex function that does nothing except invoke the cleanup( ) function.
So, on the first call you allocate the memory and remember all the pointers because the pointer variables are at the top level. On subsequent calls you simply use this memory. If you clear the mex function, your cleanup( ) function gets called to deallocate the memory. Or if you call your mex function with the special calling syntax, cleanup( ) gets called (your mex function stays in memory but gets put into an initial state).
All that being said, what do you mean by the following:
"... if I need to stop the program mannuly outside of this mex function during the computation ..."
How do you stop the mex function from outside of it?
  3 个评论
显示 1更早的评论
James Tursa
James Tursa 2020-12-8
编辑：James Tursa 2020-12-8
"... I want to know if there are any ways to deallocate the global memory allocated on the first call ..."
Yes ... it is what I already wrote. Have a special calling syntax (maybe as simple as calling the function with no inputs) that invokes the cleanup( ) function. E.g., the first thing you do in mexFunction:
if( nrhs == 0 ) {
cleanup();
return;
}
Note, however, that ctrl-C typically will not halt the mex function unless you do something special to trap this inside your mex function code.

请先登录，再进行评论。

更多回答（0 个）

类别

在 Help Center 和 File Exchange 中查找有关 Functions 的更多信息

标签

Community Treasure Hunt

Find the treasures in MATLAB Central and discover how the community can help you!

Start Hunting!

Translated by