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

Task #5395: Now I'm making a mess of things by committing from the wrong working copy. Blast.

parent 34511a56
No related branches found
No related tags found
No related merge requests found
...@@ -2099,6 +2099,7 @@ CMake/variants/variants.cbt008 -text ...@@ -2099,6 +2099,7 @@ 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.); saxpy<__complex__ float,float> (n, 0.+0.i);
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.); saxpy<__complex__ double,double> (n, 0.+0.i);
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,7 +26,6 @@ ...@@ -26,7 +26,6 @@
//# 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,7 +68,6 @@ ...@@ -68,7 +68,6 @@
#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,10 +22,6 @@ set(_inputproc_sources ...@@ -22,10 +22,6 @@ 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,8 +71,9 @@ namespace LOFAR ...@@ -71,8 +71,9 @@ namespace LOFAR
void kill() void kill()
{ {
while (!stopped) { while (!stopped) {
// interrupt blocking system calls (most notably, read()) // Interrupt blocking system calls (most notably, read()),
// note that the thread will stick around until the end // possibly multiple in a row.
// 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;
...@@ -112,8 +113,16 @@ namespace LOFAR ...@@ -112,8 +113,16 @@ namespace LOFAR
static void init() static void init()
{ {
signal(SIGHUP, sighandler); // We avoid cancellation exception for OpenMP threads.
siginterrupt(SIGHUP, 1); // Allow signalling them ourselves to cancel blocking syscalls.
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,8 +111,7 @@ set_mvapich2_options() ...@@ -111,8 +111,7 @@ 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