xref: /libCEED/backends/blocked/ceed-blocked-operator.c (revision e2b2c771c7282b3b06c9e412ce543de8dc2e42e1) 
1 // Copyright (c) 2017-2018, Lawrence Livermore National Security, LLC.
2 // Produced at the Lawrence Livermore National Laboratory. LLNL-CODE-734707.
3 // All Rights reserved. See files LICENSE and NOTICE for details.
4 //
5 // This file is part of CEED, a collection of benchmarks, miniapps, software
6 // libraries and APIs for efficient high-order finite element and spectral
7 // element discretizations for exascale applications. For more information and
8 // source code availability see http://github.com/ceed.
9 //
10 // The CEED research is supported by the Exascale Computing Project 17-SC-20-SC,
11 // a collaborative effort of two U.S. Department of Energy organizations (Office
12 // of Science and the National Nuclear Security Administration) responsible for
13 // the planning and preparation of a capable exascale ecosystem, including
14 // software, applications, hardware, advanced system engineering and early
15 // testbed platforms, in support of the nation's exascale computing imperative.
16 
17 #include "ceed-blocked.h"
18 #include "../ref/ceed-ref.h"
19 
20 static int CeedOperatorDestroy_Blocked(CeedOperator op) {
21   int ierr;
22   CeedOperator_Blocked *impl;
23   ierr = CeedOperatorGetData(op, (void *)&impl); CeedChk(ierr);
24 
25   for (CeedInt i=0; i<impl->numein+impl->numeout; i++) {
26     ierr = CeedElemRestrictionDestroy(&impl->blkrestr[i]); CeedChk(ierr);
27     ierr = CeedVectorDestroy(&impl->evecs[i]); CeedChk(ierr);
28   }
29   ierr = CeedFree(&impl->blkrestr); CeedChk(ierr);
30   ierr = CeedFree(&impl->evecs); CeedChk(ierr);
31   ierr = CeedFree(&impl->edata); CeedChk(ierr);
32   ierr = CeedFree(&impl->inputstate); CeedChk(ierr);
33 
34   for (CeedInt i=0; i<impl->numein; i++) {
35     ierr = CeedVectorDestroy(&impl->evecsin[i]); CeedChk(ierr);
36     ierr = CeedVectorDestroy(&impl->qvecsin[i]); CeedChk(ierr);
37   }
38   ierr = CeedFree(&impl->evecsin); CeedChk(ierr);
39   ierr = CeedFree(&impl->qvecsin); CeedChk(ierr);
40 
41   for (CeedInt i=0; i<impl->numeout; i++) {
42     ierr = CeedVectorDestroy(&impl->evecsout[i]); CeedChk(ierr);
43     ierr = CeedVectorDestroy(&impl->qvecsout[i]); CeedChk(ierr);
44   }
45   ierr = CeedFree(&impl->evecsout); CeedChk(ierr);
46   ierr = CeedFree(&impl->qvecsout); CeedChk(ierr);
47 
48   ierr = CeedFree(&impl); CeedChk(ierr);
49   return 0;
50 }
51 
52 /*
53   Setup infields or outfields
54  */
55 static int CeedOperatorSetupFields_Blocked(CeedQFunction qf,
56     CeedOperator op, bool inOrOut,
57     CeedElemRestriction *blkrestr,
58     CeedVector *fullevecs, CeedVector *evecs,
59     CeedVector *qvecs, CeedInt starte,
60     CeedInt numfields, CeedInt Q) {
61   CeedInt dim, ierr, ncomp, P;
62   Ceed ceed;
63   ierr = CeedOperatorGetCeed(op, &ceed); CeedChk(ierr);
64   CeedBasis basis;
65   CeedElemRestriction r;
66   CeedOperatorField *opfields;
67   CeedQFunctionField *qffields;
68   if (inOrOut) {
69     ierr = CeedOperatorGetFields(op, NULL, &opfields);
70     CeedChk(ierr);
71     ierr = CeedQFunctionGetFields(qf, NULL, &qffields);
72     CeedChk(ierr);
73   } else {
74     ierr = CeedOperatorGetFields(op, &opfields, NULL);
75     CeedChk(ierr);
76     ierr = CeedQFunctionGetFields(qf, &qffields, NULL);
77     CeedChk(ierr);
78   }
79   const CeedInt blksize = 8;
80 
81   // Loop over fields
82   for (CeedInt i=0; i<numfields; i++) {
83     CeedEvalMode emode;
84     ierr = CeedQFunctionFieldGetEvalMode(qffields[i], &emode); CeedChk(ierr);
85 
86     if (emode != CEED_EVAL_WEIGHT) {
87       ierr = CeedOperatorFieldGetElemRestriction(opfields[i], &r);
88       CeedChk(ierr);
89       CeedElemRestriction_Ref *data;
90       ierr = CeedElemRestrictionGetData(r, (void *)&data); CeedChk(ierr);
91       Ceed ceed;
92       ierr = CeedElemRestrictionGetCeed(r, &ceed); CeedChk(ierr);
93       CeedInt nelem, elemsize, nnodes;
94       ierr = CeedElemRestrictionGetNumElements(r, &nelem); CeedChk(ierr);
95       ierr = CeedElemRestrictionGetElementSize(r, &elemsize); CeedChk(ierr);
96       ierr = CeedElemRestrictionGetNumNodes(r, &nnodes); CeedChk(ierr);
97       ierr = CeedElemRestrictionGetNumComponents(r, &ncomp); CeedChk(ierr);
98       ierr = CeedElemRestrictionCreateBlocked(ceed, nelem, elemsize,
99                                               blksize, nnodes, ncomp,
100                                               CEED_MEM_HOST, CEED_COPY_VALUES,
101                                               data->indices, &blkrestr[i+starte]);
102       CeedChk(ierr);
103       ierr = CeedElemRestrictionCreateVector(blkrestr[i+starte], NULL,
104                                              &fullevecs[i+starte]);
105       CeedChk(ierr);
106     }
107 
108     switch(emode) {
109     case CEED_EVAL_NONE:
110       ierr = CeedQFunctionFieldGetNumComponents(qffields[i], &ncomp);
111       CeedChk(ierr);
112       ierr = CeedVectorCreate(ceed, Q*ncomp*blksize, &qvecs[i]); CeedChk(ierr);
113       break;
114     case CEED_EVAL_INTERP:
115       ierr = CeedQFunctionFieldGetNumComponents(qffields[i], &ncomp);
116       CeedChk(ierr);
117       ierr = CeedElemRestrictionGetElementSize(r, &P);
118       CeedChk(ierr);
119       ierr = CeedVectorCreate(ceed, P*ncomp*blksize, &evecs[i]); CeedChk(ierr);
120       ierr = CeedVectorCreate(ceed, Q*ncomp*blksize, &qvecs[i]); CeedChk(ierr);
121       break;
122     case CEED_EVAL_GRAD:
123       ierr = CeedOperatorFieldGetBasis(opfields[i], &basis); CeedChk(ierr);
124       ierr = CeedQFunctionFieldGetNumComponents(qffields[i], &ncomp);
125       CeedChk(ierr);
126       ierr = CeedBasisGetDimension(basis, &dim); CeedChk(ierr);
127       ierr = CeedElemRestrictionGetElementSize(r, &P);
128       CeedChk(ierr);
129       ierr = CeedVectorCreate(ceed, P*ncomp*blksize, &evecs[i]); CeedChk(ierr);
130       ierr = CeedVectorCreate(ceed, Q*ncomp*dim*blksize, &qvecs[i]); CeedChk(ierr);
131       break;
132     case CEED_EVAL_WEIGHT: // Only on input fields
133       ierr = CeedOperatorFieldGetBasis(opfields[i], &basis); CeedChk(ierr);
134       ierr = CeedVectorCreate(ceed, Q*blksize, &qvecs[i]); CeedChk(ierr);
135       ierr = CeedBasisApply(basis, blksize, CEED_NOTRANSPOSE,
136                             CEED_EVAL_WEIGHT, NULL, qvecs[i]); CeedChk(ierr);
137 
138       break;
139     case CEED_EVAL_DIV:
140       break; // Not implimented
141     case CEED_EVAL_CURL:
142       break; // Not implimented
143     }
144   }
145   return 0;
146 }
147 
148 /*
149   CeedOperator needs to connect all the named fields (be they active or passive)
150   to the named inputs and outputs of its CeedQFunction.
151  */
152 static int CeedOperatorSetup_Blocked(CeedOperator op) {
153   int ierr;
154   bool setupdone;
155   ierr = CeedOperatorGetSetupStatus(op, &setupdone); CeedChk(ierr);
156   if (setupdone) return 0;
157   Ceed ceed;
158   ierr = CeedOperatorGetCeed(op, &ceed); CeedChk(ierr);
159   CeedOperator_Blocked *impl;
160   ierr = CeedOperatorGetData(op, (void *)&impl); CeedChk(ierr);
161   CeedQFunction qf;
162   ierr = CeedOperatorGetQFunction(op, &qf); CeedChk(ierr);
163   CeedInt Q, numinputfields, numoutputfields;
164   ierr = CeedOperatorGetNumQuadraturePoints(op, &Q); CeedChk(ierr);
165   ierr= CeedQFunctionGetNumArgs(qf, &numinputfields, &numoutputfields);
166   CeedChk(ierr);
167   CeedOperatorField *opinputfields, *opoutputfields;
168   ierr = CeedOperatorGetFields(op, &opinputfields, &opoutputfields);
169   CeedChk(ierr);
170   CeedQFunctionField *qfinputfields, *qfoutputfields;
171   ierr = CeedQFunctionGetFields(qf, &qfinputfields, &qfoutputfields);
172   CeedChk(ierr);
173 
174   // Allocate
175   ierr = CeedCalloc(numinputfields + numoutputfields, &impl->blkrestr);
176   CeedChk(ierr);
177   ierr = CeedCalloc(numinputfields + numoutputfields, &impl->evecs);
178   CeedChk(ierr);
179   ierr = CeedCalloc(numinputfields + numoutputfields, &impl->edata);
180   CeedChk(ierr);
181 
182   ierr = CeedCalloc(16, &impl->inputstate); CeedChk(ierr);
183   ierr = CeedCalloc(16, &impl->evecsin); CeedChk(ierr);
184   ierr = CeedCalloc(16, &impl->evecsout); CeedChk(ierr);
185   ierr = CeedCalloc(16, &impl->qvecsin); CeedChk(ierr);
186   ierr = CeedCalloc(16, &impl->qvecsout); CeedChk(ierr);
187 
188   impl->numein = numinputfields; impl->numeout = numoutputfields;
189 
190   // Set up infield and outfield pointer arrays
191   // Infields
192   ierr = CeedOperatorSetupFields_Blocked(qf, op, 0, impl->blkrestr,
193                                          impl->evecs, impl->evecsin,
194                                          impl->qvecsin, 0,
195                                          numinputfields, Q);
196   CeedChk(ierr);
197   // Outfields
198   ierr = CeedOperatorSetupFields_Blocked(qf, op, 1, impl->blkrestr,
199                                          impl->evecs, impl->evecsout,
200                                          impl->qvecsout, numinputfields,
201                                          numoutputfields, Q);
202   CeedChk(ierr);
203 
204   ierr = CeedOperatorSetSetupDone(op); CeedChk(ierr);
205 
206   return 0;
207 }
208 
209 static int CeedOperatorApply_Blocked(CeedOperator op, CeedVector invec,
210                                      CeedVector outvec,
211                                      CeedRequest *request) {
212   int ierr;
213   CeedOperator_Blocked *impl;
214   ierr = CeedOperatorGetData(op, (void *)&impl); CeedChk(ierr);
215   const CeedInt blksize = 8;
216   CeedInt Q, elemsize, numinputfields, numoutputfields, numelements, ncomp;
217   ierr = CeedOperatorGetNumElements(op, &numelements); CeedChk(ierr);
218   ierr = CeedOperatorGetNumQuadraturePoints(op, &Q); CeedChk(ierr);
219   CeedInt nblks = (numelements/blksize) + !!(numelements%blksize);
220   CeedQFunction qf;
221   ierr = CeedOperatorGetQFunction(op, &qf); CeedChk(ierr);
222   ierr= CeedQFunctionGetNumArgs(qf, &numinputfields, &numoutputfields);
223   CeedChk(ierr);
224   CeedTransposeMode lmode;
225   CeedOperatorField *opinputfields, *opoutputfields;
226   ierr = CeedOperatorGetFields(op, &opinputfields, &opoutputfields);
227   CeedChk(ierr);
228   CeedQFunctionField *qfinputfields, *qfoutputfields;
229   ierr = CeedQFunctionGetFields(qf, &qfinputfields, &qfoutputfields);
230   CeedChk(ierr);
231   CeedEvalMode emode;
232   CeedVector vec;
233   CeedBasis basis;
234   CeedElemRestriction Erestrict;
235   uint64_t state;
236 
237   // Setup
238   ierr = CeedOperatorSetup_Blocked(op); CeedChk(ierr);
239 
240   // Input Evecs and Restriction
241   for (CeedInt i=0; i<numinputfields; i++) {
242     ierr = CeedQFunctionFieldGetEvalMode(qfinputfields[i], &emode);
243     CeedChk(ierr);
244     if (emode == CEED_EVAL_WEIGHT) { // Skip
245     } else {
246       // Get input vector
247       ierr = CeedOperatorFieldGetVector(opinputfields[i], &vec); CeedChk(ierr);
248       if (vec == CEED_VECTOR_ACTIVE)
249         vec = invec;
250       // Restrict
251       ierr = CeedVectorGetState(vec, &state); CeedChk(ierr);
252       if (state != impl->inputstate[i] || vec == invec) {
253         ierr = CeedOperatorFieldGetLMode(opinputfields[i], &lmode); CeedChk(ierr);
254         ierr = CeedElemRestrictionApply(impl->blkrestr[i], CEED_NOTRANSPOSE,
255                                         lmode, vec, impl->evecs[i],
256                                         request); CeedChk(ierr); CeedChk(ierr);
257         impl->inputstate[i] = state;
258       }
259       // Get evec
260       ierr = CeedVectorGetArrayRead(impl->evecs[i], CEED_MEM_HOST,
261                                     (const CeedScalar **) &impl->edata[i]);
262       CeedChk(ierr);
263     }
264   }
265 
266   // Output Evecs
267   for (CeedInt i=0; i<numoutputfields; i++) {
268     ierr = CeedVectorGetArray(impl->evecs[i+impl->numein], CEED_MEM_HOST,
269                               &impl->edata[i + numinputfields]); CeedChk(ierr);
270   }
271 
272   // Loop through elements
273   for (CeedInt e=0; e<nblks*blksize; e+=blksize) {
274     // Input basis apply if needed
275     for (CeedInt i=0; i<numinputfields; i++) {
276       // Get elemsize, emode, ncomp
277       ierr = CeedOperatorFieldGetElemRestriction(opinputfields[i], &Erestrict);
278       CeedChk(ierr);
279       ierr = CeedElemRestrictionGetElementSize(Erestrict, &elemsize);
280       CeedChk(ierr);
281       ierr = CeedQFunctionFieldGetEvalMode(qfinputfields[i], &emode);
282       CeedChk(ierr);
283       ierr = CeedQFunctionFieldGetNumComponents(qfinputfields[i], &ncomp);
284       CeedChk(ierr);
285       // Basis action
286       switch(emode) {
287       case CEED_EVAL_NONE:
288         ierr = CeedVectorSetArray(impl->qvecsin[i], CEED_MEM_HOST,
289                                   CEED_USE_POINTER,
290                                   &impl->edata[i][e*Q*ncomp]); CeedChk(ierr);
291         break;
292       case CEED_EVAL_INTERP:
293         ierr = CeedOperatorFieldGetBasis(opinputfields[i], &basis); CeedChk(ierr);
294         ierr = CeedVectorSetArray(impl->evecsin[i], CEED_MEM_HOST,
295                                   CEED_USE_POINTER,
296                                   &impl->edata[i][e*elemsize*ncomp]);
297         CeedChk(ierr);
298         ierr = CeedBasisApply(basis, blksize, CEED_NOTRANSPOSE,
299                               CEED_EVAL_INTERP, impl->evecsin[i],
300                               impl->qvecsin[i]); CeedChk(ierr);
301         break;
302       case CEED_EVAL_GRAD:
303         ierr = CeedOperatorFieldGetBasis(opinputfields[i], &basis); CeedChk(ierr);
304         ierr = CeedVectorSetArray(impl->evecsin[i], CEED_MEM_HOST,
305                                   CEED_USE_POINTER,
306                                   &impl->edata[i][e*elemsize*ncomp]);
307         CeedChk(ierr);
308         ierr = CeedBasisApply(basis, blksize, CEED_NOTRANSPOSE,
309                               CEED_EVAL_GRAD, impl->evecsin[i],
310                               impl->qvecsin[i]); CeedChk(ierr);
311         break;
312       case CEED_EVAL_WEIGHT:
313         break;  // No action
314       case CEED_EVAL_DIV:
315         break; // Not implemented
316       case CEED_EVAL_CURL:
317         break; // Not implemented
318       }
319     }
320 
321     // Output pointers
322     for (CeedInt i=0; i<numoutputfields; i++) {
323       ierr = CeedQFunctionFieldGetEvalMode(qfoutputfields[i], &emode);
324       CeedChk(ierr);
325       if (emode == CEED_EVAL_NONE) {
326         ierr = CeedQFunctionFieldGetNumComponents(qfoutputfields[i], &ncomp);
327         CeedChk(ierr);
328         ierr = CeedVectorSetArray(impl->qvecsout[i], CEED_MEM_HOST,
329                                   CEED_USE_POINTER,
330                                   &impl->edata[i + numinputfields][e*Q*ncomp]);
331         CeedChk(ierr);
332       }
333     }
334     // Q function
335     ierr = CeedQFunctionApply(qf, Q*blksize, impl->qvecsin, impl->qvecsout);
336     CeedChk(ierr);
337 
338     // Output basis apply if needed
339     for (CeedInt i=0; i<numoutputfields; i++) {
340       // Get elemsize, emode, ncomp
341       ierr = CeedOperatorFieldGetElemRestriction(opoutputfields[i], &Erestrict);
342       CeedChk(ierr);
343       ierr = CeedElemRestrictionGetElementSize(Erestrict, &elemsize);
344       CeedChk(ierr);
345       ierr = CeedQFunctionFieldGetEvalMode(qfoutputfields[i], &emode);
346       CeedChk(ierr);
347       ierr = CeedQFunctionFieldGetNumComponents(qfoutputfields[i], &ncomp);
348       CeedChk(ierr);
349       // Basis action
350       switch(emode) {
351       case CEED_EVAL_NONE:
352         break; // No action
353       case CEED_EVAL_INTERP:
354         ierr = CeedOperatorFieldGetBasis(opoutputfields[i], &basis);
355         CeedChk(ierr);
356         ierr = CeedVectorSetArray(impl->evecsout[i], CEED_MEM_HOST,
357                                   CEED_USE_POINTER,
358                                   &impl->edata[i + numinputfields][e*elemsize*ncomp]);
359         CeedChk(ierr);
360         ierr = CeedBasisApply(basis, blksize, CEED_TRANSPOSE,
361                               CEED_EVAL_INTERP, impl->qvecsout[i],
362                               impl->evecsout[i]); CeedChk(ierr);
363         break;
364       case CEED_EVAL_GRAD:
365         ierr = CeedOperatorFieldGetBasis(opoutputfields[i], &basis);
366         CeedChk(ierr);
367         ierr = CeedVectorSetArray(impl->evecsout[i], CEED_MEM_HOST,
368                                   CEED_USE_POINTER,
369                                   &impl->edata[i + numinputfields][e*elemsize*ncomp]);
370         CeedChk(ierr);
371         ierr = CeedBasisApply(basis, blksize, CEED_TRANSPOSE,
372                               CEED_EVAL_GRAD, impl->qvecsout[i],
373                               impl->evecsout[i]); CeedChk(ierr);
374         break;
375       case CEED_EVAL_WEIGHT: {
376         Ceed ceed;
377         ierr = CeedOperatorGetCeed(op, &ceed); CeedChk(ierr);
378         return CeedError(ceed, 1,
379                          "CEED_EVAL_WEIGHT cannot be an output evaluation mode");
380         break; // Should not occur
381       }
382       case CEED_EVAL_DIV:
383         break; // Not implemented
384       case CEED_EVAL_CURL:
385         break; // Not implemented
386       }
387     }
388   }
389 
390   // Zero lvecs
391   for (CeedInt i=0; i<numoutputfields; i++) {
392     ierr = CeedOperatorFieldGetVector(opoutputfields[i], &vec); CeedChk(ierr);
393     if (vec == CEED_VECTOR_ACTIVE) {
394       if (!impl->add) {
395         vec = outvec;
396         ierr = CeedVectorSetValue(vec, 0.0); CeedChk(ierr);
397       }
398     } else {
399       ierr = CeedVectorSetValue(vec, 0.0); CeedChk(ierr);
400     }
401   }
402   impl->add = false;
403 
404   // Output restriction
405   for (CeedInt i=0; i<numoutputfields; i++) {
406     // Restore evec
407     ierr = CeedVectorRestoreArray(impl->evecs[i+impl->numein],
408                                   &impl->edata[i + numinputfields]); CeedChk(ierr);
409     // Get output vector
410     ierr = CeedOperatorFieldGetVector(opoutputfields[i], &vec); CeedChk(ierr);
411     // Active
412     if (vec == CEED_VECTOR_ACTIVE)
413       vec = outvec;
414     // Restrict
415     ierr = CeedOperatorFieldGetLMode(opoutputfields[i], &lmode); CeedChk(ierr);
416     ierr = CeedElemRestrictionApply(impl->blkrestr[i+impl->numein], CEED_TRANSPOSE,
417                                     lmode, impl->evecs[i+impl->numein], vec,
418                                     request); CeedChk(ierr);
419 
420   }
421 
422   // Restore input arrays
423   for (CeedInt i=0; i<numinputfields; i++) {
424     ierr = CeedQFunctionFieldGetEvalMode(qfinputfields[i], &emode);
425     CeedChk(ierr);
426     if (emode == CEED_EVAL_WEIGHT) { // Skip
427     } else {
428       ierr = CeedVectorRestoreArrayRead(impl->evecs[i],
429                                         (const CeedScalar **) &impl->edata[i]);
430       CeedChk(ierr);
431     }
432   }
433 
434   return 0;
435 }
436 
437 int CeedOperatorCreate_Blocked(CeedOperator op) {
438   int ierr;
439   Ceed ceed;
440   ierr = CeedOperatorGetCeed(op, &ceed); CeedChk(ierr);
441   CeedOperator_Blocked *impl;
442 
443   ierr = CeedCalloc(1, &impl); CeedChk(ierr);
444   ierr = CeedOperatorSetData(op, (void *)&impl); CeedChk(ierr);
445 
446   ierr = CeedSetBackendFunction(ceed, "Operator", op, "Apply",
447                                 CeedOperatorApply_Blocked); CeedChk(ierr);
448   ierr = CeedSetBackendFunction(ceed, "Operator", op, "Destroy",
449                                 CeedOperatorDestroy_Blocked); CeedChk(ierr);
450   return 0;
451 }
452