Compare commits
5 Commits
replace_io
...
8fdf7e7063
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8fdf7e7063 | ||
|
|
54e83e194d | ||
|
|
b87b18615d | ||
|
|
e733d3d68a | ||
| fb3ac921cc |
@@ -1,6 +1,6 @@
|
|||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
#include<unordered_map>
|
#include <unordered_map>
|
||||||
|
|
||||||
#include "SgUtils.h"
|
#include "SgUtils.h"
|
||||||
#include "CommonBlock.h"
|
#include "CommonBlock.h"
|
||||||
|
|||||||
@@ -1289,6 +1289,9 @@ static set<DIST::Array*>
|
|||||||
|
|
||||||
SgStatement* declStat = NULL;
|
SgStatement* declStat = NULL;
|
||||||
|
|
||||||
|
if (realArray->GetLocation().first == DIST::l_PARAMETER)
|
||||||
|
continue;
|
||||||
|
|
||||||
if (realArray->GetLocation().first == DIST::l_COMMON)
|
if (realArray->GetLocation().first == DIST::l_COMMON)
|
||||||
{
|
{
|
||||||
commonArrays.insert(realArray);
|
commonArrays.insert(realArray);
|
||||||
|
|||||||
@@ -6,14 +6,12 @@
|
|||||||
#include <cstdint>
|
#include <cstdint>
|
||||||
|
|
||||||
#include <map>
|
#include <map>
|
||||||
#include <unordered_map>
|
|
||||||
#include <vector>
|
#include <vector>
|
||||||
#include <set>
|
#include <set>
|
||||||
#include <string>
|
#include <string>
|
||||||
|
|
||||||
using std::vector;
|
using std::vector;
|
||||||
using std::map;
|
using std::map;
|
||||||
using std::unordered_map;
|
|
||||||
using std::tuple;
|
using std::tuple;
|
||||||
using std::set;
|
using std::set;
|
||||||
using std::string;
|
using std::string;
|
||||||
|
|||||||
@@ -24,6 +24,7 @@ using std::make_pair;
|
|||||||
using std::map;
|
using std::map;
|
||||||
using std::set;
|
using std::set;
|
||||||
using std::wstring;
|
using std::wstring;
|
||||||
|
using std::tuple;
|
||||||
|
|
||||||
extern void createMapLoopGraph(map<int, LoopGraph*> &sortedLoopGraph, const vector<LoopGraph*> *loopGraph);
|
extern void createMapLoopGraph(map<int, LoopGraph*> &sortedLoopGraph, const vector<LoopGraph*> *loopGraph);
|
||||||
|
|
||||||
@@ -954,4 +955,65 @@ void calculateLinesOfCode(vector<ParallelRegion*> &allRegions)
|
|||||||
|
|
||||||
__spf_print(1, " Count of lines in region '%s' = %d\n", elem->GetName().c_str(), lineCounter);
|
__spf_print(1, " Count of lines in region '%s' = %d\n", elem->GetName().c_str(), lineCounter);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void propagateRegionInfo(map<tuple<int, string, string>, pair<DIST::Array*, DIST::ArrayAccessInfo*>>& declaredArrays,
|
||||||
|
const map<DIST::Array*, set<DIST::Array*>>& arrayLinksByFuncCalls,
|
||||||
|
const vector<ParallelRegion*> ¶llelRegions)
|
||||||
|
{
|
||||||
|
bool modified = true;
|
||||||
|
while (modified)
|
||||||
|
{
|
||||||
|
modified = false;
|
||||||
|
|
||||||
|
for (auto &array_pair: declaredArrays)
|
||||||
|
{
|
||||||
|
auto array = array_pair.second.first;
|
||||||
|
if (array->GetLocation().first == DIST::l_PARAMETER)
|
||||||
|
{
|
||||||
|
set<DIST::Array*> realArrayRef;
|
||||||
|
getAllArrayRefs(array, array, realArrayRef, arrayLinksByFuncCalls);
|
||||||
|
|
||||||
|
auto regs = array->GetRegionsName();
|
||||||
|
for (auto& ref : realArrayRef)
|
||||||
|
{
|
||||||
|
auto regsRef = ref->GetRegionsName();
|
||||||
|
for (auto& reg : regsRef)
|
||||||
|
{
|
||||||
|
if (regs.count(reg) == 0)
|
||||||
|
{
|
||||||
|
array->SetRegionPlace(reg);
|
||||||
|
modified = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
bool hasNonDefaultReg = false;
|
||||||
|
for (auto& elem : parallelRegions)
|
||||||
|
{
|
||||||
|
string regName = elem->GetName();
|
||||||
|
convertToLower(regName);
|
||||||
|
if (regName != "default")
|
||||||
|
hasNonDefaultReg = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (hasNonDefaultReg)
|
||||||
|
{
|
||||||
|
for (auto array : declaredArrays)
|
||||||
|
{
|
||||||
|
if (array.second.first->GetRegionsName().size() == 0)
|
||||||
|
array.second.first->SetDistributeFlag(DIST::NO_DISTR);
|
||||||
|
else if (array.second.first->GetRegionsName().size() == 1)
|
||||||
|
{
|
||||||
|
string regName = *array.second.first->GetRegionsName().begin();
|
||||||
|
convertToLower(regName);
|
||||||
|
if (regName == "default")
|
||||||
|
array.second.first->SetDistributeFlag(DIST::NO_DISTR);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -10,3 +10,7 @@ int printParalleRegions(const char *fileName, std::vector<ParallelRegion*> ®i
|
|||||||
bool buildGraphFromUserDirectives(const std::vector<Statement*> &userDvmAlignDirs, DIST::GraphCSR<int, double, attrType> &G, DIST::Arrays<int> &allArrays, const std::map<DIST::Array*, std::set<DIST::Array*>> &arrayLinksByFuncCalls, const std::set<DIST::Array*>& alignedArrays, std::set<DIST::Array*>& addedArrays, const std::map<std::string, std::vector<FuncInfo*>>& funcsByFile);
|
bool buildGraphFromUserDirectives(const std::vector<Statement*> &userDvmAlignDirs, DIST::GraphCSR<int, double, attrType> &G, DIST::Arrays<int> &allArrays, const std::map<DIST::Array*, std::set<DIST::Array*>> &arrayLinksByFuncCalls, const std::set<DIST::Array*>& alignedArrays, std::set<DIST::Array*>& addedArrays, const std::map<std::string, std::vector<FuncInfo*>>& funcsByFile);
|
||||||
void clearRegionStaticData();
|
void clearRegionStaticData();
|
||||||
void calculateLinesOfCode(std::vector<ParallelRegion*> &allRegions);
|
void calculateLinesOfCode(std::vector<ParallelRegion*> &allRegions);
|
||||||
|
|
||||||
|
void propagateRegionInfo(std::map<std::tuple<int, std::string, std::string>, std::pair<DIST::Array*, DIST::ArrayAccessInfo*>>& declaredArrays,
|
||||||
|
const std::map<DIST::Array*, std::set<DIST::Array*>>& arrayLinksByFuncCall,
|
||||||
|
const std::vector<ParallelRegion*>& parallelRegions);
|
||||||
|
|||||||
@@ -741,7 +741,7 @@ static bool runAnalysis(SgProject &project, const int curr_regime, const bool ne
|
|||||||
else if (curr_regime == LOOP_DATA_DEPENDENCIES)
|
else if (curr_regime == LOOP_DATA_DEPENDENCIES)
|
||||||
doDependenceAnalysisOnTheFullFile(file, 1, 1, 1);
|
doDependenceAnalysisOnTheFullFile(file, 1, 1, 1);
|
||||||
else if (curr_regime == REMOVE_DVM_DIRS || curr_regime == REMOVE_DVM_DIRS_TO_COMMENTS || curr_regime == REMOVE_SPF_DIRS) {
|
else if (curr_regime == REMOVE_DVM_DIRS || curr_regime == REMOVE_DVM_DIRS_TO_COMMENTS || curr_regime == REMOVE_SPF_DIRS) {
|
||||||
bool removeDvm = (curr_regime == REMOVE_DVM_DIRS || curr_regime == REMOVE_DVM_DIRS);
|
bool removeDvm = (curr_regime == REMOVE_DVM_DIRS);
|
||||||
bool removeSpf = (curr_regime == REMOVE_SPF_DIRS);
|
bool removeSpf = (curr_regime == REMOVE_SPF_DIRS);
|
||||||
bool toComment = (curr_regime == REMOVE_DVM_DIRS_TO_COMMENTS);
|
bool toComment = (curr_regime == REMOVE_DVM_DIRS_TO_COMMENTS);
|
||||||
removeDvmSpfDirectives(file, removeDvm, removeSpf, toComment);
|
removeDvmSpfDirectives(file, removeDvm, removeSpf, toComment);
|
||||||
@@ -1264,6 +1264,8 @@ static bool runAnalysis(SgProject &project, const int curr_regime, const bool ne
|
|||||||
|
|
||||||
moveAllocatesInterproc(arrayLinksByFuncCalls);
|
moveAllocatesInterproc(arrayLinksByFuncCalls);
|
||||||
|
|
||||||
|
propagateRegionInfo(declaredArrays, arrayLinksByFuncCalls, subs_parallelRegions);
|
||||||
|
|
||||||
removeDistrStateFromDeadFunctions(allFuncInfo, declaredArrays);
|
removeDistrStateFromDeadFunctions(allFuncInfo, declaredArrays);
|
||||||
propagateArrayFlags(arrayLinksByFuncCalls, declaredArrays, SPF_messages);
|
propagateArrayFlags(arrayLinksByFuncCalls, declaredArrays, SPF_messages);
|
||||||
}
|
}
|
||||||
@@ -1681,30 +1683,11 @@ static bool runAnalysis(SgProject &project, const int curr_regime, const bool ne
|
|||||||
findDeadFunctionsAndFillCalls(allFuncInfo_IR, SPF_messages, true);
|
findDeadFunctionsAndFillCalls(allFuncInfo_IR, SPF_messages, true);
|
||||||
else if (curr_regime == GET_ALL_ARRAY_DECL)
|
else if (curr_regime == GET_ALL_ARRAY_DECL)
|
||||||
{
|
{
|
||||||
bool hasNonDefaultReg = false;
|
if (ignoreArrayDistributeState)
|
||||||
for (auto &elem : subs_parallelRegions)
|
|
||||||
if (elem->GetName() != "DEFAULT")
|
|
||||||
hasNonDefaultReg = true;
|
|
||||||
|
|
||||||
if (hasNonDefaultReg)
|
|
||||||
{
|
{
|
||||||
for (auto array : declaredArrays)
|
|
||||||
{
|
|
||||||
if (array.second.first->GetRegionsName().size() == 0)
|
|
||||||
array.second.first->SetDistributeFlag(DIST::NO_DISTR);
|
|
||||||
else if (array.second.first->GetRegionsName().size() == 1)
|
|
||||||
{
|
|
||||||
string regName = *array.second.first->GetRegionsName().begin();
|
|
||||||
convertToLower(regName);
|
|
||||||
if (regName == "default")
|
|
||||||
array.second.first->SetDistributeFlag(DIST::NO_DISTR);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (ignoreArrayDistributeState)
|
|
||||||
for (auto array : declaredArrays)
|
for (auto array : declaredArrays)
|
||||||
array.second.first->SetDistributeFlag(DIST::NO_DISTR);
|
array.second.first->SetDistributeFlag(DIST::NO_DISTR);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
else if (curr_regime == GCOV_PARSER)
|
else if (curr_regime == GCOV_PARSER)
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -234,9 +234,8 @@ static bool hasDvmParallel(SgStatement *func)
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
void transformAssumedSizeParameters(const map<string, vector<FuncInfo*>>& allFuncInfo)
|
static map<FuncInfo*, bool> createDvmParallelInfo(const map<string, vector<FuncInfo*>>& allFuncInfo) {
|
||||||
{
|
map<FuncInfo*, bool> hasDvmParallelMap;
|
||||||
map<string, vector<int>> assumedSizeArraysByFunc;
|
|
||||||
|
|
||||||
for (auto& funcByFile : allFuncInfo)
|
for (auto& funcByFile : allFuncInfo)
|
||||||
{
|
{
|
||||||
@@ -249,7 +248,63 @@ void transformAssumedSizeParameters(const map<string, vector<FuncInfo*>>& allFun
|
|||||||
if (prog == NULL)
|
if (prog == NULL)
|
||||||
continue;
|
continue;
|
||||||
|
|
||||||
if (!hasDvmParallel(prog))
|
hasDvmParallelMap[func] = hasDvmParallel(prog);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
bool changed = true;
|
||||||
|
while (changed)
|
||||||
|
{
|
||||||
|
changed = false;
|
||||||
|
|
||||||
|
for (auto& funcByFile : allFuncInfo)
|
||||||
|
{
|
||||||
|
for (auto& func : funcByFile.second)
|
||||||
|
{
|
||||||
|
if (!hasDvmParallelMap[func])
|
||||||
|
{
|
||||||
|
bool hasParallel = false;
|
||||||
|
for (auto& callF : func->callsFromV)
|
||||||
|
{
|
||||||
|
if (hasDvmParallelMap[callF])
|
||||||
|
{
|
||||||
|
hasParallel = true;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (hasParallel)
|
||||||
|
{
|
||||||
|
changed = true;
|
||||||
|
hasDvmParallelMap[func] = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return hasDvmParallelMap;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
void transformAssumedSizeParameters(const map<string, vector<FuncInfo*>>& allFuncInfo)
|
||||||
|
{
|
||||||
|
map<string, vector<int>> assumedSizeArraysByFunc;
|
||||||
|
const map<FuncInfo*, bool> hasDvmParallelMap = createDvmParallelInfo(allFuncInfo);
|
||||||
|
|
||||||
|
for (auto& funcByFile : allFuncInfo)
|
||||||
|
{
|
||||||
|
if (SgFile::switchToFile(funcByFile.first) == -1)
|
||||||
|
printInternalError(convertFileName(__FILE__).c_str(), __LINE__);
|
||||||
|
|
||||||
|
for (auto& func : funcByFile.second)
|
||||||
|
{
|
||||||
|
SgProgHedrStmt* prog = isSgProgHedrStmt(func->funcPointer->GetOriginal());
|
||||||
|
if (prog == NULL)
|
||||||
|
continue;
|
||||||
|
|
||||||
|
if (!hasDvmParallelMap.at(func))
|
||||||
continue;
|
continue;
|
||||||
|
|
||||||
vector<SgSymbol*> parNames;
|
vector<SgSymbol*> parNames;
|
||||||
@@ -259,7 +314,8 @@ void transformAssumedSizeParameters(const map<string, vector<FuncInfo*>>& allFun
|
|||||||
bool hasRefs = false;
|
bool hasRefs = false;
|
||||||
for (int z = 0; z < func->funcParams.countOfPars; ++z)
|
for (int z = 0; z < func->funcParams.countOfPars; ++z)
|
||||||
{
|
{
|
||||||
if (func->funcParams.parametersT[z] == ARRAY_T)
|
if (func->funcParams.parametersT[z] == ARRAY_T ||
|
||||||
|
func->funcParams.parametersT[z] == STRING_ARRAY_T)
|
||||||
{
|
{
|
||||||
auto s = prog->parameter(z);
|
auto s = prog->parameter(z);
|
||||||
const string name = s->identifier();
|
const string name = s->identifier();
|
||||||
|
|||||||
@@ -1,3 +1,3 @@
|
|||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
#define VERSION_SPF "2476"
|
#define VERSION_SPF "2479"
|
||||||
|
|||||||
Reference in New Issue
Block a user