/* Copyright (C) 2021-2023 Free Software Foundation, Inc. Contributed by Oracle. This file is part of GNU Binutils. This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 3, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, 51 Franklin Street - Fifth Floor, Boston, MA 02110-1301, USA. */ #include "config.h" #include #include #include #include // creat #include // sleep #include // pthread_exit #include // wait #include #include "DbeApplication.h" #include "Histable.h" #include "ipcio.h" #include "Dbe.h" #include "DbeSession.h" #include "DbeThread.h" #include "DbeView.h" int ipc_flags = 0; IPCTraceLevel ipc_trace_level = TRACE_LVL_0; int ipc_single_threaded_mode = 0; const char *IPC_PROTOCOL_UNKNOWN = "IPC_PROTOCOL_UNKNOWN"; const char *IPC_PROTOCOL_CURR = IPC_PROTOCOL_STR; char const *ipc_protocol = NULL; DbeThreadPool *ipcThreadPool; extern int currentRequestID; extern int currentChannelID; extern BufferPool *responseBufferPool; extern bool cancelNeeded (int); extern void reexec (); /* Simple implementation of support for cancel of open experiment. Since we have only one cancellable operation supported at this moment, we are using just a global variable. As we support more and more cancellable ops we need a more sophisticated data struture such as a mt-safe array to keep track of all cancellable requests/channels and update the supporting routines - setCancellableChannel, cancelNeeded (in ipcio.cc) setCancelRequestedCh */ int cancellableChannelID = 0xFFFFFFFF; int cancelRequestedChannelID; static const char *table_name (int); #define VSIZE(v) ((long long) ((v) ? (v)->size() : 0)) inline const char* bool2str (bool v) { return v ? "true" : "false"; } inline const char* str2str (const char* v) { return v ? v : "NULL"; } inline const char* str2s (const char* v) { return v ? v : ""; } inline DbeView * getView (int index) { return dbeSession->getView (index); } extern "C" { typedef void (*SignalHandler)(int); } /* * Fatal error handlers */ static int fatalErrorCode = 1; static int fatalErrorCounter = 0; static void *fatalErrorContext = 0; static siginfo_t *fatalErrorInfo = 0; static char *fatalErrorDynamicMemory = NULL; extern "C" void fatalErrorHadler (int sig, siginfo_t *info, void *context) { if (fatalErrorCounter > 0) { // Need synchronization here //sleep(10); // Wait 10 seconds to make sure previous processing is done return; // exit(fatalErrorCode); // Already in processing } fatalErrorCounter = 1; fatalErrorCode = sig; fatalErrorContext = context; fatalErrorInfo = info; // Free reserved memory if (fatalErrorDynamicMemory != NULL) { free (fatalErrorDynamicMemory); fatalErrorDynamicMemory = NULL; } // Get process ID pid_t pid = getpid (); // Create dump file char fname[128]; snprintf (fname, sizeof (fname), "/tmp/gprofng.%lld", (long long) pid); mkdir (fname, 0700); snprintf (fname, sizeof (fname), "/tmp/gprofng.%lld/crash.sig%d.%lld", (long long) pid, sig, (long long) pid); // Dump stack trace in background using pstack char buf[256]; snprintf (buf, sizeof (buf), "/usr/bin/pstack %lld > %s.pstack", (long long) pid, fname); system (buf); int fd = creat (fname, 0600); if (fd >= 0) { // Write error message dbe_write (fd, "A fatal error has been detected by er_print: Signal %d\n", sig); dbe_write (fd, "Protocol Version: %d\n", IPC_VERSION_NUMBER); close (fd); } wait (0); // wait for pstack //sleep(10); // Wait 10 seconds to make sure processing of fatal error is done // Exit with correct status exit (fatalErrorCode); } // SIGABRT Handler extern "C" void sigABRT_handler (int sig, siginfo_t *info, void *context) { fatalErrorHadler (sig, info, context); pthread_exit (&fatalErrorCode); } // SIGSEGV Handler extern "C" void sigSEGV_handler (int sig, siginfo_t *info, void *context) { //if (fatalErrorCounter > 0) sleep(1); // Wait 1 second fatalErrorHadler (sig, info, context); pthread_exit (&fatalErrorCode); } // SIGTERM Handler extern "C" void sigterm_handler (int sig, siginfo_t *info, void *context); struct sigaction old_sigterm_handler; volatile int term_flag; int error_flag; extern "C" void sigterm_handler (int, siginfo_t *, void *) { if (fatalErrorCounter > 0) { //sleep(10); // Wait 10 seconds to make sure processing of fatal error is done //return; // Fatal error processing will exit it pthread_exit (&fatalErrorCode); } term_flag = 1; } #define ipc_log ipc_default_log #define ipc_request_trace ipc_request_log #define ipc_response_trace ipc_response_log static const char *ipc_log_name = NULL; static const char *ipc_request_log_name = NULL; static const char *ipc_response_log_name = NULL; FILE *requestLogFileP = stderr; FILE *responseLogFileP = stderr; hrtime_t begin_time; long long delta_time = 0; int ipc_delay_microsec = 0; void ipc_default_log (const char *fmt, ...) { if (!ipc_log_name || !ipc_flags) return; if (ipc_trace_level >= TRACE_LVL_3) { hrtime_t cur_time = gethrtime (); unsigned long long time_stamp = (cur_time - begin_time) / 1000000 + delta_time; fprintf (stderr, "%7llu: ", time_stamp); } va_list vp; va_start (vp, fmt); vfprintf (stderr, fmt, vp); va_end (vp); fflush (stderr); } extern "C" void sigint_handler (int sig, siginfo_t *info, void *context); struct sigaction old_sigint_handler; extern "C" void sigint_handler (int, siginfo_t *, void *) { ipc_log ("SIGINT signal happens\n"); } void ipc_request_log (IPCTraceLevel trace_level, const char *fmt, ...) { if (!ipc_request_log_name || !ipc_flags || trace_level > ipc_trace_level) return; fprintf (responseLogFileP, "thr: %llu ", (unsigned long long) pthread_self ()); if (ipc_trace_level >= TRACE_LVL_3) { hrtime_t cur_time = gethrtime (); unsigned long long time_stamp = (cur_time - begin_time) / 1000000 + delta_time; fprintf (requestLogFileP, "%7llu: ", time_stamp); } va_list vp; va_start (vp, fmt); vfprintf (requestLogFileP, fmt, vp); va_end (vp); fflush (requestLogFileP); } void ipc_response_log (IPCTraceLevel trace_level, const char *fmt, ...) { if (!ipc_response_log_name || !ipc_flags || trace_level > ipc_trace_level) return; fprintf (responseLogFileP, "thr: %llu ", (unsigned long long) pthread_self ()); if (ipc_trace_level >= TRACE_LVL_3) { hrtime_t cur_time = gethrtime (); unsigned long long time_stamp = (cur_time - begin_time) / 1000000 + delta_time; fprintf (responseLogFileP, "%7llu: ", time_stamp); } va_list vp; va_start (vp, fmt); vfprintf (responseLogFileP, fmt, vp); va_end (vp); fflush (responseLogFileP); } #ifdef IPC_LOG void ipc_dump (char *s, Vector *v) { if (v == NULL) { ipc_log (" Vector %s is NULL\n", str2s (s)); return; } ipc_log (" Vector %s size=%lld\n", str2s (s), VSIZE (v)); for (int i = 0; i < v->size (); i++) ipc_log (" [%d]: %s\n", i, bool2str (v->fetch (i))); } void ipc_dump (char *s, Vector *v) { if (v == NULL) { ipc_log (" Vector %s is NULL\n", str2s (s)); return; } ipc_log (" Vector %s size=%lld\n", str2s (s), VSIZE (v)); for (int i = 0; i < v->size (); i++) { String str = v->fetch (i); ipc_log (" [%d]: '%s'\n", i, str2str (str)); } } void ipc_dump (char *s, Vector *v) { if (v == NULL) { ipc_log (" Vector %s is NULL\n", str2s (s)); return; } ipc_log (" Vector %s size=%lld\n", str2s (s), VSIZE (v)); for (int i = 0; i < v->size (); i++) ipc_log (" [%d]: 0x%08llx\n", i, (long long) (v->fetch (i))); } #else #define ipc_dump(s, v) #endif static MetricList * readMetricListV2 (int dbevindex, IPCrequest* req) { MetricType mtype = (MetricType) readInt (req); Vector *type = (Vector*)readArray (req); Vector *subtype = (Vector*)readArray (req); Vector *sort = (Vector*)readArray (req); Vector *vis = (Vector*)readArray (req); Vector *cmd = (Vector*)readArray (req); Vector *expr_spec = (Vector*)readArray (req); Vector *legends = (Vector*)readArray (req); MetricList *mlist = dbeGetMetricListV2 (dbevindex, mtype, type, subtype, sort, vis, cmd, expr_spec, legends); return mlist; } static void setCancellableChannel (int chID) { cancellableChannelID = chID; } /* Add more entries here for other cancellable operations */ static void checkCancellableOp (char *inp, IPCrequest* req) { if (!strcmp (inp, "setFilterStr")) setCancellableChannel (currentChannelID); else if (!strcmp (inp, "openExperimentList")) setCancellableChannel (currentChannelID); else if (!strcmp (inp, "getFiles") || !strcmp (inp, "getFileAttributes")) { setCancellableChannel (currentChannelID); req->setCancelImmediate (); } } /* This is what used to be the core of ipc_mainLoop before asynch ipc. Read the details of the request from the request buffer: name, args etc do the work by calling the appropriate dbe routine(s) and write the response to a response buffer and queue it up in the response queue */ int ipc_doWork (void *arg) { IPCrequest *req = (IPCrequest *) arg; currentRequestID = req->getRequestID (); currentChannelID = req->getChannelID (); req->setStatus (IN_PROGRESS); String inp = readString (req); if (inp == NULL) { ipc_log ("NULL ipc command received, exiting\n"); return 0; } ipc_log ("ipc: %s Req %x Ch %x\n", inp, currentRequestID, currentChannelID); checkCancellableOp (inp, req); if (!strcmp (inp, "initApplication")) { bool nbm = readBoolean (req); String arg1 = readString (req); String arg2 = readString (req); Vector *arg3 = (Vector*)readArray (req); ipc_log (" nbm: %s, arg1: '%s', arg2: '%s'\n", bool2str (nbm), str2str (arg1), str2str (arg2)); ipc_dump ("arg3", arg3); // set the session to be interactive dbeSession->set_interactive (true); if (nbm) theApplication->set_name ("analyzer-NBM"); else theApplication->set_name ("analyzer"); // XXX Why does it reset the install directory???? Or a licensing directory??? // Vector *res = theDbeApplication->initApplication (arg1, arg2, &setProgress); Vector *res = theDbeApplication->initApplication (NULL, NULL, &setProgress); writeArray (res, req); free (arg1); free (arg2); destroy (arg3); destroy (res); } else if (!strcmp (inp, "syncTime")) { long long anl_time = readLong (req); hrtime_t cur_time = gethrtime (); long long time_stamp = (cur_time - begin_time) / 1000000; delta_time = anl_time - time_stamp; ipc_log (" syncTime %llu %llu \n", anl_time, delta_time); writeString (NULL, req); } else if (!strcmp (inp, "getInitMessages")) { Vector *res = dbeGetInitMessages (); ipc_log (" returned = %lld msgs\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "reExec")) { ipc_log (" started reexec()\n"); reexec (); } else if (!strcmp (inp, "dbeCreateDirectories")) { String arg1 = readString (req); // path ipc_log (" arg = %s\n", arg1); String res = dbeCreateDirectories (arg1); writeString (res, req); free (arg1); free (res); } else if (!strcmp (inp, "dbeDeleteFile")) { String arg1 = readString (req); // path ipc_log (" arg = %s\n", arg1); String res = dbeDeleteFile (arg1); writeString (res, req); free (arg1); free (res); } else if (!strcmp (inp, "dbeReadFile")) { String arg1 = readString (req); ipc_log (" arg = %s\n", arg1); // path Vector *res = dbeReadFile (arg1); writeArray (res, req); free (arg1); destroy (res); } else if (!strcmp (inp, "dbeWriteFile")) { String arg1 = readString (req); // path String arg2 = readString (req); // contents ipc_log (" arg1 = %s arg2 = %s\n", arg1, arg2); int res = dbeWriteFile (arg1, arg2); writeInt (res, req); free (arg1); } else if (!strcmp (inp, "getExpPreview")) { // XXX add another argument == DbeView index String arg1 = readString (req); ipc_log (" arg = %s\n", arg1); Vector *res = dbeGetExpPreview (0, arg1); writeArray (res, req); free (arg1); destroy (res); } else if (!strcmp (inp, "getFileAttributes")) { String arg1 = readString (req); // filename String arg2 = readString (req); // format ipc_log (" arg1 = %s arg2 = %s\n", arg1, arg2); String res = dbeGetFileAttributes (arg1, arg2); writeString (res, req); free (arg1); free (arg2); free (res); } else if (!strcmp (inp, "getFiles")) { String arg1 = readString (req); // dirname String arg2 = readString (req); // format ipc_log (" arg1 = %s arg2 = %s\n", arg1, arg2); String res = dbeGetFiles (arg1, arg2); writeString (res, req); free (arg1); free (arg2); free (res); } else if (!strcmp (inp, "getOSFamily")) writeString ("Linux", req); else if (!strcmp (inp, "getRunningProcesses")) { String arg1 = readString (req); // format ipc_log (" arg = %s\n", arg1); String res = dbeGetRunningProcesses (arg1); writeString (res, req); free (arg1); free (res); } else if (!strcmp (inp, "getCurrentDirectory")) { char buf [2048]; String res = getcwd (buf, (size_t) sizeof (buf)); // Get current directory writeString (res, req); } else if (!strcmp (inp, "getHomeDirectory")) { String res = getenv ("HOME"); // Get HOME directory writeString (res, req); } else if (!strcmp (inp, "setCurrentDirectory")) { String arg1 = readString (req); // dirname ipc_log (" arg = %s\n", arg1); int res = chdir (arg1); // Change directory writeInt (res, req); free (arg1); } else if (!strcmp (inp, "getLocale")) { String res = setlocale (LC_ALL, ""); // Get locale writeString (res, req); } else if (!strcmp (inp, "setLocale")) { String arg1 = readString (req); // locale ipc_log (" arg = %s\n", arg1); String res = setlocale (LC_ALL, arg1); // Set locale writeString (res, req); free (arg1); } else if (!strcmp (inp, "readRCFile")) { int arg1 = readInt (req); String arg2 = readString (req); // file name ipc_log (" arg1=%d, arg2=%s\n", arg1, arg2); String res = dbeReadRCFile (arg1, arg2); // Read RC File writeString (res, req); free (res); } else if (!strcmp (inp, "dbeGetExpParams")) { // XXX add another argument == DbeView index String arg1 = readString (req); ipc_log (" arg = %s\n", arg1); String res = dbeGetExpParams (0, arg1); writeString (res, req); free (arg1); free (res); } else if (!strcmp (inp, "getExperimentsGroups")) { Vector*> *groups = dbeGetExperimensGroups (); writeArray (groups, req); destroy (groups); } else if (!strcmp (inp, "setExperimentsGroups")) { Vector*> *groups = (Vector*> *)readArray (req); ipc_log (" groups.size = %lld\n", VSIZE (groups)); char *msg_str = dbeSetExperimentsGroups (groups); writeString (msg_str, req); free (msg_str); destroy (groups); } else if (!strcmp (inp, "dropExperiment")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); ipc_log (" arg = %d, exps = %lld\n", arg1, VSIZE (arg2)); char *res = dbeDropExperiment (arg1, arg2); writeString (res, req); free (res); delete arg2; } else if (!strcmp (inp, "getUserExpId")) { Vector *arg = (Vector*)readArray (req); ipc_log (" expIds = %lld\n", VSIZE (arg)); Vector *res = dbeGetUserExpId (arg); writeArray (res, req); delete res; } else if (!strcmp (inp, "getFounderExpId")) { Vector *arg = (Vector*)readArray (req); ipc_log (" expIds = %lld\n", VSIZE (arg)); Vector *res = dbeGetFounderExpId (arg); writeArray (res, req); delete res; } else if (!strcmp (inp, "getExpGroupId")) { Vector *arg = (Vector*)readArray (req); ipc_log (" expIds = %lld\n", VSIZE (arg)); Vector *res = dbeGetExpGroupId (arg); writeArray (res, req); delete res; } else if (!strcmp (inp, "getExpsProperty")) { String arg = readString (req); Vector *res = dbeGetExpsProperty (arg); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getExpName")) { // XXX add argument == DbeView index Vector *res = dbeGetExpName (0); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getExpState")) { // XXX add argument == DbeView index Vector *res = dbeGetExpState (0); writeArray (res, req); delete res; } else if (!strcmp (inp, "getExpEnable")) { int arg1 = readInt (req); ipc_log (" arg1 = %d\n", arg1); Vector *res = dbeGetExpEnable (arg1); writeArray (res, req); delete res; } else if (!strcmp (inp, "setExpEnable")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); ipc_log (" arg1=%d\n", arg1); ipc_dump ("arg2", arg2); bool b = dbeSetExpEnable (arg1, arg2); writeBoolean (b, req); ipc_log (" dbeSetExpEnable returns %s\n", bool2str (b)); delete arg2; } else if (!strcmp (inp, "getExpInfo")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetExpInfo (arg1); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getViewModeEnable")) { bool res = dbeGetViewModeEnable (); writeBoolean (res, req); } else if (!strcmp (inp, "getJavaEnable")) { bool res = dbeGetJavaEnable (); writeBoolean (res, req); } else if (!strcmp (inp, "updateNotes")) { int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); String arg4 = readString (req); bool arg5 = readBoolean (req); ipc_log (" args = %d, %d\n", arg1, arg2); int i = dbeUpdateNotes (arg1, arg2, arg3, arg4, arg5); writeInt (i, req); } else if (!strcmp (inp, "getLoadObjectList")) { int arg1 = readInt (req); ipc_log (" arg = %d\n", arg1); Vector *res = dbeGetLoadObjectList (arg1); if (res == NULL) ipc_log (" returning = NULL for LoadObjectList\n"); else { Vector *s = (Vector *) res->fetch (0); ipc_log (" returning = %lld vectors for %lld LoadObjects\n", VSIZE (res), VSIZE (s)); } writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getLoadObjectName")) { int arg1 = readInt (req); ipc_log (" arg = %d\n", arg1); Vector *res = dbeGetLoadObjectName (arg1); ipc_log (" returning = %lld strings\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getTabListInfo")) { int arg1 = readInt (req); ipc_log (" arg = %d\n", arg1); Vector *res = dbeGetTabListInfo (arg1); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getSearchPath")) { // XXX add argument == DbeView index ipc_log (" no args\n"); Vector *res = dbeGetSearchPath (0); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "setSearchPath")) { // XXX add another argument == DbeView index Vector *res = (Vector*)readArray (req); ipc_log (" %lld strings\n", VSIZE (res)); dbeSetSearchPath (0, res); writeString (NULL, req); destroy (res); } else if (!strcmp (inp, "getPathmaps")) { Vector *res = dbeGetPathmaps (0); ipc_log (" returns = %lld objects, number of pathmaps = %lld\n", VSIZE (res), VSIZE ((Vector*)res->fetch (0))); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "setPathmaps")) { Vector *from = (Vector*)readArray (req); Vector *to = (Vector*)readArray (req); char *res = dbeSetPathmaps (from, to); writeString (res, req); free (res); if (from) { from->destroy (); delete from; } if (to) { to->destroy (); delete to; } } else if (!strcmp (inp, "addPathmap")) { // XXX add another argument == DbeView index String arg1 = readString (req); String arg2 = readString (req); ipc_log (" args = '%s', '%s'\n", arg1 ? arg1 : "NULL", arg2 ? arg2 : "NULL"); char *res = dbeAddPathmap (0, arg1, arg2); ipc_log (" returns = '%s'\n", (res != NULL ? res : "NULL")); writeString (res, req); free (arg1); free (arg2); } else if (!strcmp (inp, "getMsg")) { int arg1 = readInt (req); int arg2 = readInt (req); ipc_log (" args = %d, %d\n", arg1, arg2); String res = dbeGetMsg (arg1, arg2); ipc_log (" returns = '%s'\n", (res != NULL ? res : "")); writeString (res, req); free (res); } else if (!strcmp (inp, "initView")) { int arg1 = readInt (req); int arg2 = readInt (req); ipc_log (" new view = %d; clone of view %d\n", arg1, arg2); dbeInitView (arg1, arg2); writeString (NULL, req); } else if (!strcmp (inp, "disposeWindow")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); dbeDeleteView (arg1); writeString (NULL, req); } #if 0 else if (!strcmp (inp, "createMapfile")) { int arg1 = readInt (); String arg2 = readString (); int arg3 = readInt (); ipc_log (" args = %d, %s, %d\n", arg1, arg2, arg3); String res = dbeCreateMapfile (arg1, arg2, arg3); writeString (res); free (arg2); free (res); } #endif else if (!strcmp (inp, "setCompareModeV2")) { int dbevindex = readInt (req); int cmp_mode = readInt (req); getView (dbevindex)->set_compare_mode (cmp_mode); writeResponseGeneric (RESPONSE_STATUS_SUCCESS, currentRequestID, currentChannelID); } else if (!strcmp (inp, "getCompareModeV2")) { int dbevindex = readInt (req); int res = CMP_DISABLE; if (dbeSession->expGroups && dbeSession->expGroups->size () > 1) res = getView (dbevindex)->get_compare_mode (); ipc_log (" %s: %d returns %d\n", inp, dbevindex, res); writeInt (res, req); } else if (!strcmp (inp, "getRefMetricsV2")) { Vector *res = dbeGetRefMetricsV2 (); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "setCurMetricsV2")) { int dbevindex = readInt (req); int cmp_mode = readInt (req); MetricList *mlist = readMetricListV2 (dbevindex, req); getView (dbevindex)->reset_metric_list (mlist, cmp_mode); writeResponseGeneric (RESPONSE_STATUS_SUCCESS, currentRequestID, currentChannelID); } else if (!strcmp (inp, "getCurMetricsV2")) { int arg1 = readInt (req); MetricType arg2 = (MetricType) readInt (req); ipc_log (" args = %d, %d\n", arg1, arg2); Vector *res = dbeGetCurMetricsV2 (arg1, arg2); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getRefMetricTree")) { int dbevindex = readInt (req); bool include_unregistered = readBoolean (req); ipc_log (" args = %d, %d\n", dbevindex, include_unregistered); Vector *res = dbeGetRefMetricTree (dbevindex, include_unregistered); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getRefMetricTreeValues")) { int dbevindex = readInt (req); Vector *metcmds = (Vector*)readArray (req); Vector *nonmetcmds = (Vector*)readArray (req); ipc_log (" args = %d, metcmds->size()=%lld, nonmetcmds->size()=%lld\n", dbevindex, VSIZE (metcmds), VSIZE (nonmetcmds)); ipc_dump ("metcmds", metcmds); ipc_dump ("nonmetcmds", nonmetcmds); Vector *res = dbeGetRefMetricTreeValues (dbevindex, metcmds, nonmetcmds); #ifdef IPC_LOG if (res != NULL) ipc_log (" returns = %lld objects, length = %lld\n", VSIZE (res), VSIZE (((Vector*)res->fetch (0)))); else ipc_log (" returns NULL\n"); #endif writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getOverviewText")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetOverviewText (arg1); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "setSort")) { int arg1 = readInt (req); int arg2 = readInt (req); MetricType arg3 = (MetricType) readInt (req); bool arg4 = readBoolean (req); ipc_log (" args = %d, %d, %d, %c\n", arg1, arg2, arg3, (arg4 ? 'T' : 'F')); dbeSetSort (arg1, arg2, arg3, arg4); writeString (NULL, req); } else if (!strcmp (inp, "getAnoValue")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetAnoValue (arg1); writeArray (res, req); delete res; } else if (!strcmp (inp, "setAnoValue")) { int arg1 = readInt (req); ipc_log (" args = %d, array\n", arg1); Vector *arg2 = (Vector*)readArray (req); dbeSetAnoValue (arg1, arg2); writeString (NULL, req); delete arg2; } else if (!strcmp (inp, "getNameFormat")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); int b = dbeGetNameFormat (arg1); writeInt (b, req); } else if (!strcmp (inp, "getSoName")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); bool b = dbeGetSoName (arg1); writeBoolean (b, req); } else if (!strcmp (inp, "setNameFormat")) { int arg1 = readInt (req); int arg2 = readInt (req); bool arg3 = readBoolean (req); ipc_log (" args = %d, %d, %d\n", arg1, arg2, arg3); dbeSetNameFormat (arg1, arg2, arg3); writeString (NULL, req); } else if (!strcmp (inp, "getViewMode")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); int i = dbeGetViewMode (arg1); ipc_log (" returns = %d\n", i); writeInt (i, req); } else if (!strcmp (inp, "setViewMode")) { int arg1 = readInt (req); int arg2 = readInt (req); ipc_log (" args = %d, %d\n", arg1, arg2); dbeSetViewMode (arg1, arg2); writeString (NULL, req); } else if (!strcmp (inp, "getTLValue")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetTLValue (arg1); ipc_log (" returns = %lld void*'s\n", VSIZE (res)); writeArray (res, req); delete res; } else if (!strcmp (inp, "setTLValue")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); String tldata_cmd = readString (req); int entity_prop_id = readInt (req); int align = readInt (req); int depth = readInt (req); dbeSetTLValue (arg1, tldata_cmd, entity_prop_id, align, depth); writeString (NULL, req); free (tldata_cmd); } else if (!strcmp (inp, "getExpFounderDescendants")) { Vector *res = dbeGetExpFounderDescendants (); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getExpSelection")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetExpSelection (arg1); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "setFilterStr")) { int arg1 = readInt (req); String arg2 = readString (req); ipc_log (" args = %d, %s\n", arg1, arg2); String res = dbeSetFilterStr (arg1, arg2); ipc_log (" returns = '%s'\n", res ? res : "NULL"); writeString (res, req); free (arg2); free (res); } else if (!strcmp (inp, "getFilterStr")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); String res = dbeGetFilterStr (arg1); ipc_log (" returns = '%s'\n", res ? res : "NULL"); writeString (res, req); free (res); } else if (!strcmp (inp, "validateFilterExpression")) { String arg1 = readString (req); int res = dbeValidateFilterExpression (arg1); ipc_log (" validateFilterExpression('%s') returned %d\n", str2str (arg1), res); free (arg1); writeInt (res, req); } else if (!strcmp (inp, "getFilterKeywords")) { int dbevindex = readInt (req); Vector*res = dbeGetFilterKeywords (dbevindex); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getFilters")) { int arg1 = readInt (req); int arg2 = readInt (req); ipc_log (" args: view = %d, experiment = %d\n", arg1, arg2); Vector*res = dbeGetFilters (arg1, arg2); ipc_log (" -- returned %lld Filters\n", VSIZE (res)); writeArray (res, req); delete res; } else if (!strcmp (inp, "updateFilters")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); Vector *arg3 = (Vector*)readArray (req); ipc_log ("arg1=%d arg2->size()=%lld arg3->size()=%lld\n", arg1, VSIZE (arg2), VSIZE (arg3)); ipc_dump ("arg2", arg2); ipc_dump ("arg3", arg3); bool b = dbeUpdateFilters (arg1, arg2, arg3); writeBoolean (b, req); ipc_log (" returns %s\n", (b == true ? "true" : "false")); delete arg2; delete arg3; } else if (!strcmp (inp, "getLoadObjectState")) { int arg1 = readInt (req); ipc_log (" args = %d \n", arg1); Vector *res = dbeGetLoadObjectState (arg1); ipc_log (" returning = %lld int's\n", VSIZE (res)); writeArray (res, req); delete res; } else if (!strcmp (inp, "setLoadObjectState")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); ipc_log (" args = %d, %lld objects\n", arg1, VSIZE (arg2)); dbeSetLoadObjectState (arg1, arg2); writeString (NULL, req); delete arg2; } else if (!strcmp (inp, "setLoadObjectDefaults")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); dbeSetLoadObjectDefaults (arg1); writeString (NULL, req); } else if (!strcmp (inp, "getMemTabSelectionState")) { int arg1 = readInt (req); ipc_log (" arg = %d\n", arg1); Vector *res = dbeGetMemTabSelectionState (arg1); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "setMemTabSelectionState")) { int arg1 = readInt (req); Vector *arg2 = (Vector *)readArray (req); ipc_log (" args = %d\n arg2 = %lld objects\n", arg1, VSIZE (arg2)); dbeSetMemTabSelectionState (arg1, arg2); writeString (NULL, req); destroy (arg2); } else if (!strcmp (inp, "getIndxTabSelectionState")) { int arg1 = readInt (req); ipc_log (" arg = %d\n", arg1); Vector *res = dbeGetIndxTabSelectionState (arg1); ipc_log (" -- returned %lld-vector [bool]\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "setIndxTabSelectionState")) { int arg1 = readInt (req); Vector *arg2 = (Vector *)readArray (req); ipc_log (" args = %d\n arg2 = %lld objects\n", arg1, VSIZE (arg2)); dbeSetIndxTabSelectionState (arg1, arg2); writeString (NULL, req); destroy (arg2); } else if (!strcmp (inp, "getTabSelectionState")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetTabSelectionState (arg1); writeArray (res, req); delete res; } else if (!strcmp (inp, "setTabSelectionState")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); ipc_log (" args = %d\n arg2 = %lld objects\n", arg1, VSIZE (arg2)); dbeSetTabSelectionState (arg1, arg2); writeString (NULL, req); delete arg2; } else if (!strcmp (inp, "getMemObjects")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetMemObjects (arg1); #ifdef IPC_LOG if (res == NULL) ipc_log (" -- returned NULL\n"); else { Vector *mo_types = (Vector *)res->fetch (0); ipc_log (" -- returned %lld-vector [ %lld-vectors]\n", VSIZE (res), VSIZE (mo_types)); } #endif writeArray (res, req); destroy (res); } else if (!strcmp (inp, "loadMachineModel")) { String arg1 = readString (req); #ifdef IPC_LOG ipc_log (" arg = `%s'\n", arg1); #endif String sts = dbeLoadMachineModel (arg1); #ifdef IPC_LOG ipc_log (" returns '%s'\n", sts ? sts : "NULL"); #endif writeString (sts, req); free (arg1); } else if (!strcmp (inp, "getMachineModel")) { String sts = dbeGetMachineModel (); #ifdef IPC_LOG ipc_log (" returns '%s'\n", sts ? sts : "NULL"); #endif writeString (sts, req); } else if (!strcmp (inp, "getCPUVerMachineModel")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetCPUVerMachineModel (arg1); writeArray (res, req); ipc_log (" returns %lld char*'s\n", VSIZE (res)); destroy (res); } else if (!strcmp (inp, "listMachineModels")) { Vector *res = dbeListMachineModels (); #ifdef IPC_LOG if (res != NULL) ipc_log (" returns = %lld strings\n", VSIZE (res)); else ipc_log (" returns NULL\n"); #endif writeArray (res, req); destroy (res); } else if (!strcmp (inp, "defineMemObj")) { String arg1 = readString (req); String arg2 = readString (req); String arg3 = readString (req); String arg4 = readString (req); #ifdef IPC_LOG ipc_log (" args = %s, %s, %s, %s\n", arg1, arg2, arg3 == NULL ? "NULL" : arg3, arg4 == NULL ? "NULL" : arg4); #endif String sts = dbeDefineMemObj (arg1, arg2, NULL, arg3, arg4); #ifdef IPC_LOG ipc_log (" returns '%s'\n", sts ? sts : "NULL"); #endif writeString (sts, req); free (arg1); free (arg2); free (arg3); free (arg4); } else if (!strcmp (inp, "deleteMemObj")) { String arg1 = readString (req); #ifdef IPC_LOG ipc_log (" args = %s\n", arg1); #endif String sts = dbeDeleteMemObj (arg1); #ifdef IPC_LOG ipc_log (" returns '%s'\n", sts ? sts : "NULL"); #endif writeString (sts, req); free (arg1); } else if (!strcmp (inp, "getIndxObjDescriptions")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetIndxObjDescriptions (arg1); #ifdef IPC_LOG if (res == NULL) ipc_log (" -- returned NULL\n"); else { Vector *indxo_types = (Vector *)res->fetch (0); ipc_log (" -- returned %lld-vector [ %lld-vectors]\n", VSIZE (res), VSIZE (indxo_types)); } #endif writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getCustomIndxObjects")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetCustomIndxObjects (arg1); #ifdef IPC_LOG if (res == NULL) ipc_log (" -- returned NULL\n"); else { Vector *indxo_names = (Vector *)res->fetch (0); ipc_log (" -- returned %lld-vector [ %lld-vectors]\n", VSIZE (res), VSIZE (indxo_names)); } #endif writeArray (res, req); destroy (res); } else if (!strcmp (inp, "defineIndxObj")) { String arg1 = readString (req); String arg2 = readString (req); String arg3 = readString (req); String arg4 = readString (req); ipc_log (" args = %s, %s, %s, %s\n", arg1, arg2, arg3 == NULL ? "NULL" : arg3, arg4 == NULL ? "NULL" : arg4); String sts = dbeDefineIndxObj (arg1, arg2, arg3, arg4); ipc_log (" returns '%s'\n", sts ? sts : "NULL"); writeString (sts, req); free (arg1); free (arg2); free (arg3); free (arg4); } else if (!strcmp (inp, "setSelObj")) { int arg1 = readInt (req); Obj arg2 = readObject (req); int arg3 = readInt (req); int arg4 = readInt (req); ipc_log (" args = %d, %ld, %s, %d\n", arg1, (long) arg2, table_name (arg3), arg4); dbeSetSelObj (arg1, arg2, arg3, arg4); writeString (NULL, req); } else if (!strcmp (inp, "setSelObjV2")) { int arg1 = readInt (req); uint64_t arg2 = readLong (req); ipc_log (" args = %d, %lld\n", arg1, (long long) arg2); dbeSetSelObjV2 (arg1, arg2); writeString (NULL, req); } else if (!strcmp (inp, "getSelObj")) { int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); ipc_log (" args = %d, %s, %d\n", arg1, table_name (arg2), arg3); Obj i = dbeGetSelObj (arg1, arg2, arg3); ipc_log (" returns = %ld (0x%08lx)\n", (long) i, (long) i); writeObject (i, req); } else if (!strcmp (inp, "getSelObjV2")) { int arg1 = readInt (req); String arg2 = readString (req); ipc_log (" arg1 = %d agr2 = %s\n", arg1, arg2 ? arg2 : "NULL"); Obj res = dbeGetSelObjV2 (arg1, arg2); ipc_log (" returns = %lld\n", (long long) res); writeObject (res, req); free (arg2); } else if (!strcmp (inp, "getSelObjIO")) { int arg1 = readInt (req); uint64_t arg2 = readLong (req); int arg3 = readInt (req); ipc_log (" arg1 = %d, arg2 = %lld, arg3 = %d\n", arg1, (long long) arg2, arg3); Vector *res = dbeGetSelObjIO (arg1, arg2, arg3); writeArray (res, req); delete res; } else if (!strcmp (inp, "getSelObjsIO")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); int arg3 = readInt (req); ipc_log (" arg1 = %d, arg2 size = %lld, arg3 = %d\n", arg1, VSIZE (arg2), arg3); Vector *res = dbeGetSelObjsIO (arg1, arg2, arg3); writeArray (res, req); delete res; } else if (!strcmp (inp, "getSelObjHeapTimestamp")) { int arg1 = readInt (req); uint64_t arg2 = readLong (req); ipc_log (" arg1 = %d, arg2 = %llu\n", arg1, (unsigned long long) arg2); uint64_t st = dbeGetSelObjHeapTimestamp (arg1, arg2); ipc_log (" returns = %llu\n", (unsigned long long) st); writeLong (st, req); } else if (!strcmp (inp, "getSelObjHeapUserExpId")) { int arg1 = readInt (req); uint64_t arg2 = readLong (req); ipc_log (" arg1 = %d, arg2 = %llu\n", arg1, (unsigned long long) arg2); int userExpId = dbeGetSelObjHeapUserExpId (arg1, arg2); ipc_log (" returns = %d\n", userExpId); writeInt (userExpId, req); } else if (!strcmp (inp, "getSelIndex")) { int arg1 = readInt (req); Obj arg2 = readObject (req); int arg3 = readInt (req); int arg4 = readInt (req); ipc_log (" args = %d, 0x%08lx, %s, %d\n", arg1, (long) arg2, table_name (arg3), arg4); int i = dbeGetSelIndex (arg1, arg2, arg3, arg4); ipc_log (" returns = %d\n", i); writeInt (i, req); } else if (!strcmp (inp, "printData")) { int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); String arg4 = readString (req); String arg5 = readString (req); ipc_log (" args = %d, %s, %d, `%s', `%s'\n", arg1, table_name (arg2), arg3, (arg4 == NULL ? "NULL" : arg4), (arg5 == NULL ? "NULL" : arg5)); String res = dbePrintData (arg1, arg2, arg3, arg4, arg5, NULL); writeString (res, req); free (arg4); free (arg5); free (res); } else if (!strcmp (inp, "getPrintLimit")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); int i = dbeGetPrintLimit (arg1); ipc_log (" returns = %d\n", i); writeInt (i, req); } else if (!strcmp (inp, "setPrintLimit")) { int arg1 = readInt (req); int arg2 = readInt (req); ipc_log (" args = %d, %d\n", arg1, arg2); String res = dbeSetPrintLimit (arg1, arg2); writeString (res, req); free (res); } else if (!strcmp (inp, "getPrintMode")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); int i = dbeGetPrintMode (arg1); ipc_log (" returns = %d\n", i); writeInt (i, req); } else if (!strcmp (inp, "setPrintMode")) { int arg1 = readInt (req); String arg2 = readString (req); ipc_log (" args = %d, %s\n", arg1, arg2); String res = dbeSetPrintMode (arg1, arg2); writeString (res, req); free (arg2); free (res); } else if (!strcmp (inp, "getPrintDelim")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); char i = dbeGetPrintDelim (arg1); ipc_log (" returns = %c\n", i); writeInt ((int) i, req); } else if (!strcmp (inp, "getHotMarks")) { int arg1 = readInt (req); int arg2 = readInt (req); ipc_log (" args = %d, %s (%d) \n", arg1, table_name (arg2), arg2); Vector *res = dbeGetHotMarks (arg1, arg2); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getHotMarksInc")) { int arg1 = readInt (req); int arg2 = readInt (req); ipc_log (" args = %d, %s (%d) \n", arg1, table_name (arg2), arg2); Vector *res = dbeGetHotMarksInc (arg1, arg2); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getSummaryHotMarks")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); int arg3 = readInt (req); ipc_log (" args = %d, 0x%llx, %s (%d)\n", arg1, (long long) arg2, table_name (arg3), arg3); Vector *res = dbeGetSummaryHotMarks (arg1, arg2, arg3); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getFuncId")) { int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); int arg4 = readInt (req); ipc_log (" args = %d, %s, %d, %d\n", arg1, table_name (arg2), arg3, arg4); Vector *res = dbeGetFuncId (arg1, arg2, arg3, arg4); writeArray (res, req); delete res; } else if (!strcmp (inp, "getFuncCalleeInfo")) { int arg1 = readInt (req); int arg2 = readInt (req); Vector *arg3 = (Vector*)readArray (req); int arg4 = readInt (req); ipc_log (" args = %d, %s, %lld, %d\n", arg1, table_name (arg2), VSIZE (arg3), arg4); Vector *res = dbeGetFuncCalleeInfo (arg1, arg2, arg3, arg4); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getFuncCallerInfo")) { int arg1 = readInt (req); int arg2 = readInt (req); Vector *arg3 = (Vector*)readArray (req); int arg4 = readInt (req); ipc_log (" args = %d, %s, %lld, %d\n", arg1, table_name (arg2), VSIZE (arg3), arg4); Vector *res = dbeGetFuncCallerInfo (arg1, arg2, arg3, arg4); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "setFuncData")) { int arg1 = readInt (req); Obj arg2 = readObject (req); int arg3 = readInt (req); int arg4 = readInt (req); ipc_log (" args = %d, %ld, %s, %d\n", arg1, (long) arg2, table_name (arg3), arg4); int i = dbeSetFuncData (arg1, arg2, arg3, arg4); ipc_log (" returns = %d\n", i); writeInt (i, req); } else if (!strcmp (inp, "setFuncDataV2")) { int dbevindex = readInt (req); Obj sel_obj = readObject (req); int type = readInt (req); int subtype = readInt (req); Vector *longs = new Vector(2); Vector *strings = new Vector(2); longs->append (dbeSetFuncData (dbevindex, sel_obj, type, subtype)); strings->append (dbeGetMsg (dbevindex, ERROR_MSG)); String sf_name = NULL; long long sf_id = 0; switch (type) { case DSP_SOURCE: case DSP_DISASM: { Histable *obj = (Histable *) sel_obj; if (obj) { Histable *sf = obj->convertto (Histable::SOURCEFILE); if (sf) { sf_id = sf->id; sf_name = dbe_strdup (sf->get_name ()); } } break; } } longs->append (sf_id); strings->append (sf_name); ipc_log (" setFuncData(%d, %ld, %s, %d) returns (%lld, %lld)\n (%s, %s)\n", dbevindex, (long) sel_obj, table_name (type), subtype, longs->get (0), longs->get (1), STR (strings->get (0)), STR (strings->get (1))); Vector *res = new Vector(2); res->append (longs); res->append (strings); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getFuncList")) { int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); ipc_log (" args = %d, %s, %d\n", arg1, table_name (arg2), arg3); Vector *res = dbeGetFuncList (arg1, arg2, arg3); #ifdef IPC_LOG if (res != NULL) ipc_log (" returns = %lld objects, length = %lld\n", VSIZE (res), VSIZE ((Vector*)res->fetch (0))); else ipc_log (" returns NULL\n"); #endif writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getFuncListV2")) { int dbevindex = readInt (req); int mtype = readInt (req); Obj sel_obj = readObject (req); int type = readInt (req); int subtype = readInt (req); Vector *res = dbeGetFuncListV2 (dbevindex, mtype, sel_obj, type, subtype); ipc_log (" args = %d 0x%x %ld, %s, %d returns = %d objects, length = %d\n", dbevindex, mtype, (long) sel_obj, table_name (type), subtype, (int) (res ? res->size () : 0), (int) (res ? ((Vector*)res->fetch (0))->size () : 0)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getFuncListMini")) { int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); ipc_log (" args = %d, %s, %d\n", arg1, table_name (arg2), arg3); Vector *res = dbeGetFuncListMini (arg1, arg2, arg3); #ifdef IPC_LOG if (res != NULL) ipc_log (" returns = %lld objects, length = %lld\n", VSIZE (res), VSIZE ((Vector*)res->fetch (0))); else ipc_log (" returns NULL\n"); #endif writeArray (res, req); destroy (res); } else if (!strcmp (inp, "dbeGetTotals")) { int dbevindex = readInt (req); int dsptype = readInt (req); int subtype = readInt (req); Vector *res = dbeGetTotals (dbevindex, dsptype, subtype); ipc_log (" dbeGetTotals(%d, %d, %d) returns %lld objects\n", dbevindex, dsptype, subtype, VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getComparableObjsV2")) { int arg1 = readInt (req); Obj arg2 = readObject (req); int arg3 = readInt (req); Vector *res = dbeGetComparableObjsV2 (arg1, arg2, arg3); ipc_log (" args = %d 0x%lx %d\n", arg1, (long) arg2, arg3); ipc_dump ("getComparableObjsV2:res", res); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "dbeConvertSelObj")) { Obj obj = readObject (req); int type = readInt (req); Obj res = dbeConvertSelObj (obj, type); ipc_log (" args = %lld %d res=%lld \n", (long long) obj, type, (long long) res); writeObject (res, req); } else if (!strcmp (inp, "getTableDataV2")) { int arg1 = readInt (req); String arg2 = readString (req); String arg3 = readString (req); String arg4 = readString (req); String arg5 = readString (req); Vector *arg6 = (Vector*)readArray (req); ipc_log (" args = %d, %s, %s, %s, %s, %lld\n", arg1, STR (arg2), STR (arg3), STR (arg4), STR (arg5), VSIZE (arg6)); Vector *res = dbeGetTableDataV2 (arg1, arg2, arg3, arg4, arg5, arg6); #ifdef IPC_LOG if (res != NULL) ipc_log (" returns = %lld objects, length = %lld\n", VSIZE (res), VSIZE ((Vector*)res->fetch (0))); else ipc_log (" returns NULL\n"); #endif writeArray (res, req); //destroy( arg6 ); destroy (res); } else if (!strcmp (inp, "getCallTreeNumLevels")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); int res = dbeGetCallTreeNumLevels (arg1); #ifdef IPC_LOG ipc_log (" returns = %d\n", res); #endif writeInt (res, req); } else if (!strcmp (inp, "getCallTreeLevel")) { int arg1 = readInt (req); String arg2 = readString (req); int arg3 = readInt (req); ipc_log (" args = %d, %s, %d\n", arg1, arg2, arg3); Vector *res = dbeGetCallTreeLevel (arg1, arg2, arg3); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getCallTreeChildren")) { int arg1 = readInt (req); String arg2 = readString (req); Vector *arg3 = (Vector *) readArray (req); /*NodeIdx array*/ ipc_log (" args = %d, %s, vec_size=%lld\n", arg1, arg2, (long long) (arg3 ? arg3->size () : 0)); Vector *res = dbeGetCallTreeChildren (arg1, arg2, arg3); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getCallTreeLevels")) { int arg1 = readInt (req); String arg2 = readString (req); ipc_log (" args = %d, %s\n", arg1, arg2); Vector *res = dbeGetCallTreeLevels (arg1, arg2); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getCallTreeLevelFuncs")) { int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); ipc_log (" args = %d, %d, %d\n", arg1, arg2, arg3); Vector *res = dbeGetCallTreeLevelFuncs (arg1, arg2, arg3); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getCallTreeFuncs")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetCallTreeFuncs (arg1); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getGroupIds")) { int arg1 = readInt (req); Vector *res = dbeGetGroupIds (arg1); writeArray (res, req); delete res; } else if (!strcmp (inp, "getNames")) { int arg1 = readInt (req); int arg2 = readInt (req); Obj arg3 = readObject (req); #ifdef IPC_LOG ipc_log (" args = %d, %s 0x%lx\n", arg1, table_name (arg2), (long) arg3); #endif Vector *res = dbeGetNames (arg1, arg2, arg3); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getTotalMax")) { int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); ipc_log (" args = %d, %s, %d\n", arg1, table_name (arg2), arg3); Vector *res = dbeGetTotalMax (arg1, arg2, arg3); #ifdef IPC_LOG if (res != NULL) ipc_log (" returns = %lld vectors, length %lld\n", VSIZE (res), VSIZE ((Vector*)res->fetch (0))); else ipc_log (" returns NULL\n"); #endif writeArray (res, req); destroy (res); } else if (!strcmp (inp, "composeFilterClause")) { int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); Vector *arg4 = (Vector*)readArray (req); ipc_log (" args = %d, %s, %d, %lld selections\n", arg1, table_name (arg2), arg3, VSIZE (arg4)); String s = dbeComposeFilterClause (arg1, arg2, arg3, arg4); ipc_log (" returns %s\n", (s == NULL ? "" : s)); writeString (s, req); } else if (!strcmp (inp, "getStatisOverviewList")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetStatisOverviewList (arg1); ipc_log (" dbeStatisGetOverviewList returns = %lld objects\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getStatisList")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetStatisList (arg1); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getSummary")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); int arg3 = readInt (req); int arg4 = readInt (req); ipc_log (" args = %d, 0x%llx, %s (%d), %d\n", arg1, (long long) arg2, table_name (arg3), arg3, arg4); Vector *res = dbeGetSummary (arg1, arg2, arg3, arg4); ipc_log (" dbeGetSummary returns = %lld objects\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getSummaryV2")) { int dbevindex = readInt (req); Vector *sel_objs = (Vector*)readArray (req); int type = readInt (req); int subtype = readInt (req); Vector *res = dbeGetSummaryV2 (dbevindex, sel_objs, type, subtype); ipc_log (" args = %d, [%lld], %s (%d), %d res=[%lld] 0x%llx \n", dbevindex, VSIZE (sel_objs), table_name (type), type, subtype, VSIZE (res), (unsigned long long) res); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getExpName1")) { // XXX add an argument = DbeView index String arg1 = readString (req); ipc_log (" arg = `%s'\n", arg1 ? arg1 : "NULL"); String res = dbeGetExpName (0, arg1); writeString (res, req); ipc_log (" returns `%s'\n", res ? res : "NULL"); free (arg1); free (res); } else if (!strcmp (inp, "getHwcHelp")) { // XXX add an argument = DbeView index bool forKernel = readBoolean (req); Vector *res = dbeGetHwcHelp (0, forKernel); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getHwcSets")) { // XXX add an argument = DbeView index bool forKernel = readBoolean (req); Vector*> *res = dbeGetHwcSets (0, forKernel); writeArray (res, req); ipc_log (" returns %lld char*'s\n", VSIZE (res)); destroy (res); } else if (!strcmp (inp, "getHwcsAll")) { // XXX add an argument = DbeView index bool forKernel = readBoolean (req); Vector *res = dbeGetHwcsAll (0, forKernel); writeArray (res, req); ipc_log (" returns %lld char*'s\n", VSIZE (res)); destroy (res); } else if (!strcmp (inp, "getHwcAttrList")) { // XXX add an argument = DbeView index bool forKernel = readBoolean (req); Vector *res = dbeGetHwcAttrList (0, forKernel); ipc_log (" returns %lld char*'s\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getHwcMaxConcurrent")) { // XXX add an argument = DbeView index bool forKernel = readBoolean (req); int res = dbeGetHwcMaxConcurrent (0, forKernel); writeInt (res, req); } else if (!strcmp (inp, "getIfreqData")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetIfreqData (arg1); ipc_log (" returns %lld char*'s\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getNewLeakListInfo")) { int arg1 = readInt (req); bool arg2 = readBoolean (req); ipc_log (" args = %d, %d\n", arg1, arg2); Vector *res = dbeGetLeakListInfo (arg1, arg2); ipc_log (" returns %lld void*'s\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getObject")) { int arg1 = readInt (req); Obj arg2 = readObject (req); Obj arg3 = readObject (req); Obj i = dbeGetObject (arg1, arg2, arg3); writeObject (i, req); } else if (!strcmp (inp, "getExpVerboseName")) { Vector *arg = (Vector*)readArray (req); ipc_log (" expIds = %lld\n", VSIZE (arg)); Vector *res = dbeGetExpVerboseName (arg); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getName")) { // XXX add an argument = DbeView index int arg1 = readInt (req); String res = dbeGetName (0, arg1); writeString (res, req); free (res); } else if (!strcmp (inp, "getStartTime")) { // XXX add an argument = DbeView index int arg1 = readInt (req); long long l = dbeGetStartTime (0, arg1); ipc_log (" returns = %llu\n", l); writeLong (l, req); } else if (!strcmp (inp, "getRelativeStartTime")) { // XXX add an argument = DbeView index int arg1 = readInt (req); long long l = dbeGetRelativeStartTime (0, arg1); ipc_log (" returns = %llu\n", l); writeLong (l, req); } else if (!strcmp (inp, "getEndTime")) { // XXX add an argument = DbeView index int arg1 = readInt (req); long long l = dbeGetEndTime (0, arg1); ipc_log (" returns = %llu\n", l); writeLong (l, req); } else if (!strcmp (inp, "getClock")) { // XXX add an argument = DbeView index int arg1 = readInt (req); int i = dbeGetClock (0, arg1); writeInt (i, req); } /* else if ( !strcmp( inp, "getFounderExpId" ) ) { // XXX add an argument = DbeView index int arg1 = readInt(req); int i = dbeGetFounderExpId(0, arg1 ); writeInt( i, req ); } */ else if (!strcmp (inp, "getEntityProps")) { int arg1 = readInt (req); ipc_log (" args = %d\n", arg1); Vector *res = dbeGetEntityProps (arg1); writeArray (res, req); ipc_log (" returns = %lld objects\n", VSIZE (res)); destroy (res); } else if (!strcmp (inp, "getEntities")) { int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); ipc_log (" args = %d, %d, %d\n", arg1, arg2, arg3); Vector *res = dbeGetEntities (arg1, arg2, arg3); writeArray (res, req); ipc_log (" returns = %lld objects\n", VSIZE (res)); destroy (res); } else if (!strcmp (inp, "getEntitiesV2")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); int arg3 = readInt (req); ipc_log (" args = %d, %lld, %d\n", arg1, VSIZE (arg2), arg3); Vector *res = dbeGetEntitiesV2 (arg1, arg2, arg3); writeArray (res, req); ipc_log (" returns = %lld objects\n", VSIZE (res)); destroy (res); } else if (!strcmp (inp, "getTLDetails")) {//TBR int arg1 = readInt (req); int arg2 = readInt (req); int arg3 = readInt (req); int arg4 = readInt (req); long long arg5 = readLong (req); ipc_log (" dbevindex= %d, exp_id = %d, data_id = %d, " "entity_prop_id = %d, event_id = %lld\n", arg1, arg2, arg3, arg4, arg5); Vector *res = dbeGetTLDetails (arg1, arg2, arg3, arg4, arg5); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getStackNames")) { int arg1 = readInt (req); Obj arg2 = readObject (req); ipc_log (" args = %d, %ld\n", arg1, (long) arg2); Vector *res = dbeGetStackNames (arg1, arg2); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getStackFunctions")) { // XXX add an argument = DbeView index Obj arg1 = readObject (req); ipc_log (" args = %ld\n", (long) arg1); Vector *res = dbeGetStackFunctions (0, arg1); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); delete res; } else if (!strcmp (inp, "getStacksFunctions")) { // XXX add an argument = DbeView index Vector *arg1 = (Vector*)readArray (req); ipc_log (" argc = %ld\n", (long) arg1->size ()); Vector *res = dbeGetStacksFunctions (0, arg1); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); delete res; } else if (!strcmp (inp, "getStackPCs")) { // XXX add an argument = DbeView index Obj arg1 = readObject (req); ipc_log (" args = %ld\n", (long) arg1); Vector *res = dbeGetStackPCs (0, arg1); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); delete res; } else if (!strcmp (inp, "getIOStatistics")) { int dbevindex = readInt (req); Vector*> *res = dbeGetIOStatistics (dbevindex); writeArray (res, req); ipc_log (" returns %lld char*'s\n", VSIZE (res)); destroy (res); } else if (!strcmp (inp, "getHeapStatistics")) { int dbevindex = readInt (req); Vector*> *res = dbeGetHeapStatistics (dbevindex); writeArray (res, req); ipc_log (" returns %lld char*'s\n", VSIZE (res)); destroy (res); } else if (!strcmp (inp, "getSamples")) { int dbev_id = readInt (req); int exp_id = readInt (req); int64_t lo = readLong (req); int64_t hi = readLong (req); ipc_log (" dbevindex= %d, exp_id = %d, lo_idx:%lld, hi_idx:%lld\n", dbev_id, exp_id, (long long) lo, (long long) hi); Vector *res = dbeGetSamples (dbev_id, exp_id, lo, hi); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getGCEvents")) { int dbev_id = readInt (req); int exp_id = readInt (req); int64_t lo = readLong (req); int64_t hi = readLong (req); ipc_log (" dbevindex= %d, exp_id = %d, lo_idx:%lld, hi_idx:%lld\n", dbev_id, exp_id, (long long) lo, (long long) hi); Vector *res = dbeGetGCEvents (dbev_id, exp_id, lo, hi); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getFuncNames")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); ipc_log (" arg1 = %d, arg2 absent, size = %lld\n", arg1, VSIZE (arg2)); Vector *res = dbeGetFuncNames (arg1, arg2); writeArray (res, req); delete arg2; destroy (res); } else if (!strcmp (inp, "getFuncIds")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); ipc_log (" arg1 = %d, arg2 absent, size = %lld\n", arg1, VSIZE (arg2)); Vector *res = dbeGetFuncIds (arg1, arg2); writeArray (res, req); delete arg2; destroy (res); } else if (!strcmp (inp, "getObjNamesV2")) { int arg1 = readInt (req); Vector *arg2 = (Vector*)readArray (req); ipc_log (" arg1 = %d, arg2 absent, size = %lld\n", arg1, VSIZE (arg2)); Vector *res = dbeGetObjNamesV2 (arg1, arg2); writeArray (res, req); delete arg2; destroy (res); } else if (!strcmp (inp, "getFuncName")) { int arg1 = readInt (req); Obj arg2 = readObject (req); ipc_log (" arg1 = %d, arg2 = %lld\n", arg1, (long long) arg2); String res = dbeGetFuncName (arg1, arg2); ipc_log (" returning = %s\n", res ? res : "NULL"); writeString (res, req); free (res); } else if (!strcmp (inp, "getObjNameV2")) { int arg1 = readInt (req); uint64_t arg2 = readLong (req); ipc_log (" arg1 = %d, arg2 = %llu\n", arg1, (unsigned long long) arg2); String res = dbeGetObjNameV2 (arg1, arg2); ipc_log (" returning = %s\n", res ? res : "NULL"); writeString (res, req); free (res); } else if (!strcmp (inp, "getDataspaceTypeDesc")) { // XXX add an argument = DbeView index Obj arg1 = readObject (req); ipc_log (" arg1 absent, index = %ld\n", (long) arg1); String res = dbeGetDataspaceTypeDesc (0, arg1); ipc_log (" returning = %s\n", res ? res : "NULL"); writeString (res, req); free (res); } /* * New Interface with Timeline */ #if 0 //YXXX TBR else if (!strcmp (inp, "dbeInit")) dbeInit (); else if (!strcmp (inp, "getDefaultExperimentName")) { String res = dbeGetDefaultExperimentName (); ipc_log (" returning = %s\n", res); writeString (res); free (res); } else if (!strcmp (inp, "getExperimentState")) { String res = dbeGetExperimentState (); ipc_log (" returning = %s\n", res); writeString (res); free (res); } else if (!strcmp (inp, "getExpStartTime")) { long long l = dbeGetExpStartTime (); ipc_log (" returns = %llu\n", l); writeLong (l); } else if (!strcmp (inp, "getExpEndTime")) { long long l = dbeGetExpEndTime (); ipc_log (" returns = %llu\n", l); writeLong (l); } #endif else if (!strcmp (inp, "getDataDescriptorsV2")) {//TBR? TBD int exp_id = readInt (req); ipc_log (" exp_id = %d\n", exp_id); Vector *res = dbeGetDataDescriptorsV2 (exp_id); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getDataPropertiesV2")) {//TBR? TBD int exp_id = readInt (req); int arg2 = readInt (req); ipc_log (" exp_id = %d, data_idx = %d\n", exp_id, arg2); Vector *res = dbeGetDataPropertiesV2 (exp_id, arg2); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getExperimentTimeInfo")) { Vector *exp_ids = (Vector*)readArray (req); ipc_log (" cnt = %lld\n", VSIZE (exp_ids)); Vector *res = dbeGetExperimentTimeInfo (exp_ids); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getExperimentDataDescriptors")) { Vector *exp_ids = (Vector*)readArray (req); ipc_log (" cnt = %lld\n", VSIZE (exp_ids)); Vector *res = dbeGetExperimentDataDescriptors (exp_ids); ipc_log (" returns = %lld objects\n", VSIZE (res)); writeArray (res, req); destroy (res); } #if 0 //YXXX TBR? else if (!strcmp (inp, "getExprValues")) {//TBR? TBD int arg1 = readInt (); String arg2 = readString (); ipc_log (" data_idx = %d expr = %s\n", arg1, arg2 ? arg2 : "NULL"); Vector *res = dbeGetExprValues (arg1, arg2); ipc_log (" returns = %d objects\n", res ? res->size () : 0); writeArray (res); delete res; free (arg2); } #endif else if (!strcmp (inp, "hasTLData")) { int dbevindex = readInt (req); Vector *exp_ids = (Vector*)readArray (req); Vector *data_ids = (Vector*)readArray (req); Vector *eprop_ids = (Vector*)readArray (req); Vector *eprop_vals = (Vector*)readArray (req); Vector *auxs = (Vector*)readArray (req); ipc_log (" dbev_id = %d, cnt = %lld\n", dbevindex, VSIZE (exp_ids)); Vector *res = dbeHasTLData (dbevindex, exp_ids, data_ids, eprop_ids, eprop_vals, auxs); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getTLData")) { int dbevindex = readInt (req); int exp_id = readInt (req); int tldata_type = readInt (req); int entity_prop_id = readInt (req); int entity_prop_val = readInt (req); int aux = readInt (req); long long arg5 = readLong (req); long long arg6 = readLong (req); int arg7 = readInt (req); bool getReps = readBoolean (req); Vector *secondaryProps = (Vector*)readArray (req); ipc_log (" args = %d:%d; tldata_type=%d entity_prop_id=%d ent=%d aux=%d" "\n tstart=%lld delta=%lld ndeltas=%d getReps=%d nProps=%lld\n", dbevindex, exp_id, tldata_type, entity_prop_id, entity_prop_val, aux, arg5, arg6, arg7, (int) getReps, VSIZE (secondaryProps)); Vector *res = dbeGetTLData (dbevindex, exp_id, tldata_type, entity_prop_id, entity_prop_val, aux, arg5, arg6, arg7, getReps, secondaryProps); #ifdef IPC_LOG if (res) { Vector *reps = (Vector*)res->fetch (0); Vector *props = (Vector*)res->fetch (1); if (reps) { Vector *fids = (Vector *)reps->fetch (2); int sz = fids ? fids->size () : 0; ipc_log (" returning TL reps (dDscrs); nreps=%d:", sz); int i; for (i = 0; i < sz && i < 7; i++) ipc_log (" %lld", fids->fetch (i)); if (i < sz) ipc_log (" ... %lld", fids->fetch (sz - 1)); ipc_log ("\n"); } if (props) { int nprops = props->size (); ipc_log (" returning values for %d properties:\n", nprops); assert (secondaryProps->size () == nprops); } } else ipc_log (" returning NULL\n"); #endif writeArray (res, req); destroy (res); destroy (secondaryProps); } else if (!strcmp (inp, "getTLEventCenterTime")) { int dbevindex = readInt (req); int exp_id = readInt (req); int tldata_type = readInt (req); int entity_prop_id = readInt (req); int entity_prop_val = readInt (req); int aux = readInt (req); long long event_id = readLong (req); long long move_count = readLong (req); ipc_log (" args = %d:%d; tldata_type = %d entity_prop_id = %d " "ent = %d aux = %d idx = %lld move=%lld\n", dbevindex, exp_id, tldata_type, entity_prop_id, entity_prop_val, aux, event_id, move_count); Vector * res = dbeGetTLEventCenterTime (dbevindex, exp_id, tldata_type, entity_prop_id, entity_prop_val, aux, event_id, move_count); ipc_log (" returning idx = %lld, time = %lld\n", res ? res->fetch (0) : -1, res ? res->fetch (1) : -1); writeArray (res, req); } else if (!strcmp (inp, "getTLEventIdxNearTime")) { int dbevindex = readInt (req); int exp_id = readInt (req); int tldata_type = readInt (req); int entity_prop_id = readInt (req); int entity_prop_val = readInt (req); int aux = readInt (req); int searchDirection = readInt (req); long long value = readLong (req); ipc_log (" args = %d:%d; tldata_type = %d entity_prop_id = %d " "ent = %d aux = %d direction = %d value = %lld(0x%llx)\n", dbevindex, exp_id, tldata_type, entity_prop_id, entity_prop_val, aux, searchDirection, value, value); long long res = dbeGetTLEventIdxNearTime (dbevindex, exp_id, tldata_type, entity_prop_id, entity_prop_val, aux, searchDirection, value); ipc_log (" returning = %lld\n", res); writeLong (res, req); } else if (!strcmp (inp, "getAggregatedValue")) { int arg1 = readInt (req); String arg2 = readString (req); String arg3 = readString (req); String arg4 = readString (req); long long arg5 = readLong (req); long long arg6 = readLong (req); int arg7 = readInt (req); String arg8 = readString (req); String arg9 = readString (req); ipc_log (" data_idx = %d lfilter = \"%s\" fexpr = \"%s\" " "time = \"%s\" tstart = %lld delta = %lld " "num = %d key = \"%s\" aggr = \"%s\"\n", arg1, arg2 ? arg2 : "NULL", arg3 ? arg3 : "NULL", arg4 ? arg4 : "NULL", arg5, arg6, arg7, arg8 ? arg8 : "NULL", arg9 ? arg9 : "NULL"); Vector *res = dbeGetAggregatedValue (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9); #ifdef IPC_LOG if (res) { int sz = res->size (); ipc_log (" returning = %d values:", sz); if (sz > 10) sz = 10; for (int i = 0; i < sz; i++) ipc_log (" %lld", res->fetch (i)); ipc_log ("\n"); } else ipc_log (" returning NULL\n"); #endif writeArray (res, req); delete res; free (arg2); free (arg3); free (arg4); free (arg8); free (arg9); } #if 0//YXXX TBR else if (!strcmp (inp, "getExprValue")) { int exp_id = readInt (); int arg1 = readInt (); int arg2 = readInt (); String arg3 = readString (); ipc_log (" exp_id %d, data_id = %d, event_id = %d, expr = %s\n", exp_id, arg1, arg2, arg3 ? arg3 : "NULL"); String res = dbeGetExprValue (exp_id, arg1, arg2, arg3); ipc_log (" returning = %s\n", res ? res : ""); writeString (res); free (res); free (arg3); } else if (!strcmp (inp, "getListValues")) { Obj arg1 = readObject (); ipc_log (" stack = %lu\n", (long) arg1); Vector *res = dbeGetListValues (arg1); ipc_log (" returns = %d objects\n", res ? res->size () : 0); writeArray (res); destroy (res); } else if (!strcmp (inp, "getListNames")) { Obj arg1 = readObject (); ipc_log (" stack = %lu\n", (long) arg1); Vector *res = dbeGetListNames (arg1); ipc_log (" returns = %d objects\n", res ? res->size () : 0); writeArray (res); destroy (res); } #endif else if (!strcmp (inp, "getLineInfo")) { Obj arg1 = readObject (req); ipc_log (" pc = %lu\n", (long) arg1); Vector *res = dbeGetLineInfo (arg1); ipc_log (" returning File name: '%s'\n", res ? res->fetch (0) : ""); ipc_log (" returning Lineno: '%s'\n", res ? res->fetch (1) : ""); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "setAlias")) { String arg1 = readString (req); String arg2 = readString (req); String arg3 = readString (req); ipc_log (" name=\"%s\" uname=\"%s\" expr=\"%s\"\n", arg1 ? arg1 : "", arg2 ? arg2 : "", arg3 ? arg3 : ""); int res = dbeSetAlias (arg1, arg2, arg3); ipc_log (" returning = %d\n", res); writeInt (res, req); } else if (!strcmp (inp, "getAlias")) { String arg1 = readString (req); ipc_log (" name=\"%s\"\n", arg1 ? arg1 : ""); Vector *res = dbeGetAlias (arg1); ipc_log (" returning uname: '%s'\n", res && res->fetch (0) ? res->fetch (0) : ""); ipc_log (" returning expr: '%s'\n", res && res->fetch (1) ? res->fetch (0) : ""); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getXYPlotData")) { int arg1 = readInt (req); String arg2 = readString (req); String arg3 = readString (req); String arg4 = readString (req); String arg5 = readString (req); String arg6 = readString (req); String arg7 = readString (req); String arg8 = readString (req); String arg9 = readString (req); ipc_log (" data_idx = %d lfilter = \"%s\" arg = \"%s\" " "func1 = \"%s\" aggr1 = \"%s\" " "func2 = \"%s\" aggr2 = \"%s\" " "func3 = \"%s\" aggr3 = \"%s\" \n", arg1, arg2 ? arg2 : "NULL", arg3 ? arg3 : "NULL", arg4 ? arg4 : "NULL", arg5 ? arg5 : "NULL", arg6 ? arg6 : "NULL", arg7 ? arg7 : "NULL", arg8 ? arg8 : "NULL", arg9 ? arg9 : "NULL"); Vector*> *res = dbeGetXYPlotData (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9); #ifdef IPC_LOG if (res) { long nvals = res->size (); for (long i = 0; i < nvals; ++i) { Vector *vals = res->fetch (i); long long sz = VSIZE (vals); ipc_log (" returning = %lld values:", sz); if (sz > 10) sz = 10; for (long j = 0; j < sz; j++) ipc_log (" %lld", vals->fetch (j)); ipc_log ("\n"); } } else ipc_log (" returning NULL\n"); #endif writeArray (res, req); destroy (res); } else if (strcmp (inp, "dbe_archive") == 0) { Vector *ids = (Vector *) readArray (req); Vector *locations = (Vector *) readArray (req); dbe_archive (ids, locations); delete ids; destroy (locations); writeResponseGeneric (RESPONSE_STATUS_SUCCESS, currentRequestID, currentChannelID); } else if (strcmp (inp, "dbeSetLocations") == 0) { Vector *fnames = (Vector *) readArray (req); Vector *locations = (Vector *) readArray (req); dbeSetLocations (fnames, locations); destroy (fnames); destroy (locations); writeResponseGeneric (RESPONSE_STATUS_SUCCESS, currentRequestID, currentChannelID); } else if (strcmp (inp, "dbeResolvedWith_setpath") == 0) { char *path = readString (req); Vector *res = dbeResolvedWith_setpath (path); free (path); writeArray (res, req); destroy (res); } else if (strcmp (inp, "dbeResolvedWith_pathmap") == 0) { char *old_prefix = readString (req); char *new_prefix = readString (req); Vector *res = dbeResolvedWith_pathmap (old_prefix, new_prefix); free (old_prefix); free (new_prefix); writeArray (res, req); destroy (res); } else if (!strcmp (inp, "getCollectorControlValue")) { /* int dbevindex =*/ readInt (req); char *control = readString (req); ipc_log (" args = %s\n", control); char *ret = dbeGetCollectorControlValue (control); ipc_log (" returning %s\n", STR (ret)); writeString (ret, req); } else if (!strcmp (inp, "setCollectorControlValue")) { /* int dbevindex =*/ readInt (req); char *control = readString (req); char *value = readString (req); #ifdef IPC_LOG ipc_log (" args = %s %s\n", control, value); #endif char *ret = dbeSetCollectorControlValue (control, value); #ifdef IPC_LOG if (ret) ipc_log (" returning %s\n", ret); else ipc_log (" returning NULL\n"); #endif writeString (ret, req); } else if (!strcmp (inp, "unsetCollectorControlValue")) { /* int dbevindex =*/ readInt (req); char *control = readString (req); ipc_log (" args = %s\n", control); char *ret = dbeUnsetCollectorControlValue (control); ipc_log (" returning %s\n", STR (ret)); writeString (ret, req); } else if (!strcmp (inp, "getSignalValue")) { String arg1 = readString (req); ipc_log (" arg1=\"%s\"\n", arg1 ? arg1 : ""); int res = dbeGetSignalValue (arg1); ipc_log (" returning = %d\n", res); writeInt (res, req); } else if (!strcmp (inp, "sendSignal")) { long long p = readLong (req); int signum = readInt (req); ipc_log (" args = %llu, %d\n", (long long) p, signum); char * ret = dbeSendSignal ((pid_t) p, signum); #ifdef IPC_LOG if (ret) ipc_log (" returning %s\n", ret); else ipc_log (" returning NULL\n"); #endif writeString (ret, req); } else if (!strcmp (inp, "checkConnection")) { String arg1 = readString (req); ipc_log (" arg = `%s'\n", arg1 ? arg1 : "NULL"); String res = dbeCheckConnection (arg1); writeString (res, req); ipc_log (" returns `%s'\n", res ? res : "NULL"); free (arg1); free (res); } else if (!strcmp (inp, "QUIT")) { #ifdef IPC_LOG ipc_log (" %s\n", inp); #endif exit (0); } else { ipc_log ("Unrecognized input cmd \"%s\"; Aborting.\n", inp); return 1; } ipc_log (" processing IPC command %s complete\n", inp); free (inp); fflush (stdout); if (req->getStatus () != CANCELLED_IMMEDIATE) // wake up the main working thread, let it take care of delete req->setStatus (COMPLETED); delete req; return 0; } void check_env_args (int argc, char *argv[]) { int indx = 2; // Skip "-IPC" const char *MINUS_E = "-E"; const char *SP_ER_PRINT_TRACE_LEVEL = "SP_ER_PRINT_TRACE_LEVEL"; const char *SP_IPC_PROTOCOL = "SP_IPC_PROTOCOL"; const char SEPARATOR = '='; char *cmd_env_var = NULL; while (argc - indx >= 2) { char *option = argv[indx++]; if (!streq (option, MINUS_E)) continue; cmd_env_var = argv[indx++]; char *separator = strchr (cmd_env_var, SEPARATOR); if (!separator) // Unrecognized option. Fatal error? continue; char *cmd_env_var_val = separator + 1; if (!strncmp (cmd_env_var, SP_ER_PRINT_TRACE_LEVEL, strlen (SP_ER_PRINT_TRACE_LEVEL))) { if (streq (cmd_env_var_val, "1")) ipc_trace_level = TRACE_LVL_1; else if (streq (cmd_env_var_val, "2")) ipc_trace_level = TRACE_LVL_2; else if (streq (cmd_env_var_val, "3")) ipc_trace_level = TRACE_LVL_3; else if (streq (cmd_env_var_val, "4")) ipc_trace_level = TRACE_LVL_4; continue; } if (!strncmp (cmd_env_var, SP_IPC_PROTOCOL, strlen (SP_IPC_PROTOCOL))) { if (streq (cmd_env_var_val, IPC_PROTOCOL_CURR)) // Only one protocol is currently supported ipc_protocol = IPC_PROTOCOL_CURR; else ipc_protocol = IPC_PROTOCOL_UNKNOWN; continue; } // Unrecognized option. Fatal error? } } void print_ipc_protocol_confirmation () { if (NULL != ipc_protocol) { fprintf (stdout, "ER_IPC: %s\n", ipc_protocol); fflush (stdout); } } void ipc_mainLoop (int argc, char *argv[]) { if (getenv ("GPROFNG_DBE_DELAY")) sleep (20); #ifdef IPC_LOG ipc_flags = 1; #endif // check_env_args(argc, argv); char *er_print_trace_level = getenv ("SP_ER_PRINT_TRACE_LEVEL"); if (er_print_trace_level != NULL) { if (streq (er_print_trace_level, "1")) ipc_trace_level = TRACE_LVL_1; else if (streq (er_print_trace_level, "2")) ipc_trace_level = TRACE_LVL_2; else if (streq (er_print_trace_level, "3")) ipc_trace_level = TRACE_LVL_3; else if (streq (er_print_trace_level, "4")) ipc_trace_level = TRACE_LVL_4; } check_env_args (argc, argv); print_ipc_protocol_confirmation (); if (ipc_flags || getenv ("SP_ER_PRINT_IPC_FLAG") || ipc_trace_level > TRACE_LVL_0) { ipc_flags = 1; if (ipc_trace_level == TRACE_LVL_0) ipc_trace_level = TRACE_LVL_1; // reopen stderr as file "ipc_log" ipc_log_name = getenv ("SP_ER_PRINT_IPC_LOG"); if (ipc_log_name == NULL) ipc_log_name = "ipc_log"; freopen (ipc_log_name, "w", stderr); if (ipc_trace_level >= TRACE_LVL_2) { ipc_request_log_name = "ipc_request_log"; ipc_response_log_name = "ipc_response_log"; requestLogFileP = fopen (ipc_request_log_name, "w"); responseLogFileP = fopen (ipc_response_log_name, "w"); } else { ipc_request_log_name = "ipc_log"; ipc_response_log_name = "ipc_log"; } begin_time = gethrtime (); } else // Reopen stderr as /dev/null freopen ("/dev/null", "w", stderr); struct sigaction act; memset (&act, 0, sizeof (struct sigaction)); term_flag = 0; /* install a handler for TERM */ ipc_request_trace (TRACE_LVL_1, "Installing SIGTERM handler to abort on error\n"); sigemptyset (&act.sa_mask); act.sa_handler = (SignalHandler) sigterm_handler; act.sa_flags = SA_RESTART | SA_SIGINFO; if (sigaction (SIGTERM, &act, &old_sigterm_handler) == -1) { ipc_request_trace (TRACE_LVL_1, "Unable to install SIGTERM handler\n"); abort (); } /* install a handler for INT */ ipc_request_trace (TRACE_LVL_1, "Installing SIGINT handler to send message to analyzer\n"); sigemptyset (&act.sa_mask); act.sa_handler = (SignalHandler) sigint_handler; act.sa_flags = SA_RESTART | SA_SIGINFO; if (sigaction (SIGINT, &act, &old_sigint_handler) == -1) { ipc_request_trace (TRACE_LVL_1, "Unable to install SIGINT handler\n"); abort (); } ipc_log ("Installed SIGINT handler to handle Ctrl-C properly\n"); int er_print_catch_crash = 1; // Default: catch fatal signals char *s = getenv ("GPROFNG_ALLOW_CORE_DUMP"); if (s && (strcasecmp (s, "no") == 0 || strcmp (s, "0") == 0)) er_print_catch_crash = 0; if (er_print_catch_crash) { /* reserve memory for fatal error processing */ fatalErrorDynamicMemory = (char *) malloc (4 * 1024 * 1024); // reserve 4 MB /* install a handler for SIGABRT */ ipc_request_trace (TRACE_LVL_1, "Installing SIGABRT handler to send message to analyzer\n"); sigemptyset (&act.sa_mask); act.sa_handler = (SignalHandler) sigABRT_handler; act.sa_flags = SA_RESTART | SA_SIGINFO; if (sigaction (SIGABRT, &act, NULL) == -1) { ipc_request_trace (TRACE_LVL_1, "Unable to install SIGABRT handler\n"); // abort(); } else ipc_log ("Installed SIGABRT handler to handle crash properly\n"); /* install a handler for SIGSEGV */ ipc_request_trace (TRACE_LVL_1, "Installing SIGABRT handler to send message to analyzer\n"); sigemptyset (&act.sa_mask); act.sa_handler = (SignalHandler) sigSEGV_handler; act.sa_flags = SA_RESTART | SA_SIGINFO; if (sigaction (SIGSEGV, &act, NULL) == -1) { ipc_request_trace (TRACE_LVL_1, "Unable to install SIGSEGV handler\n"); // abort(); } else ipc_log ("Installed SIGSEGV handler to handle crash properly\n"); } ipc_request_trace (TRACE_LVL_1, "Entering ipc_mainLoop; run dir `%s'\n", theApplication->get_run_dir ()); cancelRequestedChannelID = 0xFFFFFFFF; ipcThreadPool = new DbeThreadPool (0); // DbeThreadPool (-1); responseBufferPool = new BufferPool (); ipc_log (ipc_single_threaded_mode ? "RUNNING er_print -IPC IN SINGLE THREADED MODE\n" : "RUNNING er_print -IPC IN MULTITHREAD MODE\n"); /* Send "Ready" signal to the GUI */ setProgress (100, "Restart engine"); /* start listening for requests */ error_flag = 0; for (;;) { readRequestHeader (); if (term_flag == 1 || error_flag == 1) { ipc_request_trace (TRACE_LVL_1, "SIGTERM received, exiting\n"); return; } } } static const char * table_name (int flavor) { static char def_name[64]; switch ((FuncListDisp_type) flavor) { case DSP_FUNCTION: return ("FUNCTION"); case DSP_LINE: return ("LINE"); case DSP_PC: return ("PC"); case DSP_SOURCE: return ("SOURCE"); case DSP_DISASM: return ("DISASM"); case DSP_SELF: return ("SELF"); case DSP_CALLER: return ("CALLER"); case DSP_CALLEE: return ("CALLEE"); case DSP_CALLTREE: return ("CALLTREE"); case DSP_TIMELINE: return ("TIMELINE"); case DSP_STATIS: return ("STATIS"); case DSP_EXP: return ("EXP"); case DSP_LEAKLIST: return ("LEAKLIST"); case DSP_HEAPCALLSTACK: return ("HEAP"); case DSP_MEMOBJ: return ("MEMOBJ"); case DSP_DATAOBJ: return ("DATAOBJ"); case DSP_DLAYOUT: return ("DLAYOUT"); case DSP_SRC_FILE: return ("SRC_FILE"); case DSP_IFREQ: return ("IFREQ"); case DSP_RACES: return ("RACES"); case DSP_INDXOBJ: return ("INDXOBJ"); case DSP_DUALSOURCE: return ("DUALSOURCE"); case DSP_SOURCE_DISASM: return ("SOURCE_DISASM"); case DSP_DEADLOCKS: return ("DEADLOCKS"); case DSP_SOURCE_V2: return ("SOURCE_V2"); case DSP_DISASM_V2: return ("DISASM_V2"); case DSP_IOACTIVITY: return ("IOACTIVITY"); case DSP_OVERVIEW: return ("OVERVIEW"); case DSP_SAMPLE: return ("SAMPLE -- UNEXPECTED"); default: snprintf (def_name, sizeof (def_name), "table number %d", flavor); return (def_name); } }