fdurastante
/
amg4psblas
mirror of https://github.com/sfilippone/amg4psblas.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Refactoring: eliminatino of SPtr inside processMessages

Browse Source
omp-walther
StefanoPetrilli 3 years ago
parent 1ea1be33ba
commit f17082b337
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File

15
amgprec/impl/aggregator/processMessages.cpp
Unescape Escape View File

@ -24,14 +24,13 @@ void processMessages(
MilanLongInt numGhostEdges, MilanLongInt numGhostEdges,
MilanLongInt u, MilanLongInt u,
MilanLongInt v, MilanLongInt v,
MilanLongInt *SPtr, MilanLongInt *S,
staticQueue &U) staticQueue &U)
{ {
MilanInt Sender; MilanInt Sender;
MPI_Status computeStatus; MPI_Status computeStatus;
MilanLongInt bundleSize, bundleCounter = 0, myCard = *myCardPtr, msgInd = *msgIndPtr, msgActual = *msgActualPtr, w; MilanLongInt bundleSize, bundleCounter = 0, myCard = *myCardPtr, msgInd = *msgIndPtr, msgActual = *msgActualPtr, w;
MilanLongInt S = *SPtr; // TODO refactor this
MilanLongInt adj11, adj12, k1; MilanLongInt adj11, adj12, k1;
MilanLongInt ghostOwner; MilanLongInt ghostOwner;
int error_codeC; int error_codeC;
@ -39,6 +38,7 @@ void processMessages(
char error_message[MPI_MAX_ERROR_STRING]; char error_message[MPI_MAX_ERROR_STRING];
int message_length; int message_length;
MilanLongInt message_type = 0; MilanLongInt message_type = 0;
// Buffer to receive bundled messages // Buffer to receive bundled messages
// Maximum messages that can be received from any processor is // Maximum messages that can be received from any processor is
// twice the edge cut: REQUEST; REQUEST+(FAILURE/SUCCESS) // twice the edge cut: REQUEST; REQUEST+(FAILURE/SUCCESS)
@ -61,7 +61,7 @@ void processMessages(
fflush(stdout); fflush(stdout);
#endif #endif
#ifdef PRINT_DEBUG_INFO_ #ifdef PRINT_DEBUG_INFO_
cout << "\n(" << myRank << ")About to begin Message processing phase ... S=" << S << endl; cout << "\n(" << myRank << ")About to begin Message processing phase ... *S=" << *S << endl;
fflush(stdout); fflush(stdout);
#endif #endif
#ifdef PRINT_DEBUG_INFO_ #ifdef PRINT_DEBUG_INFO_
@ -196,7 +196,7 @@ void processMessages(
cout << "\n(" << myRank << ")MATCH: (" << v << "," << u << ") " << endl; cout << "\n(" << myRank << ")MATCH: (" << v << "," << u << ") " << endl;
fflush(stdout); fflush(stdout);
#endif #endif
PROCESS_CROSS_EDGE(Counter, Ghost2LocalMap, u, &S); PROCESS_CROSS_EDGE(Counter, Ghost2LocalMap, u, S);
} // End of if ( candidateMate[v-StartIndex] == u )e } // End of if ( candidateMate[v-StartIndex] == u )e
} // End of if ( Mate[v] == -1 ) } // End of if ( Mate[v] == -1 )
} // End of REQUEST } // End of REQUEST
@ -209,7 +209,7 @@ void processMessages(
fflush(stdout); fflush(stdout);
#endif #endif
GMate[Ghost2LocalMap[u]] = EndIndex + 1; // Set a Dummy Mate to make sure that we do not (u is a ghost) GMate[Ghost2LocalMap[u]] = EndIndex + 1; // Set a Dummy Mate to make sure that we do not (u is a ghost)
PROCESS_CROSS_EDGE(Counter, Ghost2LocalMap, u, &S); PROCESS_CROSS_EDGE(Counter, Ghost2LocalMap, u, S);
#ifdef DEBUG_GHOST_ #ifdef DEBUG_GHOST_
if ((v < 0) || (v < StartIndex) || ((v - StartIndex) > NLVer)) if ((v < 0) || (v < StartIndex) || ((v - StartIndex) > NLVer))
{ {
@ -262,7 +262,7 @@ void processMessages(
fflush(stdout); fflush(stdout);
#endif #endif
// Decrement the counter: // Decrement the counter:
PROCESS_CROSS_EDGE(Counter, Ghost2LocalMap, w, &S); PROCESS_CROSS_EDGE(Counter, Ghost2LocalMap, w, S);
} // End of if CandidateMate[w] = v } // End of if CandidateMate[w] = v
} // End of if a Ghost Vertex } // End of if a Ghost Vertex
else else
@ -321,13 +321,12 @@ void processMessages(
fflush(stdout); fflush(stdout);
#endif #endif
GMate[Ghost2LocalMap[u]] = EndIndex + 1; // Set a Dummy Mate to make sure that we do not (u is a ghost) process this anymore GMate[Ghost2LocalMap[u]] = EndIndex + 1; // Set a Dummy Mate to make sure that we do not (u is a ghost) process this anymore
PROCESS_CROSS_EDGE(Counter, Ghost2LocalMap, u, &S); // Decrease the counter PROCESS_CROSS_EDGE(Counter, Ghost2LocalMap, u, S); // Decrease the counter
} // End of else: CASE III } // End of else: CASE III
} // End of else: CASE I } // End of else: CASE I
} }
*myCardPtr = myCard; *myCardPtr = myCard;
*SPtr = S;
*msgIndPtr = msgInd; *msgIndPtr = msgInd;
*msgActualPtr = msgActual; *msgActualPtr = msgActual;
return; return;

Write Preview
Loading…
Cancel
Save