48#include <nlohmann/json.hpp>
85REveManager::REveManager()
87 fExcHandler(nullptr), fVizDB(nullptr), fVizDBReplace(
kTRUE), fVizDBUpdate(
kTRUE), fGeometries(nullptr),
88 fGeometryAliases(nullptr),
96 throw eh +
"There can be only one REve!";
159 fWebWindow->SetDefaultPage(
"file:rootui5sys/eve7/index.html");
161 const char *gl_viewer =
gEnv->
GetValue(
"WebEve.GLViewer",
"RCore");
162 const char *gl_dblclick =
gEnv->
GetValue(
"WebEve.DblClick",
"Off");
165 fWebWindow->SetUserArgs(
Form(
"{ GLViewer: \"%s\", DblClick: \"%s\", HTimeout: %d, TableRowHeight: %d }", gl_viewer,
166 gl_dblclick, htimeout, table_row_height));
168 if (strcmp(gl_viewer,
"RCore") == 0)
173 [
this](
unsigned connid,
const std::string &arg) {
WindowData(connid, arg); },
243 printf(
"REveManager::RegisterRedraw3D() obsolete\n");
252 printf(
"REveManager::DoRedraw3D() obsolete\n");
260 printf(
"REveManager::FullRedraw3D() obsolete\n");
281 if (parent ==
nullptr) {
324 static const REveException eh(
"REveManager::AssignElementId ");
327 throw eh +
"ElementId map is full.";
350 msg[
"content"] =
"BrowseElement";
365 sel->RemoveImpliedSelectedReferencesTo(el);
369 Error(
"REveManager::PreDeleteElement",
"ImpliedSelected not zero (%d) after cleanup of selections.",
377 if (it->second == el) {
381 Error(
"PreDeleteElement",
"element ptr in ElementIdMap does not match the argument element.");
383 Error(
"PreDeleteElement",
"element id %u was not registered in ElementIdMap.", el->
fElementId);
385 Error(
"PreDeleteElement",
"element with 0 ElementId passed in.");
492 Error(
"SaveVizDB",
"filename does not match required format '(.+)\\.\\w+'.");
500 out <<
"void " << re[1] <<
"()\n";
502 out <<
" REveManager::Create();\n";
513 var_name.
Form(
"x%03d", var_id++);
536 printf(
"REveManager::GetGeometry loading: '%s' -> '%s'.\n",
filename.Data(), exp_filename.
Data());
544 Warning(
"REveManager::GetGeometry",
"TGeoManager is locked ... unlocking it.");
548 throw eh +
"TGeoManager::Import() failed for '" + exp_filename +
"'.";
558 TFile f(exp_filename,
"READ");
564 while ((vol = (
TGeoVolume *)next()) !=
nullptr) {
590 throw eh +
"geometry alias '" + alias +
"' not registered.";
621 while ((cls = (
TClass *)nextcl())) {
632 fWebWindow->GetServer()->AddLocation(locationName.c_str(), path.c_str());
684 class XThreadTimer :
public TTimer {
702 new XThreadTimer(func);
728 printf(
"connection established %u\n", connid);
736 printf(
"\nEVEMNG ............. streaming the world scene.\n");
752 printf(
"\nEVEMNG ............. streaming scene %s [%s]\n", scene->
GetCTitle(), scene->
GetCName());
757 printf(
" sending json, len = %d\n", (
int)scene->
fOutputJson.size());
779 if (i->fId == connid) {
786 printf(
"error, connection not found!");
788 printf(
"connection closed %u\n", connid);
820 if (conn.fId == connid) {
828 R__LOG_ERROR(
REveLog()) <<
"Internal error - no connection with id " << connid <<
" found";
833 if (arg.compare(
"__REveDoneChanges") == 0)
839 if (conn.fId == connid) {
852 else if (arg.compare( 0, 10,
"FILEDIALOG") == 0)
861 ::Info(
"REveManager::WindowData",
"MIR test %s\n", cj.dump().c_str());
863 std::string cmd = cj[
"mir"];
864 int id = cj[
"fElementId"];
865 std::string ctype = cj[
"class"];
876 fMIRqueue.push(std::shared_ptr<MIR>(
new MIR(cmd,
id, ctype, connid)));
879 std::cout <<
"Warning, REveManager::ScheduleMIR(). queue size " <<
fMIRqueue.size() << std::endl;
892 ::Info(
"REveManager::ExecuteCommand",
"MIR cmd %s", mir->fCmd.c_str());
896 if ( ! el)
throw eh +
"Element with id " + mir->fId +
" not found";
898 static const std::regex cmd_re(
"^(\\w[\\w\\d]*)\\(\\s*(.*)\\s*\\)\\s*;?\\s*$", std::regex::optimize);
900 std::regex_search(mir->fCmd,
m, cmd_re);
902 throw eh +
"Command string parse error: '" + mir->fCmd +
"'.";
904 static const TClass *elem_cls = TClass::GetClass<REX::REveElement>();
908 throw eh +
"Class '" + mir->fCtype +
"' not found.";
910 void *el_casted = call_cls->
DynamicCast(elem_cls, el,
false);
912 throw eh +
"Dynamic cast from REveElement to '" + mir->fCtype +
"' failed.";
914 std::string tag(mir->fCtype +
"::" +
m.str(1));
915 std::shared_ptr<TMethodCall> mc;
926 throw eh +
"Can not find TMethod matching '" +
m.str(1) +
"'.";
927 mc = std::make_shared<TMethodCall>(meth);
932 mc->Execute(el_casted,
m.str(2).c_str());
941 }
catch (std::exception &
e) {
956 if (
s->IsChanged())
s->StreamRepresentationChanges();
965 jobj[
"content"] =
"BeginChanges";
974 s->SendChangesToSubscribers();
978 jobj[
"content"] =
"EndChanges";
982 constexpr static std::array<const char *, numLevels> sTag{
983 {
"{unset-error-level please report}",
"FATAL",
"Error",
"Warning",
"Info",
"Debug"}};
985 jobj[
"log"] = nlohmann::json::array();
986 std::stringstream strm;
989 item[
"lvl"] = entry.fLevel;
990 int cappedLevel = std::min(
static_cast<int>(entry.fLevel), numLevels - 1);
991 strm <<
"Server " << sTag[cappedLevel] <<
":";
993 if (!entry.fLocation.fFuncName.empty())
994 strm <<
" " << entry.fLocation.fFuncName;
995 strm <<
" " << entry.fMessage;
996 item[
"msg"] = strm.str();
997 jobj[
"log"].push_back(item);
1010#if defined(R__LINUX)
1011 pthread_setname_np(pthread_self(),
"mir_exec");
1027 std::shared_ptr<MIR> mir =
fMIRqueue.front();
1053 scene->RemoveSubscriber(mir->fConnId);
1058 scene->AddSubscriber(std::make_unique<REveClient>(mir->fConnId,
fWebWindow));
1059 scene->StreamElements();
1060 Send(mir->fConnId, scene->fOutputJson);
1061 if (scene->fTotalBinarySize > 0)
1062 SendBinary(mir->fConnId, &scene->fOutputBinary[0], scene->fTotalBinarySize);
1118 if (conn.fId == cinnId)
1136 printf(
"EVE URL %s\n", url.c_str());
1179#if defined(_MSC_VER)
1230 Info(
"Handle",
"Exception %s",
ex->what());
thread_local MIR_TL_Data_t gMIRData
thread_local std::vector< RLogEntry > gEveLogEntries
#define R__LOG_ERROR(...)
static void update(gsl_integration_workspace *workspace, double a1, double b1, double area1, double error1, double a2, double b2, double area2, double error2)
R__EXTERN TApplication * gApplication
void DefaultErrorHandler(Int_t level, Bool_t abort_bool, const char *location, const char *msg)
The default error handler function.
void Info(const char *location, const char *msgfmt,...)
Use this function for informational messages.
void Error(const char *location, const char *msgfmt,...)
Use this function in case an error occurred.
void Warning(const char *location, const char *msgfmt,...)
Use this function in warning situations.
ErrorHandlerFunc_t SetErrorHandler(ErrorHandlerFunc_t newhandler)
Set an errorhandler function. Returns the old handler.
R__EXTERN TEveManager * gEve
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void data
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char filename
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h Atom_t Int_t ULong_t ULong_t unsigned char prop_list Atom_t sel
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t b
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t r
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize id
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h Atom_t Int_t ULong_t ULong_t unsigned char prop_list Atom_t Atom_t Atom_t Time_t UChar_t len
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t g
R__EXTERN TGeoManager * gGeoManager
R__EXTERN TGeoIdentity * gGeoIdentity
R__EXTERN TVirtualMutex * gInterpreterMutex
#define R__LOCKGUARD_CLING(mutex)
char * Form(const char *fmt,...)
Formats a string in a circular formatting buffer.
R__EXTERN TVirtualMutex * gSystemMutex
R__EXTERN TSystem * gSystem
#define R__LOCKGUARD2(mutex)
void DecDenyDestroy()
Decreases the deny-destroy count of the element.
const std::string & GetName() const
void SaveVizParams(std::ostream &out, const TString &tag, const TString &var)
Save visualization parameters for this element with given tag.
const char * GetCTitle() const
const char * GetCName() const
virtual void AddElement(REveElement *el)
Add el to the list of children.
virtual Bool_t SetRnrChildren(Bool_t rnr)
Set render state of this element's children, i.e.
virtual void DestroyElements()
Destroy all children of this element.
REveElement * FirstChild() const
Returns the first child element or 0 if the list is empty.
Bool_t HasChildren() const
void IncDenyDestroy()
Increases the deny-destroy count of the element.
virtual void CopyVizParams(const REveElement *el)
Copy visualization parameters from element el.
void SetVizModel(REveElement *model)
Set visualization-parameter model element.
void SetChildClass(TClass *c)
virtual void RemoveElement(REveElement *el)
Remove el from the list of children.
virtual void PropagateVizParamsToProjecteds()
Propagate visualization parameters to dependent elements.
REveException Exception-type thrown by Eve classes.
bool Emit(const RLogEntry &entry) override
Utility to stream loggs to client.
virtual EStatus Handle(std::exception &exc)
Handle exceptions deriving from REveException.
std::condition_variable fCV
void DisconnectEveViewer(REveViewer *)
void ScheduleMIR(const std::string &cmd, ElementId_t i, const std::string &ctype, unsigned connid)
void ClearROOTClassSaved()
Work-around uber ugly hack used in SavePrimitive and co.
ElementId_t fMaxElementIds
void RegisterGeometryAlias(const TString &alias, const TString &filename)
Register 'name' as an alias for geometry file 'filename'.
void PreDeleteElement(REveElement *element)
Called from REveElement prior to its destruction so the framework components (like object editor) can...
void ExecuteMIR(std::shared_ptr< MIR > mir)
ElementId_t fNumElementIds
REveSceneList * GetScenes() const
std::thread fMIRExecThread
void ClearAllSelections()
Clear all selection objects.
RExceptionHandler * fExcHandler
exception handler
REveSelection * fSelection
void AssignElementId(REveElement *element)
Assign a unique ElementId to given element.
TGeoManager * GetDefaultGeometry()
Get the default geometry.
static void ExecuteInMainThread(std::function< void()> func)
void GetServerStatus(REveServerStatus &)
void SetDefaultHtmlPage(const std::string &path)
Set content of default window HTML page.
void AddLocation(const std::string &name, const std::string &path)
Register new directory to THttpServer.
void Send(unsigned connid, const std::string &data)
bool ClientConnectionsFree() const
static void Terminate()
Properly terminate global REveManager.
REveElement * FindElementById(ElementId_t id) const
Lookup ElementId in element map and return corresponding REveElement*.
void SaveVizDB(const TString &filename)
Save visualization-parameter database to file filename.
TGeoManager * GetGeometryByAlias(const TString &alias)
Get geometry with given alias.
std::unordered_map< ElementId_t, REveElement * > fElementIdMap
static REveManager * Create()
If global REveManager* REX::gEve is not set initialize it.
std::unordered_map< std::string, std::shared_ptr< TMethodCall > > fMethCallMap
void WindowConnect(unsigned connid)
Process new connection from web window.
std::vector< Conn > fConnList
REveElement * FindVizDBEntry(const TString &tag)
Find a visualization-parameter database entry corresponding to tag.
ElementId_t fLastElementId
TGeoManager * GetGeometry(const TString &filename)
Get geometry with given filename.
void ConnectEveViewer(REveViewer *)
static void ErrorHandler(Int_t level, Bool_t abort, const char *location, const char *msg)
std::shared_ptr< ROOT::Experimental::RWebWindow > fWebWindow
REveSelection * fHighlight
std::queue< std::shared_ptr< MIR > > fMIRqueue
REveViewerList * fViewers
void LoadVizDB(const TString &filename, Bool_t replace, Bool_t update)
Load visualization-parameter database from file filename.
void DoRedraw3D()
Perform 3D redraw of scenes and viewers whose contents has changed.
void SendBinary(unsigned connid, const void *data, std::size_t len)
void AddElement(REveElement *element, REveElement *parent=nullptr)
Add an element.
void SetClientVersion(const std::string &version)
Set client version, used as prefix in scripts URL When changed, web browser will reload all related J...
void AddGlobalElement(REveElement *element, REveElement *parent=nullptr)
Add a global element, i.e.
void Redraw3D(Bool_t resetCameras=kFALSE, Bool_t dropLogicals=kFALSE)
void SceneSubscriberWaitingResponse(unsigned cinnId)
REveScene * SpawnNewScene(const char *name, const char *title="")
Create a new scene.
REveServerStatus fServerStatus
void RemoveElement(REveElement *element, REveElement *parent)
Remove element from parent.
virtual ~REveManager()
Destructor.
void WindowDisconnect(unsigned connid)
Process disconnect of web window.
void FullRedraw3D(Bool_t resetCameras=kFALSE, Bool_t dropLogicals=kFALSE)
Perform 3D redraw of all scenes and viewers.
REveElement * fSelectionList
REveViewer * SpawnNewViewer(const char *name, const char *title="")
Create a new GL viewer.
Bool_t InsertVizDBEntry(const TString &tag, REveElement *model, Bool_t replace, Bool_t update)
Insert a new visualization-parameter database entry.
void StreamSceneChangesToJson()
REveScene * GetWorld() const
void BrowseElement(ElementId_t id)
Activate EVE browser (summary view) for specified element id.
void WindowData(unsigned connid, const std::string &arg)
Process data from web window.
void Show(const RWebDisplayArgs &args="")
Show eve manager in specified browser.
REveSceneInfo Scene in a viewer.
REveScene * GetScene() const
void DestroyScenes()
Destroy all scenes and their contents.
void AcceptChanges(bool)
Set accept changes flag on all scenes.
void AddSubscriber(std::unique_ptr< REveClient > &&sub)
std::vector< char > fOutputBinary
!
void StreamRepresentationChanges()
Prepare data for sending element changes.
void SendChangesToSubscribers()
void BeginAcceptingChanges()
void EndAcceptingChanges()
void RemoveSubscriber(unsigned int)
REveSelection Container for selected and highlighted elements.
void SetIsHighlight(bool m)
static void Macro(const char *mac)
Execute macro 'mac'. Do not reload the macro.
REveViewerList List of Viewers providing common operations on REveViewer collections.
void AddElement(REveElement *el) override
Call base-class implementation.
REveViewer Reve representation of TGLViewer.
static std::shared_ptr< RFileDialog > Embedded(const std::shared_ptr< RWebWindow > &window, const std::string &args)
Create dialog instance to use as embedded dialog inside other widget Embedded dialog started on the c...
A diagnostic that can be emitted by the RLogManager.
Holds different arguments for starting browser with RWebDisplayHandle::Display() method.
static std::shared_ptr< RWebWindow > Create()
Create new RWebWindow Using default RWebWindowsManager.
virtual void Terminate(Int_t status=0)
Terminate the application by call TSystem::Exit() unless application has been told to return from Run...
virtual Color_t GetLineColor() const
Return the line color.
TClass instances represent classes, structs and namespaces in the ROOT type system.
void * DynamicCast(const TClass *base, void *obj, Bool_t up=kTRUE)
Cast obj of this class type up to baseclass cl if up is true.
TMethod * GetMethodAllAny(const char *method)
Return pointer to method without looking at parameters.
static TClass * GetClass(const char *name, Bool_t load=kTRUE, Bool_t silent=kFALSE)
Static method returning pointer to TClass of the specified class name.
The color creation and management class.
virtual void GetRGB(Float_t &r, Float_t &g, Float_t &b) const
static Int_t GetColor(const char *hexcolor)
Static method returning color number for color specified by hex color string of form: "#rrggbb",...
static void SetColorThreshold(Float_t t)
This method specifies the color threshold used by GetColor to retrieve a color.
virtual Int_t GetValue(const char *name, Int_t dflt) const
Returns the integer value for a resource.
A ROOT file is a suite of consecutive data records (TKey instances) with a well defined format.
An identity transformation.
The manager class for any TGeo geometry.
static void UnlockGeometry()
Unlock current geometry.
TObjArray * GetListOfVolumes() const
TObjArray * GetListOfMatrices() const
static Bool_t IsLocked()
Check lock state.
static TGeoManager * Import(const char *filename, const char *name="", Option_t *option="")
static function Import a geometry from a gdml or ROOT file
static void LockGeometry()
Lock current geometry so that no other geometry can be imported.
TGeoVolume * GetTopVolume() const
TGeoVolume, TGeoVolumeMulti, TGeoVolumeAssembly are the volume classes.
void VisibleDaughters(Bool_t vis=kTRUE)
set visibility for daughters
virtual void SetLineColor(Color_t lcolor)
Set the line color.
TMap implements an associative array of (key,value) pairs using a THashTable for efficient retrieval ...
void Add(TObject *obj) override
This function may not be used (but we need to provide it since it is a pure virtual in TCollection).
virtual void SetOwnerKeyValue(Bool_t ownkeys=kTRUE, Bool_t ownvals=kTRUE)
Set ownership for keys and values.
TObject * FindObject(const char *keyname) const override
Check if a (key,value) pair exists with keyname as name of the key.
TObject * GetValue(const char *keyname) const
Returns a pointer to the value associated with keyname as name of the key.
Each ROOT class (see TClass) has a linked list of methods.
TObject * At(Int_t idx) const override
Collectable string class.
Mother of all ROOT objects.
Wrapper for PCRE library (Perl Compatible Regular Expressions).
Int_t Match(const TString &s, UInt_t start=0)
Runs a match on s against the regex 'this' was created with.
Class used by TMap to store (key,value) pairs.
void SetValue(TObject *val)
const char * Data() const
void Form(const char *fmt,...)
Formats a string using a printf style format descriptor.
void Beep(Int_t freq=-1, Int_t duration=-1, Bool_t setDefault=kFALSE)
Beep for duration milliseconds with a tone of frequency freq.
virtual Bool_t ExpandPathName(TString &path)
Expand a pathname getting rid of special shell characters like ~.
virtual int GetPid()
Get process id.
virtual void AddTimer(TTimer *t)
Add timer to list of system timers.
virtual int GetProcInfo(ProcInfo_t *info) const
Returns cpu and memory used by this process into the ProcInfo_t structure.
virtual TTimer * RemoveTimer(TTimer *t)
Remove timer from list of system timers.
Handles synchronous and a-synchronous timer events.
RVec< PromoteType< T > > trunc(const RVec< T > &v)
R__EXTERN REveManager * gEve
@ kDebug
Debug information; only useful for developers; can have added verbosity up to 255-kDebug.
RLogChannel & REveLog()
Log channel for Eve diagnostics.
void(off) SmallVectorTemplateBase< T
void function(const Char_t *name_, T fun, const Char_t *docstring=0)
static constexpr double s
std::vector< REveScene * > removedWatch
std::vector< REveScene * > addedWatch
std::time_t fTLastDisconnect
std::time_t fTLastConnect