apaam/mlpack
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

It turns out my MPI implementation supports only single-thread, so I need a mutex around MPI_IProbe.

Browse Source
This commit is contained in:
Dongryeol Lee
2010-10-11 18:43:42 +00:00
parent 78ec7be210
commit 29cc71da99
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fastlib/trunk/contrib/dongryel/thesis_research/core/table/mailbox.h
+8
View File
@@ -12,6 +12,10 @@
namespace core {
namespace table {
/** @brief The global variable for each MPI call.
*/
boost::mutex mpi_mutex;
class Table;
class PointInbox {
@@ -92,6 +96,7 @@ class PointInbox {
bool has_outstanding_point_messages() {
int flag;
MPI_Status status;
boost::unique_lock<boost::mutex> lock_in(core::table::mpi_mutex);
MPI_Iprobe(
MPI_ANY_SOURCE,
core::table::DistributedTableMessage::RECEIVE_POINT,
@@ -102,6 +107,7 @@ class PointInbox {
bool termination_signal_arrived() {
int flag;
MPI_Status status;
boost::unique_lock<boost::mutex> lock_in(core::table::mpi_mutex);
MPI_Iprobe(
MPI_ANY_SOURCE,
core::table::DistributedTableMessage::TERMINATE_POINT_INBOX,
@@ -228,6 +234,7 @@ class PointRequestMessageBox {
bool termination_signal_arrived() {
int flag;
MPI_Status status;
boost::unique_lock<boost::mutex> lock_in(core::table::mpi_mutex);
MPI_Iprobe(
MPI_ANY_SOURCE,
core::table::DistributedTableMessage::TERMINATE_POINT_REQUEST_MESSAGE_BOX,
@@ -258,6 +265,7 @@ class PointRequestMessageBox {
bool has_outstanding_point_request_messages() {
int flag;
MPI_Status status;
boost::unique_lock<boost::mutex> lock_in(core::table::mpi_mutex);
MPI_Iprobe(
MPI_ANY_SOURCE,
core::table::DistributedTableMessage::REQUEST_POINT,