mirror of
https://github.com/NGSolve/netgen.git
synced 2024-09-23 02:02:49 +05:00
352 lines
8.0 KiB
C++
352 lines
8.0 KiB
C++
#ifdef PARALLEL
|
|
|
|
#include "dlfcn.h"
|
|
|
|
|
|
// #include <mystdlib.h>
|
|
|
|
#include <meshing.hpp>
|
|
|
|
// #include "incvis.hpp"
|
|
#include <visual.hpp>
|
|
|
|
|
|
#ifdef PARALLELGL
|
|
|
|
#ifndef WIN32
|
|
|
|
#define GLX_GLXEXT_LEGACY
|
|
#define GLX_GLXEXT_PROTOTYPES
|
|
|
|
#include <X11/Xlib.h>
|
|
#include <X11/Xutil.h>
|
|
#include <X11/Xatom.h> /* for XA_RGB_DEFAULT_MAP atom */
|
|
#include <GL/glx.h>
|
|
#include <GL/glxext.h>
|
|
#endif
|
|
|
|
#endif
|
|
|
|
|
|
#include <meshing.hpp>
|
|
#include "../interface/writeuser.hpp"
|
|
|
|
void (*NGS_ParallelRun) (const string & message) = NULL;
|
|
|
|
|
|
namespace netgen
|
|
{
|
|
extern string ngdir;
|
|
|
|
#ifdef OPENGL
|
|
extern VisualSceneMesh vsmesh;
|
|
#endif
|
|
}
|
|
|
|
void Parallel_Exit();
|
|
|
|
|
|
namespace netgen {
|
|
extern std::shared_ptr<NetgenGeometry> ng_geometry;
|
|
extern shared_ptr<Mesh> mesh;
|
|
extern VisualSceneMesh vsmesh;
|
|
extern VisualSceneSolution vssolution;
|
|
extern Flags parameters;
|
|
extern DLL_HEADER MeshingParameters mparam;
|
|
}
|
|
|
|
using namespace netgen;
|
|
using netgen::RegisterUserFormats;
|
|
|
|
|
|
|
|
void ParallelRun()
|
|
{
|
|
string message;
|
|
MPI_Status status;
|
|
|
|
|
|
MPI_Comm_size(MPI_COMM_WORLD, &ntasks);
|
|
MPI_Comm_rank(MPI_COMM_WORLD, &id);
|
|
|
|
if (parameters.StringFlagDefined ("testout"))
|
|
testout = new ofstream (string("testout_proc") + id );
|
|
|
|
|
|
|
|
while ( true )
|
|
{
|
|
message = MyMPI_RecvCmd();
|
|
|
|
if ( message.compare(0, 3, "ngs") == 0 )
|
|
{
|
|
// PrintMessage ( 1, "Starting NgSolve routine ", message ) ;
|
|
|
|
if (NGS_ParallelRun == NULL)
|
|
{
|
|
static int timer = NgProfiler::CreateTimer ("load shared library ngsolve");
|
|
NgProfiler::RegionTimer reg (timer);
|
|
|
|
|
|
void * handle = dlopen ("libngsolve.so", RTLD_NOW | RTLD_GLOBAL);
|
|
if (!handle)
|
|
{
|
|
cerr << "cannot load shared library libngsolve.so" << endl;
|
|
exit(1);
|
|
}
|
|
|
|
NGS_ParallelRun = (void (*) (const string & message)) dlsym (handle, "NGS_ParallelRun");
|
|
|
|
if (!NGS_ParallelRun)
|
|
{
|
|
cerr << "cannot bind function NGS_ParallelRun" << endl;
|
|
exit(1);
|
|
}
|
|
}
|
|
(*NGS_ParallelRun) (message);
|
|
}
|
|
else if ( message == "mesh" )
|
|
{
|
|
VT_USER_START ("Mesh::ReceiveParallelMesh");
|
|
mesh.reset( new netgen::Mesh);
|
|
mesh->SendRecvMesh();
|
|
// vsmesh.SetMesh (mesh);
|
|
// vssolution.SetMesh (mesh);
|
|
SetGlobalMesh (mesh);
|
|
VT_USER_END ("Mesh::ReceiveParallelMesh");
|
|
}
|
|
|
|
else if ( message == "visualize" )
|
|
{
|
|
cout << "parallel message visualize depreciated" << endl;
|
|
}
|
|
|
|
else if ( message == "bcastparthread" )
|
|
{
|
|
MyMPI_Bcast (mparam.parthread);
|
|
}
|
|
|
|
|
|
#ifdef PARALLELGL
|
|
|
|
else if ( message == "redraw" )
|
|
{
|
|
// draw into the same GLX - drawing context
|
|
// works on parallel machine, but
|
|
// did not manage to get glXImportContextEXT working on Laptop (JS)
|
|
|
|
string redraw_cmd;
|
|
// MyMPI_Recv (redraw_cmd, 0, MPI_TAG_VIS);
|
|
redraw_cmd = MyMPI_RecvCmd();
|
|
|
|
// PrintMessage (1, "Redraw - ", redraw_cmd);
|
|
|
|
static string displname;
|
|
static int curDrawable, contextid;
|
|
|
|
static Display * display = NULL;
|
|
static GLXContext context;
|
|
static XVisualInfo * visinfo = 0;
|
|
|
|
// if (!display)
|
|
if (redraw_cmd == "init")
|
|
{
|
|
MyMPI_Recv (displname, 0, MPI_TAG_VIS);
|
|
MyMPI_Recv (curDrawable, 0, MPI_TAG_VIS);
|
|
MyMPI_Recv (contextid, 0, MPI_TAG_VIS);
|
|
|
|
display = XOpenDisplay (displname.c_str());
|
|
|
|
|
|
/*
|
|
PrintMessage (3, "displ - name = ", displname);
|
|
PrintMessage (3, "display = ", display,
|
|
" display props: ",
|
|
" screen w = ", XDisplayWidth (display, 0),
|
|
" , h = ", XDisplayHeight (display, 0));
|
|
*/
|
|
|
|
/*
|
|
Window win;
|
|
int wx, wy;
|
|
unsigned int ww, wh, bw, depth;
|
|
cout << "got drawable: " << curDrawable << ", contextid: " << contextid << endl;
|
|
|
|
cout << "get geometriy..." << endl;
|
|
XGetGeometry(display, curDrawable, &win,
|
|
&wx, &wy, &ww, &wh,
|
|
&bw, &depth);
|
|
cout << "have!" << endl;
|
|
|
|
cout << "P" << id << ": window-props: x = " << wx << ", y = " << wy
|
|
<< ", w = " << ww << ", h = " << wh << ", depth = " << depth << endl;
|
|
*/
|
|
|
|
#define VISUAL
|
|
#ifdef VISUAL
|
|
|
|
#ifdef VISINFO_OLD
|
|
//this does not seem to work anymore (but might still be with togl1.7?)
|
|
// make a new GLXContext
|
|
// first, generate a visual (copied from togl)
|
|
|
|
int attrib_list[1000];
|
|
|
|
# define MAX_ATTEMPTS 12
|
|
static int ci_depths[MAX_ATTEMPTS] = {
|
|
8, 4, 2, 1, 12, 16, 8, 4, 2, 1, 12, 16
|
|
};
|
|
static int dbl_flags[MAX_ATTEMPTS] = {
|
|
0, 0, 0, 0, 0, 0, 1, 1, 1, 1, 1, 1
|
|
};
|
|
|
|
/* It may take a few tries to get a visual */
|
|
|
|
for (int attempt = 0; attempt < MAX_ATTEMPTS; attempt++)
|
|
{
|
|
int attrib_count = 0;
|
|
attrib_list[attrib_count++] = GLX_USE_GL;
|
|
|
|
|
|
/* RGB[A] mode */
|
|
attrib_list[attrib_count++] = GLX_RGBA;
|
|
attrib_list[attrib_count++] = GLX_RED_SIZE;
|
|
attrib_list[attrib_count++] = 1;
|
|
attrib_list[attrib_count++] = GLX_GREEN_SIZE;
|
|
attrib_list[attrib_count++] = 1;
|
|
attrib_list[attrib_count++] = GLX_BLUE_SIZE;
|
|
attrib_list[attrib_count++] = 1;
|
|
// attrib_list[attrib_count++] = GLX_ALPHA_SIZE;
|
|
// attrib_list[attrib_count++] = 1;
|
|
|
|
attrib_list[attrib_count++] = GLX_DEPTH_SIZE;
|
|
attrib_list[attrib_count++] = 1;
|
|
|
|
attrib_list[attrib_count++] = GLX_DOUBLEBUFFER;
|
|
|
|
attrib_list[attrib_count++] = None;
|
|
|
|
visinfo = glXChooseVisual(display, 0,
|
|
attrib_list);
|
|
cout << "have vis?" << endl;
|
|
|
|
if (visinfo) {
|
|
/* found a GLX visual! */
|
|
// cout << "found VISINFO !!!" << endl;
|
|
cout << "found VISINFO !!!" << endl;
|
|
|
|
/*
|
|
int hi = 0;
|
|
std::cout << "attribs = ";
|
|
while (attrib_list[hi] != None)
|
|
std::cout << attrib_list[hi++] << " ";
|
|
std::cout << std::endl;
|
|
*/
|
|
|
|
break;
|
|
}
|
|
}
|
|
if (!visinfo)
|
|
cerr << "no VISINFO found" << endl;
|
|
|
|
#else
|
|
//get all possible confs
|
|
int nconfs;
|
|
auto cptr = glXGetFBConfigs (display,0, &nconfs);
|
|
Array<int> conf_ids(nconfs);
|
|
for(int k=0;k<nconfs;k++)
|
|
glXGetFBConfigAttrib(display, cptr[k], GLX_FBCONFIG_ID, &(conf_ids[k]));
|
|
|
|
//get drawable->FBConfig->visual
|
|
unsigned int d_fbc_id;
|
|
glXQueryDrawable( display, curDrawable, GLX_FBCONFIG_ID, &d_fbc_id);
|
|
GLXFBConfig d_fbc;
|
|
for(int k=0;k<nconfs;k++)
|
|
if(d_fbc_id==conf_ids[k])
|
|
d_fbc = cptr[k];
|
|
visinfo = glXGetVisualFromFBConfig(display,d_fbc);
|
|
#endif
|
|
|
|
// context = glXCreateContext( display, visinfo, 0, /* curContext, */ False );
|
|
context = glXCreateContext( display, visinfo, glXImportContextEXT ( display, contextid ), False);
|
|
glXMakeCurrent (display, curDrawable, context);
|
|
|
|
|
|
#else
|
|
// try to get GLXcontext from the master.
|
|
// this needs an indirect context (BUT DOES NOT WORK ????)
|
|
|
|
context = glXImportContextEXT ( display, contextid );
|
|
|
|
PrintMessage (1, "GLX-contextid = " , contextid,
|
|
" imported context ", context);
|
|
|
|
glXMakeCurrent (display, curDrawable, context);
|
|
#endif
|
|
|
|
// PrintMessage (1, "redraw - init complete");
|
|
}
|
|
|
|
if (redraw_cmd == "broadcast")
|
|
{
|
|
vsmesh.Broadcast ();
|
|
}
|
|
|
|
if (redraw_cmd == "linelist")
|
|
{
|
|
// glXMakeCurrent (display, curDrawable, context);
|
|
vsmesh.BuildLineList();
|
|
// glXMakeCurrent (display, None, NULL);
|
|
}
|
|
|
|
if (redraw_cmd == "filledlist")
|
|
{
|
|
vsmesh.BuildFilledList (false);
|
|
}
|
|
|
|
if (redraw_cmd == "solsurfellist")
|
|
{
|
|
vssolution.DrawSurfaceElements();
|
|
}
|
|
|
|
if (redraw_cmd == "solsurfellinelist")
|
|
{
|
|
vssolution.DrawSurfaceElementLines();
|
|
}
|
|
|
|
if (redraw_cmd == "clipplanetrigs")
|
|
{
|
|
vssolution.DrawClipPlaneTrigs();
|
|
}
|
|
|
|
if (redraw_cmd == "getminmax")
|
|
{
|
|
double hmin, hmax;
|
|
vssolution.GetMinMax (-1, -1, hmin, hmax);
|
|
}
|
|
}
|
|
#endif
|
|
|
|
|
|
|
|
else if ( message == "end" )
|
|
{
|
|
mesh.reset();
|
|
ng_geometry.reset();
|
|
break;
|
|
}
|
|
|
|
else
|
|
{
|
|
PrintMessage ( 1, "received unidentified message '" + message + "'\n");
|
|
break;
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
#endif
|