Skip to content
Snippets Groups Projects
Commit 34511a56 authored by Marcel Loose's avatar Marcel Loose :sunglasses:
Browse files

Task #5395: Reverted commit r27942; it breaks tMPITransfer, which now gets...

Task #5395: Reverted commit r27942; it breaks tMPITransfer, which now gets killed by SIGALRM. Maybe the test needs fixing, though. I cannot judge.
parent a69a904c
No related branches found
No related tags found
No related merge requests found
...@@ -2099,7 +2099,6 @@ CMake/variants/variants.cbt008 -text ...@@ -2099,7 +2099,6 @@ CMake/variants/variants.cbt008 -text
CMake/variants/variants.cbt009 -text CMake/variants/variants.cbt009 -text
CMake/variants/variants.dop252 -text CMake/variants/variants.dop252 -text
CMake/variants/variants.dop256 -text CMake/variants/variants.dop256 -text
CMake/variants/variants.dop282 -text
CMake/variants/variants.fs0 -text CMake/variants/variants.fs0 -text
CMake/variants/variants.gpu01 -text CMake/variants/variants.gpu01 -text
CMake/variants/variants.gpu1 -text CMake/variants/variants.gpu1 -text
......
set(GNU_COMPILE_DEFINITIONS -DCL_USE_DEPRECATED_OPENCL_1_1_APIS)
set(ENV{CUDA_LIB_PATH} /usr/lib/nvidia-current)
# NVidia does not support GCC 4.7 and up
set(GNU_C /usr/bin/gcc-4.6 )
set(GNU_CXX /usr/bin/g++-4.6 )
set(GNU_Fortran /usr/bin/gfortran-4.6)
set(GNU_ASM /usr/bin/gcc-4.6 )
...@@ -82,13 +82,13 @@ int main (int argc, const char* argv[]) ...@@ -82,13 +82,13 @@ int main (int argc, const char* argv[])
cout<< "float,float " << n << endl; cout<< "float,float " << n << endl;
saxpy<float,float> (n, 0); saxpy<float,float> (n, 0);
cout<< "__complex__ float,float " << n << endl; cout<< "__complex__ float,float " << n << endl;
saxpy<__complex__ float,float> (n, 0.+0.i); saxpy<__complex__ float,float> (n, 0.);
cout<< "std::complex<float>,float " << n << endl; cout<< "std::complex<float>,float " << n << endl;
saxpy<std::complex<float>,float> (n, std::complex<float>()); saxpy<std::complex<float>,float> (n, std::complex<float>());
cout<< "double,double " << n << endl; cout<< "double,double " << n << endl;
saxpy<double,double> (n, 0); saxpy<double,double> (n, 0);
cout<< "__complex__ double,double " << n << endl; cout<< "__complex__ double,double " << n << endl;
saxpy<__complex__ double,double> (n, 0.+0.i); saxpy<__complex__ double,double> (n, 0.);
cout<< "std::complex<double>,double " << n << endl; cout<< "std::complex<double>,double " << n << endl;
saxpy<std::complex<double>,double> (n, std::complex<double>()); saxpy<std::complex<double>,double> (n, std::complex<double>());
cout<< "std::complex<double>,std::complex<double> " << n << endl; cout<< "std::complex<double>,std::complex<double> " << n << endl;
......
...@@ -26,6 +26,7 @@ ...@@ -26,6 +26,7 @@
//# Includes //# Includes
#include <Common/LofarLogger.h> #include <Common/LofarLogger.h>
#include <Common/lofar_string.h> #include <Common/lofar_string.h>
#include <Common/SystemUtil.h>
using namespace LOFAR; using namespace LOFAR;
......
...@@ -68,6 +68,7 @@ ...@@ -68,6 +68,7 @@
#include <Interface/Align.h> #include <Interface/Align.h>
#include <Interface/AlignedStdAllocator.h> #include <Interface/AlignedStdAllocator.h>
#include <vector> #include <vector>
#include <boost/noncopyable.hpp>
#include <FilterBank.h> #include <FilterBank.h>
#include <FIR.h> #include <FIR.h>
......
...@@ -22,6 +22,10 @@ set(_inputproc_sources ...@@ -22,6 +22,10 @@ set(_inputproc_sources
Station/RSPPacketFactory.cc Station/RSPPacketFactory.cc
) )
message(STATUS "**** MPI_FOUND = ${MPI_FOUND}")
message(STATUS "**** USE_MPI = ${USE_MPI}")
message(STATUS "**** HAVE_MPI = ${HAVE_MPI}")
if(MPI_FOUND) if(MPI_FOUND)
list(APPEND _inputproc_sources list(APPEND _inputproc_sources
Transpose/MPISendStation.cc Transpose/MPISendStation.cc
......
...@@ -71,9 +71,8 @@ namespace LOFAR ...@@ -71,9 +71,8 @@ namespace LOFAR
void kill() void kill()
{ {
while (!stopped) { while (!stopped) {
// Interrupt blocking system calls (most notably, read()), // interrupt blocking system calls (most notably, read())
// possibly multiple in a row. // note that the thread will stick around until the end
// Note that the thread will stick around until the end
// of pragma parallel, so the thread id is always valid // of pragma parallel, so the thread id is always valid
// once it has been set. // once it has been set.
pthread_t oldid = id; pthread_t oldid = id;
...@@ -113,16 +112,8 @@ namespace LOFAR ...@@ -113,16 +112,8 @@ namespace LOFAR
static void init() static void init()
{ {
// We avoid cancellation exception for OpenMP threads. signal(SIGHUP, sighandler);
// Allow signalling them ourselves to cancel blocking syscalls. siginterrupt(SIGHUP, 1);
struct sigaction sa;
sa.sa_handler = sighandler;
::sigemptyset(&sa.sa_mask);
sa.sa_flags = SA_RESTART;
int err = ::sigaction(SIGHUP, &sa, NULL);
if (err != 0) {
LOG_WARN("Failed to register a handler for SIGHUP: OpenMP threads may not terminate!");
}
} }
private: private:
......
...@@ -111,7 +111,8 @@ set_mvapich2_options() ...@@ -111,7 +111,8 @@ set_mvapich2_options()
done done
} }
if [ "@HAVE_MPI@" = "TRUE" ] #if [ "@HAVE_MPI@" = "TRUE" ]
if [ "@MPI_FOUND@" = "TRUE" ]
then then
MPIEXEC=@MPIEXEC@ MPIEXEC=@MPIEXEC@
MPIEXEC_PREFLAGS=@MPIEXEC_PREFLAGS@ MPIEXEC_PREFLAGS=@MPIEXEC_PREFLAGS@
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment