Logo ROOT  
Reference Guide
 
Loading...
Searching...
No Matches
TUnixSystem.cxx
Go to the documentation of this file.
1// @(#)root/unix:$Id: 887c618d89c4ed436e4034fc133f468fecad651b $
2// Author: Fons Rademakers 15/09/95
3
4/*************************************************************************
5 * Copyright (C) 1995-2000, Rene Brun and Fons Rademakers. *
6 * All rights reserved. *
7 * *
8 * For the licensing terms see $ROOTSYS/LICENSE. *
9 * For the list of contributors see $ROOTSYS/README/CREDITS. *
10 *************************************************************************/
11
12//////////////////////////////////////////////////////////////////////////
13// //
14// TUnixSystem //
15// //
16// Class providing an interface to the UNIX Operating System. //
17// //
18//////////////////////////////////////////////////////////////////////////
19
20#include "RConfigure.h"
21#include <ROOT/RConfig.hxx>
23#include "TUnixSystem.h"
24#include "TROOT.h"
25#include "TError.h"
26#include "TOrdCollection.h"
27#include "TRegexp.h"
28#include "TPRegexp.h"
29#include "TException.h"
30#include "TEnv.h"
31#include "Getline.h"
32#include "TInterpreter.h"
33#include "TApplication.h"
34#include "TObjString.h"
35#include "TVirtualMutex.h"
36#include "ThreadLocalStorage.h"
37#include "TObjArray.h"
38#include "snprintf.h"
39#include "strlcpy.h"
40#include <iostream>
41#include <fstream>
42#include <map>
43#include <algorithm>
44#include <atomic>
45
46//#define G__OLDEXPAND
47
48#include <unistd.h>
49#include <cstdlib>
50#include <sys/types.h>
51#if defined(R__SUN) || defined(R__AIX) || \
52 defined(R__LINUX) || defined(R__SOLARIS) || \
53 defined(R__FBSD) || defined(R__OBSD) || \
54 defined(R__MACOSX) || defined(R__HURD)
55#define HAS_DIRENT
56#endif
57#ifdef HAS_DIRENT
58# include <dirent.h>
59#else
60# include <sys/dir.h>
61#endif
62#if defined(ULTRIX) || defined(R__SUN)
63# include <sgtty.h>
64#endif
65#if defined(R__AIX) || defined(R__LINUX) || \
66 defined(R__FBSD) || defined(R__OBSD) || \
67 defined(R__LYNXOS) || defined(R__MACOSX) || defined(R__HURD)
68# include <sys/ioctl.h>
69#endif
70#if defined(R__AIX) || defined(R__SOLARIS)
71# include <sys/select.h>
72#endif
73#if defined(R__MACOSX)
74# include <mach-o/dyld.h>
75# include <sys/mount.h>
76 extern "C" int statfs(const char *file, struct statfs *buffer);
77#elif defined(R__LINUX) || defined(R__HURD)
78# include <sys/vfs.h>
79#elif defined(R__FBSD) || defined(R__OBSD)
80# include <sys/param.h>
81# include <sys/mount.h>
82# ifdef R__FBSD
83# include <sys/user.h>
84# include <sys/types.h>
85# include <sys/param.h>
86# include <sys/queue.h>
87# include <libprocstat.h>
88# include <libutil.h>
89# endif
90#else
91# include <sys/statfs.h>
92#endif
93
94#include <utime.h>
95#include <syslog.h>
96#include <sys/stat.h>
97#include <csetjmp>
98#include <csignal>
99#include <sys/param.h>
100#include <pwd.h>
101#include <grp.h>
102#include <cerrno>
103#include <sys/resource.h>
104#include <sys/wait.h>
105#include <ctime>
106#include <sys/time.h>
107#include <sys/file.h>
108#include <sys/socket.h>
109#include <netinet/in.h>
110#include <netinet/tcp.h>
111#if defined(R__AIX)
112# define _XOPEN_EXTENDED_SOURCE
113# include <arpa/inet.h>
114# undef _XOPEN_EXTENDED_SOURCE
115# if !defined(_AIX41) && !defined(_AIX43)
116 // AIX 3.2 doesn't have it
117# define HASNOT_INETATON
118# endif
119#else
120# include <arpa/inet.h>
121#endif
122#include <sys/un.h>
123#include <netdb.h>
124#include <fcntl.h>
125#if defined(R__SOLARIS)
126# include <sys/systeminfo.h>
127# include <sys/filio.h>
128# include <sys/sockio.h>
129# define HASNOT_INETATON
130# ifndef INADDR_NONE
131# define INADDR_NONE (UInt_t)-1
132# endif
133#endif
134
135#if defined(R__SOLARIS)
136# define HAVE_UTMPX_H
137# define UTMP_NO_ADDR
138#endif
139
140#if defined(MAC_OS_X_VERSION_10_5)
141# define HAVE_UTMPX_H
142# define UTMP_NO_ADDR
143#endif
144
145#if defined(R__FBSD)
146# include <sys/param.h>
147# if __FreeBSD_version >= 900007
148# define HAVE_UTMPX_H
149# endif
150#endif
151
152#if defined(R__AIX) || defined(R__FBSD) || \
153 defined(R__OBSD) || defined(R__LYNXOS) || \
154 (defined(R__MACOSX) && !defined(MAC_OS_X_VERSION_10_5))
155# define UTMP_NO_ADDR
156#endif
157
158#if defined(R__LYNXOS)
159extern "C" {
160 extern int putenv(const char *);
161 extern int inet_aton(const char *, struct in_addr *);
162};
163#endif
164
165#if defined(R__ARC4_STDLIB)
166// do nothing, stdlib.h already included
167#elif defined(R__ARC4_BSDLIB)
168#include <bsd/stdlib.h>
169#elif defined(R__GETRANDOM_CLIB)
170#include <sys/random.h>
171#endif
172
173#ifdef HAVE_UTMPX_H
174#include <utmpx.h>
175#define STRUCT_UTMP struct utmpx
176#else
177#include <utmp.h>
178#define STRUCT_UTMP struct utmp
179#endif
180#if !defined(UTMP_FILE) && defined(_PATH_UTMP) // 4.4BSD
181#define UTMP_FILE _PATH_UTMP
182#endif
183#if defined(UTMPX_FILE) // Solaris, SysVr4
184#undef UTMP_FILE
185#define UTMP_FILE UTMPX_FILE
186#endif
187#ifndef UTMP_FILE
188#define UTMP_FILE "/etc/utmp"
189#endif
190
191// stack trace code
192#if (defined(R__LINUX) || defined(R__HURD)) && !defined(R__WINGCC)
193# if __GLIBC__ == 2 && __GLIBC_MINOR__ >= 1
194# define HAVE_BACKTRACE_SYMBOLS_FD
195# endif
196# define HAVE_DLADDR
197#endif
198#if defined(R__MACOSX) || defined(R__FBSD)
199# define HAVE_BACKTRACE_SYMBOLS_FD
200# define HAVE_DLADDR
201#endif
202
203#ifdef HAVE_BACKTRACE_SYMBOLS_FD
204# include <execinfo.h>
205#endif
206#ifdef HAVE_DLADDR
207# ifndef __USE_GNU
208# define __USE_GNU
209# endif
210# include <dlfcn.h>
211#endif
212
213#ifdef HAVE_BACKTRACE_SYMBOLS_FD
214 // The maximum stack trace depth for systems where we request the
215 // stack depth separately (currently glibc-based systems).
216 static const int kMAX_BACKTRACE_DEPTH = 128;
217#endif
218
219// FPE handling includes
220#if (defined(R__LINUX) && !defined(R__WINGCC))
221#include <cfenv>
222#include <sys/prctl.h> // for prctl() function used in StackTrace()
223#endif
224
225#if defined(R__MACOSX) && defined(__SSE2__)
226#include <xmmintrin.h>
227#endif
228
229#if defined(R__MACOSX) && !defined(__SSE2__) && !defined(__xlC__) && \
230 !defined(__i386__) && !defined(__x86_64__) && !defined(__arm__) && \
231 !defined(__arm64__)
232#include <cfenv>
233#include <csignal>
234#include <ucontext.h>
235#include <cstdlib>
236#include <cstdio>
237#include <mach/thread_status.h>
238
239#define fegetenvd(x) asm volatile("mffs %0" : "=f" (x));
240#define fesetenvd(x) asm volatile("mtfsf 255,%0" : : "f" (x));
241
242enum {
243 FE_ENABLE_INEXACT = 0x00000008,
244 FE_ENABLE_DIVBYZERO = 0x00000010,
245 FE_ENABLE_UNDERFLOW = 0x00000020,
246 FE_ENABLE_OVERFLOW = 0x00000040,
247 FE_ENABLE_INVALID = 0x00000080,
248 FE_ENABLE_ALL_EXCEPT = 0x000000F8
249};
250#endif
251
252#if defined(R__MACOSX) && !defined(__SSE2__) && \
253 (defined(__i386__) || defined(__x86_64__) || defined(__arm__) || defined(__arm64__))
254#include <cfenv>
255#endif
256// End FPE handling includes
257
258namespace {
259 // Depending on the platform the struct utmp (or utmpx) has either ut_name or ut_user
260 // which are semantically equivalent. Instead of using preprocessor magic,
261 // which is bothersome for cxx modules use SFINAE.
262
263 template<typename T>
264 struct ut_name {
265 template<typename U = T, typename std::enable_if<std::is_member_pointer<decltype(&U::ut_name)>::value, int>::type = 0>
266 static char getValue(U* ue, int) {
267 return ue->ut_name[0];
268 }
269
270 template<typename U = T, typename std::enable_if<std::is_member_pointer<decltype(&U::ut_user)>::value, int>::type = 0>
271 static char getValue(U* ue, long) {
272 return ue->ut_user[0];
273 }
274 };
275
276 static char get_ut_name(STRUCT_UTMP *ue) {
277 // 0 is an integer literal forcing an overload pickup in case both ut_name and ut_user are present.
278 return ut_name<STRUCT_UTMP>::getValue(ue, 0);
279 }
280}
281
284 UInt_t fEntries; // Number of entries in utmp file.
285
288
290 {
291 // Look for utmp entry which is connected to terminal tty.
292
294
295 UInt_t n = fEntries;
296 while (n--) {
297 if (get_ut_name(ue) && !strncmp(tty, ue->ut_line, sizeof(ue->ut_line)))
298 return ue;
299 ue++;
300 }
301 return nullptr;
302 }
303
305 {
306 // Read utmp file. Returns number of entries in utmp file.
307
308 FILE *utmp;
309 struct stat file_stats;
310 size_t n_read, size;
311
312 fEntries = 0;
313
315
316 utmp = fopen(UTMP_FILE, "r");
317 if (!utmp)
318 return 0;
319
320 if (fstat(fileno(utmp), &file_stats) == -1) {
321 fclose(utmp);
322 return 0;
323 }
324 size = file_stats.st_size;
325 if (size <= 0) {
326 fclose(utmp);
327 return 0;
328 }
329
331 if (!fUtmpContents) {
332 fclose(utmp);
333 return 0;
334 }
335
337 if (!ferror(utmp)) {
338 if (fclose(utmp) != EOF && n_read == size) {
339 fEntries = size / sizeof(STRUCT_UTMP);
340 return fEntries;
341 }
342 } else
343 fclose(utmp);
344
346 fUtmpContents = nullptr;
347 return 0;
348 }
349
350};
351
352const char *kServerPath = "/tmp";
353const char *kProtocolName = "tcp";
354
355//------------------- Unix TFdSet ----------------------------------------------
356#ifndef HOWMANY
357# define HOWMANY(x, y) (((x)+((y)-1))/(y))
358#endif
359
360const Int_t kNFDBITS = (sizeof(Long_t) * 8); // 8 bits per byte
361#ifdef FD_SETSIZE
362const Int_t kFDSETSIZE = FD_SETSIZE; // Linux = 1024 file descriptors
363#else
364const Int_t kFDSETSIZE = 256; // upto 256 file descriptors
365#endif
366
367
368class TFdSet {
369private:
371public:
372 TFdSet() { memset(fds_bits, 0, sizeof(fds_bits)); }
373 TFdSet(const TFdSet &org) { memcpy(fds_bits, org.fds_bits, sizeof(org.fds_bits)); }
374 TFdSet &operator=(const TFdSet &rhs) { if (this != &rhs) { memcpy(fds_bits, rhs.fds_bits, sizeof(rhs.fds_bits));} return *this; }
375 void Zero() { memset(fds_bits, 0, sizeof(fds_bits)); }
376 void Set(Int_t n)
377 {
378 if (n >= 0 && n < kFDSETSIZE) {
379 fds_bits[n/kNFDBITS] |= (1UL << (n % kNFDBITS));
380 } else {
381 ::Fatal("TFdSet::Set","fd (%d) out of range [0..%d]", n, kFDSETSIZE-1);
382 }
383 }
384 void Clr(Int_t n)
385 {
386 if (n >= 0 && n < kFDSETSIZE) {
387 fds_bits[n/kNFDBITS] &= ~(1UL << (n % kNFDBITS));
388 } else {
389 ::Fatal("TFdSet::Clr","fd (%d) out of range [0..%d]", n, kFDSETSIZE-1);
390 }
391 }
393 {
394 if (n >= 0 && n < kFDSETSIZE) {
395 return (fds_bits[n/kNFDBITS] & (1UL << (n % kNFDBITS))) != 0;
396 } else {
397 ::Fatal("TFdSet::IsSet","fd (%d) out of range [0..%d]", n, kFDSETSIZE-1);
398 return 0;
399 }
400 }
401 ULong_t *GetBits() { return (ULong_t *)fds_bits; }
402};
403
404////////////////////////////////////////////////////////////////////////////////
405/// Unix signal handler.
406
407static void SigHandler(ESignals sig)
408{
409 if (gSystem)
410 ((TUnixSystem*)gSystem)->DispatchSignals(sig);
411}
412
413////////////////////////////////////////////////////////////////////////////////
414
415static const char *GetExePath()
416{
418 if (exepath == "") {
419#if defined(R__MACOSX)
421#elif defined(R__LINUX) || defined(R__SOLARIS) || defined(R__FBSD)
422 char buf[kMAXPATHLEN]=""; // exe path name
423
424 // get the name from the link in /proc
425#if defined(R__LINUX)
426 int ret = readlink("/proc/self/exe", buf, kMAXPATHLEN);
427#elif defined(R__SOLARIS)
428 int ret = readlink("/proc/self/path/a.out", buf, kMAXPATHLEN);
429#elif defined(R__FBSD)
432
433 int ret{0};
434 if (kp!=NULL) {
435 procstat_getpathname(ps, kp, buf, sizeof(buf));
436 }
437 free(kp);
438 procstat_close(ps);
439 exepath = buf;
440#endif
441 if (ret > 0 && ret < kMAXPATHLEN) {
442 buf[ret] = 0;
443 exepath = buf;
444 }
445#else
446 if (!gApplication)
447 return exepath;
449 if (p.BeginsWith("/"))
450 exepath = p;
451 else if (p.Contains("/")) {
453 exepath += "/";
454 exepath += p;
455 } else {
456 char *exe = gSystem->Which(gSystem->Getenv("PATH"), p, kExecutePermission);
457 if (exe) {
458 exepath = exe;
459 delete [] exe;
460 }
461 }
462#endif
463 }
464 return exepath;
465}
466
467#if defined(HAVE_DLADDR) && !defined(R__MACOSX)
468////////////////////////////////////////////////////////////////////////////////
469
470static void SetRootSys()
471{
472#ifdef ROOTPREFIX
473 if (gSystem->Getenv("ROOTIGNOREPREFIX")) {
474#endif
475 void *addr = (void *)SetRootSys;
477 if (dladdr(addr, &info) && info.dli_fname && info.dli_fname[0]) {
478 char respath[kMAXPATHLEN];
479 if (!realpath(info.dli_fname, respath)) {
480 if (!gSystem->Getenv("ROOTSYS"))
481 ::SysError("TUnixSystem::SetRootSys", "error getting realpath of libCore, please set ROOTSYS in the shell");
482 } else {
484 gSystem->Setenv("ROOTSYS", gSystem->GetDirName(rs.Data()).Data());
485 }
486 }
487#ifdef ROOTPREFIX
488 }
489#endif
490}
491#endif
492
493#if defined(R__MACOSX)
495
496////////////////////////////////////////////////////////////////////////////////
497
498static void DylibAdded(const struct mach_header *mh, intptr_t /* vmaddr_slide */)
499{
500 static int i = 0;
501 static Bool_t gotFirstSo = kFALSE;
502 static TString linkedDylibs;
503
504 // to copy the local linkedDylibs to the global gLinkedDylibs call this
505 // function with mh==0
506 if (!mh) {
508 return;
509 }
510
511 TString lib = _dyld_get_image_name(i++);
512
513 TRegexp sovers = "libCore\\.[0-9]+\\.*[0-9]*\\.*[0-9]*\\.so";
514 TRegexp dyvers = "libCore\\.[0-9]+\\.*[0-9]*\\.*[0-9]*\\.dylib";
515
516#ifdef ROOTPREFIX
517 if (gSystem->Getenv("ROOTIGNOREPREFIX")) {
518#endif
519 if (lib.EndsWith("libCore.dylib") || lib.EndsWith("libCore.so") ||
520 lib.Index(sovers) != kNPOS || lib.Index(dyvers) != kNPOS) {
521 char respath[kMAXPATHLEN];
522 if (!realpath(lib, respath)) {
523 if (!gSystem->Getenv("ROOTSYS"))
524 ::SysError("TUnixSystem::DylibAdded", "error getting realpath of libCore, please set ROOTSYS in the shell");
525 } else {
527 gSystem->Setenv("ROOTSYS", gSystem->GetDirName(rs.Data()).Data());
528 }
529 }
530#ifdef ROOTPREFIX
531 }
532#endif
533
534 // when libSystem.B.dylib is loaded we have finished loading all dylibs
535 // explicitly linked against the executable. Additional dylibs
536 // come when they are explicitly linked against loaded so's, currently
537 // we are not interested in these
538 if (lib.EndsWith("/libSystem.B.dylib")) {
540 if (linkedDylibs.IsNull()) {
541 // TSystem::GetLibraries() assumes that an empty GetLinkedLibraries()
542 // means failure to extract the linked libraries. Signal "we did
543 // manage, but it's empty" by returning a single space.
544 linkedDylibs = ' ';
545 }
546 }
547
548 // add all libs loaded before libSystem.B.dylib
549 if (!gotFirstSo && (lib.EndsWith(".dylib") || lib.EndsWith(".so"))) {
550 sovers = "\\.[0-9]+\\.*[0-9]*\\.so";
551 Ssiz_t idx = lib.Index(sovers);
552 if (idx != kNPOS) {
553 lib.Remove(idx);
554 lib += ".so";
555 }
556 dyvers = "\\.[0-9]+\\.*[0-9]*\\.dylib";
557 idx = lib.Index(dyvers);
558 if (idx != kNPOS) {
559 lib.Remove(idx);
560 lib += ".dylib";
561 }
563 if (linkedDylibs.Length())
564 linkedDylibs += " ";
565 linkedDylibs += lib;
566 }
567 }
568}
569#endif
570
571
572////////////////////////////////////////////////////////////////////////////////
573
574TUnixSystem::TUnixSystem() : TSystem("Unix", "Unix System")
575{ }
576
577////////////////////////////////////////////////////////////////////////////////
578/// Reset to original state.
579
581{
583
584 delete fReadmask;
585 delete fWritemask;
586 delete fReadready;
587 delete fWriteready;
588 delete fSignals;
589}
590
591////////////////////////////////////////////////////////////////////////////////
592/// Initialize Unix system interface.
593
595{
596 if (TSystem::Init())
597 return kTRUE;
598
599 fReadmask = new TFdSet;
600 fWritemask = new TFdSet;
601 fReadready = new TFdSet;
602 fWriteready = new TFdSet;
603 fSignals = new TFdSet;
604
605 //--- install default handlers
617
618#if defined(R__MACOSX)
619 // trap loading of all dylibs to register dylib name,
620 // sets also ROOTSYS if built without ROOTPREFIX
622#elif defined(HAVE_DLADDR)
623 SetRootSys();
624#endif
625
626 // This is a fallback in case TROOT::GetRootSys() can't determine ROOTSYS
628
629 return kFALSE;
630}
631
632//---- Misc --------------------------------------------------------------------
633
634////////////////////////////////////////////////////////////////////////////////
635/// Set the application name (from command line, argv[0]) and copy it in
636/// gProgName. Copy the application pathname in gProgPath.
637/// If name is 0 let the system set the actual executable name and path
638/// (works on MacOS X and Linux).
639
641{
642 if (gProgName)
643 delete [] gProgName;
644 if (gProgPath)
645 delete [] gProgPath;
646
647 if (!name || !*name) {
648 name = GetExePath();
651 } else {
653 char *w = Which(Getenv("PATH"), gProgName);
655 delete [] w;
656 }
657}
658
659////////////////////////////////////////////////////////////////////////////////
660/// Set DISPLAY environment variable based on utmp entry. Only for UNIX.
661
663{
664 if (!Getenv("DISPLAY")) {
665 char *tty = ::ttyname(0); // device user is logged in on
666 if (tty) {
667 tty += 5; // remove "/dev/"
668
670 utmp.ReadUtmpFile();
671
672 STRUCT_UTMP *utmp_entry = utmp.SearchUtmpEntry(tty);
673 if (utmp_entry) {
674 if (utmp_entry->ut_host[0]) {
676 for (unsigned n = 0; (n < sizeof(utmp_entry->ut_host)) && utmp_entry->ut_host[n]; n++)
677 disp.Append(utmp_entry->ut_host[n]);
678 if (disp.First(':') == kNPOS)
679 disp.Append(":0.0");
680 Setenv("DISPLAY", disp.Data());
681 Warning("SetDisplay", "DISPLAY not set, setting it to %s", disp.Data());
682 }
683#ifndef UTMP_NO_ADDR
684 else if (utmp_entry->ut_addr) {
685
686 struct sockaddr_in addr;
687 addr.sin_family = AF_INET;
688 addr.sin_port = 0;
689 memcpy(&addr.sin_addr, &utmp_entry->ut_addr, sizeof(addr.sin_addr));
690 memset(&addr.sin_zero[0], 0, sizeof(addr.sin_zero));
691 struct sockaddr *sa = (struct sockaddr *) &addr; // input
692
693 char hbuf[NI_MAXHOST + 4];
694 if (getnameinfo(sa, sizeof(struct sockaddr), hbuf, sizeof(hbuf), nullptr, 0, NI_NAMEREQD) == 0) {
696 strlcat(hbuf, ":0.0", sizeof(hbuf));
697 Setenv("DISPLAY", hbuf);
698 Warning("SetDisplay", "DISPLAY not set, setting it to %s",
699 hbuf);
700 }
701 }
702#endif
703 }
704 }
705#ifndef R__HAS_COCOA
706 if (!gROOT->IsBatch() && !std::getenv("DISPLAY")) {
707 Error("SetDisplay", "Can't figure out DISPLAY, set it manually\n"
708 "In case you run a remote ssh session, restart your ssh session with:\n"
709 "=========> ssh -Y");
710 }
711#endif
712 }
713}
714
715////////////////////////////////////////////////////////////////////////////////
716/// Return system error string.
717
719{
720 Int_t err = GetErrno();
721 if (err == 0 && GetLastErrorString() != "")
722 return GetLastErrorString();
723
724#if defined(R__SOLARIS) || defined (R__LINUX) || defined(R__AIX) || \
725 defined(R__FBSD) || defined(R__OBSD) || defined(R__HURD)
726 return strerror(err);
727#else
729 return Form("errno out of range %d", err);
730 return sys_errlist[err];
731#endif
732}
733
734////////////////////////////////////////////////////////////////////////////////
735/// Return the system's host name.
736
738{
739 if (fHostname == "") {
740 char hn[64];
741#if defined(R__SOLARIS)
742 sysinfo(SI_HOSTNAME, hn, sizeof(hn));
743#else
744 gethostname(hn, sizeof(hn));
745#endif
746 fHostname = hn;
747 }
748 return (const char *)fHostname;
749}
750
751//---- EventLoop ---------------------------------------------------------------
752
753////////////////////////////////////////////////////////////////////////////////
754/// Add a file handler to the list of system file handlers. Only adds
755/// the handler if it is not already in the list of file handlers.
756
758{
760
762 if (h) {
763 int fd = h->GetFd();
764 if (h->HasReadInterest()) {
765 fReadmask->Set(fd);
766 fMaxrfd = std::max(fMaxrfd, fd);
767 }
768 if (h->HasWriteInterest()) {
769 fWritemask->Set(fd);
770 fMaxwfd = std::max(fMaxwfd, fd);
771 }
772 }
773}
774
775////////////////////////////////////////////////////////////////////////////////
776/// Remove a file handler from the list of file handlers. Returns
777/// the handler or 0 if the handler was not in the list of file handlers.
778
780{
781 if (!h) return nullptr;
782
784
786 if (oh) { // found
787 TFileHandler *th;
788 TIter next(fFileHandler);
789 fMaxrfd = -1;
790 fMaxwfd = -1;
791 fReadmask->Zero();
792 fWritemask->Zero();
793 while ((th = (TFileHandler *) next())) {
794 int fd = th->GetFd();
795 if (th->HasReadInterest()) {
796 fReadmask->Set(fd);
797 fMaxrfd = std::max(fMaxrfd, fd);
798 }
799 if (th->HasWriteInterest()) {
800 fWritemask->Set(fd);
801 fMaxwfd = std::max(fMaxwfd, fd);
802 }
803 }
804 }
805 return oh;
806}
807
808////////////////////////////////////////////////////////////////////////////////
809/// Add a signal handler to list of system signal handlers. Only adds
810/// the handler if it is not already in the list of signal handlers.
811
819
820////////////////////////////////////////////////////////////////////////////////
821/// Remove a signal handler from list of signal handlers. Returns
822/// the handler or 0 if the handler was not in the list of signal handlers.
823
825{
826 if (!h) return nullptr;
827
829
831
832 Bool_t last = kTRUE;
834 TIter next(fSignalHandler);
835
836 while ((hs = (TSignalHandler*) next())) {
837 if (hs->GetSignal() == h->GetSignal())
838 last = kFALSE;
839 }
840 if (last)
841 ResetSignal(h->GetSignal(), kTRUE);
842
843 return oh;
844}
845
846////////////////////////////////////////////////////////////////////////////////
847/// If reset is true reset the signal handler for the specified signal
848/// to the default handler, else restore previous behaviour.
849
851{
852 if (reset)
853 UnixResetSignal(sig);
854 else
856}
857
858////////////////////////////////////////////////////////////////////////////////
859/// Reset signals handlers to previous behaviour.
860
865
866////////////////////////////////////////////////////////////////////////////////
867/// If ignore is true ignore the specified signal, else restore previous
868/// behaviour.
869
874
875////////////////////////////////////////////////////////////////////////////////
876/// When the argument is true the SIGALRM signal handler is set so that
877/// interrupted syscalls will not be restarted by the kernel. This is
878/// typically used in case one wants to put a timeout on an I/O operation.
879/// By default interrupted syscalls will always be restarted (for all
880/// signals). This can be controlled for each a-synchronous TTimer via
881/// the method TTimer::SetInterruptSyscalls().
882
887
888////////////////////////////////////////////////////////////////////////////////
889/// Return the bitmap of conditions that trigger a floating point exception.
890
892{
893 Int_t mask = 0;
894
895#if defined(R__LINUX) && !defined(__powerpc__)
896#if defined(__GLIBC__) && (__GLIBC__>2 || __GLIBC__==2 && __GLIBC_MINOR__>=1)
897
898#if __GLIBC_MINOR__>=3
899
901
902#else
906#if __ia64__
908#else
909 Int_t oldmask = ~oldenv.__control_word;
910#endif
911#endif
912
913 if (oldmask & FE_INVALID ) mask |= kInvalid;
917# ifdef FE_INEXACT
918 if (oldmask & FE_INEXACT ) mask |= kInexact;
919# endif
920#endif
921#endif
922
923#if defined(R__MACOSX) && defined(__SSE2__)
924 // OS X uses the SSE unit for all FP math by default, not the x87 FP unit
926
932#endif
933
934#if defined(R__MACOSX) && !defined(__SSE2__) && \
935 (defined(__i386__) || defined(__x86_64__) || defined(__arm__) || defined(__arm64__))
939#if defined(__arm__)
940 Int_t oldmask = ~oldenv.__fpscr;
941#elif defined(__arm64__)
942 Int_t oldmask = ~oldenv.__fpcr;
943#else
944 Int_t oldmask = ~oldenv.__control;
945#endif
946
947 if (oldmask & FE_INVALID ) mask |= kInvalid;
951 if (oldmask & FE_INEXACT ) mask |= kInexact;
952#endif
953
954#if defined(R__MACOSX) && !defined(__SSE2__) && !defined(__xlC__) && \
955 !defined(__i386__) && !defined(__x86_64__) && !defined(__arm__) && \
956 !defined(__arm64__)
959
965#endif
966
967 return mask;
968}
969
970////////////////////////////////////////////////////////////////////////////////
971/// Set which conditions trigger a floating point exception.
972/// Return the previous set of conditions.
973
975{
976 if (mask) { } // use mask to avoid warning
977
978 Int_t old = GetFPEMask();
979
980#if defined(R__LINUX) && !defined(__powerpc__)
981#if defined(__GLIBC__) && (__GLIBC__>2 || __GLIBC__==2 && __GLIBC_MINOR__>=1)
982 Int_t newm = 0;
983 if (mask & kInvalid ) newm |= FE_INVALID;
985 if (mask & kOverflow ) newm |= FE_OVERFLOW;
987# ifdef FE_INEXACT
988 if (mask & kInexact ) newm |= FE_INEXACT;
989# endif
990
991#if __GLIBC_MINOR__>=3
992
993 // clear pending exceptions so feenableexcept does not trigger them
997
998#else
999
1000 fenv_t cur;
1001 fegetenv(&cur);
1002#if defined __ia64__
1003 cur &= ~newm;
1004#else
1005 cur.__control_word &= ~newm;
1006#endif
1007 fesetenv(&cur);
1008
1009#endif
1010#endif
1011#endif
1012
1013#if defined(R__MACOSX) && defined(__SSE2__)
1014 // OS X uses the SSE unit for all FP math by default, not the x87 FP unit
1015 Int_t newm = 0;
1021
1023#endif
1024
1025#if defined(R__MACOSX) && !defined(__SSE2__) && \
1026 (defined(__i386__) || defined(__x86_64__) || defined(__arm__) || defined(__arm64__))
1027 Int_t newm = 0;
1028 if (mask & kInvalid ) newm |= FE_INVALID;
1029 if (mask & kDivByZero) newm |= FE_DIVBYZERO;
1030 if (mask & kOverflow ) newm |= FE_OVERFLOW;
1031 if (mask & kUnderflow) newm |= FE_UNDERFLOW;
1032 if (mask & kInexact ) newm |= FE_INEXACT;
1033
1034 fenv_t cur;
1035 fegetenv(&cur);
1036#if defined(__arm__)
1037 cur.__fpscr &= ~newm;
1038#elif defined(__arm64__)
1039 cur.__fpcr &= ~newm;
1040#else
1041 cur.__control &= ~newm;
1042#endif
1043 fesetenv(&cur);
1044#endif
1045
1046#if defined(R__MACOSX) && !defined(__SSE2__) && !defined(__xlC__) && \
1047 !defined(__i386__) && !defined(__x86_64__) && !defined(__arm__) && \
1048 !defined(__arm64__)
1049 Int_t newm = 0;
1055
1060#endif
1061
1062 return old;
1063}
1064
1065////////////////////////////////////////////////////////////////////////////////
1066/// Dispatch a single event.
1067
1069{
1071
1072 while (1) {
1073 // first handle any X11 events
1074 if (gXDisplay && gXDisplay->Notify()) {
1075 if (fReadready->IsSet(gXDisplay->GetFd())) {
1077 fNfd--;
1078 }
1079 if (!pendingOnly) return;
1080 }
1081
1082 // check for file descriptors ready for reading/writing
1083 if (fNfd > 0 && fFileHandler && fFileHandler->GetSize() > 0)
1084 if (CheckDescriptors())
1085 if (!pendingOnly) return;
1086 fNfd = 0;
1087 fReadready->Zero();
1088 fWriteready->Zero();
1089
1090 if (pendingOnly && !pollOnce)
1091 return;
1092
1093 // check synchronous signals
1094 if (fSigcnt > 0 && fSignalHandler->GetSize() > 0)
1095 if (CheckSignals(kTRUE))
1096 if (!pendingOnly) return;
1097 fSigcnt = 0;
1098 fSignals->Zero();
1099
1100 // check synchronous timers
1101 Long_t nextto;
1102 if (fTimers && fTimers->GetSize() > 0)
1103 if (DispatchTimers(kTRUE)) {
1104 // prevent timers from blocking file descriptor monitoring
1106 if (nextto > kItimerResolution || nextto == -1)
1107 return;
1108 }
1109
1110 // if in pendingOnly mode poll once file descriptor activity
1112 if (pendingOnly) {
1113 if (fFileHandler && fFileHandler->GetSize() == 0)
1114 return;
1115 nextto = 0;
1116 pollOnce = kFALSE;
1117 }
1118
1119 // nothing ready, so setup select call
1122
1123 int mxfd = std::max(fMaxrfd, fMaxwfd);
1124 mxfd++;
1125
1126 // if nothing to select (socket or timer) return
1127 if (mxfd == 0 && nextto == -1)
1128 return;
1129
1131 if (fNfd < 0 && fNfd != -2) {
1132 int fd, rc;
1133 TFdSet t;
1134 for (fd = 0; fd < mxfd; fd++) {
1135 t.Set(fd);
1136 if (fReadmask->IsSet(fd)) {
1137 rc = UnixSelect(fd+1, &t, nullptr, 0);
1138 if (rc < 0 && rc != -2) {
1139 SysError("DispatchOneEvent", "select: read error on %d", fd);
1140 fReadmask->Clr(fd);
1141 }
1142 }
1143 if (fWritemask->IsSet(fd)) {
1144 rc = UnixSelect(fd+1, nullptr, &t, 0);
1145 if (rc < 0 && rc != -2) {
1146 SysError("DispatchOneEvent", "select: write error on %d", fd);
1147 fWritemask->Clr(fd);
1148 }
1149 }
1150 t.Clr(fd);
1151 }
1152 }
1153 }
1154}
1155
1156////////////////////////////////////////////////////////////////////////////////
1157/// Sleep milliSec milliseconds.
1158
1160{
1161 struct timeval tv;
1162
1163 tv.tv_sec = milliSec / 1000;
1164 tv.tv_usec = (milliSec % 1000) * 1000;
1165
1166 select(0, nullptr, nullptr, nullptr, &tv);
1167}
1168
1169////////////////////////////////////////////////////////////////////////////////
1170/// Select on file descriptors. The timeout to is in millisec. Returns
1171/// the number of ready descriptors, or 0 in case of timeout, or < 0 in
1172/// case of an error, with -2 being EINTR and -3 EBADF. In case of EINTR
1173/// the errno has been reset and the method can be called again. Returns
1174/// -4 in case the list did not contain any file handlers or file handlers
1175/// with file descriptor >= 0.
1176
1178{
1179 Int_t rc = -4;
1180
1181 TFdSet rd, wr;
1182 Int_t mxfd = -1;
1183 TIter next(act);
1184 TFileHandler *h = nullptr;
1185 while ((h = (TFileHandler *) next())) {
1186 Int_t fd = h->GetFd();
1187 if (fd > -1) {
1188 if (h->HasReadInterest()) {
1189 rd.Set(fd);
1190 mxfd = std::max(mxfd, fd);
1191 }
1192 if (h->HasWriteInterest()) {
1193 wr.Set(fd);
1194 mxfd = std::max(mxfd, fd);
1195 }
1196 h->ResetReadyMask();
1197 }
1198 }
1199 if (mxfd > -1)
1200 rc = UnixSelect(mxfd+1, &rd, &wr, to);
1201
1202 // Set readiness bits
1203 if (rc > 0) {
1204 next.Reset();
1205 while ((h = (TFileHandler *) next())) {
1206 Int_t fd = h->GetFd();
1207 if (rd.IsSet(fd))
1208 h->SetReadReady();
1209 if (wr.IsSet(fd))
1210 h->SetWriteReady();
1211 }
1212 }
1213
1214 return rc;
1215}
1216
1217////////////////////////////////////////////////////////////////////////////////
1218/// Select on the file descriptor related to file handler h.
1219/// The timeout to is in millisec. Returns the number of ready descriptors,
1220/// or 0 in case of timeout, or < 0 in case of an error, with -2 being EINTR
1221/// and -3 EBADF. In case of EINTR the errno has been reset and the method
1222/// can be called again. Returns -4 in case the file handler is 0 or does
1223/// not have a file descriptor >= 0.
1224
1226{
1227 Int_t rc = -4;
1228
1229 TFdSet rd, wr;
1230 Int_t mxfd = -1;
1231 Int_t fd = -1;
1232 if (h) {
1233 fd = h->GetFd();
1234 if (fd > -1) {
1235 if (h->HasReadInterest())
1236 rd.Set(fd);
1237 if (h->HasWriteInterest())
1238 wr.Set(fd);
1239 h->ResetReadyMask();
1240 mxfd = fd;
1241 rc = UnixSelect(mxfd+1, &rd, &wr, to);
1242 }
1243 }
1244
1245 // Fill output lists, if required
1246 if (rc > 0) {
1247 if (rd.IsSet(fd))
1248 h->SetReadReady();
1249 if (wr.IsSet(fd))
1250 h->SetWriteReady();
1251 }
1252
1253 return rc;
1254}
1255
1256//---- handling of system events -----------------------------------------------
1257
1258////////////////////////////////////////////////////////////////////////////////
1259/// Check if some signals were raised and call their Notify() member.
1260
1262{
1264 Int_t sigdone = -1;
1265 {
1267
1268 while ((sh = (TSignalHandler*)it.Next())) {
1269 if (sync == sh->IsSync()) {
1270 ESignals sig = sh->GetSignal();
1271 if ((fSignals->IsSet(sig) && sigdone == -1) || sigdone == sig) {
1272 if (sigdone == -1) {
1273 fSignals->Clr(sig);
1274 sigdone = sig;
1275 fSigcnt--;
1276 }
1277 if (sh->IsActive())
1278 sh->Notify();
1279 }
1280 }
1281 }
1282 }
1283 if (sigdone != -1)
1284 return kTRUE;
1285
1286 return kFALSE;
1287}
1288
1289////////////////////////////////////////////////////////////////////////////////
1290/// Check if children have finished.
1291
1293{
1294#if 0 //rdm
1295 int pid;
1296 while ((pid = UnixWaitchild()) > 0) {
1297 TIter next(zombieHandler);
1298 register UnixPtty *pty;
1299 while ((pty = (UnixPtty*) next()))
1300 if (pty->GetPid() == pid) {
1301 zombieHandler->RemovePtr(pty);
1302 pty->DiedNotify();
1303 }
1304 }
1305#endif
1306}
1307
1308////////////////////////////////////////////////////////////////////////////////
1309/// Check if there is activity on some file descriptors and call their
1310/// Notify() member.
1311
1313{
1314 TFileHandler *fh;
1315 Int_t fddone = -1;
1316 Bool_t read = kFALSE;
1318 while ((fh = (TFileHandler*) it.Next())) {
1319 Int_t fd = fh->GetFd();
1320 if ((fd <= fMaxrfd && fReadready->IsSet(fd) && fddone == -1) ||
1321 (fddone == fd && read)) {
1322 if (fddone == -1) {
1323 fReadready->Clr(fd);
1324 fddone = fd;
1325 read = kTRUE;
1326 fNfd--;
1327 }
1328 if (fh->IsActive())
1329 fh->ReadNotify();
1330 }
1331 if ((fd <= fMaxwfd && fWriteready->IsSet(fd) && fddone == -1) ||
1332 (fddone == fd && !read)) {
1333 if (fddone == -1) {
1334 fWriteready->Clr(fd);
1335 fddone = fd;
1336 read = kFALSE;
1337 fNfd--;
1338 }
1339 if (fh->IsActive())
1340 fh->WriteNotify();
1341 }
1342 }
1343 if (fddone != -1)
1344 return kTRUE;
1345
1346 return kFALSE;
1347}
1348
1349//---- Directories -------------------------------------------------------------
1350
1351////////////////////////////////////////////////////////////////////////////////
1352/// Make a Unix file system directory. Returns 0 in case of success and
1353/// -1 if the directory could not be created.
1354
1356{
1358 if (helper)
1359 return helper->MakeDirectory(name);
1360
1361 return UnixMakedir(name);
1362}
1363
1364////////////////////////////////////////////////////////////////////////////////
1365/// Open a Unix file system directory. Returns 0 if directory does not exist.
1366
1368{
1370 if (helper)
1371 return helper->OpenDirectory(name);
1372
1373 return UnixOpendir(name);
1374}
1375
1376////////////////////////////////////////////////////////////////////////////////
1377/// Close a Unix file system directory.
1378
1380{
1381 TSystem *helper = FindHelper(nullptr, dirp);
1382 if (helper) {
1383 helper->FreeDirectory(dirp);
1384 return;
1385 }
1386
1387 if (dirp)
1388 ::closedir((DIR*)dirp);
1389}
1390
1391////////////////////////////////////////////////////////////////////////////////
1392/// Get next Unix file system directory entry. Returns 0 if no more entries.
1393
1395{
1396 TSystem *helper = FindHelper(nullptr, dirp);
1397 if (helper)
1398 return helper->GetDirEntry(dirp);
1399
1400 if (dirp)
1401 return UnixGetdirentry(dirp);
1402
1403 return nullptr;
1404}
1405
1406////////////////////////////////////////////////////////////////////////////////
1407/// Change directory. Returns kTRUE in case of success, kFALSE otherwise.
1408
1410{
1411 Bool_t ret = (Bool_t) (::chdir(path) == 0);
1412 if (fWdpath != "")
1413 fWdpath = ""; // invalidate path cache
1414 return ret;
1415}
1416
1417////////////////////////////////////////////////////////////////////////////////
1418/// Return working directory.
1419
1421{
1422 // don't use cache as user can call chdir() directly somewhere else
1423 //if (fWdpath != "")
1424 // return fWdpath.Data();
1425
1427
1428 static char cwd[kMAXPATHLEN];
1430 fWdpath = cwd;
1431
1432 return fWdpath.Data();
1433}
1434
1435//////////////////////////////////////////////////////////////////////////////
1436/// Return working directory.
1437
1439{
1440 char cwd[kMAXPATHLEN];
1442 return std::string(cwd);
1443}
1444
1445//////////////////////////////////////////////////////////////////////////////
1446/// Fill buffer with current working directory.
1447
1449{
1450 if (::getcwd(cwd, kMAXPATHLEN) == nullptr) {
1451 Error("WorkingDirectory", "getcwd() failed");
1452 }
1453}
1454
1455////////////////////////////////////////////////////////////////////////////////
1456/// Return the user's home directory.
1457
1458const char *TUnixSystem::HomeDirectory(const char *userName)
1459{
1461}
1462
1463//////////////////////////////////////////////////////////////////////////////
1464/// Return the user's home directory.
1465
1466std::string TUnixSystem::GetHomeDirectory(const char *userName) const
1467{
1468 char path[kMAXPATHLEN], mydir[kMAXPATHLEN] = { '\0' };
1469 auto res = UnixHomedirectory(userName, path, mydir);
1470 if (res) return std::string(res);
1471 else return std::string();
1472}
1473
1474////////////////////////////////////////////////////////////////////////////////
1475/// Return a user configured or systemwide directory to create
1476/// temporary files in.
1477
1479{
1480 const char *dir = gSystem->Getenv("TMPDIR");
1481 if (!dir || gSystem->AccessPathName(dir, kWritePermission))
1482 dir = "/tmp";
1483
1484 return dir;
1485}
1486
1487////////////////////////////////////////////////////////////////////////////////
1488/// Create a secure temporary file by appending a unique
1489/// 6 letter string to base. The file will be created in
1490/// a standard (system) directory or in the directory
1491/// provided in dir. Optionally one can provide suffix
1492/// append to the final name - like extension ".txt" or ".html".
1493/// The full filename is returned in base
1494/// and a filepointer is returned for safely writing to the file
1495/// (this avoids certain security problems). Returns 0 in case
1496/// of error.
1497
1498FILE *TUnixSystem::TempFileName(TString &base, const char *dir, const char *suffix)
1499{
1500 PrependPathName(dir ? dir : TempDirectory(), base);
1501 base += "XXXXXX";
1502 const bool hasSuffix = suffix && *suffix;
1503 if (hasSuffix)
1504 base.Append(suffix);
1505
1506 char *arg = StrDup(base);
1507 int fd = hasSuffix ? mkstemps(arg, strlen(suffix)) : mkstemp(arg);
1508 base = arg;
1509 delete [] arg;
1510
1511 if (fd == -1) {
1512 SysError("TempFileName", "%s", base.Data());
1513 return nullptr;
1514 } else {
1515 FILE *fp = fdopen(fd, "w+");
1516 if (!fp)
1517 SysError("TempFileName", "converting filedescriptor (%d)", fd);
1518 return fp;
1519 }
1520}
1521
1522////////////////////////////////////////////////////////////////////////////////
1523/// Concatenate a directory and a file name.
1524
1525const char *TUnixSystem::PrependPathName(const char *dir, TString& name)
1526{
1527 if (name.IsNull() || name == ".") {
1528 if (dir) {
1529 name = dir;
1530 if (dir[strlen(dir) - 1] != '/')
1531 name += '/';
1532 } else name = "";
1533 return name.Data();
1534 }
1535
1536 if (!dir || !dir[0])
1537 dir = "/";
1538 else if (dir[strlen(dir) - 1] != '/')
1539 name.Prepend('/');
1540 name.Prepend(dir);
1541
1542 return name.Data();
1543}
1544
1545//---- Paths & Files -----------------------------------------------------------
1546
1547////////////////////////////////////////////////////////////////////////////////
1548/// Returns FALSE if one can access a file using the specified access mode.
1549/// Mode is the same as for the Unix access(2) function.
1550/// Attention, bizarre convention of return value!!
1551
1553{
1554 TSystem *helper = FindHelper(path);
1555 if (helper)
1556 return helper->AccessPathName(path, mode);
1557
1558 if (::access(StripOffProto(path, "file:"), mode) == 0)
1559 return kFALSE;
1561
1562 return kTRUE;
1563}
1564
1565////////////////////////////////////////////////////////////////////////////////
1566/// Copy a file. If overwrite is true and file already exists the
1567/// file will be overwritten. Returns 0 when successful, -1 in case
1568/// of file open failure, -2 in case the file already exists and overwrite
1569/// was false and -3 in case of error during copy.
1570
1571int TUnixSystem::CopyFile(const char *f, const char *t, Bool_t overwrite)
1572{
1573 if (!AccessPathName(t) && !overwrite)
1574 return -2;
1575
1576 FILE *from = fopen(f, "r");
1577 if (!from)
1578 return -1;
1579
1580 FILE *to = fopen(t, "w");
1581 if (!to) {
1582 fclose(from);
1583 return -1;
1584 }
1585
1586 const int bufsize = 1024;
1587 char buf[bufsize];
1588 int ret = 0;
1589 while (!ret && !feof(from)) {
1590 size_t numread = fread (buf, sizeof(char), bufsize, from);
1591 size_t numwritten = fwrite(buf, sizeof(char), numread, to);
1592 if (numread != numwritten)
1593 ret = -3;
1594 }
1595
1596 fclose(from);
1597 fclose(to);
1598
1599 return ret;
1600}
1601
1602////////////////////////////////////////////////////////////////////////////////
1603/// Rename a file. Returns 0 when successful, -1 in case of failure.
1604
1605int TUnixSystem::Rename(const char *f, const char *t)
1606{
1607 int ret = ::rename(f, t);
1609 return ret;
1610}
1611
1612////////////////////////////////////////////////////////////////////////////////
1613/// Returns TRUE if the url in 'path' points to the local file system.
1614/// This is used to avoid going through the NIC card for local operations.
1615
1617{
1618 TSystem *helper = FindHelper(path);
1619 if (helper)
1620 return helper->IsPathLocal(path);
1621
1622 return TSystem::IsPathLocal(path);
1623}
1624
1625////////////////////////////////////////////////////////////////////////////////
1626/// Get info about a file. Info is returned in the form of a FileStat_t
1627/// structure (see TSystem.h).
1628/// The function returns 0 in case of success and 1 if the file could
1629/// not be stat'ed.
1630
1631int TUnixSystem::GetPathInfo(const char *path, FileStat_t &buf)
1632{
1633 TSystem *helper = FindHelper(path);
1634 if (helper)
1635 return helper->GetPathInfo(path, buf);
1636
1637 return UnixFilestat(path, buf);
1638}
1639
1640////////////////////////////////////////////////////////////////////////////////
1641/// Get info about a file system: id, bsize, bfree, blocks.
1642/// Id is file system type (machine dependend, see statfs())
1643/// Bsize is block size of file system
1644/// Blocks is total number of blocks in file system
1645/// Bfree is number of free blocks in file system
1646/// The function returns 0 in case of success and 1 if the file system could
1647/// not be stat'ed.
1648
1649int TUnixSystem::GetFsInfo(const char *path, Long_t *id, Long_t *bsize,
1651{
1652 return UnixFSstat(path, id, bsize, blocks, bfree);
1653}
1654
1655////////////////////////////////////////////////////////////////////////////////
1656/// Create a link from file1 to file2. Returns 0 when successful,
1657/// -1 in case of failure.
1658
1659int TUnixSystem::Link(const char *from, const char *to)
1660{
1661 return ::link(from, to);
1662}
1663
1664////////////////////////////////////////////////////////////////////////////////
1665/// Create a symlink from file1 to file2. Returns 0 when successful,
1666/// -1 in case of failure.
1667
1668int TUnixSystem::Symlink(const char *from, const char *to)
1669{
1670#if defined(R__AIX)
1671 return ::symlink((char*)from, (char*)to);
1672#else
1673 return ::symlink(from, to);
1674#endif
1675}
1676
1677////////////////////////////////////////////////////////////////////////////////
1678/// Unlink, i.e. remove, a file or directory. Returns 0 when successful,
1679/// -1 in case of failure.
1680
1682{
1684 if (helper)
1685 return helper->Unlink(name);
1686
1687#if defined(R__SEEK64)
1688 struct stat64 finfo;
1689 if (lstat64(name, &finfo) < 0)
1690#else
1691 struct stat finfo;
1692 if (lstat(name, &finfo) < 0)
1693#endif
1694 return -1;
1695
1696 if (S_ISDIR(finfo.st_mode))
1697 return ::rmdir(name);
1698 else
1699 return ::unlink(name);
1700}
1701
1702//---- expand the metacharacters as in the shell -------------------------------
1703
1704// expand the metacharacters as in the shell
1705
1706const char
1707#ifdef G__OLDEXPAND
1708 kShellEscape = '\\',
1709 *kShellStuff = "(){}<>\"'",
1710#endif
1711 *kShellMeta = "~*[]{}?$";
1712
1713
1714#ifndef G__OLDEXPAND
1715////////////////////////////////////////////////////////////////////////////////
1716/// Expand a pathname getting rid of special shell characters like ~.$, etc.
1717/// For Unix/Win32 compatibility use $(XXX) instead of $XXX when using
1718/// environment variables in a pathname. If compatibility is not an issue
1719/// you can use on Unix directly $XXX. Returns kFALSE in case of success
1720/// or kTRUE in case of error.
1721
1723{
1724 const char *p, *patbuf = (const char *)path;
1725
1726 // skip leading blanks
1727 while (*patbuf == ' ')
1728 patbuf++;
1729
1730 // any shell meta characters ?
1731 for (p = patbuf; *p; p++)
1732 if (strchr(kShellMeta, *p))
1733 goto expand;
1734
1735 return kFALSE;
1736
1737expand:
1738 // replace $(XXX) by $XXX
1739 path.ReplaceAll("$(","$");
1740 path.ReplaceAll(")","");
1741
1742 return ExpandFileName(path);
1743}
1744#endif
1745
1746#ifdef G__OLDEXPAND
1747////////////////////////////////////////////////////////////////////////////////
1748/// Expand a pathname getting rid of special shell characters like ~.$, etc.
1749/// For Unix/Win32 compatibility use $(XXX) instead of $XXX when using
1750/// environment variables in a pathname. If compatibility is not an issue
1751/// you can use on Unix directly $XXX. Returns kFALSE in case of success
1752/// or kTRUE in case of error.
1753
1755{
1756 const char *patbuf = (const char *)patbuf0;
1757 const char *hd, *p;
1758 // char cmd[kMAXPATHLEN],
1759 char stuffedPat[kMAXPATHLEN], name[70];
1760 char *q;
1761 FILE *pf;
1762 int ch;
1763
1764 // skip leading blanks
1765 while (*patbuf == ' ')
1766 patbuf++;
1767
1768 // any shell meta characters ?
1769 for (p = patbuf; *p; p++)
1770 if (strchr(kShellMeta, *p))
1771 goto needshell;
1772
1773 return kFALSE;
1774
1775needshell:
1776 // replace $(XXX) by $XXX
1777 patbuf0.ReplaceAll("$(","$");
1778 patbuf0.ReplaceAll(")","");
1779
1780 // escape shell quote characters
1782
1783 TString cmd("echo ");
1784
1785 // emulate csh -> popen executes sh
1786 if (stuffedPat[0] == '~') {
1787 if (stuffedPat[1] != '\0' && stuffedPat[1] != '/') {
1788 // extract user name
1789 for (p = &stuffedPat[1], q = name; *p && *p !='/';)
1790 *q++ = *p++;
1791 *q = '\0';
1793 if (!hd)
1794 cmd += stuffedPat;
1795 else {
1796 cmd += hd;
1797 cmd += p;
1798 }
1799 } else {
1800 hd = UnixHomedirectory(nullptr);
1801 if (!hd) {
1803 return kTRUE;
1804 }
1805 cmd += hd;
1806 cmd += &stuffedPat[1];
1807 }
1808 } else
1809 cmd += stuffedPat;
1810
1811 if ((pf = ::popen(cmd.Data(), "r")) == 0) {
1813 return kTRUE;
1814 }
1815
1816 // read first argument
1817 patbuf0 = "";
1818 int cnt = 0;
1819#if defined(R__AIX)
1820again:
1821#endif
1822 for (ch = fgetc(pf); ch != EOF && ch != ' ' && ch != '\n'; ch = fgetc(pf)) {
1823 patbuf0.Append(ch);
1824 cnt++;
1825 }
1826#if defined(R__AIX)
1827 // Work around bug timing problem due to delay in forking a large program
1828 if (cnt == 0 && ch == EOF) goto again;
1829#endif
1830
1831 // skip rest of pipe
1832 while (ch != EOF) {
1833 ch = fgetc(pf);
1834 if (ch == ' ' || ch == '\t') {
1835 GetLastErrorString() = "expression ambigous";
1836 ::pclose(pf);
1837 return kTRUE;
1838 }
1839 }
1840
1841 ::pclose(pf);
1842
1843 return kFALSE;
1844}
1845#endif
1846
1847////////////////////////////////////////////////////////////////////////////////
1848/// Expand a pathname getting rid of special shell characaters like ~.$, etc.
1849/// For Unix/Win32 compatibility use $(XXX) instead of $XXX when using
1850/// environment variables in a pathname. If compatibility is not an issue
1851/// you can use on Unix directly $XXX. The user must delete returned string.
1852/// Returns the expanded pathname or 0 in case of error.
1853/// The user must delete returned string (delete []).
1854
1855char *TUnixSystem::ExpandPathName(const char *path)
1856{
1857 TString patbuf = path;
1859 return nullptr;
1860 return StrDup(patbuf.Data());
1861}
1862
1863////////////////////////////////////////////////////////////////////////////////
1864/// Set the file permission bits. Returns -1 in case or error, 0 otherwise.
1865
1866int TUnixSystem::Chmod(const char *file, UInt_t mode)
1867{
1868 return ::chmod(file, mode);
1869}
1870
1871////////////////////////////////////////////////////////////////////////////////
1872/// Set the process file creation mode mask.
1873
1875{
1876 return ::umask(mask);
1877}
1878
1879////////////////////////////////////////////////////////////////////////////////
1880/// Set a files modification and access times. If actime = 0 it will be
1881/// set to the modtime. Returns 0 on success and -1 in case of error.
1882
1883int TUnixSystem::Utime(const char *file, Long_t modtime, Long_t actime)
1884{
1885 if (!actime)
1886 actime = modtime;
1887
1888 struct utimbuf t;
1889 t.actime = (time_t)actime;
1890 t.modtime = (time_t)modtime;
1891 return ::utime(file, &t);
1892}
1893
1894////////////////////////////////////////////////////////////////////////////////
1895/// Find location of file "wfil" in a search path.
1896/// The search path is specified as a : separated list of directories.
1897/// Return value is pointing to wfile for compatibility with
1898/// Which(const char*,const char*,EAccessMode) version.
1899/// \note This function does not support finding files in directories containing
1900/// colons in their name. For that specific use case and if you know the filename,
1901/// deploy instead TSystem::AccessPathName(dirName+fileName, kReadPermission)
1902
1904{
1905 TString show;
1906 if (gEnv->GetValue("Root.ShowPath", 0))
1907 show.Form("Which: %s =", wfil.Data());
1908
1910
1911 if (wfil[0] == '/') {
1912#if defined(R__SEEK64)
1913 struct stat64 finfo;
1914 if (access(wfil.Data(), mode) == 0 &&
1915 stat64(wfil.Data(), &finfo) == 0 && S_ISREG(finfo.st_mode)) {
1916#else
1917 struct stat finfo;
1918 if (access(wfil.Data(), mode) == 0 &&
1919 stat(wfil.Data(), &finfo) == 0 && S_ISREG(finfo.st_mode)) {
1920#endif
1921 if (show != "")
1922 Printf("%s %s", show.Data(), wfil.Data());
1923 return wfil.Data();
1924 }
1925 if (show != "")
1926 Printf("%s <not found>", show.Data());
1927 wfil = "";
1928 return nullptr;
1929 }
1930
1931 if (!search)
1932 search = ".";
1933
1935 apwd += "/";
1936 for (const char* ptr = search; *ptr;) {
1937 TString name;
1938 if (*ptr != '/' && *ptr !='$' && *ptr != '~')
1939 name = apwd;
1940 const char* posEndOfPart = strchr(ptr, ':');
1941 if (posEndOfPart) {
1942 name.Append(ptr, posEndOfPart - ptr);
1943 ptr = posEndOfPart + 1; // skip ':'
1944 } else {
1945 name.Append(ptr);
1946 ptr += strlen(ptr);
1947 }
1948
1949 if (!name.EndsWith("/"))
1950 name += '/';
1951 name += wfil;
1952
1954#if defined(R__SEEK64)
1955 struct stat64 finfo;
1956 if (access(name.Data(), mode) == 0 &&
1957 stat64(name.Data(), &finfo) == 0 && S_ISREG(finfo.st_mode)) {
1958#else
1959 struct stat finfo;
1960 if (access(name.Data(), mode) == 0 &&
1961 stat(name.Data(), &finfo) == 0 && S_ISREG(finfo.st_mode)) {
1962#endif
1963 if (show != "")
1964 Printf("%s %s", show.Data(), name.Data());
1965 wfil = name;
1966 return wfil.Data();
1967 }
1968 }
1969
1970 if (show != "")
1971 Printf("%s <not found>", show.Data());
1972 wfil = "";
1973 return nullptr;
1974}
1975
1976//---- Users & Groups ----------------------------------------------------------
1977
1978////////////////////////////////////////////////////////////////////////////////
1979/// Returns the user's id. If user = 0, returns current user's id.
1980
1982{
1983 if (!user || !user[0])
1984 return getuid();
1985 else {
1986 struct passwd *apwd = getpwnam(user);
1987 if (apwd)
1988 return apwd->pw_uid;
1989 }
1990 return 0;
1991}
1992
1993////////////////////////////////////////////////////////////////////////////////
1994/// Returns the effective user id. The effective id corresponds to the
1995/// set id bit on the file being executed.
1996
1998{
1999 return geteuid();
2000}
2001
2002////////////////////////////////////////////////////////////////////////////////
2003/// Returns the group's id. If group = 0, returns current user's group.
2004
2006{
2007 if (!group || !group[0])
2008 return getgid();
2009 else {
2010 struct group *grp = getgrnam(group);
2011 if (grp)
2012 return grp->gr_gid;
2013 }
2014 return 0;
2015}
2016
2017////////////////////////////////////////////////////////////////////////////////
2018/// Returns the effective group id. The effective group id corresponds
2019/// to the set id bit on the file being executed.
2020
2022{
2023 return getegid();
2024}
2025
2026////////////////////////////////////////////////////////////////////////////////
2027/// Returns all user info in the UserGroup_t structure. The returned
2028/// structure must be deleted by the user. In case of error 0 is returned.
2029
2031{
2032 typedef std::map<Int_t /*uid*/, UserGroup_t> UserInfoCache_t;
2034
2036 if (iUserInfo != gUserInfo.end())
2037 return new UserGroup_t(iUserInfo->second);
2038
2039 struct passwd *apwd = getpwuid(uid);
2040 if (apwd) {
2041 UserGroup_t *ug = new UserGroup_t;
2042 ug->fUid = apwd->pw_uid;
2043 ug->fGid = apwd->pw_gid;
2044 ug->fUser = apwd->pw_name;
2045 ug->fPasswd = apwd->pw_passwd;
2046 ug->fRealName = apwd->pw_gecos;
2047 ug->fShell = apwd->pw_shell;
2048 UserGroup_t *gr = GetGroupInfo(apwd->pw_gid);
2049 if (gr) ug->fGroup = gr->fGroup;
2050 delete gr;
2051
2052 gUserInfo[uid] = *ug;
2053 return ug;
2054 }
2055 return nullptr;
2056}
2057
2058////////////////////////////////////////////////////////////////////////////////
2059/// Returns all user info in the UserGroup_t structure. If user = 0, returns
2060/// current user's id info. The returned structure must be deleted by the
2061/// user. In case of error 0 is returned.
2062
2064{
2065 return GetUserInfo(GetUid(user));
2066}
2067
2068////////////////////////////////////////////////////////////////////////////////
2069/// Returns all group info in the UserGroup_t structure. The only active
2070/// fields in the UserGroup_t structure for this call are:
2071/// fGid and fGroup
2072/// The returned structure must be deleted by the user. In case of
2073/// error 0 is returned.
2074
2076{
2077 struct group *grp = getgrgid(gid);
2078 if (grp) {
2079 UserGroup_t *gr = new UserGroup_t;
2080 gr->fUid = 0;
2081 gr->fGid = grp->gr_gid;
2082 gr->fGroup = grp->gr_name;
2083 return gr;
2084 }
2085 return nullptr;
2086}
2087
2088////////////////////////////////////////////////////////////////////////////////
2089/// Returns all group info in the UserGroup_t structure. The only active
2090/// fields in the UserGroup_t structure for this call are:
2091/// fGid and fGroup
2092/// If group = 0, returns current user's group. The returned structure
2093/// must be deleted by the user. In case of error 0 is returned.
2094
2096{
2097 return GetGroupInfo(GetGid(group));
2098}
2099
2100//---- environment manipulation ------------------------------------------------
2101
2102////////////////////////////////////////////////////////////////////////////////
2103/// Set environment variable.
2104
2105void TUnixSystem::Setenv(const char *name, const char *value)
2106{
2107 ::setenv(name, value, 1);
2108}
2109
2110////////////////////////////////////////////////////////////////////////////////
2111/// Get environment variable.
2112
2113const char *TUnixSystem::Getenv(const char *name)
2114{
2115 return std::getenv(name);
2116}
2117
2118////////////////////////////////////////////////////////////////////////////////
2119/// Unset environment variable.
2120
2122{
2124}
2125
2126//---- Processes ---------------------------------------------------------------
2127
2128////////////////////////////////////////////////////////////////////////////////
2129/// Execute a command.
2130
2132{
2133 return ::system(shellcmd);
2134}
2135
2136////////////////////////////////////////////////////////////////////////////////
2137/// Open a pipe.
2138
2139FILE *TUnixSystem::OpenPipe(const char *command, const char *mode)
2140{
2141 return ::popen(command, mode);
2142}
2143
2144////////////////////////////////////////////////////////////////////////////////
2145/// Close the pipe.
2146
2148{
2149 return ::pclose(pipe);
2150}
2151
2152////////////////////////////////////////////////////////////////////////////////
2153/// Get process id.
2154
2156{
2157 return ::getpid();
2158}
2159
2160////////////////////////////////////////////////////////////////////////////////
2161/// Exit the application.
2162
2164{
2165 // Insures that the files and sockets are closed before any library is unloaded
2166 // and before emptying CINT.
2168
2169 if (mode)
2170 ::exit(code);
2171 else
2172 ::_exit(code);
2173}
2174
2175////////////////////////////////////////////////////////////////////////////////
2176/// Abort the application.
2177
2179{
2181 ::abort();
2182}
2183
2184
2185#ifdef R__MACOSX
2186/// Use CoreSymbolication to retrieve the stacktrace.
2187#include <mach/mach.h>
2188extern "C" {
2189 // Adapted from https://github.com/mountainstorm/CoreSymbolication
2190 // Under the hood the framework basically just calls through to a set of C++ libraries
2191 typedef struct {
2192 void* csCppData;
2193 void* csCppObj;
2194 } CSTypeRef;
2196 typedef CSTypeRef CSSourceInfoRef;
2198 typedef CSTypeRef CSSymbolRef;
2199
2203 const char* CSSymbolGetName(CSSymbolRef sym);
2208}
2209
2211 return ref.csCppData || ref.csCppObj;
2212}
2213
2214void macosx_backtrace() {
2216 // retrieve current stack addresses
2217 int numstacks = backtrace( addrlist, sizeof( addrlist ) / sizeof( void* ));
2218
2220
2221 // skip TUnixSystem::Backtrace(), macosx_backtrace()
2222 static const int skipFrames = 2;
2223 for (int i = skipFrames; i < numstacks; ++i) {
2224 // No debug info, try to get at least the symbol name.
2227 0x80000000u);
2229
2230 if (const char* libPath = CSSymbolOwnerGetPath(symOwner)) {
2231 printf("[%s]", libPath);
2232 } else {
2233 printf("[<unknown binary>]");
2234 }
2235
2236 if (const char* symname = CSSymbolGetName(sym)) {
2237 printf(" %s", symname);
2238 }
2239
2243 0x80000000u /*"now"*/);
2244 if (const char* sourcePath = CSSourceInfoGetPath(sourceInfo)) {
2246 } else {
2247 printf(" (no debug info)");
2248 }
2249 printf("\n");
2250 }
2251}
2252#endif // R__MACOSX
2253
2254////////////////////////////////////////////////////////////////////////////////
2255/// Print a stack trace.
2256
2258{
2259 if (!gEnv->GetValue("Root.Stacktrace", 1))
2260 return;
2261
2262#ifndef R__MACOSX
2263 TString gdbscript = gEnv->GetValue("Root.StacktraceScript", "");
2264 gdbscript = gdbscript.Strip();
2265 if (gdbscript != "") {
2267 fprintf(stderr, "Root.StacktraceScript %s does not exist\n", gdbscript.Data());
2268 gdbscript = "";
2269 }
2270 }
2271 if (gdbscript == "") {
2272 gdbscript = "gdb-backtrace.sh";
2275 fprintf(stderr, "Error in <TUnixSystem::StackTrace> script %s is missing\n", gdbscript.Data());
2276 return;
2277 }
2278 }
2279 gdbscript += " ";
2280
2281 TString gdbmess = gEnv->GetValue("Root.StacktraceMessage", "");
2282 gdbmess = gdbmess.Strip();
2283
2284 std::cout.flush();
2285 fflush(stdout);
2286
2287 std::cerr.flush();
2288 fflush(stderr);
2289
2290 int fd = STDERR_FILENO;
2291
2292 const char *message = " Generating stack trace...\n";
2293
2294 if (fd && message) { } // remove unused warning (remove later)
2295
2296 if (gApplication && !strcmp(gApplication->GetName(), "TRint"))
2297 Getlinem(kCleanUp, nullptr);
2298
2299#if defined(USE_GDB_STACK_TRACE)
2300 char *gdb = Which(Getenv("PATH"), "gdb", kExecutePermission);
2301 if (!gdb) {
2302 fprintf(stderr, "gdb not found, need it for stack trace\n");
2303 return;
2304 }
2305
2306 // write custom message file
2307 TString gdbmessf = "gdb-message";
2308 if (gdbmess != "") {
2310 fprintf(f, "%s\n", gdbmess.Data());
2311 fclose(f);
2312 }
2313
2314 // use gdb to get stack trace
2315 gdbscript += GetExePath();
2316 gdbscript += " ";
2317 gdbscript += GetPid();
2318 if (gdbmess != "") {
2319 gdbscript += " ";
2321 }
2322 gdbscript += " 1>&2";
2323 Exec(gdbscript);
2324 delete [] gdb;
2325 return;
2326
2327#elif defined(R__AIX)
2328 TString script = "procstack ";
2329 script += GetPid();
2330 Exec(script);
2331 return;
2332#elif defined(R__SOLARIS)
2333 char *cppfilt = Which(Getenv("PATH"), "c++filt", kExecutePermission);
2334 TString script = "pstack ";
2335 script += GetPid();
2336 if (cppfilt) {
2337 script += " | ";
2338 script += cppfilt;
2339 delete [] cppfilt;
2340 }
2341 Exec(script);
2342 return;
2343#elif defined(HAVE_BACKTRACE_SYMBOLS_FD) && defined(HAVE_DLADDR) // linux + MacOS X >= 10.5
2344 // we could have used backtrace_symbols_fd, except its output
2345 // format is pretty bad, so recode that here :-(
2346
2347 // take care of demangling
2349
2350 // check for c++filt
2351 const char *cppfilt = "c++filt";
2352 const char *cppfiltarg = "";
2353#ifdef R__B64
2354 const char *format1 = " 0x%016lx in %.200s %s 0x%lx from %.200s\n";
2355#ifdef R__MACOSX
2356 const char *format2 = " 0x%016lx in %.200s\n";
2357#else
2358 const char *format2 = " 0x%016lx in %.200s at %.200s from %.200s\n";
2359#endif
2360 const char *format3 = " 0x%016lx in %.200s from %.200s\n";
2361 const char *format4 = " 0x%016lx in <unknown function>\n";
2362#else
2363 const char *format1 = " 0x%08lx in %.200s %s 0x%lx from %.200s\n";
2364#ifdef R__MACOSX
2365 const char *format2 = " 0x%08lx in %.200s\n";
2366#else
2367 const char *format2 = " 0x%08lx in %.200s at %.200s from %.200s\n";
2368#endif
2369 const char *format3 = " 0x%08lx in %.200s from %.200s\n";
2370 const char *format4 = " 0x%08lx in <unknown function>\n";
2371#endif
2372
2373 char *filter = Which(Getenv("PATH"), cppfilt, kExecutePermission);
2374 if (!filter)
2375 demangle = kFALSE;
2376
2377#if (__GNUC__ >= 3)
2378 // try finding supported format option for g++ v3
2379 if (filter) {
2380 FILE *p = OpenPipe(TString::Format("%s --help 2>&1", filter), "r");
2381 TString help;
2382 while (help.Gets(p)) {
2383 if (help.Index("gnu-v3") != kNPOS) {
2384 cppfiltarg = "--format=gnu-v3";
2385 break;
2386 } else if (help.Index("gnu-new-abi") != kNPOS) {
2387 cppfiltarg = "--format=gnu-new-abi";
2388 break;
2389 }
2390 }
2391 ClosePipe(p);
2392 }
2393#endif
2394 // gdb-backtrace.sh uses gdb to produce a backtrace. See if it is available.
2395 // If it is, use it. If not proceed as before.
2396#if (defined(R__LINUX) && !defined(R__WINGCC))
2397 // Declare the process that will be generating the stacktrace
2398 // For more see: http://askubuntu.com/questions/41629/after-upgrade-gdb-wont-attach-to-process
2399#ifdef PR_SET_PTRACER
2400 prctl(PR_SET_PTRACER, getpid(), 0, 0, 0);
2401#endif
2402#endif
2403 char *gdb = Which(Getenv("PATH"), "gdb", kExecutePermission);
2404 if (gdb) {
2405 // write custom message file
2406 TString gdbmessf = "gdb-message";
2407 if (gdbmess != "") {
2409 fprintf(f, "%s\n", gdbmess.Data());
2410 fclose(f);
2411 }
2412
2413 // use gdb to get stack trace
2414#ifdef R__MACOSX
2415 gdbscript += GetExePath();
2416 gdbscript += " ";
2417#endif
2418 gdbscript += GetPid();
2419 if (gdbmess != "") {
2420 gdbscript += " ";
2422 }
2423 gdbscript += " 1>&2";
2424 Exec(gdbscript);
2425 delete [] gdb;
2426 } else {
2427 // addr2line uses debug info to convert addresses into file names
2428 // and line numbers
2429#ifdef R__MACOSX
2430 char *addr2line = Which(Getenv("PATH"), "atos", kExecutePermission);
2431#else
2432 char *addr2line = Which(Getenv("PATH"), "addr2line", kExecutePermission);
2433#endif
2434 if (addr2line) {
2435 // might take some time so tell what we are doing...
2436 if (write(fd, message, strlen(message)) < 0)
2437 Warning("StackTrace", "problems writing line numbers (errno: %d)", TSystem::GetErrno());
2438 }
2439
2440 // open tmp file for demangled stack trace
2441 TString tmpf1 = "gdb-backtrace";
2442 std::ofstream file1;
2443 if (demangle) {
2445 if (f) fclose(f);
2446 file1.open(tmpf1);
2447 if (!file1) {
2448 Error("StackTrace", "could not open file %s", tmpf1.Data());
2449 Unlink(tmpf1);
2450 demangle = kFALSE;
2451 }
2452 }
2453
2454#ifdef R__MACOSX
2455 if (addr2line)
2456 demangle = kFALSE; // atos always demangles
2457#endif
2458
2459 char buffer[4096];
2462 for (int n = 5; n < depth; n++) {
2463 ULong_t addr = (ULong_t) trace[n];
2464 Dl_info info;
2465
2466 if (dladdr(trace[n], &info) && info.dli_fname && info.dli_fname[0]) {
2467 const char *libname = info.dli_fname;
2468 const char *symname = (info.dli_sname && info.dli_sname[0]) ?
2469 info.dli_sname : "<unknown>";
2470 ULong_t libaddr = (ULong_t) info.dli_fbase;
2471 ULong_t symaddr = (ULong_t) info.dli_saddr;
2472 Bool_t gte = (addr >= symaddr);
2473 ULong_t diff = (gte) ? addr - symaddr : symaddr - addr;
2474 if (addr2line && symaddr) {
2476#ifdef R__MACOSX
2477 if (libaddr) { } // use libaddr
2478#if defined(MAC_OS_X_VERSION_10_10)
2479 snprintf(buffer, sizeof(buffer), "%s -p %d 0x%016lx", addr2line, GetPid(), addr);
2480#elif defined(MAC_OS_X_VERSION_10_9)
2481 // suppress deprecation warning with opti
2482 snprintf(buffer, sizeof(buffer), "%s -d -p %d 0x%016lx", addr2line, GetPid(), addr);
2483#else
2484 snprintf(buffer, sizeof(buffer), "%s -p %d 0x%016lx", addr2line, GetPid(), addr);
2485#endif
2486#else
2487 ULong_t offset = (addr >= libaddr) ? addr - libaddr :
2488 libaddr - addr;
2492 if (name[0] != '/') noPath = kTRUE;
2493 if (name.Contains(".so") || name.Contains(".sl")) noShare = kFALSE;
2494 if (noShare) offset = addr;
2495 if (noPath) {
2496 char *fullpath = noShare ? Which(Getenv("PATH"), name, kExecutePermission)
2498 if (fullpath) {
2499 name = fullpath;
2500 delete [] fullpath;
2501 }
2502 }
2503 snprintf(buffer, sizeof(buffer), "%s -e %s 0x%016lx", addr2line, name.Data(), offset);
2504#endif
2505 if (FILE *pf = ::popen(buffer, "r")) {
2506 char buf[2048];
2507 if (fgets(buf, 2048, pf)) {
2508 buf[strlen(buf)-1] = 0; // remove trailing \n
2509 if (strncmp(buf, "??", 2)) {
2510#ifdef R__MACOSX
2511 snprintf(buffer, sizeof(buffer), format2, addr, buf);
2512#else
2513 snprintf(buffer, sizeof(buffer), format2, addr, symname, buf, libname);
2514#endif
2515 nodebug = kFALSE;
2516 }
2517 }
2518 ::pclose(pf);
2519 }
2520 if (nodebug)
2521 snprintf(buffer, sizeof(buffer), format1, addr, symname,
2522 gte ? "+" : "-", diff, libname);
2523 } else {
2524 if (symaddr)
2525 snprintf(buffer, sizeof(buffer), format1, addr, symname,
2526 gte ? "+" : "-", diff, libname);
2527 else
2528 snprintf(buffer, sizeof(buffer), format3, addr, symname, libname);
2529 }
2530 } else {
2531 snprintf(buffer, sizeof(buffer), format4, addr);
2532 }
2533
2534 if (demangle)
2535 file1 << buffer;
2536 else
2537 if (write(fd, buffer, ::strlen(buffer)) < 0)
2538 Warning("StackTrace", "problems writing buffer (errno: %d)", TSystem::GetErrno());
2539 }
2540
2541 if (demangle) {
2542 TString tmpf2 = "gdb-backtrace";
2544 if (f) fclose(f);
2545 file1.close();
2546 snprintf(buffer, sizeof(buffer), "%s %s < %s > %s", filter, cppfiltarg, tmpf1.Data(), tmpf2.Data());
2547 Exec(buffer);
2548 std::ifstream file2(tmpf2);
2549 TString line;
2550 while (file2) {
2551 line = "";
2552 line.ReadString(file2);
2553 if (write(fd, line.Data(), line.Length()) < 0)
2554 Warning("StackTrace", "problems writing line (errno: %d)", TSystem::GetErrno());
2555 }
2556 file2.close();
2557 Unlink(tmpf1);
2558 Unlink(tmpf2);
2559 }
2560
2561 delete [] addr2line;
2562 }
2563 delete [] filter;
2564#elif defined(HAVE_EXCPT_H) && defined(HAVE_PDSC_H) && \
2565 defined(HAVE_RLD_INTERFACE_H) // tru64
2566 // Tru64 stack walk. Uses the exception handling library and the
2567 // run-time linker's core functions (loader(5)). FIXME: Tru64
2568 // should have _RLD_DLADDR like IRIX below. Verify and update.
2569
2570 char buffer [128];
2571 sigcontext context;
2572 int rc = 0;
2573
2574 exc_capture_context (&context);
2575 while (!rc && context.sc_pc) {
2576 // FIXME: Elf32?
2577 pdsc_crd *func, *base, *crd
2578 = exc_remote_lookup_function_entry(0, 0, context.sc_pc, 0, &func, &base);
2580 // const char *name = _rld_address_to_name(addr);
2581 const char *name = "<unknown function>";
2582 sprintf(buffer, " 0x%012lx %.200s + 0x%lx\n",
2583 context.sc_pc, name, context.sc_pc - addr);
2584 write(fd, buffer, ::strlen(buffer));
2585 rc = exc_virtual_unwind(0, &context);
2586 }
2587#endif
2588#else //R__MACOSX
2590#endif //R__MACOSX
2591}
2592
2593//---- System Logging ----------------------------------------------------------
2594
2595////////////////////////////////////////////////////////////////////////////////
2596/// Open connection to system log daemon. For the use of the options and
2597/// facility see the Unix openlog man page.
2598
2600{
2601 int fac = 0;
2602
2603 switch (facility) {
2604 case kLogLocal0:
2605 fac = LOG_LOCAL0;
2606 break;
2607 case kLogLocal1:
2608 fac = LOG_LOCAL1;
2609 break;
2610 case kLogLocal2:
2611 fac = LOG_LOCAL2;
2612 break;
2613 case kLogLocal3:
2614 fac = LOG_LOCAL3;
2615 break;
2616 case kLogLocal4:
2617 fac = LOG_LOCAL4;
2618 break;
2619 case kLogLocal5:
2620 fac = LOG_LOCAL5;
2621 break;
2622 case kLogLocal6:
2623 fac = LOG_LOCAL6;
2624 break;
2625 case kLogLocal7:
2626 fac = LOG_LOCAL7;
2627 break;
2628 }
2629
2630 ::openlog(name, options, fac);
2631}
2632
2633////////////////////////////////////////////////////////////////////////////////
2634/// Send mess to syslog daemon. Level is the logging level and mess the
2635/// message that will be written on the log.
2636
2637void TUnixSystem::Syslog(ELogLevel level, const char *mess)
2638{
2639 // ELogLevel matches exactly the Unix values.
2640 ::syslog(level, "%s", mess);
2641}
2642
2643////////////////////////////////////////////////////////////////////////////////
2644/// Close connection to system log daemon.
2645
2647{
2648 ::closelog();
2649}
2650
2651//---- Standard output redirection ---------------------------------------------
2652
2653////////////////////////////////////////////////////////////////////////////////
2654/// Redirect standard output (stdout, stderr) to the specified file.
2655/// If the file argument is 0 the output is set again to stderr, stdout.
2656/// The second argument specifies whether the output should be added to the
2657/// file ("a", default) or the file be truncated before ("w").
2658/// This function saves internally the current state into a static structure.
2659/// The call can be made reentrant by specifying the opaque structure pointed
2660/// by 'h', which is filled with the relevant information. The handle 'h'
2661/// obtained on the first call must then be used in any subsequent call,
2662/// included ShowOutput, to display the redirected output.
2663/// Returns 0 on success, -1 in case of error.
2664
2665Int_t TUnixSystem::RedirectOutput(const char *file, const char *mode,
2667{
2668 // Instance to be used if the caller does not passes 'h'
2669 static RedirectHandle_t loch;
2670
2671 Int_t rc = 0;
2672
2673 // Which handle to use ?
2674 RedirectHandle_t *xh = (h) ? h : &loch;
2675
2676 if (file) {
2677 // Save the paths
2679 if (xh->fStdOutTty.IsNull()) {
2680 const char *tty = ttyname(STDOUT_FILENO);
2681 if (tty) {
2682 xh->fStdOutTty = tty;
2683 } else {
2684 if ((xh->fStdOutDup = dup(STDOUT_FILENO)) < 0) {
2685 SysError("RedirectOutput", "could not 'dup' stdout (errno: %d)", TSystem::GetErrno());
2686 return -1;
2687 }
2688 outdone = kTRUE;
2689 }
2690 }
2691 if (xh->fStdErrTty.IsNull()) {
2692 const char *tty = ttyname(STDERR_FILENO);
2693 if (tty) {
2694 xh->fStdErrTty = tty;
2695 } else {
2696 if ((xh->fStdErrDup = dup(STDERR_FILENO)) < 0) {
2697 SysError("RedirectOutput", "could not 'dup' stderr (errno: %d)", TSystem::GetErrno());
2698 if (outdone && dup2(xh->fStdOutDup, STDOUT_FILENO) < 0) {
2699 Warning("RedirectOutput", "could not restore stdout (back to original redirected"
2700 " file) (errno: %d)", TSystem::GetErrno());
2701 }
2702 return -1;
2703 }
2704 }
2705 }
2706
2707 // Make sure mode makes sense; default "a"
2708 const char *m = (mode[0] == 'a' || mode[0] == 'w') ? mode : "a";
2709
2710 // Current file size
2711 xh->fReadOffSet = 0;
2712 if (m[0] == 'a') {
2713 // If the file exists, save the current size
2714 FileStat_t st;
2715 if (!gSystem->GetPathInfo(file, st))
2716 xh->fReadOffSet = (st.fSize > 0) ? st.fSize : xh->fReadOffSet;
2717 }
2718 xh->fFile = file;
2719
2720 // Redirect stdout & stderr
2721 if (freopen(file, m, stdout) == nullptr) {
2722 SysError("RedirectOutput", "could not freopen stdout (errno: %d)", TSystem::GetErrno());
2723 return -1;
2724 }
2725 if (freopen(file, m, stderr) == nullptr) {
2726 SysError("RedirectOutput", "could not freopen stderr (errno: %d)", TSystem::GetErrno());
2727 if (freopen(xh->fStdOutTty.Data(), "a", stdout) == nullptr)
2728 SysError("RedirectOutput", "could not restore stdout (errno: %d)", TSystem::GetErrno());
2729 return -1;
2730 }
2731 } else {
2732 // Restore stdout & stderr
2733 fflush(stdout);
2734 if (!(xh->fStdOutTty.IsNull())) {
2735 if (freopen(xh->fStdOutTty.Data(), "a", stdout) == nullptr) {
2736 SysError("RedirectOutput", "could not restore stdout (errno: %d)", TSystem::GetErrno());
2737 rc = -1;
2738 }
2739 xh->fStdOutTty = "";
2740 } else {
2741 if (close(STDOUT_FILENO) != 0) {
2742 SysError("RedirectOutput",
2743 "problems closing STDOUT_FILENO (%d) before 'dup2' (errno: %d)",
2745 rc = -1;
2746 }
2747 if (dup2(xh->fStdOutDup, STDOUT_FILENO) < 0) {
2748 SysError("RedirectOutput", "could not restore stdout (back to original redirected"
2749 " file) (errno: %d)", TSystem::GetErrno());
2750 rc = -1;
2751 }
2752 if (close(xh->fStdOutDup) != 0) {
2753 SysError("RedirectOutput",
2754 "problems closing temporary 'out' descriptor %d (errno: %d)",
2755 TSystem::GetErrno(), xh->fStdOutDup);
2756 rc = -1;
2757 }
2758 }
2759 fflush(stderr);
2760 if (!(xh->fStdErrTty.IsNull())) {
2761 if (freopen(xh->fStdErrTty.Data(), "a", stderr) == nullptr) {
2762 SysError("RedirectOutput", "could not restore stderr (errno: %d)", TSystem::GetErrno());
2763 rc = -1;
2764 }
2765 xh->fStdErrTty = "";
2766 } else {
2767 if (close(STDERR_FILENO) != 0) {
2768 SysError("RedirectOutput",
2769 "problems closing STDERR_FILENO (%d) before 'dup2' (errno: %d)",
2771 rc = -1;
2772 }
2773 if (dup2(xh->fStdErrDup, STDERR_FILENO) < 0) {
2774 SysError("RedirectOutput", "could not restore stderr (back to original redirected"
2775 " file) (errno: %d)", TSystem::GetErrno());
2776 rc = -1;
2777 }
2778 if (close(xh->fStdErrDup) != 0) {
2779 SysError("RedirectOutput",
2780 "problems closing temporary 'err' descriptor %d (errno: %d)",
2781 TSystem::GetErrno(), xh->fStdErrDup);
2782 rc = -1;
2783 }
2784 }
2785 // Reset the static instance, if using that
2786 if (xh == &loch)
2787 xh->Reset();
2788 }
2789 return rc;
2790}
2791
2792//---- dynamic loading and linking ---------------------------------------------
2793
2794////////////////////////////////////////////////////////////////////////////////
2795///dynamic linking of module
2796
2797Func_t TUnixSystem::DynFindSymbol(const char * /*module*/, const char *entry)
2798{
2799 return TSystem::DynFindSymbol("*", entry);
2800}
2801
2802////////////////////////////////////////////////////////////////////////////////
2803/// Load a shared library. Returns 0 on successful loading, 1 in
2804/// case lib was already loaded and -1 in case lib does not exist
2805/// or in case of error.
2806
2807int TUnixSystem::Load(const char *module, const char *entry, Bool_t system)
2808{
2809 return TSystem::Load(module, entry, system);
2810}
2811
2812////////////////////////////////////////////////////////////////////////////////
2813/// Unload a shared library.
2814
2816{
2817 if (module) { TSystem::Unload(module); }
2818}
2819
2820////////////////////////////////////////////////////////////////////////////////
2821/// List symbols in a shared library.
2822
2823void TUnixSystem::ListSymbols(const char * /*module*/, const char * /*regexp*/)
2824{
2825 Error("ListSymbols", "not yet implemented");
2826}
2827
2828////////////////////////////////////////////////////////////////////////////////
2829/// List all loaded shared libraries.
2830
2831void TUnixSystem::ListLibraries(const char *regexp)
2832{
2833 TSystem::ListLibraries(regexp);
2834}
2835
2836////////////////////////////////////////////////////////////////////////////////
2837/// Get list of shared libraries loaded at the start of the executable.
2838/// Returns 0 in case list cannot be obtained or in case of error.
2839
2841{
2842 static TString linkedLibs;
2843 static Bool_t once = kFALSE;
2844
2846
2847 if (!linkedLibs.IsNull())
2848 return linkedLibs;
2849
2850 if (once)
2851 return nullptr;
2852
2853#if !defined(R__MACOSX)
2854 const char *exe = GetExePath();
2855 if (!exe || !*exe)
2856 return nullptr;
2857#endif
2858
2859#if defined(R__MACOSX)
2860 DylibAdded(0, 0);
2862#if 0
2863 FILE *p = OpenPipe(TString::Format("otool -L %s", exe), "r");
2864 TString otool;
2865 while (otool.Gets(p)) {
2866 TString delim(" \t");
2867 TObjArray *tok = otool.Tokenize(delim);
2868 TString dylib = ((TObjString*)tok->At(0))->String();
2869 if (dylib.EndsWith(".dylib") && !dylib.Contains("/libSystem.B.dylib")) {
2870 if (!linkedLibs.IsNull())
2871 linkedLibs += " ";
2872 linkedLibs += dylib;
2873 }
2874 delete tok;
2875 }
2876 if (p) {
2877 ClosePipe(p);
2878 }
2879#endif
2880#elif defined(R__LINUX) || defined(R__SOLARIS) || defined(R__AIX)
2881#if defined(R__WINGCC )
2882 const char *cLDD="cygcheck";
2883 const char *cSOEXT=".dll";
2884 size_t lenexe = strlen(exe);
2885 if (strcmp(exe + lenexe - 4, ".exe")
2886 && strcmp(exe + lenexe - 4, ".dll")) {
2887 // it's not a dll and exe doesn't end on ".exe";
2888 // need to add it for cygcheck to find it:
2889 char* longerexe = new char[lenexe + 5];
2891 strlcat(longerexe, ".exe",lenexe+5);
2892 exe = longerexe; // memory leak
2893 #error "unsupported platform, fix memory leak to use it"
2894 }
2895 TRegexp sovers = "\\.so\\.[0-9]+";
2896#else
2897 const char *cLDD="ldd";
2898#if defined(R__AIX)
2899 const char *cSOEXT=".a";
2900 TRegexp sovers = "\\.a\\.[0-9]+";
2901#else
2902 const char *cSOEXT=".so";
2903 TRegexp sovers = "\\.so\\.[0-9]+";
2904#endif
2905#endif
2906 FILE *p = OpenPipe(TString::Format("%s '%s'", cLDD, exe), "r");
2907 if (p) {
2908 TString ldd;
2909 while (ldd.Gets(p)) {
2910 TString delim(" \t");
2911 TObjArray *tok = ldd.Tokenize(delim);
2912
2913 // expected format:
2914 // libCore.so => /home/rdm/root/lib/libCore.so (0x40017000)
2915 TObjString *solibName = (TObjString*)tok->At(2);
2916 if (!solibName) {
2917 // case where there is only one name of the list:
2918 // /usr/platform/SUNW,UltraAX-i2/lib/libc_psr.so.1
2919 solibName = (TObjString*)tok->At(0);
2920 }
2921 if (solibName) {
2922 TString solib = solibName->String();
2923 Ssiz_t idx = solib.Index(sovers);
2924 if (solib.EndsWith(cSOEXT) || idx != kNPOS) {
2925 if (idx != kNPOS)
2926 solib.Remove(idx+3);
2928 if (!linkedLibs.IsNull())
2929 linkedLibs += " ";
2930 linkedLibs += solib;
2931 }
2932 }
2933 }
2934 delete tok;
2935 }
2936 ClosePipe(p);
2937 }
2938#endif
2939
2940 once = kTRUE;
2941
2942 if (linkedLibs.IsNull())
2943 return nullptr;
2944
2945 return linkedLibs;
2946}
2947
2948//---- Time & Date -------------------------------------------------------------
2949
2950////////////////////////////////////////////////////////////////////////////////
2951/// Get current time in milliseconds since 0:00 Jan 1 1995.
2952
2954{
2955 return UnixNow();
2956}
2957
2958////////////////////////////////////////////////////////////////////////////////
2959/// Handle and dispatch timers. If mode = kTRUE dispatch synchronous
2960/// timers else a-synchronous timers.
2961
2963{
2964 if (!fTimers) return kFALSE;
2965
2967
2968 TListIter it(fTimers);
2969 TTimer *t;
2971
2972 while ((t = (TTimer *) it.Next())) {
2973 // NB: the timer resolution is added in TTimer::CheckTimer()
2974 Long64_t now = UnixNow();
2975 if (mode && t->IsSync()) {
2976 if (t->CheckTimer(now))
2977 timedout = kTRUE;
2978 } else if (!mode && t->IsAsync()) {
2979 if (t->CheckTimer(now)) {
2981 timedout = kTRUE;
2982 }
2983 }
2984 }
2986 return timedout;
2987}
2988
2989////////////////////////////////////////////////////////////////////////////////
2990/// Add timer to list of system timers.
2991
2997
2998////////////////////////////////////////////////////////////////////////////////
2999/// Remove timer from list of system timers.
3000
3002{
3003 if (!ti) return nullptr;
3004
3006
3008 if (ti->IsAsync())
3010 return t;
3011}
3012
3013////////////////////////////////////////////////////////////////////////////////
3014/// Reset a-sync timer.
3015
3017{
3018 if (!fInsideNotify && ti && ti->IsAsync())
3020}
3021
3022//---- RPC ---------------------------------------------------------------------
3023
3024////////////////////////////////////////////////////////////////////////////////
3025/// Get Internet Protocol (IP) address of host. Returns an TInetAddress
3026/// object. To see if the hostname lookup was successfull call
3027/// TInetAddress::IsValid().
3028
3030{
3032 struct addrinfo hints;
3033 struct addrinfo *result, *rp;
3034 memset(&hints, 0, sizeof(struct addrinfo));
3035 hints.ai_family = AF_INET; // only IPv4
3036 hints.ai_socktype = 0; // any socket type
3037 hints.ai_protocol = 0; // any protocol
3038 hints.ai_flags = AI_CANONNAME; // get canonical name
3039#ifdef R__MACOSX
3040 // Anything ending on ".local" causes a 5 second delay in getaddrinfo().
3041 // See e.g. https://apple.stackexchange.com/questions/175320/why-is-my-hostname-resolution-taking-so-long
3042 // Only reasonable solution: remove the "domain" part if it's ".local".
3043 size_t lenHostname = strlen(hostname);
3044 std::string hostnameWithoutLocal{hostname};
3045 if (lenHostname > 6 && !strcmp(hostname + lenHostname - 6, ".local")) {
3048 }
3049#endif
3050
3051 // obsolete gethostbyname() replaced by getaddrinfo()
3052 int rc = getaddrinfo(hostname, nullptr, &hints, &result);
3053 if (rc != 0) {
3054 if (rc == EAI_NONAME) {
3055 if (gDebug > 0) Error("GetHostByName", "unknown host '%s'", hostname);
3056 ia.fHostname = "UnNamedHost";
3057 } else {
3058 Error("GetHostByName", "getaddrinfo failed for '%s': %s", hostname, gai_strerror(rc));
3059 ia.fHostname = "UnknownHost";
3060 }
3061 return ia;
3062 }
3063
3064 std::string hostcanon(result->ai_canonname ? result->ai_canonname : hostname);
3065 ia.fHostname = hostcanon.data();
3066 ia.fFamily = result->ai_family;
3067 ia.fAddresses[0] = ntohl(((struct sockaddr_in *)(result->ai_addr))->sin_addr.s_addr);
3068 // with getaddrinfo() no way to get list of aliases for a hostname
3069 if (hostcanon.compare(hostname) != 0) ia.AddAlias(hostname);
3070
3071 // check on numeric hostname
3072 char tmp[sizeof(struct in_addr)];
3073 if (inet_pton(AF_INET, hostcanon.data(), tmp) == 1) {
3074 char hbuf[NI_MAXHOST];
3075 if (getnameinfo(result->ai_addr, result->ai_addrlen, hbuf, sizeof(hbuf), nullptr, 0, 0) == 0)
3076 ia.fHostname = hbuf;
3077 }
3078
3079 // check other addresses (if exist)
3080 rp = result->ai_next;
3081 for (; rp != nullptr; rp = rp->ai_next) {
3082 UInt_t arp = ntohl(((struct sockaddr_in *)(rp->ai_addr))->sin_addr.s_addr);
3083 if ( !(std::find(ia.fAddresses.begin(), ia.fAddresses.end(), arp) != ia.fAddresses.end()) )
3084 ia.AddAddress(arp);
3085 }
3086
3088 return ia;
3089}
3090
3091////////////////////////////////////////////////////////////////////////////////
3092/// Get Internet Protocol (IP) address of host and port #.
3093
3095{
3096 struct sockaddr addr;
3097 socklen_t len = sizeof(addr);
3098
3100 if (getsockname(sock, &addr, &len) == -1) {
3101 SysError("GetSockName", "getsockname failed");
3102 return ia;
3103 }
3104
3105 if (addr.sa_family != AF_INET) return ia; // only IPv4
3106 ia.fFamily = addr.sa_family;
3107 struct sockaddr_in *addrin = (struct sockaddr_in *)&addr;
3108 ia.fPort = ntohs(addrin->sin_port);
3109 ia.fAddresses[0] = ntohl(addrin->sin_addr.s_addr);
3110
3111 char hbuf[NI_MAXHOST];
3112 if (getnameinfo(&addr, sizeof(struct sockaddr), hbuf, sizeof(hbuf), nullptr, 0, 0) != 0) {
3113 Error("GetSockName", "getnameinfo failed");
3114 ia.fHostname = "????";
3115 } else
3116 ia.fHostname = hbuf;
3117
3118 return ia;
3119}
3120
3121////////////////////////////////////////////////////////////////////////////////
3122/// Get Internet Protocol (IP) address of remote host and port #.
3123
3125{
3126 struct sockaddr addr;
3127 socklen_t len = sizeof(addr);
3128
3130 if (getpeername(sock, &addr, &len) == -1) {
3131 SysError("GetPeerName", "getpeername failed");
3132 return ia;
3133 }
3134
3135 if (addr.sa_family != AF_INET) return ia; // only IPv4
3136 ia.fFamily = addr.sa_family;
3137 struct sockaddr_in *addrin = (struct sockaddr_in *)&addr;
3138 ia.fPort = ntohs(addrin->sin_port);
3139 ia.fAddresses[0] = ntohl(addrin->sin_addr.s_addr);
3140
3141 char hbuf[NI_MAXHOST];
3142 if (getnameinfo(&addr, sizeof(struct sockaddr), hbuf, sizeof(hbuf), nullptr, 0, 0) != 0) {
3143 Error("GetPeerName", "getnameinfo failed");
3144 ia.fHostname = "????";
3145 } else
3146 ia.fHostname = hbuf;
3147
3148 return ia;
3149}
3150
3151////////////////////////////////////////////////////////////////////////////////
3152/// Get port # of internet service.
3153
3155{
3156 struct servent *sp;
3157
3158 if ((sp = getservbyname(servicename, kProtocolName)) == nullptr) {
3159 Error("GetServiceByName", "no service \"%s\" with protocol \"%s\"\n",
3161 return -1;
3162 }
3163 return ntohs(sp->s_port);
3164}
3165
3166////////////////////////////////////////////////////////////////////////////////
3167/// Get name of internet service.
3168
3170{
3171 struct servent *sp;
3172
3173 if ((sp = getservbyport(htons(port), kProtocolName)) == nullptr) {
3174 //::Error("GetServiceByPort", "no service \"%d\" with protocol \"%s\"",
3175 // port, kProtocolName);
3176 return Form("%d", port);
3177 }
3178 return sp->s_name;
3179}
3180
3181////////////////////////////////////////////////////////////////////////////////
3182/// Connect to service servicename on server servername.
3183
3184int TUnixSystem::ConnectService(const char *servername, int port,
3185 int tcpwindowsize, const char *protocol)
3186{
3187 if (!strcmp(servername, "unix")) {
3188 return UnixUnixConnect(port);
3189 } else if (!gSystem->AccessPathName(servername) || servername[0] == '/') {
3191 }
3192
3193 if (!strcmp(protocol, "udp")){
3194 return UnixUdpConnect(servername, port);
3195 }
3196
3198}
3199
3200////////////////////////////////////////////////////////////////////////////////
3201/// Open a connection to a service on a server. Returns -1 in case
3202/// connection cannot be opened.
3203/// Use tcpwindowsize to specify the size of the receive buffer, it has
3204/// to be specified here to make sure the window scale option is set (for
3205/// tcpwindowsize > 65KB and for platforms supporting window scaling).
3206/// Is called via the TSocket constructor.
3207
3208int TUnixSystem::OpenConnection(const char *server, int port, int tcpwindowsize, const char *protocol)
3209{
3210 return ConnectService(server, port, tcpwindowsize, protocol);
3211}
3212
3213////////////////////////////////////////////////////////////////////////////////
3214/// Announce TCP/IP service.
3215/// Open a socket, bind to it and start listening for TCP/IP connections
3216/// on the port. If reuse is true reuse the address, backlog specifies
3217/// how many sockets can be waiting to be accepted.
3218/// Use tcpwindowsize to specify the size of the receive buffer, it has
3219/// to be specified here to make sure the window scale option is set (for
3220/// tcpwindowsize > 65KB and for platforms supporting window scaling).
3221/// Returns socket fd or -1 if socket() failed, -2 if bind() failed
3222/// or -3 if listen() failed.
3223
3229
3230////////////////////////////////////////////////////////////////////////////////
3231/// Announce UDP service.
3232
3237
3238////////////////////////////////////////////////////////////////////////////////
3239/// Announce unix domain service on path "kServerPath/<port>"
3240
3242{
3243 return UnixUnixService(port, backlog);
3244}
3245
3246////////////////////////////////////////////////////////////////////////////////
3247/// Announce unix domain service on path 'sockpath'
3248
3250{
3252}
3253
3254////////////////////////////////////////////////////////////////////////////////
3255/// Accept a connection. In case of an error return -1. In case
3256/// non-blocking I/O is enabled and no connections are available
3257/// return -2.
3258
3260{
3261 int soc = -1;
3262
3263 while ((soc = ::accept(sock, nullptr, nullptr)) == -1 && GetErrno() == EINTR)
3264 ResetErrno();
3265
3266 if (soc == -1) {
3267 if (GetErrno() == EWOULDBLOCK)
3268 return -2;
3269 else {
3270 SysError("AcceptConnection", "accept");
3271 return -1;
3272 }
3273 }
3274
3275 return soc;
3276}
3277
3278////////////////////////////////////////////////////////////////////////////////
3279/// Close socket.
3280
3282{
3283 if (sock < 0) return;
3284
3285#if !defined(R__AIX) || defined(_AIX41) || defined(_AIX43)
3286 if (force)
3287 ::shutdown(sock, 2); // will also close connection of parent
3288#endif
3289
3290 while (::close(sock) == -1 && GetErrno() == EINTR)
3291 ResetErrno();
3292}
3293
3294////////////////////////////////////////////////////////////////////////////////
3295/// Receive a buffer headed by a length indicator. Length is the size of
3296/// the buffer. Returns the number of bytes received in buf or -1 in
3297/// case of error.
3298
3299int TUnixSystem::RecvBuf(int sock, void *buf, int length)
3300{
3301 Int_t header;
3302
3303 if (UnixRecv(sock, &header, sizeof(header), 0) > 0) {
3304 int count = ntohl(header);
3305
3306 if (count > length) {
3307 Error("RecvBuf", "record header exceeds buffer size");
3308 return -1;
3309 } else if (count > 0) {
3310 if (UnixRecv(sock, buf, count, 0) < 0) {
3311 Error("RecvBuf", "cannot receive buffer");
3312 return -1;
3313 }
3314 }
3315 return count;
3316 }
3317 return -1;
3318}
3319
3320////////////////////////////////////////////////////////////////////////////////
3321/// Send a buffer headed by a length indicator. Returns length of sent buffer
3322/// or -1 in case of error.
3323
3324int TUnixSystem::SendBuf(int sock, const void *buf, int length)
3325{
3326 Int_t header = htonl(length);
3327
3328 if (UnixSend(sock, &header, sizeof(header), 0) < 0) {
3329 Error("SendBuf", "cannot send header");
3330 return -1;
3331 }
3332 if (length > 0) {
3333 if (UnixSend(sock, buf, length, 0) < 0) {
3334 Error("SendBuf", "cannot send buffer");
3335 return -1;
3336 }
3337 }
3338 return length;
3339}
3340
3341////////////////////////////////////////////////////////////////////////////////
3342/// Receive exactly length bytes into buffer. Use opt to receive out-of-band
3343/// data or to have a peek at what is in the buffer (see TSocket). Buffer
3344/// must be able to store at least length bytes. Returns the number of
3345/// bytes received (can be 0 if other side of connection was closed) or -1
3346/// in case of error, -2 in case of MSG_OOB and errno == EWOULDBLOCK, -3
3347/// in case of MSG_OOB and errno == EINVAL and -4 in case of kNoBlock and
3348/// errno == EWOULDBLOCK. Returns -5 if pipe broken or reset by peer
3349/// (EPIPE || ECONNRESET).
3350
3351int TUnixSystem::RecvRaw(int sock, void *buf, int length, int opt)
3352{
3353 int flag;
3354
3355 switch (opt) {
3356 case kDefault:
3357 flag = 0;
3358 break;
3359 case kOob:
3360 flag = MSG_OOB;
3361 break;
3362 case kPeek:
3363 flag = MSG_PEEK;
3364 break;
3365 case kDontBlock:
3366 flag = -1;
3367 break;
3368 default:
3369 flag = 0;
3370 break;
3371 }
3372
3373 int n;
3374 if ((n = UnixRecv(sock, buf, length, flag)) <= 0) {
3375 if (n == -1 && GetErrno() != EINTR)
3376 Error("RecvRaw", "cannot receive buffer");
3377 return n;
3378 }
3379 return n;
3380}
3381
3382////////////////////////////////////////////////////////////////////////////////
3383/// Send exactly length bytes from buffer. Use opt to send out-of-band
3384/// data (see TSocket). Returns the number of bytes sent or -1 in case of
3385/// error. Returns -4 in case of kNoBlock and errno == EWOULDBLOCK.
3386/// Returns -5 if pipe broken or reset by peer (EPIPE || ECONNRESET).
3387
3388int TUnixSystem::SendRaw(int sock, const void *buf, int length, int opt)
3389{
3390 int flag;
3391
3392 switch (opt) {
3393 case kDefault:
3394 flag = 0;
3395 break;
3396 case kOob:
3397 flag = MSG_OOB;
3398 break;
3399 case kDontBlock:
3400 flag = -1;
3401 break;
3402 case kPeek: // receive only option (see RecvRaw)
3403 default:
3404 flag = 0;
3405 break;
3406 }
3407
3408 int n;
3409 if ((n = UnixSend(sock, buf, length, flag)) <= 0) {
3410 if (n == -1 && GetErrno() != EINTR)
3411 Error("SendRaw", "cannot send buffer");
3412 return n;
3413 }
3414 return n;
3415}
3416
3417////////////////////////////////////////////////////////////////////////////////
3418/// Set socket option.
3419
3420int TUnixSystem::SetSockOpt(int sock, int opt, int val)
3421{
3422 if (sock < 0) return -1;
3423
3424 switch (opt) {
3425 case kSendBuffer:
3426 if (setsockopt(sock, SOL_SOCKET, SO_SNDBUF, (char*)&val, sizeof(val)) == -1) {
3427 SysError("SetSockOpt", "setsockopt(SO_SNDBUF)");
3428 return -1;
3429 }
3430 break;
3431 case kRecvBuffer:
3432 if (setsockopt(sock, SOL_SOCKET, SO_RCVBUF, (char*)&val, sizeof(val)) == -1) {
3433 SysError("SetSockOpt", "setsockopt(SO_RCVBUF)");
3434 return -1;
3435 }
3436 break;
3437 case kOobInline:
3438 if (setsockopt(sock, SOL_SOCKET, SO_OOBINLINE, (char*)&val, sizeof(val)) == -1) {
3439 SysError("SetSockOpt", "setsockopt(SO_OOBINLINE)");
3440 return -1;
3441 }
3442 break;
3443 case kKeepAlive:
3444 if (setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, (char*)&val, sizeof(val)) == -1) {
3445 SysError("SetSockOpt", "setsockopt(SO_KEEPALIVE)");
3446 return -1;
3447 }
3448 break;
3449 case kReuseAddr:
3450 if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char*)&val, sizeof(val)) == -1) {
3451 SysError("SetSockOpt", "setsockopt(SO_REUSEADDR)");
3452 return -1;
3453 }
3454 break;
3455 case kNoDelay:
3456 if (setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, (char*)&val, sizeof(val)) == -1) {
3457 SysError("SetSockOpt", "setsockopt(TCP_NODELAY)");
3458 return -1;
3459 }
3460 break;
3461 case kNoBlock:
3462 if (ioctl(sock, FIONBIO, (char*)&val) == -1) {
3463 SysError("SetSockOpt", "ioctl(FIONBIO)");
3464 return -1;
3465 }
3466 break;
3467 case kProcessGroup:
3468#ifndef R__WINGCC
3469 if (ioctl(sock, SIOCSPGRP, (char*)&val) == -1) {
3470 SysError("SetSockOpt", "ioctl(SIOCSPGRP)");
3471 return -1;
3472 }
3473#else
3474 Error("SetSockOpt", "ioctl(SIOCGPGRP) not supported on cygwin/gcc");
3475 return -1;
3476#endif
3477 break;
3478 case kAtMark: // read-only option (see GetSockOpt)
3479 case kBytesToRead: // read-only option
3480 default:
3481 Error("SetSockOpt", "illegal option (%d)", opt);
3482 return -1;
3483 }
3484 return 0;
3485}
3486
3487////////////////////////////////////////////////////////////////////////////////
3488/// Get socket option.
3489
3490int TUnixSystem::GetSockOpt(int sock, int opt, int *val)
3491{
3492 if (sock < 0) return -1;
3493
3494 socklen_t optlen = sizeof(*val);
3495
3496 switch (opt) {
3497 case kSendBuffer:
3498 if (getsockopt(sock, SOL_SOCKET, SO_SNDBUF, (char*)val, &optlen) == -1) {
3499 SysError("GetSockOpt", "getsockopt(SO_SNDBUF)");
3500 return -1;
3501 }
3502 break;
3503 case kRecvBuffer:
3504 if (getsockopt(sock, SOL_SOCKET, SO_RCVBUF, (char*)val, &optlen) == -1) {
3505 SysError("GetSockOpt", "getsockopt(SO_RCVBUF)");
3506 return -1;
3507 }
3508 break;
3509 case kOobInline:
3510 if (getsockopt(sock, SOL_SOCKET, SO_OOBINLINE, (char*)val, &optlen) == -1) {
3511 SysError("GetSockOpt", "getsockopt(SO_OOBINLINE)");
3512 return -1;
3513 }
3514 break;
3515 case kKeepAlive:
3516 if (getsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, (char*)val, &optlen) == -1) {
3517 SysError("GetSockOpt", "getsockopt(SO_KEEPALIVE)");
3518 return -1;
3519 }
3520 break;
3521 case kReuseAddr:
3522 if (getsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char*)val, &optlen) == -1) {
3523 SysError("GetSockOpt", "getsockopt(SO_REUSEADDR)");
3524 return -1;
3525 }
3526 break;
3527 case kNoDelay:
3528 if (getsockopt(sock, IPPROTO_TCP, TCP_NODELAY, (char*)val, &optlen) == -1) {
3529 SysError("GetSockOpt", "getsockopt(TCP_NODELAY)");
3530 return -1;
3531 }
3532 break;
3533 case kNoBlock:
3534 int flg;
3535 if ((flg = fcntl(sock, F_GETFL, 0)) == -1) {
3536 SysError("GetSockOpt", "fcntl(F_GETFL)");
3537 return -1;
3538 }
3539 *val = flg & O_NDELAY;
3540 break;
3541 case kProcessGroup:
3542#if !defined(R__LYNXOS) && !defined(R__WINGCC)
3543 if (ioctl(sock, SIOCGPGRP, (char*)val) == -1) {
3544 SysError("GetSockOpt", "ioctl(SIOCGPGRP)");
3545 return -1;
3546 }
3547#else
3548 Error("GetSockOpt", "ioctl(SIOCGPGRP) not supported on LynxOS and cygwin/gcc");
3549 return -1;
3550#endif
3551 break;
3552 case kAtMark:
3553#if !defined(R__LYNXOS)
3554 if (ioctl(sock, SIOCATMARK, (char*)val) == -1) {
3555 SysError("GetSockOpt", "ioctl(SIOCATMARK)");
3556 return -1;
3557 }
3558#else
3559 Error("GetSockOpt", "ioctl(SIOCATMARK) not supported on LynxOS");
3560 return -1;
3561#endif
3562 break;
3563 case kBytesToRead:
3564#if !defined(R__LYNXOS)
3565 if (ioctl(sock, FIONREAD, (char*)val) == -1) {
3566 SysError("GetSockOpt", "ioctl(FIONREAD)");
3567 return -1;
3568 }
3569#else
3570 Error("GetSockOpt", "ioctl(FIONREAD) not supported on LynxOS");
3571 return -1;
3572#endif
3573 break;
3574 default:
3575 Error("GetSockOpt", "illegal option (%d)", opt);
3576 *val = 0;
3577 return -1;
3578 }
3579 return 0;
3580}
3581
3582//////////////////////////////////////////////////////////////////////////
3583// //
3584// Static Protected Unix Interface functions. //
3585// //
3586//////////////////////////////////////////////////////////////////////////
3587
3588//---- signals -----------------------------------------------------------------
3589
3590static struct Signalmap_t {
3594 const char *fSigName;
3595} gSignalMap[kMAXSIGNALS] = { // the order of the signals should be identical
3596 { SIGBUS, nullptr, nullptr, "bus error" }, // to the one in TSysEvtHandler.h
3597 { SIGSEGV, nullptr, nullptr, "segmentation violation" },
3598 { SIGSYS, nullptr, nullptr, "bad argument to system call" },
3599 { SIGPIPE, nullptr, nullptr, "write on a pipe with no one to read it" },
3600 { SIGILL, nullptr, nullptr, "illegal instruction" },
3601 { SIGABRT, nullptr, nullptr, "abort" },
3602 { SIGQUIT, nullptr, nullptr, "quit" },
3603 { SIGINT, nullptr, nullptr, "interrupt" },
3604 { SIGWINCH, nullptr, nullptr, "window size change" },
3605 { SIGALRM, nullptr, nullptr, "alarm clock" },
3606 { SIGCHLD, nullptr, nullptr, "death of a child" },
3607 { SIGURG, nullptr, nullptr, "urgent data arrived on an I/O channel" },
3608 { SIGFPE, nullptr, nullptr, "floating point exception" },
3609 { SIGTERM, nullptr, nullptr, "termination signal" },
3610 { SIGUSR1, nullptr, nullptr, "user-defined signal 1" },
3611 { SIGUSR2, nullptr, nullptr, "user-defined signal 2" }
3613
3614
3615////////////////////////////////////////////////////////////////////////////////
3616/// Call the signal handler associated with the signal.
3617
3618static void sighandler(int sig)
3619{
3620 for (int i= 0; i < kMAXSIGNALS; i++) {
3621 if (gSignalMap[i].fCode == sig) {
3622 (*gSignalMap[i].fHandler)((ESignals)i);
3623 return;
3624 }
3625 }
3626}
3627
3628////////////////////////////////////////////////////////////////////////////////
3629/// Handle and dispatch signals.
3630
3632{
3633 switch (sig) {
3634 case kSigAlarm:
3636 break;
3637 case kSigChild:
3638 CheckChilds();
3639 break;
3640 case kSigBus:
3643 case kSigAbort:
3647 else {
3648 if (sig == kSigAbort)
3649 return;
3650 Break("TUnixSystem::DispatchSignals", "%s", UnixSigname(sig));
3651 StackTrace();
3652 if (gApplication)
3653 //sig is ESignal, should it be mapped to the correct signal number?
3655 else
3656 //map to the real signal code + set the
3657 //high order bit to indicate a signal (?)
3658 Exit(gSignalMap[sig].fCode + 0x80);
3659 }
3660 break;
3661 case kSigSystem:
3662 case kSigPipe:
3663 Break("TUnixSystem::DispatchSignals", "%s", UnixSigname(sig));
3664 break;
3665 case kSigWindowChanged:
3667 break;
3668 case kSigUser2:
3669 Break("TUnixSystem::DispatchSignals", "%s: printing stacktrace", UnixSigname(sig));
3670 StackTrace();
3671 // Intentional fall-through; pass the signal to handlers (or terminate):
3672 default:
3673 fSignals->Set(sig);
3674 fSigcnt++;
3675 break;
3676 }
3677
3678 // check a-synchronous signals
3679 if (fSigcnt > 0 && fSignalHandler->GetSize() > 0)
3681}
3682
3683////////////////////////////////////////////////////////////////////////////////
3684/// Set a signal handler for a signal.
3685
3687{
3688 if (gEnv && !gEnv->GetValue("Root.ErrorHandlers", 1))
3689 return;
3690
3691 if (gSignalMap[sig].fHandler != handler) {
3692 struct sigaction sigact;
3693
3694 gSignalMap[sig].fHandler = handler;
3695 gSignalMap[sig].fOldHandler = new struct sigaction();
3696
3697#if defined(R__SUN)
3698 sigact.sa_handler = (void (*)())sighandler;
3699#elif defined(R__SOLARIS)
3700 sigact.sa_handler = sighandler;
3701#elif defined(R__LYNXOS)
3702# if (__GNUG__>=3)
3703 sigact.sa_handler = sighandler;
3704# else
3705 sigact.sa_handler = (void (*)(...))sighandler;
3706# endif
3707#else
3708 sigact.sa_handler = sighandler;
3709#endif
3710 sigemptyset(&sigact.sa_mask);
3711 sigact.sa_flags = 0;
3712#if defined(SA_RESTART)
3713 sigact.sa_flags |= SA_RESTART;
3714#endif
3715 if (sigaction(gSignalMap[sig].fCode, &sigact,
3716 gSignalMap[sig].fOldHandler) < 0)
3717 ::SysError("TUnixSystem::UnixSignal", "sigaction");
3718 }
3719}
3720
3721////////////////////////////////////////////////////////////////////////////////
3722/// If ignore is true ignore the specified signal, else restore previous
3723/// behaviour.
3724
3726{
3729
3730 if (ignore != ignoreSig[sig]) {
3731 ignoreSig[sig] = ignore;
3732 if (ignore) {
3733 struct sigaction sigact;
3734#if defined(R__SUN)
3735 sigact.sa_handler = (void (*)())SIG_IGN;
3736#elif defined(R__SOLARIS)
3737 sigact.sa_handler = (void (*)(int))SIG_IGN;
3738#else
3739 sigact.sa_handler = SIG_IGN;
3740#endif
3741 sigemptyset(&sigact.sa_mask);
3742 sigact.sa_flags = 0;
3743 if (sigaction(gSignalMap[sig].fCode, &sigact, &oldsigact[sig]) < 0)
3744 ::SysError("TUnixSystem::UnixIgnoreSignal", "sigaction");
3745 } else {
3746 if (sigaction(gSignalMap[sig].fCode, &oldsigact[sig], nullptr) < 0)
3747 ::SysError("TUnixSystem::UnixIgnoreSignal", "sigaction");
3748 }
3749 }
3750}
3751
3752////////////////////////////////////////////////////////////////////////////////
3753/// When the argument is true the SIGALRM signal handler is set so that
3754/// interrupted syscalls will not be restarted by the kernel. This is
3755/// typically used in case one wants to put a timeout on an I/O operation.
3756/// By default interrupted syscalls will always be restarted (for all
3757/// signals). This can be controlled for each a-synchronous TTimer via
3758/// the method TTimer::SetInterruptSyscalls().
3759
3761{
3762 if (gSignalMap[kSigAlarm].fHandler) {
3763 struct sigaction sigact;
3764#if defined(R__SUN)
3765 sigact.sa_handler = (void (*)())sighandler;
3766#elif defined(R__SOLARIS)
3767 sigact.sa_handler = sighandler;
3768#elif defined(R__LYNXOS)
3769# if (__GNUG__>=3)
3770 sigact.sa_handler = sighandler;
3771# else
3772 sigact.sa_handler = (void (*)(...))sighandler;
3773# endif
3774#else
3775 sigact.sa_handler = sighandler;
3776#endif
3777 sigemptyset(&sigact.sa_mask);
3778 sigact.sa_flags = 0;
3779 if (set) {
3780#if defined(SA_INTERRUPT) // SunOS
3781 sigact.sa_flags |= SA_INTERRUPT;
3782#endif
3783 } else {
3784#if defined(SA_RESTART)
3785 sigact.sa_flags |= SA_RESTART;
3786#endif
3787 }
3788 if (sigaction(gSignalMap[kSigAlarm].fCode, &sigact, nullptr) < 0)
3789 ::SysError("TUnixSystem::UnixSigAlarmInterruptsSyscalls", "sigaction");
3790 }
3791}
3792
3793////////////////////////////////////////////////////////////////////////////////
3794/// Return the signal name associated with a signal.
3795
3797{
3798 return gSignalMap[sig].fSigName;
3799}
3800
3801////////////////////////////////////////////////////////////////////////////////
3802/// Restore old signal handler for specified signal.
3803
3805{
3806 if (gSignalMap[sig].fOldHandler) {
3807 // restore old signal handler
3808 if (sigaction(gSignalMap[sig].fCode, gSignalMap[sig].fOldHandler, nullptr) < 0)
3809 ::SysError("TUnixSystem::UnixSignal", "sigaction");
3810 delete gSignalMap[sig].fOldHandler;
3811 gSignalMap[sig].fOldHandler = nullptr;
3812 gSignalMap[sig].fHandler = nullptr;
3813 }
3814}
3815
3816////////////////////////////////////////////////////////////////////////////////
3817/// Restore old signal handlers.
3818
3820{
3821 for (int sig = 0; sig < kMAXSIGNALS; sig++)
3823}
3824
3825//---- time --------------------------------------------------------------------
3826
3827////////////////////////////////////////////////////////////////////////////////
3828/// Get current time in milliseconds since 0:00 Jan 1 1995.
3829
3831{
3832 static std::atomic<time_t> jan95{0};
3833 if (!jan95) {
3834 struct tm tp;
3835 tp.tm_year = 95;
3836 tp.tm_mon = 0;
3837 tp.tm_mday = 1;
3838 tp.tm_hour = 0;
3839 tp.tm_min = 0;
3840 tp.tm_sec = 0;
3841 tp.tm_isdst = -1;
3842
3843 jan95 = mktime(&tp);
3844 if ((int)jan95 == -1) {
3845 ::SysError("TUnixSystem::UnixNow", "error converting 950001 0:00 to time_t");
3846 return 0;
3847 }
3848 }
3849
3850 struct timeval t;
3851 gettimeofday(&t, nullptr);
3852 return Long64_t(t.tv_sec-(Long_t)jan95)*1000 + t.tv_usec/1000;
3853}
3854
3855////////////////////////////////////////////////////////////////////////////////
3856/// Set interval timer to time-out in ms milliseconds.
3857
3859{
3860 struct itimerval itv;
3861 itv.it_value.tv_sec = 0;
3862 itv.it_value.tv_usec = 0;
3863 itv.it_interval.tv_sec = 0;
3864 itv.it_interval.tv_usec = 0;
3865 if (ms > 0) {
3866 itv.it_value.tv_sec = time_t(ms / 1000);
3867 itv.it_value.tv_usec = time_t((ms % 1000) * 1000);
3868 }
3869 int st = setitimer(ITIMER_REAL, &itv, nullptr);
3870 if (st == -1)
3871 ::SysError("TUnixSystem::UnixSetitimer", "setitimer");
3872 return st;
3873}
3874
3875//---- file descriptors --------------------------------------------------------
3876
3877////////////////////////////////////////////////////////////////////////////////
3878/// Wait for events on the file descriptors specified in the readready and
3879/// writeready masks or for timeout (in milliseconds) to occur. Returns
3880/// the number of ready descriptors, or 0 in case of timeout, or < 0 in
3881/// case of an error, with -2 being EINTR and -3 EBADF. In case of EINTR
3882/// the errno has been reset and the method can be called again.
3883
3886{
3887 int retcode;
3888
3889 fd_set *rd = (readready) ? (fd_set*)readready->GetBits() : nullptr;
3890 fd_set *wr = (writeready) ? (fd_set*)writeready->GetBits() : nullptr;
3891
3892 if (timeout >= 0) {
3893 struct timeval tv;
3894 tv.tv_sec = Int_t(timeout / 1000);
3895 tv.tv_usec = (timeout % 1000) * 1000;
3896 retcode = select(nfds, rd, wr, nullptr, &tv);
3897 } else {
3898 retcode = select(nfds, rd, wr, nullptr, nullptr);
3899 }
3900 if (retcode == -1) {
3901 if (GetErrno() == EINTR) {
3902 ResetErrno(); // errno is not self reseting
3903 return -2;
3904 }
3905 if (GetErrno() == EBADF)
3906 return -3;
3907 return -1;
3908 }
3909
3910 return retcode;
3911}
3912
3913//---- directories -------------------------------------------------------------
3914
3915////////////////////////////////////////////////////////////////////////////////
3916/// Returns the user's home directory.
3917
3918const char *TUnixSystem::UnixHomedirectory(const char *name)
3919{
3920 static char path[kMAXPATHLEN], mydir[kMAXPATHLEN] = { '\0' };
3921 return UnixHomedirectory(name, path, mydir);
3922}
3923
3924////////////////////////////////////////////////////////////////////////////
3925/// Returns the user's home directory.
3926
3927const char *TUnixSystem::UnixHomedirectory(const char *name, char *path, char *mydir)
3928{
3929 struct passwd *pw;
3930 if (name) {
3931 pw = getpwnam(name);
3932 if (pw) {
3933 strncpy(path, pw->pw_dir, kMAXPATHLEN-1);
3934 path[kMAXPATHLEN-1] = '\0';
3935 return path;
3936 }
3937 } else {
3938 if (mydir[0])
3939 return mydir;
3940 pw = getpwuid(getuid());
3941 if (gSystem->Getenv("HOME")) {
3942 strncpy(mydir, gSystem->Getenv("HOME"), kMAXPATHLEN-1);
3943 mydir[kMAXPATHLEN-1] = '\0';
3944 return mydir;
3945 } else if (pw && pw->pw_dir) {
3946 strncpy(mydir, pw->pw_dir, kMAXPATHLEN-1);
3947 mydir[kMAXPATHLEN-1] = '\0';
3948 return mydir;
3949 }
3950 }
3951 return nullptr;
3952}
3953
3954////////////////////////////////////////////////////////////////////////////////
3955/// Make a Unix file system directory. Returns 0 in case of success and
3956/// -1 if the directory could not be created (either already exists or
3957/// illegal path name).
3958
3959int TUnixSystem::UnixMakedir(const char *dir)
3960{
3961 return ::mkdir(StripOffProto(dir, "file:"), 0755);
3962}
3963
3964////////////////////////////////////////////////////////////////////////////////
3965/// Open a directory.
3966
3967void *TUnixSystem::UnixOpendir(const char *dir)
3968{
3969 struct stat finfo;
3970
3971 const char *edir = StripOffProto(dir, "file:");
3972
3973 if (stat(edir, &finfo) < 0)
3974 return nullptr;
3975
3976 if (!S_ISDIR(finfo.st_mode))
3977 return nullptr;
3978
3979 return (void*) opendir(edir);
3980}
3981
3982#if defined(_POSIX_SOURCE)
3983// Posix does not require that the d_ino field be present, and some
3984// systems do not provide it.
3985# define REAL_DIR_ENTRY(dp) 1
3986#else
3987# define REAL_DIR_ENTRY(dp) (dp->d_ino != 0)
3988#endif
3989
3990////////////////////////////////////////////////////////////////////////////////
3991/// Returns the next directory entry.
3992
3994{
3995 DIR *dirp = (DIR*)dirp1;
3996#ifdef HAS_DIRENT
3997 struct dirent *dp;
3998#else
3999 struct direct *dp;
4000#endif
4001
4002 if (dirp) {
4003 for (;;) {
4004 dp = readdir(dirp);
4005 if (!dp)
4006 return nullptr;
4007 if (REAL_DIR_ENTRY(dp))
4008 return dp->d_name;
4009 }
4010 }
4011 return nullptr;
4012}
4013
4014//---- files -------------------------------------------------------------------
4015
4016////////////////////////////////////////////////////////////////////////////////
4017/// Get info about a file. Info is returned in the form of a FileStat_t
4018/// structure (see TSystem.h).
4019/// The function returns 0 in case of success and 1 if the file could
4020/// not be stat'ed.
4021
4023{
4024 const char *path = StripOffProto(fpath, "file:");
4025 buf.fIsLink = kFALSE;
4026
4027#if defined(R__SEEK64)
4028 struct stat64 sbuf;
4029 if (path && lstat64(path, &sbuf) == 0) {
4030#else
4031 struct stat sbuf;
4032 if (path && lstat(path, &sbuf) == 0) {
4033#endif
4034 buf.fIsLink = S_ISLNK(sbuf.st_mode);
4035 if (buf.fIsLink) {
4036#if defined(R__SEEK64)
4037 if (stat64(path, &sbuf) == -1) {
4038#else
4039 if (stat(path, &sbuf) == -1) {
4040#endif
4041 return 1;
4042 }
4043 }
4044 buf.fDev = sbuf.st_dev;
4045 buf.fIno = sbuf.st_ino;
4046 buf.fMode = sbuf.st_mode;
4047 buf.fUid = sbuf.st_uid;
4048 buf.fGid = sbuf.st_gid;
4049 buf.fSize = sbuf.st_size;
4050 buf.fMtime = sbuf.st_mtime;
4051
4052 return 0;
4053 }
4054 return 1;
4055}
4056
4057////////////////////////////////////////////////////////////////////////////////
4058/// Get info about a file system: id, bsize, bfree, blocks.
4059/// Id is file system type (machine dependend, see statfs())
4060/// Bsize is block size of file system
4061/// Blocks is total number of blocks in file system
4062/// Bfree is number of free blocks in file system
4063/// The function returns 0 in case of success and 1 if the file system could
4064/// not be stat'ed.
4065
4066int TUnixSystem::UnixFSstat(const char *path, Long_t *id, Long_t *bsize,
4068{
4069 struct statfs statfsbuf;
4070#if (defined(R__SOLARIS) && !defined(R__LINUX))
4071 if (statfs(path, &statfsbuf, sizeof(struct statfs), 0) == 0) {
4072 *id = statfsbuf.f_fstyp;
4073 *bsize = statfsbuf.f_bsize;
4074 *blocks = statfsbuf.f_blocks;
4075 *bfree = statfsbuf.f_bfree;
4076#else
4077 if (statfs((char*)path, &statfsbuf) == 0) {
4078#ifdef R__OBSD
4079 // Convert BSD filesystem names to Linux filesystem type numbers
4080 // where possible. Linux statfs uses a value of -1 to indicate
4081 // an unsupported field.
4082
4083 if (!strcmp(statfsbuf.f_fstypename, MOUNT_FFS) ||
4084 !strcmp(statfsbuf.f_fstypename, MOUNT_MFS))
4085 *id = 0x11954;
4086 else if (!strcmp(statfsbuf.f_fstypename, MOUNT_NFS))
4087 *id = 0x6969;
4088 else if (!strcmp(statfsbuf.f_fstypename, MOUNT_MSDOS))
4089 *id = 0x4d44;
4090 else if (!strcmp(statfsbuf.f_fstypename, MOUNT_EXT2FS))
4091 *id = 0xef53;
4092 else if (!strcmp(statfsbuf.f_fstypename, MOUNT_CD9660))
4093 *id = 0x9660;
4094 else if (!strcmp(statfsbuf.f_fstypename, MOUNT_NCPFS))
4095 *id = 0x6969;
4096 else
4097 *id = -1;
4098#else
4099 *id = statfsbuf.f_type;
4100#endif
4101 *bsize = statfsbuf.f_bsize;
4102 *blocks = statfsbuf.f_blocks;
4103 *bfree = statfsbuf.f_bavail;
4104#endif
4105 return 0;
4106 }
4107 return 1;
4108}
4109
4110////////////////////////////////////////////////////////////////////////////////
4111/// Wait till child is finished.
4112
4114{
4115 int status;
4116 return (int) waitpid(0, &status, WNOHANG);
4117}
4118
4119//---- RPC -------------------------------------------------------------------
4120
4121////////////////////////////////////////////////////////////////////////////////
4122/// Open a TCP/IP connection to server and connect to a service (i.e. port).
4123/// Use tcpwindowsize to specify the size of the receive buffer, it has
4124/// to be specified here to make sure the window scale option is set (for
4125/// tcpwindowsize > 65KB and for platforms supporting window scaling).
4126/// Is called via the TSocket constructor. Returns -1 in case of error.
4127
4128int TUnixSystem::UnixTcpConnect(const char *hostname, int port,
4129 int tcpwindowsize)
4130{
4131 short sport;
4132 struct servent *sp;
4133
4134 if ((sp = getservbyport(htons(port), kProtocolName)))
4135 sport = sp->s_port;
4136 else
4137 sport = htons(port);
4138
4140 if (!addr.IsValid()) return -1;
4141 UInt_t adr = htonl(addr.GetAddress());
4142
4143 struct sockaddr_in server;
4144 memset(&server, 0, sizeof(server));
4145 memcpy(&server.sin_addr, &adr, sizeof(adr));
4146 server.sin_family = addr.GetFamily();
4147 server.sin_port = sport;
4148
4149 // Create socket
4150 int sock;
4151 if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
4152 ::SysError("TUnixSystem::UnixTcpConnect", "socket (%s:%d)",
4153 hostname, port);
4154 return -1;
4155 }
4156
4157 if (tcpwindowsize > 0) {
4160 }
4161
4162 while (connect(sock, (struct sockaddr*) &server, sizeof(server)) == -1) {
4163 if (GetErrno() == EINTR)
4164 ResetErrno();
4165 else {
4166 ::SysError("TUnixSystem::UnixTcpConnect", "connect (%s:%d)",
4167 hostname, port);
4168 close(sock);
4169 return -1;
4170 }
4171 }
4172 return sock;
4173}
4174
4175
4176////////////////////////////////////////////////////////////////////////////////
4177/// Creates a UDP socket connection
4178/// Is called via the TSocket constructor. Returns -1 in case of error.
4179
4180int TUnixSystem::UnixUdpConnect(const char *hostname, int port)
4181{
4182 short sport;
4183 struct servent *sp;
4184
4185 if ((sp = getservbyport(htons(port), kProtocolName)))
4186 sport = sp->s_port;
4187 else
4188 sport = htons(port);
4189
4191 if (!addr.IsValid()) return -1;
4192 UInt_t adr = htonl(addr.GetAddress());
4193
4194 struct sockaddr_in server;
4195 memset(&server, 0, sizeof(server));
4196 memcpy(&server.sin_addr, &adr, sizeof(adr));
4197 server.sin_family = addr.GetFamily();
4198 server.sin_port = sport;
4199
4200 // Create socket
4201 int sock;
4202 if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
4203 ::SysError("TUnixSystem::UnixUdpConnect", "socket (%s:%d)",
4204 hostname, port);
4205 return -1;
4206 }
4207
4208 while (connect(sock, (struct sockaddr*) &server, sizeof(server)) == -1) {
4209 if (GetErrno() == EINTR)
4210 ResetErrno();
4211 else {
4212 ::SysError("TUnixSystem::UnixUdpConnect", "connect (%s:%d)",
4213 hostname, port);
4214 close(sock);
4215 return -1;
4216 }
4217 }
4218 return sock;
4219}
4220
4221////////////////////////////////////////////////////////////////////////////////
4222/// Connect to a Unix domain socket.
4223
4225{
4226 return UnixUnixConnect(TString::Format("%s/%d", kServerPath, port));
4227}
4228
4229////////////////////////////////////////////////////////////////////////////////
4230/// Connect to a Unix domain socket. Returns -1 in case of error.
4231
4233{
4234 if (!sockpath || strlen(sockpath) <= 0) {
4235 ::SysError("TUnixSystem::UnixUnixConnect", "socket path undefined");
4236 return -1;
4237 }
4238
4239 int sock;
4240 struct sockaddr_un unserver;
4241 unserver.sun_family = AF_UNIX;
4242
4243 if (strlen(sockpath) > sizeof(unserver.sun_path)-1) {
4244 ::Error("TUnixSystem::UnixUnixConnect", "socket path %s, longer than max allowed length (%u)",
4245 sockpath, (UInt_t)sizeof(unserver.sun_path)-1);
4246 return -1;
4247 }
4248 strlcpy(unserver.sun_path, sockpath, sizeof(unserver.sun_path));
4249
4250 // Open socket
4251 if ((sock = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
4252 ::SysError("TUnixSystem::UnixUnixConnect", "socket");
4253 return -1;
4254 }
4255
4256 while (connect(sock, (struct sockaddr*) &unserver, strlen(unserver.sun_path)+2) == -1) {
4257 if (GetErrno() == EINTR)
4258 ResetErrno();
4259 else {
4260 ::SysError("TUnixSystem::UnixUnixConnect", "connect");
4261 close(sock);
4262 return -1;
4263 }
4264 }
4265 return sock;
4266}
4267
4268////////////////////////////////////////////////////////////////////////////////
4269/// Open a socket, bind to it and start listening for TCP/IP connections
4270/// on the port. If reuse is true reuse the address, backlog specifies
4271/// how many sockets can be waiting to be accepted. If port is 0 a port
4272/// scan will be done to find a free port. This option is mutual exlusive
4273/// with the reuse option.
4274/// Use tcpwindowsize to specify the size of the receive buffer, it has
4275/// to be specified here to make sure the window scale option is set (for
4276/// tcpwindowsize > 65KB and for platforms supporting window scaling).
4277/// The socketBindOption parameter allows to specify how the socket will be
4278/// bound. See the documentation of ESocketBindOption for the details.
4279/// Returns socket fd or -1 if socket() failed, -2 if bind() failed
4280/// or -3 if listen() failed.
4281
4284{
4285 const short kSOCKET_MINPORT = 5000, kSOCKET_MAXPORT = 15000;
4286 short sport, tryport = kSOCKET_MINPORT;
4287 struct servent *sp;
4288
4289 if (port == 0 && reuse) {
4290 ::Error("TUnixSystem::UnixTcpService", "cannot do a port scan while reuse is true");
4291 return -1;
4292 }
4293
4294 if ((sp = getservbyport(htons(port), kProtocolName)))
4295 sport = sp->s_port;
4296 else
4297 sport = htons(port);
4298
4299 // Create tcp socket
4300 int sock;
4301 if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
4302 ::SysError("TUnixSystem::UnixTcpService", "socket");
4303 return -1;
4304 }
4305
4306 if (reuse)
4307 gSystem->SetSockOpt(sock, kReuseAddr, 1);
4308
4309 if (tcpwindowsize > 0) {
4312 }
4313
4314 struct sockaddr_in inserver;
4315 memset(&inserver, 0, sizeof(inserver));
4316 inserver.sin_family = AF_INET;
4318 inserver.sin_port = sport;
4319
4320 // Bind socket
4321 if (port > 0) {
4322 if (::bind(sock, (struct sockaddr*) &inserver, sizeof(inserver))) {
4323 ::SysError("TUnixSystem::UnixTcpService", "bind");
4324 close(sock);
4325 return -2;
4326 }
4327 } else {
4328 int bret;
4329 do {
4330 inserver.sin_port = htons(tryport);
4331 bret = ::bind(sock, (struct sockaddr*) &inserver, sizeof(inserver));
4332 tryport++;
4333 } while (bret < 0 && GetErrno() == EADDRINUSE && tryport < kSOCKET_MAXPORT);
4334 if (bret < 0) {
4335 ::SysError("TUnixSystem::UnixTcpService", "bind (port scan)");
4336 close(sock);
4337 return -2;
4338 }
4339 }
4340
4341 // Start accepting connections
4342 if (::listen(sock, backlog)) {
4343 ::SysError("TUnixSystem::UnixTcpService", "listen");
4344 close(sock);
4345 return -3;
4346 }
4347
4348 return sock;
4349}
4350
4351////////////////////////////////////////////////////////////////////////////////
4352/// Open a socket, bind to it and start listening for UDP connections
4353/// on the port. If reuse is true reuse the address, backlog specifies
4354/// how many sockets can be waiting to be accepted. If port is 0 a port
4355/// scan will be done to find a free port. This option is mutual exlusive
4356/// with the reuse option.
4357/// The socketBindOption parameter allows to specify how the socket will be
4358/// bound. See the documentation of ESocketBindOption for the details.
4359
4361{
4362 const short kSOCKET_MINPORT = 5000, kSOCKET_MAXPORT = 15000;
4363 short sport, tryport = kSOCKET_MINPORT;
4364 struct servent *sp;
4365
4366 if ((sp = getservbyport(htons(port), kProtocolName)))
4367 sport = sp->s_port;
4368 else
4369 sport = htons(port);
4370
4371 // Create udp socket
4372 int sock;
4373 if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
4374 ::SysError("TUnixSystem::UnixUdpService", "socket");
4375 return -1;
4376 }
4377
4378 struct sockaddr_in inserver;
4379 memset(&inserver, 0, sizeof(inserver));
4380 inserver.sin_family = AF_INET;
4382 inserver.sin_port = sport;
4383
4384 // Bind socket
4385 if (port > 0) {
4386 if (::bind(sock, (struct sockaddr*) &inserver, sizeof(inserver))) {
4387 ::SysError("TUnixSystem::UnixUdpService", "bind");
4388 close(sock);
4389 return -2;
4390 }
4391 } else {
4392 int bret;
4393 do {
4394 inserver.sin_port = htons(tryport);
4395 bret = ::bind(sock, (struct sockaddr*) &inserver, sizeof(inserver));
4396 tryport++;
4397 } while (bret < 0 && GetErrno() == EADDRINUSE && tryport < kSOCKET_MAXPORT);
4398 if (bret < 0) {
4399 ::SysError("TUnixSystem::UnixUdpService", "bind (port scan)");
4400 close(sock);
4401 return -2;
4402 }
4403 }
4404
4405 // Start accepting connections
4406 if (::listen(sock, backlog)) {
4407 ::SysError("TUnixSystem::UnixUdpService", "listen");
4408 close(sock);
4409 return -3;
4410 }
4411
4412 return sock;
4413}
4414
4415////////////////////////////////////////////////////////////////////////////////
4416/// Open a socket, bind to it and start listening for Unix domain connections
4417/// to it. Returns socket fd or -1.
4418
4420{
4421 int oldumask;
4422
4423 // Assure that socket directory exists
4424 oldumask = umask(0);
4425 int res = ::mkdir(kServerPath, 0777);
4426 umask(oldumask);
4427
4428 if (res == -1)
4429 return -1;
4430
4431 // Socket path
4433 sockpath.Form("%s/%d", kServerPath, port);
4434
4435 // Remove old socket
4436 unlink(sockpath.Data());
4437
4439}
4440
4441////////////////////////////////////////////////////////////////////////////////
4442/// Open a socket on path 'sockpath', bind to it and start listening for Unix
4443/// domain connections to it. Returns socket fd or -1.
4444
4446{
4447 if (!sockpath || strlen(sockpath) <= 0) {
4448 ::SysError("TUnixSystem::UnixUnixService", "socket path undefined");
4449 return -1;
4450 }
4451
4452 struct sockaddr_un unserver;
4453 int sock;
4454
4455 // Prepare structure
4456 memset(&unserver, 0, sizeof(unserver));
4457 unserver.sun_family = AF_UNIX;
4458
4459 if (strlen(sockpath) > sizeof(unserver.sun_path)-1) {
4460 ::Error("TUnixSystem::UnixUnixService", "socket path %s, longer than max allowed length (%u)",
4461 sockpath, (UInt_t)sizeof(unserver.sun_path)-1);
4462 return -1;
4463 }
4464 strlcpy(unserver.sun_path, sockpath, sizeof(unserver.sun_path));
4465
4466 // Create socket
4467 if ((sock = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
4468 ::SysError("TUnixSystem::UnixUnixService", "socket");
4469 return -1;
4470 }
4471
4472 if (::bind(sock, (struct sockaddr*) &unserver, strlen(unserver.sun_path)+2)) {
4473 ::SysError("TUnixSystem::UnixUnixService", "bind");
4474 close(sock);
4475 return -1;
4476 }
4477
4478 // Start accepting connections
4479 if (::listen(sock, backlog)) {
4480 ::SysError("TUnixSystem::UnixUnixService", "listen");
4481 close(sock);
4482 return -1;
4483 }
4484
4485 return sock;
4486}
4487
4488////////////////////////////////////////////////////////////////////////////////
4489/// Receive exactly length bytes into buffer. Returns number of bytes
4490/// received. Returns -1 in case of error, -2 in case of MSG_OOB
4491/// and errno == EWOULDBLOCK, -3 in case of MSG_OOB and errno == EINVAL
4492/// and -4 in case of kNoBlock and errno == EWOULDBLOCK.
4493/// Returns -5 if pipe broken or reset by peer (EPIPE || ECONNRESET).
4494
4495int TUnixSystem::UnixRecv(int sock, void *buffer, int length, int flag)
4496{
4497 ResetErrno();
4498
4499 if (sock < 0) return -1;
4500
4501 int once = 0;
4502 if (flag == -1) {
4503 flag = 0;
4504 once = 1;
4505 }
4506 if (flag == MSG_PEEK)
4507 once = 1;
4508
4509 int n, nrecv = 0;
4510 char *buf = (char *)buffer;
4511
4512 for (n = 0; n < length; n += nrecv) {
4513 if ((nrecv = recv(sock, buf+n, length-n, flag)) <= 0) {
4514 if (nrecv == 0)
4515 break; // EOF
4516 if (flag == MSG_OOB) {
4517 if (GetErrno() == EWOULDBLOCK)
4518 return -2;
4519 else if (GetErrno() == EINVAL)
4520 return -3;
4521 }
4522 if (GetErrno() == EWOULDBLOCK)
4523 return -4;
4524 else {
4525 if (GetErrno() != EINTR)
4526 ::SysError("TUnixSystem::UnixRecv", "recv");
4527 if (GetErrno() == EPIPE || GetErrno() == ECONNRESET)
4528 return -5;
4529 else
4530 return -1;
4531 }
4532 }
4533 if (once)
4534 return nrecv;
4535 }
4536 return n;
4537}
4538
4539////////////////////////////////////////////////////////////////////////////////
4540/// Send exactly length bytes from buffer. Returns -1 in case of error,
4541/// otherwise number of sent bytes. Returns -4 in case of kNoBlock and
4542/// errno == EWOULDBLOCK. Returns -5 if pipe broken or reset by peer
4543/// (EPIPE || ECONNRESET).
4544
4545int TUnixSystem::UnixSend(int sock, const void *buffer, int length, int flag)
4546{
4547 if (sock < 0) return -1;
4548
4549 int once = 0;
4550 if (flag == -1) {
4551 flag = 0;
4552 once = 1;
4553 }
4554
4555 int n, nsent = 0;
4556 const char *buf = (const char *)buffer;
4557
4558 for (n = 0; n < length; n += nsent) {
4559 if ((nsent = send(sock, buf+n, length-n, flag)) <= 0) {
4560 if (nsent == 0)
4561 break;
4562 if (GetErrno() == EWOULDBLOCK)
4563 return -4;
4564 else {
4565 if (GetErrno() != EINTR)
4566 ::SysError("TUnixSystem::UnixSend", "send");
4567 if (GetErrno() == EPIPE || GetErrno() == ECONNRESET)
4568 return -5;
4569 else
4570 return -1;
4571 }
4572 }
4573 if (once)
4574 return nsent;
4575 }
4576 return n;
4577}
4578
4579//---- Dynamic Loading ---------------------------------------------------------
4580
4581////////////////////////////////////////////////////////////////////////////////
4582/// Get shared library search path. Static utility function.
4583///
4584/// The runtime cost (syscalls) of this function can be shortened by injecting
4585/// a pre-calculated result for the system library search path in form of
4586/// `export ROOT_LDSYSPATH=$(LD_DEBUG=libs LD_PRELOAD=DOESNOTEXIST ls /tmp/DOESNOTEXIST 2>&1 | grep -m 1 "system search
4587/// path" | sed 's/.*=//g' | awk '//{print $1}')` This might be useful in scenarios, where ROOT is instantiated many
4588/// times.
4589
4590static const char *DynamicPath(const char *newpath = nullptr, Bool_t reset = kFALSE)
4591{
4592 static TString dynpath_full;
4593 static std::atomic<bool> initialized(kFALSE);
4594 static std::atomic<bool> seenCling(kFALSE);
4595
4596 // If we have not seen Cling but the result has been initialized and gCling
4597 // is still nullptr, the result won't change.
4598 if (newpath == nullptr && !reset && (seenCling || (initialized && gCling == nullptr)))
4599 return dynpath_full;
4600
4602
4603 if (newpath) {
4605 // Don't erase the user given path at the next call.
4606 initialized = kTRUE;
4607 // We do not (otherwise) record whether the path was set automatically or
4608 // whether it was set explicitly by the user. If the user set the path
4609 // explicitly, we should never automatically over-ride the value; if
4610 // seenCling stayed false, it would tell this routine that at the next
4611 // call it should update the value (to insert the Cling provided parts)
4612 // back to the default.
4613 seenCling = kTRUE;
4614 return dynpath_full;
4615 }
4616
4617 // Another thread might have updated this. Even-though this is executed at the
4618 // start of the process, we might get there if the user is explicitly
4619 // 'resetting' the value.
4620 if (!reset && (seenCling || (initialized && gCling == nullptr)))
4621 return dynpath_full;
4622
4623 if (!initialized) {
4624 // force one time initialization of gROOT before we start
4625 // (otherwise it might be done as a side effect of gEnv->GetValue and
4626 // TROOT's initialization will call this routine).
4627 gROOT;
4628 }
4629
4630 static TString dynpath_envpart;
4631 static TString dynpath_syspart;
4632
4633 if (reset || !initialized) {
4634
4635 dynpath_envpart = gSystem->Getenv("ROOT_LIBRARY_PATH");
4636 TString rdynpath = gEnv->GetValue("Root.DynamicPath", nullptr);
4637 rdynpath.ReplaceAll(": ", ":"); // in case DynamicPath was extended
4638 if (rdynpath.IsNull()) {
4639 rdynpath = ".:"; rdynpath += TROOT::GetLibDir();
4640 }
4642 #if defined (R__AIX)
4643 ldpath = gSystem->Getenv("LIBPATH");
4644 #elif defined(R__MACOSX)
4645 ldpath = gSystem->Getenv("DYLD_LIBRARY_PATH");
4646 if (!ldpath.IsNull())
4647 ldpath += ":";
4648 ldpath += gSystem->Getenv("LD_LIBRARY_PATH");
4649 if (!ldpath.IsNull())
4650 ldpath += ":";
4651 ldpath += gSystem->Getenv("DYLD_FALLBACK_LIBRARY_PATH");
4652 #else
4653 ldpath = gSystem->Getenv("LD_LIBRARY_PATH");
4654 #endif
4655 if (!ldpath.IsNull()) {
4656 if (!dynpath_envpart.IsNull())
4657 dynpath_envpart += ":";
4659 }
4660 if (!rdynpath.IsNull()) {
4661 if (!dynpath_envpart.IsNull())
4662 dynpath_envpart += ":";
4664 }
4665 if (!dynpath_envpart.Contains(TROOT::GetLibDir())) {
4667 }
4668
4669 #if defined(R__WINGCC) || defined(R__MACOSX)
4670 // if (!dynpath.EndsWith(":")) dynpath += ":";
4671 dynpath_syspart = "/usr/local/lib:/usr/X11R6/lib:/usr/lib:/lib:";
4672 dynpath_syspart += "/lib/x86_64-linux-gnu:/usr/local/lib64:/usr/lib64:/lib64:";
4673 #else
4674 // Obtain the system search path ...
4675
4676 // First of all, let's see if an outside entity gave us the system path.
4677 // This is a power-user feature for users bringing up many executables with ROOT linked in.
4678 // In this case, the system path could be cached in an environment variable ROOT_LDSYSPATH and prevent
4679 // repeated sys-calls (popen) and to having to search through potentially long LD_LIBRARY_PATH strings.
4680 const auto ldsyspath = std::getenv("ROOT_LDSYSPATH");
4681 if (ldsyspath != nullptr) {
4683 } else {
4684 // trick to get the system search path at runtime (default case)
4685 std::string cmd("LD_DEBUG=libs LD_PRELOAD=DOESNOTEXIST ls 2>&1");
4686 FILE *pf = popen(cmd.c_str(), "r");
4687 std::string result = "";
4688 char buffer[128];
4689 while (!feof(pf)) {
4690 if (fgets(buffer, 128, pf) != nullptr)
4691 result += buffer;
4692 }
4693 pclose(pf);
4694 std::size_t from = result.find("search path=", result.find("(LD_LIBRARY_PATH)"));
4695 std::size_t to = result.find("(system search path)");
4696 if (from != std::string::npos && to != std::string::npos) {
4697 from += 12;
4698 std::string sys_path = result.substr(from, to - from);
4699 sys_path.erase(std::remove_if(sys_path.begin(), sys_path.end(), isspace), sys_path.end());
4700 dynpath_syspart = sys_path.c_str();
4701 }
4702 }
4703 dynpath_envpart.ReplaceAll("::", ":");
4704 dynpath_syspart.ReplaceAll("::", ":");
4705 #endif
4706 }
4707
4708 if (!initialized || (!seenCling && gCling)) {
4710 if (!dynpath_full.EndsWith(":")) dynpath_full += ":";
4711 if (gCling) {
4713 if (!dynpath_full.EndsWith(":")) dynpath_full += ":";
4714
4715 seenCling = kTRUE;
4716 }
4718 initialized = kTRUE;
4719
4720 if (gDebug > 0) std::cout << "dynpath = " << dynpath_full.Data() << std::endl;
4721 }
4722
4723 return dynpath_full;
4724}
4725
4726////////////////////////////////////////////////////////////////////////////////
4727/// Add a new directory to the dynamic path.
4728
4729void TUnixSystem::AddDynamicPath(const char *path)
4730{
4731 if (path) {
4732 TString oldpath = DynamicPath(nullptr, kFALSE);
4733 oldpath.Append(":");
4734 oldpath.Append(path);
4736 }
4737}
4738
4739////////////////////////////////////////////////////////////////////////////////
4740/// Return the dynamic path (used to find shared libraries).
4741
4743{
4744 return DynamicPath(nullptr, kFALSE);
4745}
4746
4747////////////////////////////////////////////////////////////////////////////////
4748/// Set the dynamic path to a new value.
4749/// If the value of 'path' is zero, the dynamic path is reset to its
4750/// default value.
4751
4752void TUnixSystem::SetDynamicPath(const char *path)
4753{
4754 if (!path)
4755 DynamicPath(nullptr, kTRUE);
4756 else
4757 DynamicPath(path);
4758}
4759
4760////////////////////////////////////////////////////////////////////////////////
4761/// Returns the path of a shared library (searches for library in the
4762/// shared library search path). If no file name extension is provided
4763/// it first tries .so, .sl, .dl and then .a (for AIX).
4764
4766{
4767 char buf[PATH_MAX + 1];
4768 char *res = realpath(sLib.Data(), buf);
4769 if (res) sLib = buf;
4772 return sLib;
4773 }
4774 sLib = searchFor;
4775 const char* lib = sLib.Data();
4776 int len = sLib.Length();
4777 if (len > 3 && (!strcmp(lib+len-3, ".so") ||
4778 !strcmp(lib+len-3, ".dl") ||
4779 !strcmp(lib+len-4, ".dll") ||
4780 !strcmp(lib+len-4, ".DLL") ||
4781 !strcmp(lib+len-6, ".dylib") ||
4782 !strcmp(lib+len-3, ".sl") ||
4783 !strcmp(lib+len-2, ".a"))) {
4785 return sLib;
4786 }
4787 if (!quiet)
4788 Error("FindDynamicLibrary",
4789 "%s does not exist in %s", searchFor.Data(), GetDynamicPath());
4790 return nullptr;
4791 }
4792 static const char* exts[] = {
4793 ".so", ".dll", ".dylib", ".sl", ".dl", ".a", nullptr };
4794 const char** ext = exts;
4795 while (*ext) {
4797 fname += *ext;
4798 ++ext;
4800 sLib.Swap(fname);
4801 return sLib;
4802 }
4803 }
4804
4805 if (!quiet)
4806 Error("FindDynamicLibrary",
4807 "%s[.so | .dll | .dylib | .sl | .dl | .a] does not exist in %s",
4808 searchFor.Data(), GetDynamicPath());
4809
4810 return nullptr;
4811}
4812
4813//---- System, CPU and Memory info ---------------------------------------------
4814
4815#if defined(R__FBSD)
4816///////////////////////////////////////////////////////////////////////////////
4817//// Get system info for FreeBSD
4818
4820{
4821 // it probably would be better to get this information from syscalls
4822 // this is possibly less error prone
4823 FILE *p = gSystem->OpenPipe("sysctl -n kern.ostype hw.model hw.ncpu "
4824 "hw.realmem dev.cpu.0.freq", "r");
4825 TString s;
4826 s.Gets(p);
4827 sysinfo->fOS = s;
4828 s.Gets(p);
4829 sysinfo->fCpuType = s;
4830 s.Gets(p);
4831 sysinfo->fCpus = s.Atoi();
4832 s.Gets(p);
4833 Long64_t t = s.Atoll();
4834 sysinfo->fPhysRam = Int_t(t / 1024 / 1024);
4835 s.Gets(p);
4836 t = s.Atoll();
4837 sysinfo->fCpuSpeed = Int_t(t);
4839}
4840
4841static void GetFreeBSDCpuInfo(CpuInfo_t*, Int_t)
4842{
4843 Error("ListSymbols", "not yet implemented");
4844}
4845#endif
4846
4847#if defined(R__MACOSX)
4848#include <sys/resource.h>
4849#include <mach/mach.h>
4850#include <mach/mach_error.h>
4851
4852////////////////////////////////////////////////////////////////////////////////
4853/// Get system info for Mac OS X.
4854
4856{
4857 FILE *p = gSystem->OpenPipe("sysctl -n kern.ostype hw.model hw.ncpu hw.cpufrequency "
4858 "hw.busfrequency hw.l2cachesize hw.memsize", "r");
4859 TString s;
4860 s.Gets(p);
4861 sysinfo->fOS = s;
4862 s.Gets(p);
4863 sysinfo->fModel = s;
4864 s.Gets(p);
4865 sysinfo->fCpus = s.Atoi();
4866 s.Gets(p);
4867 Long64_t t = s.Atoll();
4868 sysinfo->fCpuSpeed = Int_t(t / 1000000);
4869 s.Gets(p);
4870 t = s.Atoll();
4871 sysinfo->fBusSpeed = Int_t(t / 1000000);
4872 s.Gets(p);
4873 sysinfo->fL2Cache = s.Atoi() / 1024;
4874 s.Gets(p);
4875 t = s.Atoll();
4876 sysinfo->fPhysRam = Int_t(t / 1024 / 1024);
4878 p = gSystem->OpenPipe("hostinfo", "r");
4879 while (s.Gets(p)) {
4880 if (s.BeginsWith("Processor type: ")) {
4881 TPRegexp("Processor type: ([^ ]+).*").Substitute(s, "$1");
4882 sysinfo->fCpuType = s;
4883 }
4884 }
4886}
4887
4888////////////////////////////////////////////////////////////////////////////////
4889/// Get CPU load on Mac OS X.
4890
4891static void ReadDarwinCpu(long *ticks)
4892{
4896
4897 ticks[0] = ticks[1] = ticks[2] = ticks[3] = 0;
4898
4901 if (kr != KERN_SUCCESS) {
4902 ::Error("TUnixSystem::ReadDarwinCpu", "host_statistics: %s", mach_error_string(kr));
4903 } else {
4904 ticks[0] = cpu.cpu_ticks[CPU_STATE_USER];
4905 ticks[1] = cpu.cpu_ticks[CPU_STATE_SYSTEM];
4906 ticks[2] = cpu.cpu_ticks[CPU_STATE_IDLE];
4907 ticks[3] = cpu.cpu_ticks[CPU_STATE_NICE];
4908 }
4909}
4910
4911////////////////////////////////////////////////////////////////////////////////
4912/// Get CPU stat for Mac OS X. Use sampleTime to set the interval over which
4913/// the CPU load will be measured, in ms (default 1000).
4914
4916{
4917 Double_t avg[3];
4918 if (getloadavg(avg, sizeof(avg)) < 0) {
4919 ::Error("TUnixSystem::GetDarwinCpuInfo", "getloadavg failed");
4920 } else {
4921 cpuinfo->fLoad1m = (Float_t)avg[0];
4922 cpuinfo->fLoad5m = (Float_t)avg[1];
4923 cpuinfo->fLoad15m = (Float_t)avg[2];
4924 }
4925
4930
4932 (cpu_ticks1[0] + cpu_ticks1[3]);
4935 if (userticks < 0) userticks = 0;
4936 if (systicks < 0) systicks = 0;
4937 if (idleticks < 0) idleticks = 0;
4939 if (totalticks) {
4940 cpuinfo->fUser = ((Float_t)(100 * userticks)) / ((Float_t)totalticks);
4941 cpuinfo->fSys = ((Float_t)(100 * systicks)) / ((Float_t)totalticks);
4942 cpuinfo->fTotal = cpuinfo->fUser + cpuinfo->fSys;
4943 cpuinfo->fIdle = ((Float_t)(100 * idleticks)) / ((Float_t)totalticks);
4944 }
4945}
4946
4947////////////////////////////////////////////////////////////////////////////////
4948/// Get VM stat for Mac OS X.
4949
4951{
4952 static Int_t pshift = 0;
4953
4957 if (kr != KERN_SUCCESS) {
4958 ::Error("TUnixSystem::GetDarwinMemInfo", "host_statistics: %s", mach_error_string(kr));
4959 return;
4960 }
4961 if (pshift == 0) {
4962 for (int psize = getpagesize(); psize > 1; psize >>= 1)
4963 pshift++;
4964 }
4965
4966 // Figure out total swap. This adds up the size of the swapfiles */
4967 DIR *dirp = opendir("/private/var/vm");
4968 if (!dirp)
4969 return;
4970
4971 Long64_t swap_total = 0;
4972 struct dirent *dp;
4973 while ((dp = readdir(dirp)) != 0) {
4974 struct stat sb;
4975 char fname [MAXNAMLEN];
4976 if (strncmp(dp->d_name, "swapfile", 8))
4977 continue;
4978 strlcpy(fname, "/private/var/vm/",MAXNAMLEN);
4979 strlcat (fname, dp->d_name,MAXNAMLEN);
4980 if (stat(fname, &sb) < 0)
4981 continue;
4982 swap_total += sb.st_size;
4983 }
4984 closedir(dirp);
4985
4986 Long64_t used = (Long64_t)(vm_info.active_count + vm_info.inactive_count + vm_info.wire_count) << pshift;
4987 Long64_t free = (Long64_t)(vm_info.free_count) << pshift;
4988 Long64_t total = (Long64_t)(vm_info.active_count + vm_info.inactive_count + vm_info.free_count + vm_info.wire_count) << pshift;
4989 Long64_t avail = (Long64_t)(vm_info.inactive_count + vm_info.free_count) << pshift;
4990
4991 // Swap is available at same time as mem, so grab values here.
4992 Long64_t swap_used = vm_info.pageouts << pshift;
4993
4994 meminfo->fMemTotal = (Int_t) (total >> 20); // divide by 1024 * 1024
4995 meminfo->fMemUsed = (Int_t) (used >> 20);
4996 meminfo->fMemFree = (Int_t) (free >> 20);
4997 meminfo->fSwapTotal = (Int_t) (swap_total >> 20);
4998 meminfo->fSwapUsed = (Int_t) (swap_used >> 20);
4999 meminfo->fSwapFree = meminfo->fSwapTotal - meminfo->fSwapUsed;
5000 meminfo->fMemAvailable = (Int_t)(avail >> 20);
5001}
5002
5003////////////////////////////////////////////////////////////////////////////////
5004/// Get process info for this process on Mac OS X.
5005/// Code largely taken from:
5006/// http://www.opensource.apple.com/source/top/top-15/libtop.c
5007/// The virtual memory usage is slightly over estimated as we don't
5008/// subtract shared regions, but the value makes more sense
5009/// than using `virtual_size`, which is useless on 64-bit machines.
5010
5012{
5013#ifdef _LP64
5014#define vm_region vm_region_64
5015#endif
5016
5017// taken from <mach/shared_memory_server.h> which is obsoleted in 10.5
5018#define GLOBAL_SHARED_TEXT_SEGMENT 0x90000000U
5019#define GLOBAL_SHARED_DATA_SEGMENT 0xA0000000U
5020#define SHARED_TEXT_REGION_SIZE 0x10000000
5021#define SHARED_DATA_REGION_SIZE 0x10000000
5022
5023 struct rusage ru;
5024 if (getrusage(RUSAGE_SELF, &ru) < 0) {
5025 ::SysError("TUnixSystem::GetDarwinProcInfo", "getrusage failed");
5026 } else {
5027 procinfo->fCpuUser = (Float_t)(ru.ru_utime.tv_sec) +
5028 ((Float_t)(ru.ru_utime.tv_usec) / 1000000.);
5029 procinfo->fCpuSys = (Float_t)(ru.ru_stime.tv_sec) +
5030 ((Float_t)(ru.ru_stime.tv_usec) / 1000000.);
5031 }
5032
5036
5037 task_t a_task = mach_task_self();
5038
5039 count = TASK_BASIC_INFO_COUNT;
5041 if (kr != KERN_SUCCESS) {
5042 ::Error("TUnixSystem::GetDarwinProcInfo", "task_info: %s", mach_error_string(kr));
5043 } else {
5044 // resident size does not require any calculation. Virtual size
5045 // needs to be adjusted if traversing memory objects do not include the
5046 // globally shared text and data regions
5048 vm_address_t address;
5051 rsize = ti.resident_size;
5052 vprvt = 0;
5053 for (address = 0; ; address += size) {
5054 // get memory region
5056 if (vm_region(a_task, &address, &size,
5059 // no more memory regions.
5060 break;
5061 }
5062
5063 if (address >= GLOBAL_SHARED_TEXT_SEGMENT &&
5065 // This region is private shared.
5066 // Check if this process has the globally shared
5067 // text and data regions mapped in. If so, adjust
5068 // virtual memory size and exit loop.
5069 if (info.share_mode == SM_EMPTY) {
5072 if (vm_region_64(a_task, &address,
5074 (vm_region_info_t)&b_info, &count,
5076 break;
5077 }
5078 }
5079 // Short circuit the loop if this isn't a shared
5080 // private region, since that's the only region
5081 // type we care about within the current address range.
5082 if (info.share_mode != SM_PRIVATE) {
5083 continue;
5084 }
5085 }
5086 switch (info.share_mode) {
5087 case SM_COW: {
5088 if (info.ref_count == 1) {
5089 vprvt += size;
5090 } else {
5091 vprvt += info.private_pages_resident * getpagesize();
5092 }
5093 break;
5094 }
5095 case SM_PRIVATE: {
5096 vprvt += size;
5097 break;
5098 }
5099 default:
5100 break;
5101 }
5102 }
5103
5104 procinfo->fMemResident = (Long_t)(rsize / 1024);
5105 procinfo->fMemVirtual = (Long_t)(vprvt / 1024);
5106 }
5107}
5108#endif
5109
5110#if defined(R__LINUX)
5111
5112namespace {
5113bool parseLine(TString &s, const char *prefix, Int_t &field)
5114{
5115 if (s.BeginsWith(prefix)) {
5116 TPRegexp{"^.+: *([^ ]+).*"}.Substitute(s, "$1");
5117 field = (s.Atoi() / 1024);
5118 return true;
5119 }
5120 return false;
5121};
5122} // namespace
5123
5124////////////////////////////////////////////////////////////////////////////////
5125/// Get system info for Linux. Only fBusSpeed is not set.
5126
5127static void GetLinuxSysInfo(SysInfo_t *sysinfo)
5128{
5129 TString s;
5130 FILE *f = fopen("/proc/cpuinfo", "r");
5131 if (f) {
5132 while (s.Gets(f)) {
5133 if (s.BeginsWith("model name")) {
5134 TPRegexp("^.+: *(.*$)").Substitute(s, "$1");
5135 sysinfo->fModel = s;
5136 }
5137 parseLine(s, "cpu MHz", sysinfo->fCpuSpeed);
5138 parseLine(s, "cache size", sysinfo->fL2Cache);
5139 if (parseLine(s, "processor", sysinfo->fCpus)) {
5140 sysinfo->fCpus++;
5141 }
5142 }
5143 fclose(f);
5144 }
5145
5146 f = fopen("/proc/meminfo", "r");
5147 if (f) {
5148 while (s.Gets(f)) {
5149 if (parseLine(s, "MemTotal", sysinfo->fPhysRam)) {
5150 break;
5151 }
5152 }
5153 fclose(f);
5154 }
5155
5156 f = gSystem->OpenPipe("uname -s -p", "r");
5157 if (f) {
5158 s.Gets(f);
5159 Ssiz_t from = 0;
5160 s.Tokenize(sysinfo->fOS, from);
5161 s.Tokenize(sysinfo->fCpuType, from);
5163 }
5164}
5165
5166////////////////////////////////////////////////////////////////////////////////
5167/// Get CPU load on Linux.
5168
5169static void ReadLinuxCpu(long *ticks)
5170{
5171 ticks[0] = ticks[1] = ticks[2] = ticks[3] = 0;
5172
5173 TString s;
5174 FILE *f = fopen("/proc/stat", "r");
5175 if (!f) return;
5176 s.Gets(f);
5177 // user, user nice, sys, idle
5178 sscanf(s.Data(), "%*s %ld %ld %ld %ld", &ticks[0], &ticks[3], &ticks[1], &ticks[2]);
5179 fclose(f);
5180}
5181
5182////////////////////////////////////////////////////////////////////////////////
5183/// Get CPU stat for Linux. Use sampleTime to set the interval over which
5184/// the CPU load will be measured, in ms (default 1000).
5185
5187{
5188 Double_t avg[3] = { -1., -1., -1. };
5189#ifndef R__WINGCC
5190 if (getloadavg(avg, sizeof(avg)) < 0) {
5191 ::Error("TUnixSystem::GetLinuxCpuInfo", "getloadavg failed");
5192 } else
5193#endif
5194 {
5195 cpuinfo->fLoad1m = (Float_t)avg[0];
5196 cpuinfo->fLoad5m = (Float_t)avg[1];
5197 cpuinfo->fLoad15m = (Float_t)avg[2];
5198 }
5199
5204
5206 (cpu_ticks1[0] + cpu_ticks1[3]);
5209 if (userticks < 0) userticks = 0;
5210 if (systicks < 0) systicks = 0;
5211 if (idleticks < 0) idleticks = 0;
5213 if (totalticks) {
5214 cpuinfo->fUser = ((Float_t)(100 * userticks)) / ((Float_t)totalticks);
5215 cpuinfo->fSys = ((Float_t)(100 * systicks)) / ((Float_t)totalticks);
5216 cpuinfo->fTotal = cpuinfo->fUser + cpuinfo->fSys;
5217 cpuinfo->fIdle = ((Float_t)(100 * idleticks)) / ((Float_t)totalticks);
5218 }
5219}
5220
5221////////////////////////////////////////////////////////////////////////////////
5222/// Get VM stat for Linux.
5223
5224static void GetLinuxMemInfo(MemInfo_t *meminfo)
5225{
5226 TString s;
5227 FILE *f = fopen("/proc/meminfo", "r");
5228 if (!f)
5229 return;
5230
5231 while (s.Gets(f)) {
5232 parseLine(s, "MemTotal", meminfo->fMemTotal);
5233 parseLine(s, "MemFree", meminfo->fMemFree);
5234 parseLine(s, "MemAvailable", meminfo->fMemAvailable);
5235 parseLine(s, "Cached", meminfo->fMemCached);
5236 parseLine(s, "Buffers", meminfo->fMemBuffer);
5237 parseLine(s, "Shmem", meminfo->fMemShared);
5238 parseLine(s, "SwapTotal", meminfo->fSwapTotal);
5239 parseLine(s, "SwapFree", meminfo->fSwapFree);
5240 parseLine(s, "SwapCached", meminfo->fSwapCached);
5241 parseLine(s, "SReclaimable", meminfo->fSReclaimable);
5242 }
5243 fclose(f);
5244
5245 /*
5246 * Compute memory partition like procps(free), see https://gitlab.com/procps-ng/procps/-/blob/master/proc/sysinfo.c
5247 *
5248 * fMemShared is a part of Cached (see https://lore.kernel.org/patchwork/patch/648763/), does not subtract twice from used
5249 */
5250
5251 meminfo->fMemCached = meminfo->fMemCached + meminfo->fSReclaimable - meminfo->fMemShared;
5252 const Int_t usedDiff = meminfo->fMemFree + meminfo->fMemCached + meminfo->fSReclaimable + meminfo->fMemBuffer;
5253
5254 meminfo->fMemUsed = (meminfo->fMemTotal >= usedDiff) ? meminfo->fMemTotal - usedDiff : meminfo->fMemTotal - meminfo->fMemFree;
5255 meminfo->fMemAvailable = meminfo->fMemAvailable != 0 ? std::min(meminfo->fMemAvailable, meminfo->fMemTotal) : meminfo->fMemFree;
5256
5257 meminfo->fSwapUsed = meminfo->fSwapTotal - meminfo->fSwapFree - meminfo->fSwapCached;
5258
5259}
5260
5261////////////////////////////////////////////////////////////////////////////////
5262/// Get process info for this process on Linux.
5263
5265{
5266 struct rusage ru;
5267 if (getrusage(RUSAGE_SELF, &ru) < 0) {
5268 ::SysError("TUnixSystem::GetLinuxProcInfo", "getrusage failed");
5269 } else {
5270 procinfo->fCpuUser = (Float_t)(ru.ru_utime.tv_sec) +
5271 ((Float_t)(ru.ru_utime.tv_usec) / 1000000.);
5272 procinfo->fCpuSys = (Float_t)(ru.ru_stime.tv_sec) +
5273 ((Float_t)(ru.ru_stime.tv_usec) / 1000000.);
5274 }
5275
5276 procinfo->fMemVirtual = -1;
5277 procinfo->fMemResident = -1;
5278 TString s;
5279 FILE *f = fopen(TString::Format("/proc/%d/statm", gSystem->GetPid()), "r");
5280 if (f) {
5281 s.Gets(f);
5282 fclose(f);
5283 Long_t total, rss;
5284 sscanf(s.Data(), "%ld %ld", &total, &rss);
5285 procinfo->fMemVirtual = total * (getpagesize() / 1024);
5286 procinfo->fMemResident = rss * (getpagesize() / 1024);
5287 }
5288}
5289#endif
5290
5291////////////////////////////////////////////////////////////////////////////////
5292/// Returns static system info, like OS type, CPU type, number of CPUs
5293/// RAM size, etc into the SysInfo_t structure. Returns -1 in case of error,
5294/// 0 otherwise.
5295
5297{
5298 if (!info) return -1;
5299
5300 static SysInfo_t sysinfo;
5301
5302 if (!sysinfo.fCpus) {
5303#if defined(R__MACOSX)
5305#elif defined(R__LINUX)
5307#elif defined(R__FBSD)
5309#endif
5310 }
5311
5312 *info = sysinfo;
5313
5314 return 0;
5315}
5316
5317////////////////////////////////////////////////////////////////////////////////
5318/// Returns cpu load average and load info into the CpuInfo_t structure.
5319/// Returns -1 in case of error, 0 otherwise. Use sampleTime to set the
5320/// interval over which the CPU load will be measured, in ms (default 1000).
5321
5323{
5324 if (!info) return -1;
5325
5326#if defined(R__MACOSX)
5328#elif defined(R__LINUX)
5330#elif defined(R__FBSD)
5332#endif
5333
5334 return 0;
5335}
5336
5337////////////////////////////////////////////////////////////////////////////////
5338/// Returns ram and swap memory usage info into the MemInfo_t structure.
5339/// Returns -1 in case of error, 0 otherwise.
5340
5342{
5343 if (!info) return -1;
5344
5345#if defined(R__MACOSX)
5347#elif defined(R__LINUX)
5349#endif
5350
5351 return 0;
5352}
5353
5354////////////////////////////////////////////////////////////////////////////////
5355/// Returns cpu and memory used by this process into the ProcInfo_t structure.
5356/// Returns -1 in case of error, 0 otherwise.
5357
5359{
5360 if (!info) return -1;
5361
5362#if defined(R__MACOSX)
5364#elif defined(R__LINUX)
5366#endif
5367
5368 return 0;
5369}
The file contains utilities which are foundational and could be used across the core component of ROO...
#define f(i)
Definition RSha256.hxx:104
#define h(i)
Definition RSha256.hxx:106
size_t size(const MatrixT &matrix)
retrieve the size of a square matrix
bool Bool_t
Boolean (0=false, 1=true) (bool)
Definition RtypesCore.h:77
int Int_t
Signed integer 4 bytes (int)
Definition RtypesCore.h:59
int Ssiz_t
String size (currently int)
Definition RtypesCore.h:81
unsigned long ULong_t
Unsigned long integer 4 bytes (unsigned long). Size depends on architecture.
Definition RtypesCore.h:69
long Long_t
Signed long integer 4 bytes (long). Size depends on architecture.
Definition RtypesCore.h:68
float Float_t
Float 4 bytes (float)
Definition RtypesCore.h:71
constexpr Bool_t kFALSE
Definition RtypesCore.h:108
double Double_t
Double 8 bytes.
Definition RtypesCore.h:73
constexpr Ssiz_t kNPOS
The equivalent of std::string::npos for the ROOT class TString.
Definition RtypesCore.h:131
long long Long64_t
Portable signed long integer 8 bytes.
Definition RtypesCore.h:83
constexpr Bool_t kTRUE
Definition RtypesCore.h:107
@ kItimerResolution
interval-timer resolution in ms (used for TThread, TTimer, Emit, Connect, etc.)
Definition Rtypes.h:63
@ kMAXSIGNALS
Definition Rtypes.h:60
@ kMAXPATHLEN
Definition Rtypes.h:61
R__EXTERN TApplication * gApplication
ROOT::Detail::TRangeCast< T, true > TRangeDynCast
TRangeDynCast is an adapter class that allows the typed iteration through a TCollection.
R__EXTERN TEnv * gEnv
Definition TEnv.h:170
void SysError(const char *location, const char *msgfmt,...)
Use this function in case a system (OS or GUI) related error occurred.
Definition TError.cxx:219
void Break(const char *location, const char *msgfmt,...)
Use this function in case an error occurred.
Definition TError.cxx:230
void Fatal(const char *location, const char *msgfmt,...)
Use this function in case of a fatal error. It will abort the program.
Definition TError.cxx:267
R__EXTERN TExceptionHandler * gExceptionHandler
Definition TException.h:79
static unsigned int total
winID h TVirtualViewer3D TVirtualGLPainter p
winID h direct
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 mask
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 offset
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 result
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 length
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void value
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 mode
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 org
char name[80]
Definition TGX11.cxx:148
float * q
R__EXTERN TInterpreter * gCling
#define HOWMANY(x, y)
const Int_t kFDSETSIZE
const Int_t kNFDBITS
Int_t gDebug
Global variable setting the debug level. Set to 0 to disable, increase it in steps of 1 to increase t...
Definition TROOT.cxx:777
#define gROOT
Definition TROOT.h:417
char * Form(const char *fmt,...)
Formats a string in a circular formatting buffer.
Definition TString.cxx:2495
void Printf(const char *fmt,...)
Formats a string in a circular formatting buffer and prints the string.
Definition TString.cxx:2509
char * StrDup(const char *str)
Duplicate the string str.
Definition TString.cxx:2563
int EscChar(const char *src, char *dst, int dstlen, char *specchars, char escchar)
Escape specchars in src with escchar and copy to dst.
Definition TString.cxx:2599
ESignals
@ kSigIllegalInstruction
@ kSigPipe
@ kSigBus
@ kSigAbort
@ kSigWindowChanged
@ kSigUrgent
@ kSigUser2
@ kSigFloatingException
@ kSigChild
@ kSigAlarm
@ kSigSegmentationViolation
@ kSigSystem
R__EXTERN const char * gProgName
Definition TSystem.h:252
R__EXTERN TVirtualMutex * gSystemMutex
Definition TSystem.h:254
@ kKeepAlive
Definition TSystem.h:233
@ kBytesToRead
Definition TSystem.h:239
@ kReuseAddr
Definition TSystem.h:234
@ kNoBlock
Definition TSystem.h:236
@ kSendBuffer
Definition TSystem.h:230
@ kNoDelay
Definition TSystem.h:235
@ kOobInline
Definition TSystem.h:232
@ kRecvBuffer
Definition TSystem.h:231
@ kProcessGroup
Definition TSystem.h:237
@ kAtMark
Definition TSystem.h:238
@ kDontBlock
Definition TSystem.h:246
@ kPeek
Definition TSystem.h:245
@ kOob
Definition TSystem.h:244
void(* Func_t)()
Definition TSystem.h:249
R__EXTERN const char * gRootDir
Definition TSystem.h:251
EAccessMode
Definition TSystem.h:51
@ kExecutePermission
Definition TSystem.h:53
@ kReadPermission
Definition TSystem.h:55
@ kWritePermission
Definition TSystem.h:54
ELogFacility
Definition TSystem.h:74
@ kLogLocal2
Definition TSystem.h:77
@ kLogLocal6
Definition TSystem.h:81
@ kLogLocal4
Definition TSystem.h:79
@ kLogLocal5
Definition TSystem.h:80
@ kLogLocal0
Definition TSystem.h:75
@ kLogLocal3
Definition TSystem.h:78
@ kLogLocal1
Definition TSystem.h:76
@ kLogLocal7
Definition TSystem.h:82
ESocketBindOption
Options for binging the sockets created.
Definition TSystem.h:46
@ kInaddrAny
Any address for socket binding.
Definition TSystem.h:47
ELogLevel
Definition TSystem.h:63
R__EXTERN TSystem * gSystem
Definition TSystem.h:582
@ kDivByZero
Definition TSystem.h:88
@ kInexact
Definition TSystem.h:91
@ kInvalid
Definition TSystem.h:87
@ kUnderflow
Definition TSystem.h:90
@ kOverflow
Definition TSystem.h:89
R__EXTERN TFileHandler * gXDisplay
Definition TSystem.h:583
R__EXTERN const char * gProgPath
Definition TSystem.h:253
const char * kServerPath
static void sighandler(int sig)
Call the signal handler associated with the signal.
const char * kShellMeta
const Int_t kFDSETSIZE
#define STRUCT_UTMP
static const char * DynamicPath(const char *newpath=nullptr, Bool_t reset=kFALSE)
Get shared library search path.
#define UTMP_FILE
static void SigHandler(ESignals sig)
Unix signal handler.
#define REAL_DIR_ENTRY(dp)
const char * kProtocolName
static struct Signalmap_t gSignalMap[kMAXSIGNALS]
static const char * GetExePath()
const Int_t kNFDBITS
void(* SigHandler_t)(ESignals)
Definition TUnixSystem.h:29
#define R__LOCKGUARD2(mutex)
#define free
Definition civetweb.c:1578
#define snprintf
Definition civetweb.c:1579
#define malloc
Definition civetweb.c:1575
const_iterator begin() const
const_iterator end() const
virtual void HandleException(Int_t sig)
Handle exceptions (kSigBus, kSigSegmentationViolation, kSigIllegalInstruction and kSigFloatingExcepti...
char ** Argv() const
virtual Int_t GetSize() const
Return the capacity of the collection, i.e.
virtual Int_t GetValue(const char *name, Int_t dflt) const
Returns the integer value for a resource.
Definition TEnv.cxx:503
virtual void HandleException(int sig)=0
void Zero()
void Set(Int_t n)
TFdSet & operator=(const TFdSet &rhs)
void Clr(Int_t n)
Int_t IsSet(Int_t n)
ULong_t * GetBits()
ULong_t fds_bits[(((kFDSETSIZE)+((kNFDBITS) -1))/(kNFDBITS))]
TFdSet(const TFdSet &org)
virtual Bool_t HasReadInterest()
True if handler is interested in read events.
virtual Bool_t WriteNotify()
Notify when something can be written to the descriptor associated with this handler.
virtual Bool_t HasWriteInterest()
True if handler is interested in write events.
int GetFd() const
virtual Bool_t ReadNotify()
Notify when something can be read from the descriptor associated with this handler.
Bool_t Notify() override
Notify when event occurred on descriptor associated with this handler.
This class represents an Internet Protocol (IP) address.
virtual const char * GetSTLIncludePath() const
void Reset()
Iterator of linked list.
Definition TList.h:196
TObject * Next() override
Return next object in the list. Returns 0 when no more objects in list.
Definition TList.cxx:1243
A doubly linked list.
Definition TList.h:38
An array of TObjects.
Definition TObjArray.h:31
Collectable string class.
Definition TObjString.h:28
virtual const char * GetName() const
Returns name of object.
Definition TObject.cxx:459
virtual void SysError(const char *method, const char *msgfmt,...) const
Issue system error message.
Definition TObject.cxx:1109
virtual void Warning(const char *method, const char *msgfmt,...) const
Issue warning message.
Definition TObject.cxx:1081
virtual void Error(const char *method, const char *msgfmt,...) const
Issue error message.
Definition TObject.cxx:1095
Iterator of ordered collection.
TObject * Next() override
Return next object in collection.
Ordered collection.
Int_t Substitute(TString &s, const TString &replace, const TString &mods="", Int_t start=0, Int_t nMatchMax=10)
Substitute replaces the string s by a new string in which matching patterns are replaced by the repla...
Definition TPRegexp.cxx:560
static void ShutDown()
Shut down ROOT.
Definition TROOT.cxx:3465
static const TString & GetEtcDir()
Get the sysconfig directory in the installation. Static utility function.
Definition TROOT.cxx:3381
static const TString & GetLibDir()
Get the library directory in the installation.
Definition TROOT.cxx:3178
Regular expression class.
Definition TRegexp.h:31
Basic string class.
Definition TString.h:138
Int_t Atoi() const
Return integer value of string.
Definition TString.cxx:1994
Bool_t Gets(FILE *fp, Bool_t chop=kTRUE)
Read one line from the stream, including the \n, or until EOF.
Definition Stringio.cxx:204
Bool_t EndsWith(const char *pat, ECaseCompare cmp=kExact) const
Return true if string ends with the specified string.
Definition TString.cxx:2250
const char * Data() const
Definition TString.h:384
TString & ReplaceAll(const TString &s1, const TString &s2)
Definition TString.h:713
TObjArray * Tokenize(const TString &delim) const
This function is used to isolate sequential tokens in a TString.
Definition TString.cxx:2270
Bool_t BeginsWith(const char *s, ECaseCompare cmp=kExact) const
Definition TString.h:632
TString & Remove(Ssiz_t pos)
Definition TString.h:694
TString & Append(const char *cs)
Definition TString.h:581
static TString Format(const char *fmt,...)
Static method which formats a string using a printf style format descriptor and return a TString.
Definition TString.cxx:2384
Ssiz_t Index(const char *pat, Ssiz_t i=0, ECaseCompare cmp=kExact) const
Definition TString.h:660
Long64_t Atoll() const
Return long long value of string.
Definition TString.cxx:2020
Bool_t IsActive() const
Abstract base class defining a generic interface to the underlying Operating System.
Definition TSystem.h:276
virtual void Unload(const char *module)
Unload a shared library.
Definition TSystem.cxx:2067
TSeqCollection * fFileHandler
Definition TSystem.h:316
Int_t fMaxrfd
Definition TSystem.h:301
virtual void AddFileHandler(TFileHandler *fh)
Add a file handler to the list of system file handlers.
Definition TSystem.cxx:556
TString & GetLastErrorString()
Return the thread local storage for the custom last error message.
Definition TSystem.cxx:2117
virtual Func_t DynFindSymbol(const char *module, const char *entry)
Find specific entry point in specified library.
Definition TSystem.cxx:2059
static void ResetErrno()
Static function resetting system error number.
Definition TSystem.cxx:286
virtual Bool_t ExpandPathName(TString &path)
Expand a pathname getting rid of special shell characters like ~.
Definition TSystem.cxx:1289
static Int_t GetErrno()
Static function returning system error number.
Definition TSystem.cxx:278
@ kDefault
Definition TSystem.h:285
TFdSet * fReadmask
!Files that should be checked for read events
Definition TSystem.h:295
TString fWdpath
Definition TSystem.h:304
virtual const char * DirName(const char *pathname)
Return the directory name in pathname.
Definition TSystem.cxx:1020
virtual int GetPid()
Get process id.
Definition TSystem.cxx:720
TString fHostname
Definition TSystem.h:305
virtual Long_t NextTimeOut(Bool_t mode)
Time when next timer of mode (synchronous=kTRUE or asynchronous=kFALSE) will time-out (in ms).
Definition TSystem.cxx:496
virtual int SetSockOpt(int sock, int kind, int val)
Set socket option.
Definition TSystem.cxx:2451
virtual const char * Getenv(const char *env)
Get environment variable.
Definition TSystem.cxx:1680
TFdSet * fWritemask
!Files that should be checked for write events
Definition TSystem.h:296
TFdSet * fSignals
!Signals that were trapped
Definition TSystem.h:299
virtual Bool_t IsPathLocal(const char *path)
Returns TRUE if the url in 'path' points to the local file system.
Definition TSystem.cxx:1320
virtual const char * FindFile(const char *search, TString &file, EAccessMode mode=kFileExists)
Find location of file in a search path.
Definition TSystem.cxx:1553
virtual int mkdir(const char *name, Bool_t recursive=kFALSE)
Make a file system directory.
Definition TSystem.cxx:920
virtual const char * ExpandFileName(const char *fname)
Expand a pathname getting rid of special shell characters like ~.
Definition TSystem.cxx:1113
virtual TFileHandler * RemoveFileHandler(TFileHandler *fh)
Remove a file handler from the list of file handlers.
Definition TSystem.cxx:566
Int_t fSigcnt
Definition TSystem.h:303
virtual int Load(const char *module, const char *entry="", Bool_t system=kFALSE)
Load a shared library.
Definition TSystem.cxx:1872
virtual void ListLibraries(const char *regexp="")
List the loaded shared libraries.
Definition TSystem.cxx:2100
virtual FILE * OpenPipe(const char *command, const char *mode)
Open a pipe.
Definition TSystem.cxx:664
int GetPathInfo(const char *path, Long_t *id, Long_t *size, Long_t *flags, Long_t *modtime)
Get info about a file: id, size, flags, modification time.
Definition TSystem.cxx:1413
virtual const char * PrependPathName(const char *dir, TString &name)
Concatenate a directory and a file name.
Definition TSystem.cxx:1096
virtual Bool_t AccessPathName(const char *path, EAccessMode mode=kFileExists)
Returns FALSE if one can access a file using the specified access mode.
Definition TSystem.cxx:1311
virtual Bool_t Init()
Initialize the OS interface.
Definition TSystem.cxx:182
virtual void AddTimer(TTimer *t)
Add timer to list of system timers.
Definition TSystem.cxx:473
TFdSet * fWriteready
!Files with writes waiting
Definition TSystem.h:298
virtual int ClosePipe(FILE *pipe)
Close the pipe.
Definition TSystem.cxx:673
virtual const char * BaseName(const char *pathname)
Base name of a file name. Base name of /user/root is root.
Definition TSystem.cxx:948
virtual void AddSignalHandler(TSignalHandler *sh)
Add a signal handler to list of system signal handlers.
Definition TSystem.cxx:534
TSeqCollection * fSignalHandler
Definition TSystem.h:315
TFdSet * fReadready
!Files with reads waiting
Definition TSystem.h:297
TSystem * FindHelper(const char *path, void *dirptr=nullptr)
Create helper TSystem to handle file and directory operations that might be special for remote file a...
Definition TSystem.cxx:759
TList * fTimers
Definition TSystem.h:314
Int_t fNfd
Definition TSystem.h:300
std::atomic< Bool_t > fInsideNotify
Definition TSystem.h:306
virtual void Sleep(UInt_t milliSec)
Sleep milliSec milli seconds.
Definition TSystem.cxx:439
Int_t fMaxwfd
Definition TSystem.h:302
virtual const char * WorkingDirectory()
Return working directory.
Definition TSystem.cxx:885
virtual char * Which(const char *search, const char *file, EAccessMode mode=kFileExists)
Find location of file in a search path.
Definition TSystem.cxx:1563
virtual TInetAddress GetHostByName(const char *server)
Get Internet Protocol (IP) address of host.
Definition TSystem.cxx:2306
virtual TSignalHandler * RemoveSignalHandler(TSignalHandler *sh)
Remove a signal handler from list of signal handlers.
Definition TSystem.cxx:544
virtual void Setenv(const char *name, const char *value)
Set environment variable.
Definition TSystem.cxx:1664
static const char * StripOffProto(const char *path, const char *proto)
Strip off protocol string from specified path.
Definition TSystem.cxx:116
virtual TTimer * RemoveTimer(TTimer *t)
Remove timer from list of system timers.
Definition TSystem.cxx:483
virtual TString GetDirName(const char *pathname)
Return the directory name in pathname.
Definition TSystem.cxx:1046
Basic time type with millisecond precision.
Definition TTime.h:27
Handles synchronous and a-synchronous timer events.
Definition TTimer.h:51
Bool_t IsAsync() const
Definition TTimer.h:81
Bool_t CheckTimer(const TTime &now)
Check if timer timed out.
Definition TTimer.cxx:133
Bool_t IsSync() const
Definition TTimer.h:80
void AddTimer(TTimer *ti) override
Add timer to list of system timers.
int RecvRaw(int sock, void *buffer, int length, int flag) override
Receive exactly length bytes into buffer.
int OpenConnection(const char *server, int port, int tcpwindowsize=-1, const char *protocol="tcp") override
Open a connection to a service on a server.
int GetMemInfo(MemInfo_t *info) const override
Returns ram and swap memory usage info into the MemInfo_t structure.
Bool_t IsPathLocal(const char *path) override
Returns TRUE if the url in 'path' points to the local file system.
int Symlink(const char *from, const char *to) override
Create a symlink from file1 to file2.
const char * HomeDirectory(const char *userName=nullptr) override
Return the user's home directory.
Int_t GetGid(const char *group=nullptr) override
Returns the group's id. If group = 0, returns current user's group.
static int UnixUdpConnect(const char *hostname, int port)
Creates a UDP socket connection Is called via the TSocket constructor.
int CopyFile(const char *from, const char *to, Bool_t overwrite=kFALSE) override
Copy a file.
TTimer * RemoveTimer(TTimer *ti) override
Remove timer from list of system timers.
int AnnounceUnixService(int port, int backlog) override
Announce unix domain service on path "kServerPath/<port>".
static int UnixTcpConnect(const char *hostname, int port, int tcpwindowsize)
Open a TCP/IP connection to server and connect to a service (i.e.
Int_t SetFPEMask(Int_t mask=kDefaultMask) override
Set which conditions trigger a floating point exception.
static const char * UnixGetdirentry(void *dir)
Returns the next directory entry.
void Setenv(const char *name, const char *value) override
Set environment variable.
int ConnectService(const char *server, int port, int tcpwindowsize, const char *protocol="tcp")
Connect to service servicename on server servername.
Bool_t ChangeDirectory(const char *path) override
Change directory. Returns kTRUE in case of success, kFALSE otherwise.
static int UnixTcpService(int port, Bool_t reuse, int backlog, int tcpwindowsize, ESocketBindOption socketBindOption)
Open a socket, bind to it and start listening for TCP/IP connections on the port.
static const char * UnixHomedirectory(const char *user=nullptr)
Returns the user's home directory.
char * GetServiceByPort(int port) override
Get name of internet service.
Bool_t CheckSignals(Bool_t sync)
Check if some signals were raised and call their Notify() member.
static int UnixMakedir(const char *name)
Make a Unix file system directory.
static void UnixSigAlarmInterruptsSyscalls(Bool_t set)
When the argument is true the SIGALRM signal handler is set so that interrupted syscalls will not be ...
Int_t GetFPEMask() override
Return the bitmap of conditions that trigger a floating point exception.
static int UnixUnixConnect(int port)
Connect to a Unix domain socket.
int GetSysInfo(SysInfo_t *info) const override
Returns static system info, like OS type, CPU type, number of CPUs RAM size, etc into the SysInfo_t s...
void Exit(int code, Bool_t mode=kTRUE) override
Exit the application.
void AddDynamicPath(const char *lib) override
Add a new directory to the dynamic path.
void SetDynamicPath(const char *lib) override
Set the dynamic path to a new value.
int ClosePipe(FILE *pipe) override
Close the pipe.
std::string GetHomeDirectory(const char *userName=nullptr) const override
Return the user's home directory.
Int_t Select(TList *active, Long_t timeout) override
Select on file descriptors.
void Unsetenv(const char *name) override
Unset environment variable.
virtual ~TUnixSystem()
Reset to original state.
void Abort(int code=0) override
Abort the application.
void Syslog(ELogLevel level, const char *mess) override
Send mess to syslog daemon.
int AnnounceTcpService(int port, Bool_t reuse, int backlog, int tcpwindowsize=-1, ESocketBindOption socketBindOption=ESocketBindOption::kInaddrAny) override
Announce TCP/IP service.
UserGroup_t * GetGroupInfo(Int_t gid) override
Returns all group info in the UserGroup_t structure.
Int_t GetUid(const char *user=nullptr) override
Returns the user's id. If user = 0, returns current user's id.
Bool_t ExpandPathName(TString &patbuf) override
Expand a pathname getting rid of special shell characters like ~.
void Openlog(const char *name, Int_t options, ELogFacility facility) override
Open connection to system log daemon.
int AcceptConnection(int sock) override
Accept a connection.
TTime Now() override
Get current time in milliseconds since 0:00 Jan 1 1995.
static void UnixResetSignal(ESignals sig)
Restore old signal handler for specified signal.
int GetServiceByName(const char *service) override
Get port # of internet service.
const char * FindFile(const char *search, TString &file, EAccessMode mode=kFileExists) override
Find location of file "wfil" in a search path.
void SigAlarmInterruptsSyscalls(Bool_t set) override
When the argument is true the SIGALRM signal handler is set so that interrupted syscalls will not be ...
int Utime(const char *file, Long_t modtime, Long_t actime) override
Set a files modification and access times.
const char * GetLinkedLibraries() override
Get list of shared libraries loaded at the start of the executable.
const char * GetError() override
Return system error string.
std::string GetWorkingDirectory() const override
Return working directory.
Bool_t AccessPathName(const char *path, EAccessMode mode=kFileExists) override
Returns FALSE if one can access a file using the specified access mode.
FILE * TempFileName(TString &base, const char *dir=nullptr, const char *suffix=nullptr) override
Create a secure temporary file by appending a unique 6 letter string to base.
void DispatchOneEvent(Bool_t pendingOnly=kFALSE) override
Dispatch a single event.
int Chmod(const char *file, UInt_t mode) override
Set the file permission bits. Returns -1 in case or error, 0 otherwise.
const char * PrependPathName(const char *dir, TString &name) override
Concatenate a directory and a file name.
Bool_t DispatchTimers(Bool_t mode)
Handle and dispatch timers.
void IgnoreSignal(ESignals sig, Bool_t ignore=kTRUE) override
If ignore is true ignore the specified signal, else restore previous behaviour.
void ListSymbols(const char *module, const char *re="") override
List symbols in a shared library.
int Load(const char *module, const char *entry="", Bool_t system=kFALSE) override
Load a shared library.
void StackTrace() override
Print a stack trace.
TInetAddress GetHostByName(const char *server) override
Get Internet Protocol (IP) address of host.
int SendBuf(int sock, const void *buffer, int length) override
Send a buffer headed by a length indicator.
const char * HostName() override
Return the system's host name.
void CheckChilds()
Check if children have finished.
int RecvBuf(int sock, void *buffer, int length) override
Receive a buffer headed by a length indicator.
static int UnixUnixService(int port, int backlog)
Open a socket, bind to it and start listening for Unix domain connections to it.
UserGroup_t * GetUserInfo(Int_t uid) override
Returns all user info in the UserGroup_t structure.
void SetDisplay() override
Set DISPLAY environment variable based on utmp entry. Only for UNIX.
TFileHandler * RemoveFileHandler(TFileHandler *fh) override
Remove a file handler from the list of file handlers.
static const char * UnixSigname(ESignals sig)
Return the signal name associated with a signal.
static Long64_t UnixNow()
Get current time in milliseconds since 0:00 Jan 1 1995.
static int UnixFSstat(const char *path, Long_t *id, Long_t *bsize, Long_t *blocks, Long_t *bfree)
Get info about a file system: id, bsize, bfree, blocks.
void ResetSignals() override
Reset signals handlers to previous behaviour.
TInetAddress GetSockName(int sock) override
Get Internet Protocol (IP) address of host and port #.
int Link(const char *from, const char *to) override
Create a link from file1 to file2.
int GetProcInfo(ProcInfo_t *info) const override
Returns cpu and memory used by this process into the ProcInfo_t structure.
int SetSockOpt(int sock, int option, int val) override
Set socket option.
static int UnixSetitimer(Long_t ms)
Set interval timer to time-out in ms milliseconds.
static int UnixSend(int sock, const void *buf, int len, int flag)
Send exactly length bytes from buffer.
TInetAddress GetPeerName(int sock) override
Get Internet Protocol (IP) address of remote host and port #.
static void UnixIgnoreSignal(ESignals sig, Bool_t ignore)
If ignore is true ignore the specified signal, else restore previous behaviour.
void DispatchSignals(ESignals sig)
Handle and dispatch signals.
void AddFileHandler(TFileHandler *fh) override
Add a file handler to the list of system file handlers.
int AnnounceUdpService(int port, int backlog, ESocketBindOption socketBindOption=ESocketBindOption::kInaddrAny) override
Announce UDP service.
void * OpenDirectory(const char *name) override
Open a Unix file system directory. Returns 0 if directory does not exist.
int Rename(const char *from, const char *to) override
Rename a file. Returns 0 when successful, -1 in case of failure.
const char * Getenv(const char *name) override
Get environment variable.
int GetPathInfo(const char *path, FileStat_t &buf) override
Get info about a file.
Int_t GetEffectiveGid() override
Returns the effective group id.
static int UnixSelect(Int_t nfds, TFdSet *readready, TFdSet *writeready, Long_t timeout)
Wait for events on the file descriptors specified in the readready and writeready masks or for timeou...
int GetPid() override
Get process id.
Int_t Exec(const char *shellcmd) override
Execute a command.
void ResetTimer(TTimer *ti) override
Reset a-sync timer.
TSignalHandler * RemoveSignalHandler(TSignalHandler *sh) override
Remove a signal handler from list of signal handlers.
static void UnixSignal(ESignals sig, SigHandler_t h)
Set a signal handler for a signal.
void CloseConnection(int sock, Bool_t force=kFALSE) override
Close socket.
Bool_t CheckDescriptors()
Check if there is activity on some file descriptors and call their Notify() member.
Bool_t Init() override
Initialize Unix system interface.
void Unload(const char *module) override
Unload a shared library.
int Umask(Int_t mask) override
Set the process file creation mode mask.
static int UnixFilestat(const char *path, FileStat_t &buf)
Get info about a file.
static int UnixRecv(int sock, void *buf, int len, int flag)
Receive exactly length bytes into buffer.
Int_t GetEffectiveUid() override
Returns the effective user id.
void FillWithCwd(char *cwd) const
Fill buffer with current working directory.
static int UnixWaitchild()
Wait till child is finished.
int Unlink(const char *name) override
Unlink, i.e.
void ListLibraries(const char *regexp="") override
List all loaded shared libraries.
void Closelog() override
Close connection to system log daemon.
Int_t RedirectOutput(const char *name, const char *mode="a", RedirectHandle_t *h=nullptr) override
Redirect standard output (stdout, stderr) to the specified file.
void Sleep(UInt_t milliSec) override
Sleep milliSec milliseconds.
void ResetSignal(ESignals sig, Bool_t reset=kTRUE) override
If reset is true reset the signal handler for the specified signal to the default handler,...
const char * TempDirectory() const override
Return a user configured or systemwide directory to create temporary files in.
Func_t DynFindSymbol(const char *module, const char *entry) override
dynamic linking of module
const char * GetDynamicPath() override
Return the dynamic path (used to find shared libraries).
FILE * OpenPipe(const char *shellcmd, const char *mode) override
Open a pipe.
void FreeDirectory(void *dirp) override
Close a Unix file system directory.
static void UnixResetSignals()
Restore old signal handlers.
int GetCpuInfo(CpuInfo_t *info, Int_t sampleTime=1000) const override
Returns cpu load average and load info into the CpuInfo_t structure.
void AddSignalHandler(TSignalHandler *sh) override
Add a signal handler to list of system signal handlers.
static void * UnixOpendir(const char *name)
Open a directory.
int SendRaw(int sock, const void *buffer, int length, int flag) override
Send exactly length bytes from buffer.
const char * WorkingDirectory() override
Return working directory.
int GetSockOpt(int sock, int option, int *val) override
Get socket option.
const char * FindDynamicLibrary(TString &lib, Bool_t quiet=kFALSE) override
Returns the path of a shared library (searches for library in the shared library search path).
void SetProgname(const char *name) override
Set the application name (from command line, argv[0]) and copy it in gProgName.
const char * GetDirEntry(void *dirp) override
Get next Unix file system directory entry. Returns 0 if no more entries.
int MakeDirectory(const char *name) override
Make a Unix file system directory.
static int UnixUdpService(int port, int backlog, ESocketBindOption socketBindOption)
Open a socket, bind to it and start listening for UDP connections on the port.
int GetFsInfo(const char *path, Long_t *id, Long_t *bsize, Long_t *blocks, Long_t *bfree) override
Get info about a file system: id, bsize, bfree, blocks.
TLine * line
const Int_t n
Definition legend1.C:16
TGraphErrors * gr
Definition legend1.C:25
const std::string & GetFallbackRootSys()
const char * cnt
Definition TXMLSetup.cxx:74
const char * GetExePath()
Returns the executable path name, used e.g. by SetRootSys().
Int_t fMode
Definition TSystem.h:135
Long64_t fSize
Definition TSystem.h:138
Long_t fDev
Definition TSystem.h:133
Int_t fGid
Definition TSystem.h:137
Long_t fMtime
Definition TSystem.h:139
Long_t fIno
Definition TSystem.h:134
Bool_t fIsLink
Definition TSystem.h:140
Int_t fUid
Definition TSystem.h:136
struct sigaction * fOldHandler
const char * fSigName
SigHandler_t fHandler
struct utmp * fUtmpContents
struct utmp * SearchUtmpEntry(const char *tty)
TMarker m
Definition textangle.C:8