//*CMZ : 2.22/01 21/04/99 11.24.57 by Fons Rademakers
//*CMZ : 2.21/05 08/02/99 12.53.47 by Fons Rademakers
//*CMZ : 2.21/04 02/02/99 19.23.12 by Fons Rademakers
//*CMZ : 2.21/03 22/01/99 18.25.23 by Fons Rademakers
//*CMZ : 2.21/01 14/01/99 13.35.08 by Fons Rademakers
//*CMZ : 2.20/01 02/12/98 18.00.58 by Fons Rademakers
//*CMZ : 2.20/00 25/11/98 18.28.15 by Fons Rademakers
//*CMZ : 2.00/13 29/10/98 10.34.15 by Rene Brun
//*CMZ : 2.00/12 08/10/98 15.54.29 by Fons Rademakers
//*CMZ : 2.00/11 26/08/98 13.38.10 by Fons Rademakers
//*CMZ : 2.00/10 29/07/98 11.31.49 by Rene Brun
//*CMZ : 2.00/09 08/06/98 19.08.10 by Fons Rademakers
//*CMZ : 2.00/07 18/05/98 21.24.13 by Fons Rademakers
//*CMZ : 2.00/06 23/04/98 18.40.57 by Fons Rademakers
//*CMZ : 2.00/04 06/04/98 21.05.10 by Fons Rademakers
//*CMZ : 2.00/01 12/03/98 20.16.34 by Fons Rademakers
//*CMZ : 2.00/00 08/03/98 00.17.14 by Fons Rademakers
//*CMZ : 1.03/09 16/12/97 17.59.20 by Fons Rademakers
//*-- Author : Fons Rademakers 15/09/95
//*KEEP,CopyRight,T=C.
/*************************************************************************
* Copyright(c) 1995-1999, The ROOT System, All rights reserved. *
* Authors: Rene Brun, Fons Rademakers. *
* For list of contributors see $ROOTSYS/AA_CREDITS. *
* *
* Permission to use, copy, modify and distribute this software and its *
* documentation for non-commercial purposes is hereby granted without *
* fee, provided that the above copyright notice appears in all copies *
* and that both the copyright notice and this permission notice appear *
* in the supporting documentation. The authors make no claims about the *
* suitability of this software for any purpose. It is provided "as is" *
* without express or implied warranty. *
*************************************************************************/
//*KEND.
//////////////////////////////////////////////////////////////////////////
// //
// TUnixSystem //
// //
// Class providing an interface to the UNIX Operating System. //
// //
//////////////////////////////////////////////////////////////////////////
//*KEEP,TUnixSystem.
#include "TUnixSystem.h"
//*KEEP,TROOT.
#include "TROOT.h"
//*KEEP,TError.
#include "TError.h"
//*KEEP,TMath.
#include "TMath.h"
//*KEEP,TOrdCollection.
#include "TOrdCollection.h"
//*KEEP,TRegexp.
#include "TRegexp.h"
//*KEEP,TException.
#include "TException.h"
//*KEEP,Demangle.
#include "Demangle.h"
//*KEEP,TEnv.
#include "TEnv.h"
//*KEEP,TSocket,T=C++.
#include "TSocket.h"
//*KEEP,Getline.
#include "Getline.h"
//*KEEP,TInterpreter, T=C++.
#include "TInterpreter.h"
//*KEEP,TApplication.
#include "TApplication.h"
//*KEND.
//#define G__OLDEXPAND
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#if defined(R__SUN) || defined(R__SGI) || defined(R__HPUX) || defined(R__AIX) || \
defined(R__LINUX) || defined(R__SOLARIS) || defined(R__ALPHA) || \
defined(R__HIUX) || defined(R__FBSD)
# include <dirent.h>
#else
# include <sys/dir.h>
#endif
#if defined(ULTRIX) || defined(R__SUN)
# include <sgtty.h>
#endif
#if defined(R__AIX) || defined(R__LINUX) || defined(R__ALPHA) || defined(R__SGI) || \
defined(R__HIUX) || defined(R__FBSD)
# include <sys/ioctl.h>
#endif
#if defined(R__AIX) || defined(R__SOLARIS)
# include <sys/select.h>
#endif
#if defined(R__LINUX)
# define SIGSYS SIGUNUSED // SIGSYS does not exist in linux ??
# include <dlfcn.h>
#endif
#include <syslog.h>
#include <sys/stat.h>
#include <setjmp.h>
#include <signal.h>
#include <sys/param.h>
#include <pwd.h>
#include <errno.h>
#include <sys/wait.h>
#include <time.h>
#include <sys/time.h>
#include <sys/file.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#if defined(R__AIX)
# define _XOPEN_EXTENDED_SOURCE
# include <arpa/inet.h>
# undef _XOPEN_EXTENDED_SOURCE
# if !defined(_AIX41) && !defined(_AIX43)
// AIX 3.2 doesn't have it
extern "C" int inet_aton(const char *, struct in_addr *) { return 0; }
# endif
#else
# include <arpa/inet.h>
#endif
#include <sys/un.h>
#include <netdb.h>
#include <fcntl.h>
#if defined(R__SGI)
#include <net/soioctl.h>
#endif
#if defined(R__SOLARIS)
# include <sys/systeminfo.h>
# include <sys/filio.h>
# include <sys/sockio.h>
extern "C" int inet_aton(const char *, struct in_addr *) { return 0; }
#endif
#if defined(R__HPUX)
# include <symlink.h>
# include <dl.h>
# if defined(R__GNU)
extern "C" {
extern shl_t cxxshl_load(const char *path, int flags, long address);
extern int cxxshl_unload(shl_t handle);
}
# elif !defined(__STDCPP__)
# include <cxxdl.h>
# endif
// print stack trace (HP undocumented internal call)
extern "C" void U_STACK_TRACE();
# if defined(hpux9)
extern "C" {
int inet_aton(const char *, struct in_addr *) { return 0; }
extern void openlog(const char *, int, int);
extern void syslog(int, const char *, ...);
extern void closelog(void);
extern int setlogmask(int);
}
# endif
#endif
#if defined(R__ALPHA) && !defined(R__GNU)
extern "C" int inet_aton(const char *, struct in_addr *) { return 0; }
#endif
#if defined(R__HIUX)
extern "C" {
int inet_aton(const char *, struct in_addr *) { return 0; }
}
#endif
#if defined(R__SGI) || defined(R__SOLARIS)
#define HAVE_UTMPX_H
#define UTMP_NO_ADDR
#endif
#if defined(R__ALPHA) || defined(R__AIX) || defined(R__FBSD)
#define UTMP_NO_ADDR
#endif
#ifdef HAVE_UTMPX_H
#include <utmpx.h>
#define STRUCT_UTMP struct utmpx
#else
#if defined(R__MKLINUX) && !defined(R__PPCEGCS)
extern "C" {
#endif
#include <utmp.h>
#define STRUCT_UTMP struct utmp
#endif
#if !defined(UTMP_FILE) && defined(_PATH_UTMP) // 4.4BSD
#define UTMP_FILE _PATH_UTMP
#endif
#if defined(UTMPX_FILE) // Solaris, SysVr4
#undef UTMP_FILE
#define UTMP_FILE UTMPX_FILE
#endif
#ifndef UTMP_FILE
#define UTMP_FILE "/etc/utmp"
#endif
static STRUCT_UTMP *gUtmpContents;
//*KEEP,G__ci.
#include "G__ci.h"
//*KEND.
const char *kServerPath = "/tmp";
const char *kProtocolName = "tcp";
//______________________________________________________________________________
static void SigHandler(ESignals sig)
{
// Unix signal handler.
if (gSystem)
((TUnixSystem*)gSystem)->DispatchSignals(sig);
}
ClassImp(TUnixSystem)
//______________________________________________________________________________
TUnixSystem::TUnixSystem() : TSystem("Unix", "Unix System")
{ }
//______________________________________________________________________________
TUnixSystem::~TUnixSystem()
{ }
//______________________________________________________________________________
Bool_t TUnixSystem::Init()
{
// Initialize Unix system interface.
if (TSystem::Init())
return kTRUE;
//--- install default handlers
UnixSignal(kSigChild, SigHandler);
UnixSignal(kSigBus, SigHandler);
UnixSignal(kSigSegmentationViolation, SigHandler);
UnixSignal(kSigIllegalInstruction, SigHandler);
UnixSignal(kSigSystem, SigHandler);
UnixSignal(kSigPipe, SigHandler);
UnixSignal(kSigAlarm, SigHandler);
UnixSignal(kSigUrgent, SigHandler);
UnixSignal(kSigFloatingException, SigHandler);
UnixSignal(kSigWindowChanged, SigHandler);
gRootDir = Getenv("ROOTSYS");
if (gRootDir == 0)
gRootDir= "/usr/local/root";
return kFALSE;
}
//---- Misc --------------------------------------------------------------------
//______________________________________________________________________________
void TUnixSystem::SetProgname(const char *name)
{
// Set the application name (from command line, argv[0]) and copy it in
// gProgName. Copy the application pathname in gProgPath.
if (name && strlen(name) > 0) {
gProgName = StrDup(BaseName(name));
char *w = Which(Getenv("PATH"), gProgName);
gProgPath = StrDup(DirName(w));
delete [] w;
}
}
//______________________________________________________________________________
void TUnixSystem::SetDisplay()
{
// Set DISPLAY environment variable based on utmp entry. Only for UNIX.
if (!Getenv("DISPLAY")) {
char *tty = ::ttyname(0); // device user is logged in on
if (tty) {
tty += 5; // remove "/dev/"
STRUCT_UTMP *utmp_entry;
utmp_entry = (STRUCT_UTMP *)SearchUtmpEntry(ReadUtmpFile(), tty);
if (utmp_entry) {
if (utmp_entry->ut_host[0])
if (strchr(utmp_entry->ut_host, ':')) {
Setenv("DISPLAY", utmp_entry->ut_host);
Warning("SetDisplay", "DISPLAY not set, setting it to %s",
utmp_entry->ut_host);
} else {
char disp[64];
sprintf(disp, "%s:0.0", utmp_entry->ut_host);
Setenv("DISPLAY", disp);
Warning("SetDisplay", "DISPLAY not set, setting it to %s",
disp);
}
#ifndef UTMP_NO_ADDR
else if (utmp_entry->ut_addr) {
struct hostent *he;
if ((he = gethostbyaddr((const char*)&utmp_entry->ut_addr,
sizeof(utmp_entry->ut_addr), AF_INET))) {
char disp[64];
sprintf(disp, "%s:0.0", he->h_name);
Setenv("DISPLAY", disp);
Warning("SetDisplay", "DISPLAY not set, setting it to %s",
disp);
}
}
#endif
}
free(gUtmpContents);
}
}
}
//______________________________________________________________________________
const char *TUnixSystem::GetError()
{
// Return system error string.
#if defined(R__SOLARIS) || defined (R__LINUX) || defined(R__AIX) || defined(R__FBSD)
return strerror(errno);
#else
if (errno < 0 || errno >= sys_nerr)
return Form("errno out of range %d", errno);
return sys_errlist[errno];
#endif
}
//______________________________________________________________________________
const char *TUnixSystem::HostName()
{
// Return the system's host name.
if (fHostname == "") {
char hn[64];
#if defined(R__SOLARIS)
sysinfo(SI_HOSTNAME, hn, sizeof(hn));
#else
gethostname(hn, sizeof(hn));
#endif
fHostname = hn;
}
return (const char *)fHostname;
}
//---- EventLoop ---------------------------------------------------------------
//______________________________________________________________________________
void TUnixSystem::AddFileHandler(TFileHandler *h)
{
// Add a file handler to the list of system file handlers.
TSystem::AddFileHandler(h);
if (h) {
int fd = h->GetFd();
if (h->HasReadInterest()) {
fReadmask.Set(fd);
fMaxrfd = TMath::Max(fMaxrfd, fd);
}
if (h->HasWriteInterest()) {
fWritemask.Set(fd);
fMaxwfd = TMath::Max(fMaxwfd, fd);
}
}
}
//______________________________________________________________________________
TFileHandler *TUnixSystem::RemoveFileHandler(TFileHandler *h)
{
// Remove a file handler from the list of file handlers.
TFileHandler *oh = TSystem::RemoveFileHandler(h);
if (oh) { // found
fReadmask.Clr(oh->GetFd());
fWritemask.Clr(oh->GetFd());
// need to reset fMaxrfd and fMaxwfd
}
return oh;
}
//______________________________________________________________________________
void TUnixSystem::AddSignalHandler(TSignalHandler *h)
{
// Add a signal handler to list of system signal handlers.
TSystem::AddSignalHandler(h);
UnixSignal(h->GetSignal(), SigHandler);
}
//______________________________________________________________________________
TSignalHandler *TUnixSystem::RemoveSignalHandler(TSignalHandler *h)
{
// Remove a signal handler from list of signal handlers.
// if last handler of specific signal need to reset sighandler to default
return TSystem::RemoveSignalHandler(h);
}
//______________________________________________________________________________
void TUnixSystem::IgnoreInterrupt(Bool_t ignore)
{
// Ignore the interrupt signal if ignore == kTRUE else restore previous
// behaviour. Typically call ignore interrupt before writing to disk.
static Bool_t ignoreInt = kFALSE;
static struct sigaction oldsigact;
if (ignore != ignoreInt) {
ignoreInt = ignore;
if (ignore) {
struct sigaction sigact;
#if defined(R__SOLARIS) && !defined(R__I386) && !defined(__SunOS_5_6)
sigact.sa_handler = (void (*)())SIG_IGN;
#else
# if defined(__SunOS_5_6)
sigact.sa_handler = (void (*)(int))SIG_IGN;
# else
sigact.sa_handler = SIG_IGN;
# endif
#endif
sigemptyset(&sigact.sa_mask);
#if defined(SA_INTERRUPT) // SunOS
sigact.sa_flags = SA_INTERRUPT;
#else
sigact.sa_flags = 0;
#endif
if (sigaction(SIGINT, &sigact, &oldsigact) < 0)
::SysError("TUnixSystem::IgnoreInterrupt", "sigaction");
} else {
if (sigaction(SIGINT, &oldsigact, 0) < 0)
::SysError("TUnixSystem::IgnoreInterrupt", "sigaction");
}
}
}
//______________________________________________________________________________
void TUnixSystem::DispatchOneEvent(Bool_t pendingOnly)
{
// Dispatch a single event.
while (1) {
// first handle any X11 events
if (gXDisplay && gXDisplay->Notify())
return;
// check for file descriptors ready for reading/writing
if (fNfd > 0 && fFileHandler->GetSize() > 0) {
TFileHandler *fh;
TOrdCollectionIter it((TOrdCollection*)fFileHandler);
while ((fh = (TFileHandler*) it.Next())) {
int fd = fh->GetFd();
if (fd <= fMaxrfd && fReadready.IsSet(fd)) {
fReadready.Clr(fd);
if (fh->ReadNotify())
return;
}
if (fd <= fMaxwfd && fWriteready.IsSet(fd)) {
fWriteready.Clr(fd);
if (fh->WriteNotify())
return;
}
}
}
fNfd = 0;
fReadready.Zero();
fWriteready.Zero();
// check synchronous signals
if (fSigcnt > 0 && fSignalHandler->GetSize() > 0)
if (CheckSignals(kTRUE))
return;
fSigcnt = 0;
fSignals.Zero();
// check synchronous timers
if (fTimers && fTimers->GetSize() > 0)
if (DispatchTimers(kTRUE)) {
// prevent timers from blocking file descriptor monitoring
Long_t to = NextTimeOut(kTRUE);
if (to > kItimerResolution || to == -1)
return;
}
if (pendingOnly) return;
// nothing ready, so setup select call
fReadready = fReadmask;
fWriteready = fWritemask;
int mxfd = TMath::Max(fMaxrfd, fMaxwfd) + 1;
fNfd = UnixSelect(mxfd, &fReadready, &fWriteready, NextTimeOut(kTRUE));
if (fNfd < 0 && fNfd != -2) {
int fd, rc;
TFdSet t;
for (fd = 0; fd < mxfd; fd++) {
t.Set(fd);
if (fReadmask.IsSet(fd)) {
rc = UnixSelect(fd+1, &t, 0, 0);
if (rc < 0 && rc != -2) {
SysError("DispatchOneEvent", "select: read error on %dn", fd);
fReadmask.Clr(fd);
}
}
if (fWritemask.IsSet(fd)) {
rc = UnixSelect(fd+1, &t, 0, 0);
if (rc < 0 && rc != -2) {
SysError("DispatchOneEvent", "select: write error on %dn", fd);
fWritemask.Clr(fd);
}
}
t.Clr(fd);
}
}
}
}
//______________________________________________________________________________
void TUnixSystem::Sleep(UInt_t milliSec)
{
// Sleep milliSec milliseconds.
struct timeval tv;
tv.tv_sec = milliSec / 1000;
tv.tv_usec = (milliSec % 1000) * 1000;
select(0, 0, 0, 0, &tv);
}
//---- handling of system events -----------------------------------------------
//______________________________________________________________________________
void TUnixSystem::DispatchSignals(ESignals sig)
{
// Handle and dispatch signals.
switch (sig) {
case kSigAlarm:
DispatchTimers(kFALSE);
break;
case kSigChild:
CheckChilds();
return;
case kSigBus:
case kSigSegmentationViolation:
case kSigIllegalInstruction:
case kSigFloatingException:
Printf("n *** Break *** %s", UnixSigname(sig));
StackTrace();
if (TROOT::Initialized()) {
if (gException) {
if (gApplication && gApplication->InheritsFrom("TRint")) {
Getlinem(kCleanUp, 0);
Getlinem(kInit, "Root > ");
}
gInterpreter->RewindDictionary();
}
Throw(sig);
}
Abort(-1);
break;
case kSigSystem:
case kSigPipe:
Printf("n *** Break *** %s", UnixSigname(sig));
break;
case kSigWindowChanged:
Gl_windowchanged();
break;
default:
fSignals.Set(sig);
fSigcnt++;
break;
}
// check a-synchronous signals
if (fSigcnt && fSignalHandler->GetSize() > 0)
CheckSignals(kFALSE);
}
//______________________________________________________________________________
Bool_t TUnixSystem::CheckSignals(Bool_t sync)
{
// Check if some signals were raised and call their Notify() member.
TSignalHandler *sh;
{
TOrdCollectionIter it((TOrdCollection*)fSignalHandler);
while ((sh = (TSignalHandler*)it.Next())) {
if (sync == sh->IsSync()) {
ESignals sig = sh->GetSignal();
if (fSignals.IsSet(sig)) {
fSignals.Clr(sig);
fSigcnt--;
break;
}
}
}
}
if (sh) {
sh->Notify();
return kTRUE;
}
return kFALSE;
}
//______________________________________________________________________________
void TUnixSystem::CheckChilds()
{
// Check if childs have finished.
#if 0 //rdm
int pid;
while ((pid = UnixWaitchild()) > 0) {
TIter next(zombieHandler);
register UnixPtty *pty;
while (pty = (UnixPtty*) next())
if (pty->GetPid() == pid) {
zombieHandler->RemovePtr(pty);
pty->DiedNotify();
}
}
#endif
}
//---- Directories -------------------------------------------------------------
//______________________________________________________________________________
int TUnixSystem::MakeDirectory(const char *name)
{
// Make a Unix file system directory. Returns 0 in case of success and
// -1 if the directory could not be created.
return UnixMakedir(name);
}
//______________________________________________________________________________
void *TUnixSystem::OpenDirectory(const char *name)
{
// Open a Unix file system directory. Returns 0 if directory does not exist.
return UnixOpendir(name);
}
//______________________________________________________________________________
void TUnixSystem::FreeDirectory(void *dirp)
{
// Close a Unix file system directory.
if (dirp)
::closedir((DIR*)dirp);
}
//______________________________________________________________________________
const char *TUnixSystem::GetDirEntry(void *dirp)
{
// Get next Unix file system directory entry. Returns 0 if no more entries.
if (dirp)
return UnixGetdirentry(dirp);
return 0;
}
//______________________________________________________________________________
Bool_t TUnixSystem::ChangeDirectory(const char *path)
{
// Change directory. Returns kTRUE in case of success, kFALSE otherwise.
Bool_t ret = (Bool_t) (::chdir(path) == 0);
if (fWdpath != "")
fWdpath = ""; // invalidate path cache
return ret;
}
//______________________________________________________________________________
const char *TUnixSystem::WorkingDirectory()
{
// Return working directory.
if (fWdpath != "")
return fWdpath.Data();
static char cwd[kMAXPATHLEN];
if (::getcwd(cwd, kMAXPATHLEN) == 0) {
fWdpath = "/";
Error("WorkingDirectory", "getcwd() failed");
}
fWdpath = cwd;
return fWdpath.Data();
}
//______________________________________________________________________________
const char *TUnixSystem::HomeDirectory(const Char_t *userName)
{
// Return the user's home directory.
return UnixHomedirectory(userName);
}
//______________________________________________________________________________
char *TUnixSystem::ConcatFileName(const char *dir, const char *name)
{
// Concatenate a directory and a file name. Returned string must be
// deleted by user.
if (name == 0 || strlen(name) <= 0 || strcmp(name, ".") == 0)
return StrDup(dir);
char buf[kMAXPATHLEN];
if (dir && (strcmp(dir, "/") != 0)) {
if (dir[strlen(dir)-1] == '/')
sprintf(buf, "%s%s", dir, name);
else
sprintf(buf, "%s/%s", dir, name);
} else
sprintf(buf, "/%s", name);
return StrDup(buf);
}
//---- Paths & Files -----------------------------------------------------------
//______________________________________________________________________________
Bool_t TUnixSystem::AccessPathName(const char *path, EAccessMode mode)
{
// Returns FALSE if one can access a file using the specified access mode.
// Mode is the same as for the Unix access(2) function.
if (::access(path, mode) == 0)
return kFALSE;
fLastErrorString = GetError();
return kTRUE;
}
//______________________________________________________________________________
void TUnixSystem::Rename(const char *f, const char *t)
{
// Rename a file.
::rename(f, t);
fLastErrorString = GetError();
}
//______________________________________________________________________________
int TUnixSystem::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.
// Id is (statbuf.st_dev << 24) + statbuf.st_ino
// Size is the file size
// Flags is file type: bit 1 set executable, bit 2 set directory,
// bit 3 set regular file
// Modtime is modification time
return UnixFilestat(path, id, size, flags, modtime);
}
//______________________________________________________________________________
int TUnixSystem::Link(const char *from, const char *to)
{
// Create a link from file1 to file2. Returns 0 when successful,
// -1 in case of failure.
return ::link(from, to);
}
//______________________________________________________________________________
int TUnixSystem::Symlink(const char *from, const char *to)
{
// Create a symlink from file1 to file2. Returns 0 when succesfull,
// -1 in case of failure.
#if defined(R__AIX)
return ::symlink((char*)from, (char*)to);
#else
return ::symlink(from, to);
#endif
}
//______________________________________________________________________________
int TUnixSystem::Unlink(const char *name)
{
// Unlink, i.e. remove, a file or directory.
struct stat finfo;
if (stat(name, &finfo) < 0)
return -1;
if (S_ISDIR(finfo.st_mode))
return ::rmdir(name);
else
return ::unlink(name);
}
//---- expand the metacharacters as in the shell -------------------------------
// expand the metacharacters as in the shell
static const char
#ifdef G__OLDEXPAND
shellEscape = '\\',
*shellStuff = "(){}<>\"'",
#endif
*shellMeta = "~*[]{}?$";
#ifndef G__OLDEXPAND
//______________________________________________________________________________
Bool_t TUnixSystem::ExpandPathName(TString &path)
{
// Expand a pathname getting rid of special shell characters like ~.$, etc.
// For Unix/Win32 compatibility use $(XXX) instead of $XXX when using
// environment variables in a pathname. If compatibility is not an issue
// you can use on Unix directly $XXX.
const char *p, *patbuf = (const char *)path;
// skip leading blanks
while (*patbuf == ' ')
patbuf++;
// any shell meta characters ?
for (p = patbuf; *p; p++)
if (strchr(shellMeta, *p))
goto expand;
return kFALSE;
expand:
// replace $(XXX) by $XXX
path.ReplaceAll("$(","$");
path.ReplaceAll(")","");
path = ExpandFileName(path.Data());
return kFALSE;
}
#endif
#ifdef G__OLDEXPAND
//______________________________________________________________________________
Bool_t TUnixSystem::ExpandPathName(TString &patbuf0)
{
// Expand a pathname getting rid of special shell characters like ~.$, etc.
// For Unix/Win32 compatibility use $(XXX) instead of $XXX when using
// environment variables in a pathname. If compatibility is not an issue
// you can use on Unix directly $XXX.
const char *patbuf = (const char *)patbuf0;
const char *hd, *p;
char cmd[kMAXPATHLEN], stuffedPat[kMAXPATHLEN], name[70];
char *q;
FILE *pf;
int ch;
// skip leading blanks
while (*patbuf == ' ')
patbuf++;
// any shell meta characters ?
for (p = patbuf; *p; p++)
if (strchr(shellMeta, *p))
goto needshell;
return kFALSE;
needshell:
// replace $(XXX) by $XXX
patbuf0.ReplaceAll("$(","$");
patbuf0.ReplaceAll(")","");
// escape shell quote characters
EscChar(patbuf, stuffedPat, sizeof(stuffedPat), (char*)shellStuff, shellEscape);
#ifdef R__HPUX
strcpy(cmd, "/bin/echo ");
#else
strcpy(cmd, "echo ");
#endif
// emulate csh -> popen executes sh
if (stuffedPat[0] == '~') {
if (stuffedPat[1] != '0' && stuffedPat[1] != '/') {
// extract user name
for (p = &stuffedPat[1], q = name; *p && *p !='/';)
*q++ = *p++;
*q = '0';
hd = UnixHomedirectory(name);
if (hd == 0)
strcat(cmd, stuffedPat);
else {
strcat(cmd, hd);
strcat(cmd, p);
}
} else {
hd = UnixHomedirectory(0);
if (hd == 0) {
fLastErrorString = GetError();
return kTRUE;
}
strcat(cmd, hd);
strcat(cmd, &stuffedPat[1]);
}
} else
strcat(cmd, stuffedPat);
if ((pf = ::popen(&cmd[0], "r")) == NULL) {
fLastErrorString = GetError();
return kTRUE;
}
// read first argument
patbuf0 = "";
int cnt = 0;
#if defined(R__ALPHA) || defined(R__AIX)
again:
#endif
for (ch = fgetc(pf); ch != EOF && ch != ' ' && ch != '\n'; ch = fgetc(pf)) {
patbuf0.Append(ch);
cnt++;
}
#if defined(R__ALPHA) || defined(R__AIX)
// Work around bug timing problem due to delay in forking a large program
if (cnt == 0 && ch == EOF) goto again;
#endif
// skip rest of pipe
while (ch != EOF) {
ch = fgetc(pf);
if (ch == ' ' || ch == 't') {
fLastErrorString = "expression ambigous";
::pclose(pf);
return kTRUE;
}
}
::pclose(pf);
return kFALSE;
}
#endif
//______________________________________________________________________________
char *TUnixSystem::ExpandPathName(const char *path)
{
// Expand a pathname getting rid of special shell characaters like ~.$, etc.
// For Unix/Win32 compatibility use $(XXX) instead of $XXX when using
// environment variables in a pathname. If compatibility is not an issue
// you can use on Unix directly $XXX. The user must delete returned string.
TString patbuf = path;
if (ExpandPathName(patbuf))
return 0;
return StrDup(patbuf.Data());
}
//______________________________________________________________________________
int TUnixSystem::Umask(Int_t mask)
{
// Set the process file creation mode mask.
return ::umask(mask);
}
//______________________________________________________________________________
char *TUnixSystem::Which(const char *search, const char *file, EAccessMode mode)
{
// Find location of file in a search path.
// User must delete returned string.
char name[kMAXPATHLEN];
const char *ptr;
char *next, *exname;
if (strchr(file, '/')) {
if (file[0] != '/' && file[0] != '$' && file[0] != '~') {
char tmp[kMAXPATHLEN];
strcpy(tmp, file);
strcpy(name, gSystem->WorkingDirectory());
strcat(name, "/");
strcat(name, tmp);
} else
strcpy(name, file);
exname = gSystem->ExpandPathName(name);
if (exname && access(exname, mode) == 0) {
if (gEnv->GetValue("Root.ShowPath", 0))
Printf("Which: %s = %s", file, exname);
return exname;
}
delete [] exname;
if (gEnv->GetValue("Root.ShowPath", 0))
Printf("Which: %s = <not found>", file);
return 0;
}
if (search == 0)
search = ".";
for (ptr = search; *ptr;) {
for (next = name; *ptr && *ptr != ':'; )
*next++ = *ptr++;
*next = '0';
if (name[0] != '/' && name[0] != '$' && name[0] != '~') {
char tmp[kMAXPATHLEN];
strcpy(tmp, name);
strcpy(name, gSystem->WorkingDirectory());
strcat(name, "/");
strcat(name, tmp);
}
if (*(name + strlen(name) - 1) != '/')
strcat(name, "/");
strcat(name, file);
exname = gSystem->ExpandPathName(name);
if (exname && access(exname, mode) == 0) {
if (gEnv->GetValue("Root.ShowPath", 0))
Printf("Which: %s = %s", file, exname);
return exname;
}
delete [] exname;
if (*ptr)
ptr++;
}
if (gEnv->GetValue("Root.ShowPath", 0))
Printf("Which: %s = <not found>", file);
return 0;
}
//---- environment manipulation ------------------------------------------------
//______________________________________________________________________________
void TUnixSystem::Setenv(const char *name, const char *value)
{
// Set environment variable. The string passed will be owned by
// the environment and can not be reused till a "name" is set
// again. The solution below will lose the space for the string
// in that case, but if this functions is not called thousands
// of times that should not be a problem.
char *s = new char [strlen(name)+strlen(value) + 2];
sprintf(s, "%s=%s", name, value);
::putenv(s);
}
//______________________________________________________________________________
const char *TUnixSystem::Getenv(const char *name)
{
// Get environment variable.
return ::getenv(name);
}
//---- Processes ---------------------------------------------------------------
//______________________________________________________________________________
int TUnixSystem::Exec(const char *shellcmd)
{
// Execute a command.
return ::system(shellcmd);
}
//______________________________________________________________________________
FILE *TUnixSystem::OpenPipe(const char *command, const char *mode)
{
// Open a pipe.
return ::popen(command, mode);
}
//______________________________________________________________________________
int TUnixSystem::ClosePipe(FILE *pipe)
{
// Close the pipe.
return ::pclose(pipe);
}
//______________________________________________________________________________
int TUnixSystem::GetPid()
{
// Get process id.
return ::getpid();
}
//______________________________________________________________________________
void TUnixSystem::Exit(int code, Bool_t mode)
{
// Exit the application.
if (mode)
::exit(code);
else
::_exit(code);
}
//______________________________________________________________________________
void TUnixSystem::Abort(int)
{
// Abort the application.
::abort();
}
//______________________________________________________________________________
void TUnixSystem::StackTrace()
{
// Print a stack trace.
#ifdef R__HPUX
Printf("");
U_STACK_TRACE();
Printf("");
#endif
}
//---- System Logging ----------------------------------------------------------
//______________________________________________________________________________
void TUnixSystem::Openlog(const char *name, Int_t options, ELogFacility facility)
{
// Open connection to system log daemon. For the use of the options and
// facility see the Unix openlog man page.
int fac = 0;
switch (facility) {
case kLogLocal0:
fac = LOG_LOCAL0;
break;
case kLogLocal1:
fac = LOG_LOCAL1;
break;
case kLogLocal2:
fac = LOG_LOCAL2;
break;
case kLogLocal3:
fac = LOG_LOCAL3;
break;
case kLogLocal4:
fac = LOG_LOCAL4;
break;
case kLogLocal5:
fac = LOG_LOCAL5;
break;
case kLogLocal6:
fac = LOG_LOCAL6;
break;
case kLogLocal7:
fac = LOG_LOCAL7;
break;
}
::openlog(name, options, fac);
}
//______________________________________________________________________________
void TUnixSystem::Syslog(ELogLevel level, const char *mess)
{
// Send mess to syslog daemon. Level is the logging level and mess the
// message that will be written on the log.
// ELogLevel matches exactly the Unix values.
::syslog(level, mess);
}
//______________________________________________________________________________
void TUnixSystem::Closelog()
{
// Close connection to system log daemon.
::closelog();
}
//---- dynamic loading and linking ---------------------------------------------
//______________________________________________________________________________
Func_t TUnixSystem::DynFindSymbol(const char *module, const char *entry)
{
return UnixDynFindSymbol(module,entry);
}
//______________________________________________________________________________
int TUnixSystem::Load(const char *module, const char *entry)
{
// Load a shared library. Returns 0 on successful loading, 1 in
// case lib was already loaded and -1 in case lib does not exist
// or in case of error.
int i = UnixDynLoad(module);
if (!entry || !strlen(entry)) return i;
Func_t f = UnixDynFindSymbol(module, entry);
if (f) return 0;
return -1;
}
//______________________________________________________________________________
void TUnixSystem::Unload(const char *module)
{
// Unload a shared library.
UnixDynUnload(module);
}
//______________________________________________________________________________
void TUnixSystem::ListSymbols(const char *module, const char *regexp)
{
// List symbols in a shared library.
UnixDynListSymbols(module, regexp);
}
//______________________________________________________________________________
void TUnixSystem::ListLibraries(const char *regexp)
{
// List all loaded shared libraries.
UnixDynListLibs(regexp);
}
//---- Time & Date -------------------------------------------------------------
//______________________________________________________________________________
TTime TUnixSystem::Now()
{
// Return current time.
return UnixNow();
}
//______________________________________________________________________________
Bool_t TUnixSystem::DispatchTimers(Bool_t mode)
{
// Handle and dispatch timers. If mode = kTRUE dispatch synchronous
// timers else a-synchronous timers.
if (!fTimers) return kFALSE;
fInsideNotify = kTRUE;
TOrdCollectionIter it((TOrdCollection*)fTimers);
TTimer *t;
Bool_t timedout = kFALSE;
while ((t = (TTimer *) it.Next())) {
Long_t now = UnixNow()+kItimerResolution;
if (mode && t->IsSync()) {
if (t->CheckTimer(now))
timedout = kTRUE;
} else if (!mode && t->IsAsync()) {
if (t->CheckTimer(now)) {
UnixSetitimer(NextTimeOut(kFALSE));
timedout = kTRUE;
}
}
}
fInsideNotify = kFALSE;
return timedout;
}
//______________________________________________________________________________
void TUnixSystem::AddTimer(TTimer *ti)
{
// Add timer to list of system timers.
TSystem::AddTimer(ti);
ResetTimer(ti);
}
//______________________________________________________________________________
TTimer *TUnixSystem::RemoveTimer(TTimer *ti)
{
// Remove timer from list of system timers.
TTimer *t = TSystem::RemoveTimer(ti);
if (ti->IsAsync())
UnixSetitimer(NextTimeOut(kFALSE));
return t;
}
//______________________________________________________________________________
void TUnixSystem::ResetTimer(TTimer *ti)
{
// Reset a-sync timer.
if (!fInsideNotify && ti->IsAsync())
UnixSetitimer(NextTimeOut(kFALSE));
}
//---- RPC ---------------------------------------------------------------------
//______________________________________________________________________________
TInetAddress TUnixSystem::GetHostByName(const char *hostname)
{
// Get Internet Protocol (IP) address of host.
struct hostent *host_ptr;
struct in_addr ad;
const char *host;
int type;
UInt_t addr; // good for 4 byte addresses
if (inet_aton(hostname, &ad)) {
memcpy(&addr, &ad.s_addr, sizeof(ad.s_addr));
if ((host_ptr = gethostbyaddr((const char *)&ad.s_addr,
sizeof(ad.s_addr), AF_INET)))
host = host_ptr->h_name;
else
host = hostname;
type = AF_INET;
} else if ((host_ptr = gethostbyname(hostname))) {
// Check the address type for an internet host
if (host_ptr->h_addrtype != AF_INET) {
Error("GetHostByName", "%s is not an internet hostn", hostname);
return TInetAddress();
}
memcpy(&addr, host_ptr->h_addr, host_ptr->h_length);
host = host_ptr->h_name;
type = host_ptr->h_addrtype;
} else {
Error("GetHostByName", "unknown host %s", hostname);
return TInetAddress();
}
return TInetAddress(host, ntohl(addr), type);
}
//______________________________________________________________________________
TInetAddress TUnixSystem::GetSockName(int sock)
{
// Get Internet Protocol (IP) address of host and port #.
struct sockaddr_in addr;
#if defined(R__AIX) || defined(R__FBSD)
size_t len = sizeof(addr);
#elif defined(R__GLIBC)
socklen_t len = sizeof(addr);
#else
int len = sizeof(addr);
#endif
if (getsockname(sock, (struct sockaddr *)&addr, &len) == -1) {
SysError("GetSockName", "getsockname");
return TInetAddress();
}
struct hostent *host_ptr;
const char *hostname;
int family;
UInt_t iaddr;
if ((host_ptr = gethostbyaddr((const char *)&addr.sin_addr,
sizeof(addr.sin_addr), AF_INET))) {
memcpy(&iaddr, host_ptr->h_addr, host_ptr->h_length);
hostname = host_ptr->h_name;
family = host_ptr->h_addrtype;
} else {
memcpy(&iaddr, &addr.sin_addr, sizeof(addr.sin_addr));
hostname = "????";
family = AF_INET;
}
return TInetAddress(hostname, ntohl(iaddr), family, ntohs(addr.sin_port));
}
//______________________________________________________________________________
TInetAddress TUnixSystem::GetPeerName(int sock)
{
// Get Internet Protocol (IP) address of remote host and port #.
struct sockaddr_in addr;
#if defined(R__AIX) || defined(R__FBSD)
size_t len = sizeof(addr);
#elif defined(R__GLIBC)
socklen_t len = sizeof(addr);
#else
int len = sizeof(addr);
#endif
if (getpeername(sock, (struct sockaddr *)&addr, &len) == -1) {
SysError("GetPeerName", "getpeername");
return TInetAddress();
}
struct hostent *host_ptr;
const char *hostname;
int family;
UInt_t iaddr;
if ((host_ptr = gethostbyaddr((const char *)&addr.sin_addr,
sizeof(addr.sin_addr), AF_INET))) {
memcpy(&iaddr, host_ptr->h_addr, host_ptr->h_length);
hostname = host_ptr->h_name;
family = host_ptr->h_addrtype;
} else {
memcpy(&iaddr, &addr.sin_addr, sizeof(addr.sin_addr));
hostname = "????";
family = AF_INET;
}
return TInetAddress(hostname, ntohl(iaddr), family, ntohs(addr.sin_port));
}
//______________________________________________________________________________
int TUnixSystem::GetServiceByName(const char *servicename)
{
// Get port # of internet service.
struct servent *sp;
if ((sp = getservbyname(servicename, kProtocolName)) == 0) {
Error("GetServiceByName", "no service "%s" with protocol "%s"n",
servicename, kProtocolName);
return -1;
}
return ntohs(sp->s_port);
}
//______________________________________________________________________________
char *TUnixSystem::GetServiceByPort(int port)
{
// Get name of internet service.
struct servent *sp;
if ((sp = getservbyport(port, kProtocolName)) == 0) {
//::Error("GetServiceByPort", "no service "%d" with protocol "%s"",
// port, kProtocolName);
return Form("%d", port);
}
return sp->s_name;
}
//______________________________________________________________________________
int TUnixSystem::ConnectService(const char *servername, int port)
{
// Connect to service servicename on server servername.
if (!strcmp(servername, "unix"))
return UnixUnixConnect(port);
return UnixTcpConnect(servername, port);
}
//______________________________________________________________________________
int TUnixSystem::OpenConnection(const char *server, int port)
{
// Open a connection to a service on a server. Try 3 times with an
// interval of 1 second.
for (int i = 0; i < 3; i++) {
int fd = ConnectService(server, port);
if (fd >= 0)
return fd;
sleep(1);
}
return -1;
}
//______________________________________________________________________________
int TUnixSystem::AnnounceTcpService(int port, Bool_t reuse, int backlog)
{
// Announce TCP/IP service.
return UnixTcpService(port, reuse, backlog);
}
//______________________________________________________________________________
int TUnixSystem::AnnounceUnixService(int port, int backlog)
{
// Announce unix domain service.
return UnixUnixService(port, backlog);
}
//______________________________________________________________________________
int TUnixSystem::AcceptConnection(int sock)
{
// Accept a connection. In case of an error return -1. In case
// non-blocking I/O is enabled and no connections are available
// return -2.
int soc = -1;
while ((soc = ::accept(sock, 0, 0)) == -1 && errno == EINTR)
errno = 0;
if (soc == -1) {
if (errno == EWOULDBLOCK)
return -2;
else {
SysError("AcceptConnection", "accept");
return -1;
}
}
return soc;
}
//______________________________________________________________________________
void TUnixSystem::CloseConnection(int sock)
{
// Close socket.
if (sock < 0) return;
#if !defined(R__AIX) || defined(_AIX41) || defined(_AIX43)
::shutdown(sock, 2);
#endif
while (::close(sock) == -1 && errno == EINTR)
errno = 0;
}
//______________________________________________________________________________
int TUnixSystem::RecvBuf(int sock, void *buf, int length)
{
// Receive a buffer headed by a length indicator. Lenght is the size of
// the buffer. Returns the number of bytes received in buf or -1 in
// case of error.
Int_t header;
if (UnixRecv(sock, &header, sizeof(header), 0) > 0) {
int count = ntohl(header);
if (count > length) {
Error("RecvBuf", "record header exceeds buffer size");
return -1;
} else if (count > 0) {
if (UnixRecv(sock, buf, count, 0) < 0) {
Error("RecvBuf", "cannot receive buffer");
return -1;
}
}
return count;
}
return -1;
}
//______________________________________________________________________________
int TUnixSystem::SendBuf(int sock, const void *buf, int length)
{
// Send a buffer headed by a length indicator. Returns length of sent buffer
// or -1 in case of error.
Int_t header = htonl(length);
if (UnixSend(sock, &header, sizeof(header), 0) < 0) {
Error("SendBuf", "cannot send header");
return -1;
}
if (length > 0) {
if (UnixSend(sock, buf, length, 0) < 0) {
Error("SendBuf", "cannot send buffer");
return -1;
}
}
return length;
}
//______________________________________________________________________________
int TUnixSystem::RecvRaw(int sock, void *buf, int length, int opt)
{
// Receive exactly length bytes into buffer. Use opt to receive out-of-band
// data or to have a peek at what is in the buffer (see TSocket). Buffer
// must be able to store at least length bytes. Returns the number of
// bytes received (can be 0 if other side of connection was closed) or -1
// in case of error, -2 in case of MSG_OOB and errno == EWOULDBLOCK, -3
// in case of MSG_OOB and errno == EINVAL and -4 in case of kNoBlock and
// errno == EWOULDBLOCK.
int flag;
switch (opt) {
case kDefault:
flag = 0;
break;
case kOob:
flag = MSG_OOB;
break;
case kPeek:
flag = MSG_PEEK;
break;
default:
flag = 0;
break;
}
int n;
if ((n = UnixRecv(sock, buf, length, flag)) <= 0) {
if (n == -1 && errno != EINTR)
Error("RecvRaw", "cannot receive buffer");
return n;
}
return length;
}
//______________________________________________________________________________
int TUnixSystem::SendRaw(int sock, const void *buf, int length, int opt)
{
// Send exactly length bytes from buffer. Use opt to send out-of-band
// data (see TSocket). Returns the number of bytes sent or -1 in case of
// error.
int flag;
switch (opt) {
case kDefault:
flag = 0;
break;
case kOob:
flag = MSG_OOB;
break;
case kPeek: // receive only option (see RecvRaw)
default:
flag = 0;
break;
}
if (UnixSend(sock, buf, length, flag) < 0) {
Error("SendRaw", "cannot send buffer");
return -1;
}
return length;
}
//______________________________________________________________________________
int TUnixSystem::SetSockOpt(int sock, int opt, int val)
{
// Set socket option.
if (sock < 0) return -1;
switch (opt) {
case kSendBuffer:
if (setsockopt(sock, SOL_SOCKET, SO_SNDBUF, (char*)&val, sizeof(val)) == -1) {
SysError("SetSockOpt", "setsockopt(SO_SNDBUF)");
return -1;
}
break;
case kRecvBuffer:
if (setsockopt(sock, SOL_SOCKET, SO_RCVBUF, (char*)&val, sizeof(val)) == -1) {
SysError("SetSockOpt", "setsockopt(SO_RCVBUF)");
return -1;
}
break;
case kOobInline:
if (setsockopt(sock, SOL_SOCKET, SO_OOBINLINE, (char*)&val, sizeof(val)) == -1) {
SysError("SetSockOpt", "setsockopt(SO_OOBINLINE)");
return -1;
}
break;
case kKeepAlive:
if (setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, (char*)&val, sizeof(val)) == -1) {
SysError("SetSockOpt", "setsockopt(SO_KEEPALIVE)");
return -1;
}
break;
case kReuseAddr:
if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char*)&val, sizeof(val)) == -1) {
SysError("SetSockOpt", "setsockopt(SO_REUSEADDR)");
return -1;
}
break;
case kNoDelay:
if (setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, (char*)&val, sizeof(val)) == -1) {
SysError("SetSockOpt", "setsockopt(TCP_NODELAY)");
return -1;
}
break;
case kNoBlock:
if (ioctl(sock, FIONBIO, (char*)&val) == -1) {
SysError("SetSockOpt", "ioctl(FIONBIO)");
return -1;
}
break;
case kProcessGroup:
if (ioctl(sock, SIOCSPGRP, (char*)&val) == -1) {
SysError("SetSockOpt", "ioctl(SIOCSPGRP)");
return -1;
}
break;
case kAtMark: // read-only option (see GetSockOpt)
case kBytesToRead: // read-only option
default:
Error("SetSockOpt", "illegal option (%d)", opt);
return -1;
}
return 0;
}
//______________________________________________________________________________
int TUnixSystem::GetSockOpt(int sock, int opt, int *val)
{
// Get socket option.
if (sock < 0) return -1;
#if defined(R__GLIBC) || defined(_AIX43)
socklen_t optlen = sizeof(*val);
#elif defined(R__FBSD)
size_t optlen = sizeof(*val);
#else
int optlen = sizeof(*val);
#endif
switch (opt) {
case kSendBuffer:
if (getsockopt(sock, SOL_SOCKET, SO_SNDBUF, (char*)val, &optlen) == -1) {
SysError("GetSockOpt", "getsockopt(SO_SNDBUF)");
return -1;
}
break;
case kRecvBuffer:
if (getsockopt(sock, SOL_SOCKET, SO_RCVBUF, (char*)val, &optlen) == -1) {
SysError("GetSockOpt", "getsockopt(SO_RCVBUF)");
return -1;
}
break;
case kOobInline:
if (getsockopt(sock, SOL_SOCKET, SO_OOBINLINE, (char*)val, &optlen) == -1) {
SysError("GetSockOpt", "getsockopt(SO_OOBINLINE)");
return -1;
}
break;
case kKeepAlive:
if (getsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, (char*)val, &optlen) == -1) {
SysError("GetSockOpt", "getsockopt(SO_KEEPALIVE)");
return -1;
}
break;
case kReuseAddr:
if (getsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char*)val, &optlen) == -1) {
SysError("GetSockOpt", "getsockopt(SO_REUSEADDR)");
return -1;
}
break;
case kNoDelay:
if (getsockopt(sock, IPPROTO_TCP, TCP_NODELAY, (char*)val, &optlen) == -1) {
SysError("GetSockOpt", "getsockopt(TCP_NODELAY)");
return -1;
}
break;
case kNoBlock:
int flg;
if ((flg = fcntl(sock, F_GETFL, 0)) == -1) {
SysError("GetSockOpt", "fcntl(F_GETFL)");
return -1;
}
*val = flg & O_NDELAY;
break;
case kProcessGroup:
if (ioctl(sock, SIOCGPGRP, (char*)val) == -1) {
SysError("GetSockOpt", "ioctl(SIOCGPGRP)");
return -1;
}
break;
case kAtMark:
if (ioctl(sock, SIOCATMARK, (char*)val) == -1) {
SysError("GetSockOpt", "ioctl(SIOCATMARK)");
return -1;
}
break;
case kBytesToRead:
if (ioctl(sock, FIONREAD, (char*)val) == -1) {
SysError("GetSockOpt", "ioctl(FIONREAD)");
return -1;
}
break;
default:
Error("GetSockOpt", "illegal option (%d)", opt);
*val = 0;
return -1;
}
return 0;
}
//////////////////////////////////////////////////////////////////////////
// //
// Static Protected Unix Interface functions. //
// //
//////////////////////////////////////////////////////////////////////////
//---- signals -----------------------------------------------------------------
static struct signal_map {
int code;
SigHandler_t handler;
const char *signame;
} gSignalMap[kMAXSIGNALS] = { // the order of the signals should be identical
{ SIGBUS, 0, "bus error" }, // to the one in SysEvtHandler.h
{ SIGSEGV, 0, "segmentation violation" },
{ SIGSYS, 0, "bad argument to system call" },
{ SIGPIPE, 0, "write on a pipe with no one to read it" },
{ SIGILL, 0, "illegal instruction" },
{ SIGQUIT, 0, "quit" },
{ SIGINT, 0, "interrupt" },
{ SIGWINCH, 0, "window size change" },
{ SIGALRM, 0, "alarm clock" },
{ SIGCHLD, 0, "death of a child" },
{ SIGURG, 0, "urgent data arrived on an I/O channel" },
{ SIGFPE, 0, "floating point exception" },
{ SIGTERM, 0, "termination signal" },
{ SIGUSR1, 0, "user-defined signal 1" },
{ SIGUSR2, 0, "user-defined signal 2" }
};
//______________________________________________________________________________
static void sighandler(int sig)
{
// Call the signal handler associated with the signal.
for (int i= 0; i < kMAXSIGNALS; i++) {
if (gSignalMap[i].code == sig) {
(*gSignalMap[i].handler)((ESignals)i);
return;
}
}
}
//______________________________________________________________________________
void TUnixSystem::UnixSignal(ESignals sig, SigHandler_t handler)
{
// Set a signal handler for a signal.
if (gSignalMap[sig].handler != handler) {
struct sigaction sigact;
gSignalMap[sig].handler = handler;
#if defined(R__SOLARIS) && !defined(R__I386) && !defined(__SunOS_5_6)
sigact.sa_handler = (void (*)())sighandler;
#elif defined(__SunOS_5_6)
sigact.sa_handler = (void (*)(int))sighandler;
#elif defined(R__SGI) && !defined(R__KCC)
# if defined(R__SGI64)
sigact.sa_handler = (void (*)(int))sighandler;
# else
sigact.sa_handler = (void (*)(...))sighandler;
# endif
#else
sigact.sa_handler = sighandler;
#endif
sigemptyset(&sigact.sa_mask);
#if defined(SA_INTERRUPT) // SunOS
sigact.sa_flags = SA_INTERRUPT;
#else
sigact.sa_flags = 0;
#endif
if (sigaction(gSignalMap[sig].code, &sigact, 0) < 0)
::SysError("TUnixSystem::UnixSignal", "sigaction");
}
}
//______________________________________________________________________________
const char *TUnixSystem::UnixSigname(ESignals sig)
{
// Return the signal name associated with a signal.
return gSignalMap[sig].signame;
}
//---- time --------------------------------------------------------------------
//______________________________________________________________________________
Long_t TUnixSystem::UnixNow()
{
// Get current time in milliseconds since 0:00 Jan 1 1995.
static time_t jan95 = 0;
if (!jan95) {
struct tm tp;
tp.tm_year = 95;
tp.tm_mon = 0;
tp.tm_mday = 1;
tp.tm_hour = 0;
tp.tm_min = 0;
tp.tm_sec = 0;
tp.tm_isdst = -1;
jan95 = mktime(&tp);
if ((int)jan95 == -1) {
::SysError("TUnixSystem::UnixNow", "error converting 950001 0:00 to time_t");
return 0;
}
}
struct timeval t;
gettimeofday(&t, 0);
return (t.tv_sec-(Long_t)jan95)*1000 + t.tv_usec/1000;
}
//______________________________________________________________________________
int TUnixSystem::UnixSetitimer(Long_t ms)
{
// Set interval timer to time-out in ms milliseconds.
struct itimerval itv;
itv.it_value.tv_sec = 0;
itv.it_value.tv_usec = 0;
itv.it_interval.tv_sec = 0;
itv.it_interval.tv_usec = 0;
if (ms > 0) {
itv.it_value.tv_sec = time_t(ms / 1000);
itv.it_value.tv_usec = time_t((ms % 1000) * 1000);
}
int st = setitimer(ITIMER_REAL, &itv, 0);
if (st == -1)
::SysError("TUnixSystem::UnixSetitimer", "setitimer");
return st;
}
//---- file descriptors --------------------------------------------------------
//______________________________________________________________________________
int TUnixSystem::UnixSelect(UInt_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 timeout (in milliseconds) to occur.
int retcode;
if (timeout >= 0) {
struct timeval tv;
tv.tv_sec = Int_t(timeout / 1000);
tv.tv_usec = (timeout % 1000) * 1000;
#if (defined(R__HPUX) && !defined(_XPG4_EXTENDED) && !defined(R__GNU)) || \
(defined(R__HIUX) && !defined(R__GNU)) || (defined(R__AIX) && !defined(_AIX43))
retcode = select(nfds, readready->GetBits(), writeready->GetBits(), 0, &tv);
#else
retcode = select(nfds, (fd_set*)readready->GetBits(), (fd_set*)writeready->GetBits(), 0, &tv);
#endif
} else {
#if (defined(R__HPUX) && !defined(_XPG4_EXTENDED) && !defined(R__GNU)) || \
(defined(R__HIUX) && !defined(R__GNU)) || (defined(R__AIX) && !defined(_AIX43))
retcode = select(nfds, readready->GetBits(), writeready->GetBits(), 0, 0);
#else
retcode = select(nfds, (fd_set*)readready->GetBits(), (fd_set*)writeready->GetBits(), 0, 0);
#endif
}
if (retcode == -1) {
if (errno == EINTR) {
errno = 0; // errno is not self reseting
return -2;
}
if (errno == EBADF)
return -3;
return -1;
}
return retcode;
}
//---- directories -------------------------------------------------------------
//______________________________________________________________________________
const char *TUnixSystem::UnixHomedirectory(const char *name)
{
// Returns the user's home directory.
static char path[kMAXPATHLEN], mydir[kMAXPATHLEN];
struct passwd *pw;
if (name) {
pw = getpwnam(name);
if (pw) {
strncpy(path, pw->pw_dir, kMAXPATHLEN);
return path;
}
} else {
if (mydir[0])
return mydir;
pw = getpwuid(getuid());
if (pw) {
strncpy(mydir, pw->pw_dir, kMAXPATHLEN);
return mydir;
}
}
return 0;
}
//______________________________________________________________________________
int TUnixSystem::UnixMakedir(const char *dir)
{
// Make a Unix file system directory. Returns 0 in case of success and
// -1 if the directory could not be created.
return ::mkdir(dir, 0755);
}
//______________________________________________________________________________
void *TUnixSystem::UnixOpendir(const char *dir)
{
// Open a directory.
struct stat finfo;
if (stat(dir, &finfo) < 0)
return 0;
if (!S_ISDIR(finfo.st_mode))
return 0;
return (void*) opendir(dir);
}
#if defined(_POSIX_SOURCE)
// Posix does not require that the d_ino field be present, and some
// systems do not provide it.
# define REAL_DIR_ENTRY(dp) 1
#else
# define REAL_DIR_ENTRY(dp) (dp->d_ino != 0)
#endif
//______________________________________________________________________________
const char *TUnixSystem::UnixGetdirentry(void *dirp1)
{
// Returns the next directory entry.
DIR *dirp = (DIR*)dirp1;
#if defined(R__SUN) || defined(R__SGI) || defined(R__AIX) || defined(R__HPUX) || \
defined(R__LINUX) || defined(R__SOLARIS) || defined(R__ALPHA) || \
defined(R__HIUX) || defined(R__FBSD)
struct dirent *dp;
#else
struct direct *dp;
#endif
if (dirp) {
for (;;) {
dp = readdir(dirp);
if (dp == 0)
return 0;
if (REAL_DIR_ENTRY(dp))
return dp->d_name;
}
}
return 0;
}
//---- files -------------------------------------------------------------------
//______________________________________________________________________________
int TUnixSystem::UnixFilestat(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.
// Id is (statbuf.st_dev << 24) + statbuf.st_ino
// Size is the file size
// Flags is file type: bit 0 set executable, bit 1 set directory,
// bit 2 set regular file
// Modtime is modification time
// The function returns 0 in case of success and 1 if the file could
// not be stat'ed.
struct stat statbuf;
if (path != 0 && stat(path, &statbuf) >= 0) {
if (id)
#if defined(R__KCC) && defined(R__LINUX)
*id = (statbuf.st_dev.__val[0] << 24) + statbuf.st_ino;
#else
*id = (statbuf.st_dev << 24) + statbuf.st_ino;
#endif
if (size)
*size = statbuf.st_size;
if (modtime)
*modtime = statbuf.st_mtime;
if (flags) {
*flags = 0;
if (statbuf.st_mode & ((S_IEXEC)|(S_IEXEC>>3)|(S_IEXEC>>6)))
*flags |= 1;
if ((statbuf.st_mode & S_IFMT) == S_IFDIR)
*flags |= 2;
if ((statbuf.st_mode & S_IFMT) != S_IFREG &&
(statbuf.st_mode & S_IFMT) != S_IFDIR)
*flags |= 4;
}
return 0;
}
return 1;
}
//______________________________________________________________________________
int TUnixSystem::UnixWaitchild()
{
// Wait till child is finished.
int status;
return (int) waitpid(0, &status, WNOHANG);
}
//---- RPC -------------------------------------------------------------------
//______________________________________________________________________________
int TUnixSystem::UnixTcpConnect(const char *hostname, int port)
{
// Open a TCP/IP connection to server and connect to a service (i.e. port).
// Is called via the TSocket constructor.
short sport;
struct servent *sp;
if ((sp = getservbyport(port, kProtocolName)))
sport = sp->s_port;
else
sport = htons(port);
TInetAddress addr = gSystem->GetHostByName(hostname);
if (!addr.IsValid()) return -1;
UInt_t adr = htonl(addr.GetAddress());
struct sockaddr_in server;
memset(&server, 0, sizeof(server));
memcpy(&server.sin_addr, &adr, sizeof(adr));
server.sin_family = addr.GetFamily();
server.sin_port = sport;
// Create socket
int sock;
if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
::SysError("TUnixSystem::UnixConnectTcp", "socket");
return -1;
}
if (connect(sock, (struct sockaddr*) &server, sizeof(server)) < 0) {
//::SysError("TUnixSystem::UnixConnectTcp", "connect");
close(sock);
return -1;
}
return sock;
}
//______________________________________________________________________________
int TUnixSystem::UnixUnixConnect(int port)
{
// Connect to a Unix domain socket.
int sock;
char buf[100];
struct sockaddr_un unserver;
sprintf(buf, "%s/%d", kServerPath, port);
unserver.sun_family = AF_UNIX;
strcpy(unserver.sun_path, buf);
// Open socket
if ((sock = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
::SysError("TUnixSystem::UnixUnixConnect", "socket");
return -1;
}
if (connect(sock, (struct sockaddr*) &unserver, strlen(unserver.sun_path)+2) < 0) {
// ::SysError("TUnixSystem::UnixUnixConnect", "connect");
close(sock);
return -1;
}
return sock;
}
//______________________________________________________________________________
int TUnixSystem::UnixTcpService(int port, Bool_t reuse, int backlog)
{
// Open a socket, bind to it and start listening for TCP/IP connections
// on the port. Returns socket fd or -1 if socket() failed, -2 if bind() failed
// or -3 if listen() failed.
short sport;
struct servent *sp;
if ((sp = getservbyport(port, kProtocolName)))
sport = sp->s_port;
else
sport = htons(port);
// Create tcp socket
int sock;
if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
::SysError("TUnixSystem::UnixTcpService", "socket");
return -1;
}
if (reuse)
gSystem->SetSockOpt(sock, kReuseAddr, 1);
struct sockaddr_in inserver;
memset(&inserver, 0, sizeof(inserver));
inserver.sin_family = AF_INET;
inserver.sin_addr.s_addr = htonl(INADDR_ANY);
inserver.sin_port = sport;
// Bind socket
if (bind(sock, (struct sockaddr*) &inserver, sizeof(inserver))) {
::SysError("TUnixSystem::UnixTcpService", "bind");
return -2;
}
// Start accepting connections
if (listen(sock, backlog)) {
::SysError("TUnixSystem::UnixTcpService", "listen");
return -3;
}
return sock;
}
//______________________________________________________________________________
int TUnixSystem::UnixUnixService(int port, int backlog)
{
// Open a socket, bind to it and start listening for Unix domain connections
// to it. Returns socket fd or -1.
struct sockaddr_un unserver;
int sock, oldumask;
memset(&unserver, 0, sizeof(unserver));
unserver.sun_family = AF_UNIX;
// Assure that socket directory exists
oldumask = umask(0);
::mkdir(kServerPath, 0777);
umask(oldumask);
sprintf(unserver.sun_path, "%s/%d", kServerPath, port);
// Remove old socket
unlink(unserver.sun_path);
// Create socket
if ((sock = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
::SysError("TUnixSystem::UnixUnixService", "socket");
return -1;
}
if (bind(sock, (struct sockaddr*) &unserver, strlen(unserver.sun_path)+2)) {
::SysError("TUnixSystem::UnixUnixService", "bind");
return -1;
}
// Start accepting connections
if (listen(sock, backlog)) {
::SysError("TUnixSystem::UnixUnixService", "listen");
return -1;
}
return sock;
}
//______________________________________________________________________________
int TUnixSystem::UnixRecv(int sock, void *buffer, int length, int flag)
{
// Receive exactly length bytes into buffer. Returns number of bytes
// received. Returns -1 in case of error, -2 in case of MSG_OOB
// and errno == EWOULDBLOCK, -3 in case of MSG_OOB and errno == EINVAL
// and -4 in case of kNoBlock and errno == EWOULDBLOCK.
errno = 0;
if (sock < 0) return -1;
int n, nrecv = 0;
char *buf = (char *)buffer;
for (n = 0; n < length; n += nrecv) {
if ((nrecv = recv(sock, buf+n, length-n, flag)) <= 0) {
if (nrecv == 0)
break; // EOF
if (flag == MSG_OOB) {
if (errno == EWOULDBLOCK)
return -2;
else if (errno == EINVAL)
return -3;
}
if (errno == EWOULDBLOCK)
return -4;
else {
if (errno != EINTR)
::SysError("TUnixSystem::UnixRecv", "recv");
return -1;
}
}
}
return n;
}
//______________________________________________________________________________
int TUnixSystem::UnixSend(int sock, const void *buffer, int length, int flag)
{
// Send exactly length bytes from buffer. Returns -1 in case of error,
// otherwise number of sent bytes.
if (sock < 0) return -1;
int n, nsent = 0;
const char *buf = (const char *)buffer;
for (n = 0; n < length; n += nsent) {
if ((nsent = send(sock, buf+n, length-n, flag)) <= 0) {
::SysError("TUnixSystem::UnixSend", "send");
return nsent;
}
}
return n;
}
//---- Dynamic Loading ---------------------------------------------------------
//______________________________________________________________________________
const char *TUnixSystem::GetDynamicPath()
{
// Get shared library search path. Static utility function.
static const char *dynpath = 0;
if (dynpath == 0) {
dynpath = gEnv->GetValue("Root.DynamicPath", (char*)0);
if (dynpath == 0)
dynpath = StrDup(Form(".:%s/lib", gRootDir));
}
return dynpath;
}
//______________________________________________________________________________
char *TUnixSystem::DynamicPathName(const char *lib, Bool_t quiet)
{
// Returns the path of a shared library (searches for library in the
// shared library search path). If no file name extension is provided
// it first tries .so, .sl, .dl and then .a (for AIX). The returned string
// must be deleted.
char *name;
int len = strlen(lib);
if (len > 3 && (!strcmp(lib+len-3, ".sl") ||
!strcmp(lib+len-3, ".dl") ||
!strcmp(lib+len-3, ".so") ||
!strcmp(lib+len-2, ".a")))
name = gSystem->Which(GetDynamicPath(), lib, kReadPermission);
else {
name = Form("%s.so", lib);
name = gSystem->Which(GetDynamicPath(), name, kReadPermission);
if (!name) {
name = Form("%s.sl", lib);
name = gSystem->Which(GetDynamicPath(), name, kReadPermission);
if (!name) {
name = Form("%s.dl", lib);
name = gSystem->Which(GetDynamicPath(), name, kReadPermission);
if (!name) {
name = Form("%s.a", lib);
name = gSystem->Which(GetDynamicPath(), name, kReadPermission);
}
}
}
}
if (!name && !quiet)
Error("DynamicPathName",
"%s does not exist or wrong file extension (.so, .sl, .dl or .a)", lib);
return name;
}
//______________________________________________________________________________
void *TUnixSystem::FindDynLib(const char *lib)
{
// Returns the handle to a loaded shared library. Returns 0 when library
// not loaded.
#ifdef R__HPUX
const char *path;
if ((path = gSystem->DynamicPathName(lib))) {
// find handle of shared library using its name
struct shl_descriptor *desc;
int index = 0;
while (shl_get(index++, &desc) == 0)
if (!strcmp(path, desc->filename))
return desc->handle;
}
#endif
if (lib) { } // avoid warning, use lib
return 0;
}
//______________________________________________________________________________
int TUnixSystem::UnixDynLoad(const char *lib)
{
// Load a shared library. Returns 0 on successful loading, 1 in
// case lib was already loaded and -1 in case lib does not exist
// or in case of error.
const char *path;
if ((path = gSystem->DynamicPathName(lib))) {
#if defined(R__HPUX) && defined(NOCINT)
shl_t handle = cxxshl_load(path, BIND_IMMEDIATE | BIND_NONFATAL, 0L);
if (handle > 0) return 0;
#else
return G__loadfile((char *)path);
#endif
}
return -1;
}
//______________________________________________________________________________
Func_t TUnixSystem::UnixDynFindSymbol(const char *lib, const char *entry)
{
// Finds and returns a function pointer to a symbol in the shared library.
// Returns 0 when symbol not found.
#ifdef R__HPUX
shl_t handle;
if (handle = (shl_t)FindDynLib(lib)) {
Func_t addr = 0;
if (shl_findsym(&handle, entry, TYPE_PROCEDURE, addr) == -1)
::SysError("TUnixSystem::UnixDynFindSymbol", "shl_findsym");
return addr;
}
return 0;
#else
if (lib || entry) { }
// Always assume symbol found
return (Func_t)1;
#endif
}
//______________________________________________________________________________
void TUnixSystem::UnixDynListSymbols(const char *lib, const char *regexp)
{
// List symbols in a shared library. One can use wildcards to list only
// the intresting symbols.
#ifdef R__HPUX
shl_t handle;
if (handle = (shl_t)FindDynLib(lib)) {
struct shl_symbol *symbols;
int nsym = shl_getsymbols(handle, TYPE_PROCEDURE,
EXPORT_SYMBOLS|NO_VALUES, (void *(*)())malloc,
&symbols);
if (nsym != -1) {
if (nsym > 0) {
int cnt = 0;
TRegexp *re = 0;
if (regexp && strlen(regexp)) re = new TRegexp(regexp, kTRUE);
Printf("");
Printf("Functions exported by library %s", gSystem->DynamicPathName(lib));
Printf("=========================================================");
for (int i = 0; i < nsym; i++)
if (symbols[i].type == TYPE_PROCEDURE) {
cnt++;
char *dsym = cplus_demangle(symbols[i].name,
DMGL_PARAMS|DMGL_ANSI|DMGL_ARM);
if (re) {
TString s = dsym;
if (s.Index(*re) != kNPOS) Printf("%s", dsym);
} else
Printf("%s", dsym);
free(dsym);
}
Printf("---------------------------------------------------------");
Printf("%d exported functions", cnt);
Printf("=========================================================");
delete re;
}
free(symbols);
}
}
#endif
if (lib || regexp) { }
}
//______________________________________________________________________________
void TUnixSystem::UnixDynListLibs(const char *lib)
{
// List all loaded shared libraries.
#ifdef R__HPUX
TRegexp *re = 0;
if (lib && strlen(lib)) re = new TRegexp(lib, kTRUE);
struct shl_descriptor *desc;
int index = 0;
Printf("");
Printf("Loaded shared libraries");
Printf("=======================");
while (shl_get(index++, &desc) == 0)
if (re) {
TString s = desc->filename;
if (s.Index(*re) != kNPOS) Printf("%s", desc->filename);
} else
Printf("%s", desc->filename);
Printf("-----------------------");
Printf("%d libraries loaded", index-1);
Printf("=======================");
delete re;
#endif
if (lib) { }
}
//______________________________________________________________________________
void TUnixSystem::UnixDynUnload(const char *lib)
{
// Unload a shared library.
#if defined(R__HPUX) && defined (NOCINT)
shl_t handle;
if (handle = (shl_t)FindDynLib(lib))
if (cxxshl_unload(handle) == -1)
::SysError("TUnixSystem::UnixDynUnload", "could not unload library %s", lib);
#else
if (lib) { }
// should call CINT unload file here, but does not work for sl's yet.
::Warning("TUnixSystem::UnixDynUnload", "CINT does not support unloading shared libs");
#endif
}
//______________________________________________________________________________
int TUnixSystem::ReadUtmpFile()
{
// Read utmp file. Returns number of entries in utmp file.
FILE *utmp;
struct stat file_stats;
size_t n_read, size;
gUtmpContents = 0;
utmp = fopen(UTMP_FILE, "r");
if (!utmp)
return 0;
fstat(fileno(utmp), &file_stats);
size = file_stats.st_size;
if (size <= 0) {
fclose(utmp);
return 0;
}
gUtmpContents = (STRUCT_UTMP *) malloc(size);
if (!gUtmpContents) return 0;
n_read = fread(gUtmpContents, 1, size, utmp);
if (ferror(utmp) || fclose(utmp) == EOF || n_read < size) {
free(gUtmpContents);
gUtmpContents = 0;
return 0;
}
return size / sizeof(STRUCT_UTMP);
}
//______________________________________________________________________________
void *TUnixSystem::SearchUtmpEntry(int n, const char *tty)
{
// Look for utmp entry which is connected to terminal tty.
STRUCT_UTMP *ue = gUtmpContents;
while (n--) {
if (ue->ut_name[0] && !strncmp(tty, ue->ut_line, sizeof(ue->ut_line)))
return ue;
ue++;
}
return 0;
}
ROOT page - Class index - Top of the page
This page has been automatically generated. If you have any comments or suggestions about the page layout send a mail to ROOT support, or contact the developers with any questions or problems regarding ROOT.