openfam::fam::fam_quiet
Ensures that all pending operations to FAM issued by the calling PE thread have completed before proceeding
Synopsis
void fam_quiet(void);
Description
This method blocks the calling PE thread until all its pending FAM operations are complete.
Input Arguments
None.
Return Values
None. Throws an exception on error.
Exceptions
Exception | Description |
---|---|
Fam_Datapath_Exception | error occurred during write operation over fabric. |
FAM_ERR_LIBFABRIC | libfabric error occurred. |
Fam_Timeout_Exception | number of libfabric retry count reached the timeout limit. (Only for blocking call) |
FAM_ERR_NOPERM | Caller does not have access rights |
Notes
Note that this method does NOT order or wait for completion of fam_map()-enabled load/store accesses by the processor to FAM.
Example
#include <string.h> #include <fam/fam.h> #include <fam/fam_exception.h> using namespace std; using namespace openfam; int main(void) { fam *myFam = new fam(); // ... Initialization code here try { // look up the descriptor to a previously allocated data item // (a 50-element integer array) Fam_Descriptor *descriptor = myFam->fam_lookup("myItem", "myRegion"); // local data int local[] = {0,1,2,3,4}; uint64_t indexes[] = {10, 17, 13, 15, 16}; // scatter local data in myItem[10,17,13,15,16] respectively myFam->fam_scatter_nonblocking(local, descriptor, 5, indexes, sizeof(int)); // ensure that the scatter operation is complete myFam->fam_quiet(); // look up the descriptor to a previously allocated completion flag Fam_Descriptor *flagDescriptor = myFam->fam_lookup("completionFlag", "myRegion"); // atomically set the completion flag in FAM myFam->fam_set(flagDescriptor, 0, 1); // ensure that the set operation is complete myFam->fam_quiet(); // we now have the correct items in FAM, and the completion flag has been set // ... subsequent code here } catch (Fam_Exception &e) { printf("fam API failed: %d: %s\n", e.fam_error(), e.fam_error_msg()); } // ... Finalization code follows }