Alexander_KS/SAPFOR
4
2
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

delete comms

Browse Source 
const added
This commit is contained in:
Anton
2023-12-15 09:45:10 +03:00
parent e5572d9dff
commit 5e16437845
445 changed files with 11021 additions and 97 deletions
Download Patch File Download Diff File Expand all files Collapse all files

105
sapfor/experts/Sapfor_2017/_src/Transformations/checkpoints.cpp
View File

@@ -3,8 +3,6 @@
#include <vector>
#include <string>
#include <set>
#include <iostream>
#include <fstream>
#include "../Utils/SgUtils.h"
#include "../Utils/utils.h"
@@ -506,7 +504,7 @@ void deleteIntentIn(SgStatement* start, SgStatement* end)
{
if (st->expr(2)) {
int var = st->expr(2)->lhs()->variant();
if (var == 468)
if (var == IN_OP)
st->setExpression(2, NULL);
}
}
@@ -518,7 +516,7 @@ void replaceIntentInWithIntentinOut(SgStatement* start, SgStatement* end)
{
if (st->expr(2)) {
int var = st->expr(2)->lhs()->variant();
if (var == 468)
if (var == IN_OP)
st->expr(2)->lhs()->setVariant(470);
}
}
@@ -543,7 +541,7 @@ static void findLocalDataNoIntentIn(SgStatement* start, SgStatement* end, vector
for (SgStatement* st = start; st != end; st = st->lexNext())
if (st->variant() == VAR_DECL || st->variant() == VAR_DECL_90)
if (st->expr(2) && st->expr(2)->lhs()->variant() == 468) {
if (st->expr(2) && st->expr(2)->lhs()->variant() == IN_OP) {
SgExpression* ex = st->expr(0);
while (ex)
{
@@ -564,7 +562,7 @@ static void findLocalDataNoIntentIn(SgStatement* start, SgStatement* end, vector
for (SgStatement* st = start; st != end; st = st->lexNext())
if (st->variant() == VAR_DECL || st->variant() == VAR_DECL_90)
if (st->expr(2) && st->expr(2)->lhs()->variant() == 468) {
if (st->expr(2) && st->expr(2)->lhs()->variant() == IN_OP) {
SgExpression* ex = st->expr(0);
while (ex)
{
@@ -656,7 +654,6 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
SgStatement* loadBlock = new SgStatement(IF_NODE);
SgStatement* storeBlock = new SgStatement(IF_NODE);
//std::cout << "##############################################################################" << std::endl;
point->insertStmtBefore(*loadBlock, *point->controlParent());
point->insertStmtBefore(*storeBlock, *point->controlParent());
@@ -670,37 +667,22 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
SgArrayRefExp* journal = new SgArrayRefExp(*files, *new SgValueExp(numOfFiles + 1));
//give max len, dont insert
/* after store-block in func with cp:
spf_cp_files_0_26(1) = 'spf_cp_file_1_0_26'
spf_cp_files_0_26(2) = 'spf_cp_file_2_0_26'
spf_cp_files_0_26(3) = 'spf_cp_journal_0_26'
*/
int maxFileLen = insertInitNamesOfFiles(numOfFiles, additional, files, journal, NULL);
vector<SgSymbol*> everyS;
vector<SgSymbol*> profS;
vector<SgExpression*> initS;
string
profSs = "spf_cp_prof_s" + additional,
profEs = "spf_cp_prof_e" + additional;
string profSs = "spf_cp_prof_s" + additional;
string profEs = "spf_cp_prof_e" + additional;
profS.push_back(new SgSymbol(VARIABLE_NAME, profSs.c_str(), SgTypeFloat(), func));
profS.push_back(new SgSymbol(VARIABLE_NAME, profEs.c_str(), SgTypeFloat(), func));
SgSymbol* timeF = new SgSymbol(FUNCTION_NAME, "omp_get_wtime", SgTypeDouble(), func); // OR dvtime
//spf_cp_prof_s(e)_0_26 = omp_get_wtime()
SgStatement* profCallS = new SgAssignStmt(*new SgVarRefExp(profS[0]), *new SgFunctionCallExp(*timeF));
SgStatement* profCallE = new SgAssignStmt(*new SgVarRefExp(profS[1]), *new SgFunctionCallExp(*timeF));
/* beginning of store block :
* ! STORE CHECKPOINT
spf_cp_interval_0_26 = spf_cp_interval_0_26 + 1
if (spf_cp_interval_0_26 .ge. 1) then
spf_cp_interval_0_26 = 0
endif
*/
if (type == typeEvery::TIME)
{
string everySs = "spf_cp_start" + additional;
@@ -731,31 +713,14 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
everyS.push_back(new SgSymbol(VARIABLE_NAME, everyIs.c_str(), SgTypeInt(), func));
initS.push_back(new SgValueExp(0));
SgAssignStmt* init = new SgAssignStmt(*new SgVarRefExp(everyS[0]), *new SgValueExp(0));
//std::cout << "INIT::" << std::endl;
//init->unparsestdout();
//std::cout << "storeBlock before::" << std::endl;
//storeBlock->unparsestdout();
storeBlock->insertStmtAfter(*init, *storeBlock);
//std::cout << "storeBlock after init::" << std::endl;
//storeBlock->unparsestdout();
SgAssignStmt* inc = new SgAssignStmt(*new SgVarRefExp(everyS[0]), *new SgVarRefExp(everyS[0]) + *new SgValueExp(1));
//std::cout << "INC::" << std::endl;
//init->unparsestdout();
//std::cout << "storeBlock->controlParent()::" << std::endl;
//storeBlock->controlParent()->unparsestdout();
storeBlock->insertStmtBefore(*inc, *storeBlock->controlParent());
inc->addComment("! STORE CHECKPOINT\n");
//std::cout << "storeBlock after inc::" << std::endl;
//storeBlock->unparsestdout();
storeBlock->setExpression(0, *new SgVarRefExp(everyS[0]) >= *new SgValueExp(every));
//std::cout << "storeBlock after setexpr::" << std::endl;
//storeBlock->unparsestdout();
//std::cout << "storeBlock->controlParent()::" << std::endl;
//storeBlock->controlParent()->unparsestdout();
}
//std::cout << "##############################################################################" << std::endl;
vector<SgSymbol*> loadS;
vector<SgExpression*> initLoadS;
@@ -785,18 +750,10 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
loadS.push_back(new SgSymbol(VARIABLE_NAME, saveFS.c_str(), SgTypeInt(), func));
initLoadS.push_back(new SgValueExp(0));
//std::cout << "loadBlock->controlParent()::" << std::endl;
//loadBlock->controlParent()->unparsestdout();
loadBlock->setExpression(0, *new SgVarRefExp(loadS[0]) == *new SgValueExp(0));
SgAssignStmt* init = new SgAssignStmt(*new SgVarRefExp(loadS[0]), *new SgValueExp(1));
//std::cout << "INIT::" << std::endl;
//init->unparsestdout();
insertToLoadS.push_back(init);
//std::cout << "loadBlock->controlParent()::" << std::endl;
//loadBlock->controlParent()->unparsestdout();
//std::cout << "##############################################################################" << std::endl;
vector<SgExpression*> listSpec;
SgExpression& unitNull = SgAssignOp(*new SgKeywordValExp("unit"), *new SgKeywordValExp("*"));
@@ -807,7 +764,6 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
SgExpression* iostat = new SgVarRefExp(loadS[2]);
SgExpression* fileIdx = new SgVarRefExp(loadS[1]);
// for first open journal file in load block
listSpec.push_back(&SgAssignOp(*new SgKeywordValExp("iostat"), *iostat));
listSpec.push_back(&SgAssignOp(*new SgKeywordValExp("status"), *new SgValueExp("old")));
listSpec.push_back(&SgAssignOp(*new SgKeywordValExp("file"), *journal));
@@ -835,17 +791,9 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
insertToifLoadOk.push_back(open);
SgIfStmt* ifLoadOk1 = new SgIfStmt(*iostat == *new SgValueExp(0), *new SgIOControlStmt(CLOSE_STAT, unit));
//std::cout << "ifLoadOk1::" << std::endl;
//ifLoadOk1->unparsestdout();
insertToifLoadOk.push_back(ifLoadOk1);
/* from "! LOAD DATA FROM CHECKPOINT"
spf_cp_file_n_0_26 = spf_cp_file_n_0_26 + 1
if (spf_cp_file_n_0_26 .eq. 3) then
spf_cp_file_n_0_26 = 1
endif
*/
ifLoadOk1->insertStmtAfter(*new SgIfStmt(*fileIdx == *new SgValueExp(numOfFiles + 1), *new SgAssignStmt(*fileIdx, *new SgValueExp(1))), *ifLoadOk1);
ifLoadOk1->insertStmtAfter(*new SgAssignStmt(*fileIdx, *fileIdx + *new SgValueExp(1)), *ifLoadOk1);
ifLoadOk1->addComment("! LOAD DATA FROM CHECKPOINT\n");
@@ -862,7 +810,6 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
//open all files
if (createdModuleForIO)
{
//std::cout << "createdModuleForIO" << std::endl;
SgCallStmt* call = new SgCallStmt(*new SgSymbol(FUNCTION_NAME, iosNames[1].c_str()));
ifLoadOk1->insertStmtAfter(*call, *ifLoadOk1);
}
@@ -870,7 +817,6 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
//READ from modules
for (auto& mod : moduleNames)
{
//std::cout << "READ from modules" << std::endl;
SgCallStmt* call = new SgCallStmt(*new SgSymbol(FUNCTION_NAME, ("SPF_CP_" + mod).c_str()));
call->addArg(*new SgValueExp(unitNum));
call->addArg(*new SgValueExp(0));
@@ -880,16 +826,11 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
//READ DATA
if (local.size())
{
//std::cout << "READ DATA" << std::endl;
auto dataRead = new SgInputOutputStmt(READ_STAT, unit, *makeExprList(local, false));
ifLoadOk1->insertStmtAfter(*dataRead, *ifLoadOk1);
}
ifLoadOk1->insertStmtAfter(profCallS->copy(), *ifLoadOk1);
//std::cout << "loadBlock->controlParent()::" << std::endl;
//loadBlock->controlParent()->unparsestdout();
// loadblock done (need to upload)
listSpec.clear();
listSpec.push_back(&SgAssignOp(*new SgKeywordValExp("form"), *new SgValueExp("unformatted")));
@@ -961,41 +902,19 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
assign->insertStmtBefore(*new SgIOControlStmt(CLOSE_STAT, unit), *ifStoreOk);
ifStoreOk->insertStmtAfter(profCallS->copy(), *ifStoreOk);
// store-block done
// block after name of files and before first executable operator
SgStatement* copyForGoto = loadBlock->copyPtr();
//std::cout << "copyForGoto::" << std::endl;
//copyForGoto->unparsestdout();
copyForGoto->deleteLabel();
//std::cout << "copyForGoto after delete label::" << std::endl;
//copyForGoto->unparsestdout();
//std::cout << "firstExec::" << std::endl;
//firstExec->unparsestdout();
firstExec->insertStmtBefore(*copyForGoto, *func);
//std::cout << "firstExec parent after insert::" << std::endl;
//firstExec->controlParent()->unparsestdout();
//loadBlock->controlParent()->unparsestdout();
insertInitNamesOfFiles(numOfFiles, additional, files, journal, copyForGoto, true);
//std::cout << "insert names of files::" << std::endl;
copyForGoto->insertStmtAfter(insertToLoadS[insertToLoadS.size() - 1]->copy(), *copyForGoto);
//std::cout << "copyForGoto::" << std::endl;
//copyForGoto->controlParent()->unparsestdout();
copyForGoto->insertStmtAfter(insertToLoadS[insertToLoadS.size() - 2]->copy(), *copyForGoto);
//std::cout << "copyForGoto::" << std::endl;
//copyForGoto->controlParent()->unparsestdout();
copyForGoto = copyForGoto->lexNext()->lexNext();
//std::cout << "copyForGoto after double lexnext::" << std::endl;
//copyForGoto->unparsestdout();
copyForGoto->insertStmtAfter(*new SgGotoStmt(*loadblockLab), *copyForGoto);
//std::cout << "copyForGoto::" << std::endl;
//copyForGoto->controlParent()->unparsestdout();
copyForGoto->insertStmtAfter(*new SgIOControlStmt(CLOSE_STAT, unit), *copyForGoto);
//std::cout << "copyForGoto::" << std::endl;
//copyForGoto->controlParent()->unparsestdout();
for (int z = insertToLoadS.size() - 1; z >= 0; --z)
loadBlock->insertStmtAfter(*insertToLoadS[z], *loadBlock);
@@ -1003,9 +922,6 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
for (int z = insertToifLoadOk.size() - 1; z >= 0; --z)
ifLoadOk->insertStmtAfter(*insertToifLoadOk[z], *ifLoadOk);
// load block added
//std::cout << "##############################################################################" << std::endl;
//TODO:
/*set<string> elemNotDeclHere;
@@ -1091,7 +1007,6 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
map<FuncInfo*, SgStatement*> processedFrom;
for (auto j = toProcess.begin(); j != toProcess.end(); j++)
{
std::cout << "( " << (j->first)->funcName << " , " << (j->second)->funcName << " ) " << std::endl;
int callNum = 1;
SgStatement* hedrTo = (j->first)->funcPointer->GetOriginal();
SgStatement* hedrFrom = (j->second)->funcPointer->GetOriginal();
@@ -1175,18 +1090,14 @@ void createCheckpoints(SgFile* file, const map<string, CommonBlock*>& commonBloc
SgStatement* read = new SgInputOutputStmt(READ_STAT, *makeExprList({ &frmt, &unit }, false), *new SgVarRefExp(loadS[3]));
gotoBlock->insertStmtAfter(*read, *gotoBlock);
processedFrom[j->second] = gotoBlock->lexNext();
firstExec->insertStmtBefore(*gotoBlock, *hedrFrom);
firstExec->insertStmtBefore(*gotoBlock, *hedrFrom); // block created but did not added to fortran
}
processedFrom[j->second]->unparsestdout();
//std::cout << "gotoblock: " << std::endl;
//gotoBlock->unparsestdout();
}
for (auto& callInfo : j->second->callsFromDetailed)
{
//std::cout << "callinfo name: " << callInfo.detailCallsFrom.first << std::endl;
auto& call = callInfo.pointerDetailCallsFrom;
//std::cout << "callinfo var: " << call.second << std::endl;
SgStatement* st = NULL;
if (isSgFuncHedrStmt(hedrTo) && call.second == FUNC_CALL)