@ -1,4 +1,5 @@
# include "MatchBoxPC.h"
# ifdef OMP
//#define DEBUG_HANG_
void processMatchedVerticesAndSendMessages (
MilanLongInt NLVer ,
@ -63,29 +64,29 @@ void processMatchedVerticesAndSendMessages(
{
while ( ! U . empty ( ) ) {
extractUChunk ( UChunkBeingProcessed , U , privateU ) ;
for ( MilanLongInt u : UChunkBeingProcessed ) {
# ifdef PRINT_DEBUG_INFO_
cout < < " \n ( " < < myRank < < " )u: " < < u ;
fflush ( stdout ) ;
# endif
if ( ( u > = StartIndex ) & & ( u < = EndIndex ) ) { // Process Only the Local Vertices
# ifdef COUNT_LOCAL_VERTEX
localVertices + + ;
# endif
// Get the Adjacency list for u
adj1 = verLocPtr [ u - StartIndex ] ; // Pointer
adj2 = verLocPtr [ u - StartIndex + 1 ] ;
for ( k = adj1 ; k < adj2 ; k + + ) {
option = - 1 ;
v = verLocInd [ k ] ;
if ( ( v > = StartIndex ) & & ( v < = EndIndex ) ) { // If Local Vertex:
# ifdef PRINT_DEBUG_INFO_
cout < < " \n ( " < < myRank < < " )v: " < < v < < " c(v)= " < < candidateMate [ v - StartIndex ] < < " Mate[v]: " < < Mate [ v ] ;
fflush ( stdout ) ;
@ -107,28 +108,28 @@ void processMatchedVerticesAndSendMessages(
GMate ,
Mate ,
Ghost2LocalMap ) ;
candidateMate [ v - StartIndex ] = w ;
# ifdef PRINT_DEBUG_INFO_
cout < < " \n ( " < < myRank < < " ) " < < v < < " Points to: " < < w ;
fflush ( stdout ) ;
# endif
// If found a dominating edge:
if ( w > = 0 ) {
if ( ( w < StartIndex ) | | ( w > EndIndex ) ) { // A ghost
# ifdef PRINT_DEBUG_INFO_
cout < < " \n ( " < < myRank < < " )Sending a request message: " ;
cout < < " \n ( " < < myRank < < " )Ghost is " < < w < < " Owner is: " < < findOwnerOfGhost ( w , verDistance , myRank , numProcs ) ;
# endif
option = 2 ;
if ( candidateMate [ NLVer + Ghost2LocalMap [ w ] ] = = v ) {
option = 1 ;
Mate [ v - StartIndex ] = w ; // v is a local vertex
GMate [ Ghost2LocalMap [ w ] ] = v ; // w is a ghost vertex
} // End of if CandidateMate[w] = v
} // End of if a Ghost Vertex
else { // w is a local vertex
@ -136,7 +137,7 @@ void processMatchedVerticesAndSendMessages(
option = 3 ;
Mate [ v - StartIndex ] = w ; // v is a local vertex
Mate [ w - StartIndex ] = v ; // w is a local vertex
# ifdef PRINT_DEBUG_INFO_
cout < < " \n ( " < < myRank < < " )MATCH: ( " < < v < < " , " < < w < < " ) " ;
fflush ( stdout ) ;
@ -152,7 +153,7 @@ void processMatchedVerticesAndSendMessages(
} // mateval < 0
} // End of if ( (v >= StartIndex) && (v <= EndIndex) ) //If Local Vertex:
else { // Neighbor is a ghost vertex
# pragma omp critical
{
if ( candidateMate [ NLVer + Ghost2LocalMap [ v ] ] = = u )
@ -161,7 +162,7 @@ void processMatchedVerticesAndSendMessages(
option = 5 ; // u is local
} // End of critical
} // End of Else //A Ghost Vertex
switch ( option )
{
case - 1 :
@ -179,20 +180,20 @@ void processMatchedVerticesAndSendMessages(
// Decrement the counter:
PROCESS_CROSS_EDGE ( & Counter [ Ghost2LocalMap [ w ] ] , SPtr ) ;
case 2 :
// Found a dominating edge, it is a ghost
ghostOwner = findOwnerOfGhost ( w , verDistance , myRank , numProcs ) ;
// Build the Message Packet:
// Message[0] = v; // LOCAL
// Message[1] = w; // GHOST
// Message[2] = REQUEST; // TYPE
// Send a Request (Asynchronous)
// MPI_Bsend(&Message[0], 3, TypeMap<MilanLongInt>(), ghostOwner, ComputeTag, comm);
( * msgActual ) + + ;
( * msgInd ) + + ;
privateQLocalVtx . push_back ( v ) ;
privateQGhostVtx . push_back ( w ) ;
privateQMsgType . push_back ( REQUEST ) ;
@ -210,94 +211,94 @@ void processMatchedVerticesAndSendMessages(
for ( k1 = adj11 ; k1 < adj12 ; k1 + + ) {
w = verLocInd [ k1 ] ;
if ( ( w < StartIndex ) | | ( w > EndIndex ) ) { // A ghost
# ifdef PRINT_DEBUG_INFO_
cout < < " \n ( " < < myRank < < " )Sending a failure message: " ;
cout < < " \n ( " < < myRank < < " )Ghost is " < < w < < " Owner is: " < < findOwnerOfGhost ( w , verDistance , myRank , numProcs ) ;
fflush ( stdout ) ;
# endif
ghostOwner = findOwnerOfGhost ( w , verDistance , myRank , numProcs ) ;
// Build the Message Packet:
// Message[0] = v; // LOCAL
// Message[1] = w; // GHOST
// Message[2] = FAILURE; // TYPE
// Send a Request (Asynchronous)
// MPI_Bsend(&Message[0], 3, TypeMap<MilanLongInt>(), ghostOwner, ComputeTag, comm);
( * msgActual ) + + ;
( * msgInd ) + + ;
privateQLocalVtx . push_back ( v ) ;
privateQGhostVtx . push_back ( w ) ;
privateQMsgType . push_back ( FAILURE ) ;
privateQOwner . push_back ( ghostOwner ) ;
} // End of if(GHOST)
} // End of for loop
break ;
case 5 :
default :
# ifdef PRINT_DEBUG_INFO_
cout < < " \n ( " < < myRank < < " )Sending a success message: " ;
cout < < " \n ( " < < myRank < < " )Ghost is " < < v < < " Owner is: " < < findOwnerOfGhost ( v , verDistance , myRank , numProcs ) < < " \n " ;
fflush ( stdout ) ;
# endif
ghostOwner = findOwnerOfGhost ( v , verDistance , myRank , numProcs ) ;
// Build the Message Packet:
// Message[0] = u; // LOCAL
// Message[1] = v; // GHOST
// Message[2] = SUCCESS; // TYPE
// Send a Request (Asynchronous)
// MPI_Bsend(&Message[0], 3, TypeMap<MilanLongInt>(), ghostOwner, ComputeTag, comm);
( * msgActual ) + + ;
( * msgInd ) + + ;
privateQLocalVtx . push_back ( u ) ;
privateQGhostVtx . push_back ( v ) ;
privateQMsgType . push_back ( SUCCESS ) ;
privateQOwner . push_back ( ghostOwner ) ;
break ;
} // End of switch
} // End of inner for
}
} // End of outer for
queuesTransfer ( U , privateU , QLocalVtx ,
QGhostVtx ,
QMsgType , QOwner , privateQLocalVtx ,
privateQGhostVtx ,
privateQMsgType ,
privateQOwner ) ;
} // End of while ( !U.empty() )
# ifdef COUNT_LOCAL_VERTEX
printf ( " Count local vertexes: %ld for thread %d of processor %d \n " ,
localVertices ,
omp_get_thread_num ( ) ,
myRank ) ;
# endif
} // End of parallel region
// Send the messages
# ifdef DEBUG_HANG_
cout < < myRank < < " Sending: " < < QOwner . size ( ) - initialSize < < " messages " < < endl ;
# endif
for ( int i = initialSize ; i < QOwner . size ( ) ; i + + ) {
Message [ 0 ] = QLocalVtx [ i ] ;
Message [ 1 ] = QGhostVtx [ i ] ;
Message [ 2 ] = QMsgType [ i ] ;
ghostOwner = QOwner [ i ] ;
//MPI_Bsend(&Message[0], 3, TypeMap<MilanLongInt>(), ghostOwner, ComputeTag, comm);
//cout << myRank<<" Sending to "<<ghostOwner<<endl;
MPI_Bsend ( & Message [ 0 ] , 3 , TypeMap < MilanLongInt > ( ) , ghostOwner , ComputeTag , comm ) ;
@ -306,3 +307,4 @@ void processMatchedVerticesAndSendMessages(
cout < < myRank < < " Done sending messages " < < endl ;
# endif
}
# endif
Cirdans-Home
11 months ago