hg/stx-libbasic: comparison UnixOperatingSystem.st

equal deleted inserted replaced

-:47b429933e0e
+:e0683b878c4c
 hereby transferred.
 "
 "{ Package: 'stx:libbasic' }"
 AbstractOperatingSystem subclass:#UnixOperatingSystem
-instanceVariableNames: ''
+	instanceVariableNames:''
-classVariableNames: 'HostName DomainName SlowFork ForkFailed CurrentDirectory
+	classVariableNames:'HostName DomainName SlowFork ForkFailed CurrentDirectory
 		LastTimeInfo LastTimeInfoSeconds LastTimeInfoMilliseconds
 		LastTimeInfoIsLocal CachedMountPoints CacheMountPointsTimeStamp
 		Codeset CodesetEncoder'
-poolDictionaries: ''
+	poolDictionaries:''
-category: 'OS-Unix'
+	category:'OS-Unix'
 !
 Object subclass:#FileDescriptorHandle
-instanceVariableNames: 'fd'
+	instanceVariableNames:'fd'
-classVariableNames: 'OpenFiles'
+	classVariableNames:'OpenFiles'
-poolDictionaries: ''
+	poolDictionaries:''
-privateIn: UnixOperatingSystem
+	privateIn:UnixOperatingSystem
 !
 OSFileHandle subclass:#FilePointerHandle
-instanceVariableNames: ''
+	instanceVariableNames:''
-classVariableNames: ''
+	classVariableNames:''
-poolDictionaries: ''
+	poolDictionaries:''
-privateIn: UnixOperatingSystem
+	privateIn:UnixOperatingSystem
 !
 Object subclass:#FileStatusInfo
-instanceVariableNames: 'type mode uid gid size id accessed modified statusChanged path
+	instanceVariableNames:'type mode uid gid size id accessed modified statusChanged path
 		numLinks'
-classVariableNames: ''
+	classVariableNames:''
-poolDictionaries: ''
+	poolDictionaries:''
-privateIn: UnixOperatingSystem
+	privateIn:UnixOperatingSystem
 !
 Object subclass:#MountInfo
-instanceVariableNames: 'mountPointPath deviceOrRemotePath fsType attributeString'
+	instanceVariableNames:'mountPointPath deviceOrRemotePath fsType attributeString'
-classVariableNames: ''
+	classVariableNames:''
-poolDictionaries: ''
+	poolDictionaries:''
-privateIn: UnixOperatingSystem
+	privateIn:UnixOperatingSystem
 !
 Object subclass:#OSProcessStatus
-instanceVariableNames: 'pid status code core'
+	instanceVariableNames:'pid status code core'
-classVariableNames: ''
+	classVariableNames:''
-poolDictionaries: ''
+	poolDictionaries:''
-privateIn: UnixOperatingSystem
+	privateIn:UnixOperatingSystem
 !
 UnixOperatingSystem::FileDescriptorHandle subclass:#SocketHandle
-instanceVariableNames: ''
+	instanceVariableNames:''
-classVariableNames: 'ProtocolCache'
+	classVariableNames:'ProtocolCache'
-poolDictionaries: ''
+	poolDictionaries:''
-privateIn: UnixOperatingSystem
+	privateIn:UnixOperatingSystem
 !
 !UnixOperatingSystem primitiveDefinitions!
 %{
 #if defined(_AIX)
 #ifdef USE_H_ERRNO
 # ifndef h_errno
 extern h_errno;
 # endif
 #endif
+%}
+! !
+!UnixOperatingSystem primitiveFunctions!
+%{
+/*
+* some systems' system() is broken in that it does not correctly
+* handle EINTR and returns failure even though it actually succeeded.
+* (LINUX is one of them)
+* Here is a fixed version. If you encounter EINTR returns from
+* UnixOperatingSystem>>executeCommand, you ought to define WANT_SYSTEM
+* in the xxxIntern.h file to get this fixed version.
+*
+* As an added BONUS, this system() enables interrupts while waiting
+* for the child which enables other threads to continue.
+* (i.e. it is RT safe)
+*/
+#if defined(WANT_SYSTEM)
+/* # define DPRINTF(x)     printf x */
+# define DPRINTF(x)     /* nothing */
+# ifndef _STDDEF_H_INCLUDED_
+#  include <stddef.h>
+#  define _STDDEF_H_INCLUDED_
+# endif
+# ifndef _STDLIB_H_INCLUDED_
+#  include <stdlib.h>
+#  define _STDLIB_H_INCLUDED_
+# endif
+# ifndef _UNISTD_H_INCLUDED_
+#  include <unistd.h>
+#  define _UNISTD_H_INCLUDED_
+# endif
+# ifndef _SYS_WAIT_H_INCLUDED
+#  include <sys/wait.h>
+#  define _SYS_WAIT_H_INCLUDED
+# endif
+# ifndef _SIGNAL_H_INCLUDED_
+#  include <signal.h>
+#  define _SIGNAL_H_INCLUDED_
+# endif
+# ifndef _SYS_TYPES_H_INCLUDED_
+#  include <sys/types.h>
+#  define _SYS_TYPES_H_INCLUDED_
+# endif
+# if (!defined(HAVE_GNU_LD) && !defined (__ELF__)) || !defined(LINUX)
+#  define       __environ       environ
+#  if 1 /* !defined(LINUX) */
+#   define      __sigemptyset   sigemptyset
+#   define      __sigaction     sigaction
+#   define      __sigaddset     sigaddset
+#   define      __sigprocmask   sigprocmask
+#   define      __execve        execve
+#   define      __wait          wait
+#   define      __waitpid       waitpid
+#  endif /* ! LINUX */
+// #  ifndef __osx__
+extern char **environ;
+// #  endif
+# endif
+# define      __sigprocmask   sigprocmask
+# define      __execve        execve
+# define        SHELL_PATH      "/bin/sh"       /* Path of the shell.  */
+# define        SHELL_NAME      "sh"            /* Name to give it.  */
+static int
+mySystem(line)
+register CONST char *line;
+{
+int status, save;
+pid_t pid;
+struct sigaction sa, intr, quit;
+sigset_t block, omask;
+if (line == NULL)
+	return -1;
+sa.sa_handler = SIG_IGN;
+sa.sa_flags = 0;
+__sigemptyset (&sa.sa_mask);
+if (__sigaction (SIGINT, &sa, &intr) < 0) {
+	DPRINTF(("1: errno=%d\n", errno));
+	return -1;
+}
+if (__sigaction (SIGQUIT, &sa, &quit) < 0) {
+	save = errno;
+	(void) __sigaction (SIGINT, &intr, (struct sigaction *) NULL);
+	errno = save;
+	DPRINTF(("2: errno=%d\n", errno));
+	return -1;
+}
+__sigemptyset (&block);
+__sigaddset (&block, SIGCHLD);
+save = errno;
+if (__sigprocmask(SIG_BLOCK, &block, &omask) < 0) {
+	if (errno == ENOSYS)
+	    errno = save;
+	else {
+	    save = errno;
+	    (void) __sigaction(SIGINT, &intr, (struct sigaction *) NULL);
+	    (void) __sigaction (SIGQUIT, &quit, (struct sigaction *) NULL);
+	    errno = save;
+	    DPRINTF(("3: errno=%d\n", errno));
+	    return -1;
+	}
+}
+pid = FORK ();
+if (pid == (pid_t) 0) {
+	/* Child side.  */
+	CONST char *new_argv[4];
+	new_argv[0] = SHELL_NAME;
+	new_argv[1] = "-c";
+	new_argv[2] = line;
+	new_argv[3] = NULL;
+	/* Restore the signals.  */
+	(void) __sigaction (SIGINT, &intr, (struct sigaction *) NULL);
+	(void) __sigaction (SIGQUIT, &quit, (struct sigaction *) NULL);
+	(void) __sigprocmask (SIG_SETMASK, &omask, (sigset_t *) NULL);
+	/* Exec the shell.  */
+	(void) __execve (SHELL_PATH, (char *CONST *) new_argv, __environ);
+	_exit (127);
+} else {
+	if (pid < (pid_t) 0) {
+	    /* The fork failed.  */
+	    DPRINTF(("4: errno=%d\n", errno));
+	    status = -1;
+	} else {
+	    /* Parent side.  */
+#ifdef  NO_WAITPID
+	    pid_t child;
+	    do {
+		__BEGIN_INTERRUPTABLE__
+		child = __wait (&status);
+		__END_INTERRUPTABLE__
+		if (child < 0 && errno != EINTR) {
+		    DPRINTF(("5: errno=%d\n", errno));
+		    status = -1;
+		    break;
+		}
+	    } while (child != pid);
+#else
+	    pid_t child;
+	    /* claus: the original did not care for EINTR here ... */
+	    do {
+		__BEGIN_INTERRUPTABLE__
+		child = __waitpid (pid, &status, 0);
+		__END_INTERRUPTABLE__
+	    } while ((child != pid) && (errno == EINTR));
+	    if (child != pid) {
+		DPRINTF(("6: errno=%d\n", errno));
+		status = -1;
+	    }
+#endif /* NO_WAITPID */
+	}
+}
+save = errno;
+if ((__sigaction (SIGINT, &intr, (struct sigaction *) NULL)
+| __sigaction (SIGQUIT, &quit, (struct sigaction *) NULL)
+| __sigprocmask (SIG_SETMASK, &omask, (sigset_t *) NULL)) != 0) {
+	if (errno == ENOSYS) {
+	    errno = save;
+	} else {
+	    status = -1;
+	    DPRINTF(("7: errno=%d\n", errno));
+	}
+}
+return status;
+}
+#else
+# define __wait wait
+#endif /* WANT_SYSTEM */
+/*
+* some systems do not have realpath();
+* the alternative of reading from a 'pwp'-pipe
+* is way too slow. Here is a realpath for the rest of us.
+* define WANT_REALPATH in the xxxIntern-file to get it.
+*/
+#if defined(HAS_REALPATH)
+# undef WANT_REALPATH
+#endif
+#if !defined(HAS_GETWD) && !defined(HAS_GETCWD)
+# undef WANT_REALPATH
+#endif
+#if defined(WANT_REALPATH)
+# ifndef NULL
+#  define NULL (char *)0
+# endif
+# define MAX_READLINKS 32
+# ifndef MAXPATHLEN
+#  define MAXPATHLEN     1024
+# endif
+static
+char *
+realpath(path, resolved_path)
+char *path;
+char resolved_path [];
+{
+	char copy_path[MAXPATHLEN];
+	char link_path[MAXPATHLEN];
+	char *new_path = resolved_path;
+	char *max_path;
+	int readlinks = 0;
+	int n;
+	/* Make a copy of the source path since we may need to modify it. */
+	strcpy(copy_path, path);
+	path = copy_path;
+	max_path = copy_path + MAXPATHLEN - 2;
+	/* If it's a relative pathname use getwd for starters. */
+	if (*path != '/') {
+#ifdef HAS_GETCWD
+		new_path = getcwd(new_path, MAXPATHLEN - 1);
+#else
+		new_path = getwd(new_path);
+#endif
+		if (new_path == NULL)
+		    return(NULL);
+		new_path += strlen(new_path);
+		if (new_path[-1] != '/')
+			*new_path++ = '/';
+	}
+	else {
+		*new_path++ = '/';
+		path++;
+	}
+	/* Expand each slash-separated pathname component. */
+	while (*path != '\0') {
+		/* Ignore stray "/". */
+		if (*path == '/') {
+			path++;
+			continue;
+		}
+		if (*path == '.') {
+			/* Ignore ".". */
+			if (path[1] == '\0' || path[1] == '/') {
+				path++;
+				continue;
+			}
+			if (path[1] == '.') {
+				if (path[2] == '\0' || path[2] == '/') {
+					path += 2;
+					/* Ignore ".." at root. */
+					if (new_path == resolved_path + 1)
+						continue;
+					/* Handle ".." by backing up. */
+					while ((--new_path)[-1] != '/')
+						;
+					continue;
+				}
+			}
+		}
+		/* Safely copy the next pathname component. */
+		while (*path != '\0' && *path != '/') {
+			if (path > max_path) {
+				errno = ENAMETOOLONG;
+				return NULL;
+			}
+			*new_path++ = *path++;
+		}
+#ifdef S_IFLNK
+		/* Protect against infinite loops. */
+		if (readlinks++ > MAX_READLINKS) {
+			errno = ELOOP;
+			return NULL;
+		}
+		/* See if latest pathname component is a symlink. */
+		*new_path = '\0';
+		n = readlink(resolved_path, link_path, MAXPATHLEN - 1);
+		if (n < 0) {
+			/* EINVAL means the file exists but isn't a symlink. */
+			if (errno != EINVAL)
+				return NULL;
+		}
+		else {
+			/* Note: readlink doesn't add the null byte. */
+			link_path[n] = '\0';
+			if (*link_path == '/')
+				/* Start over for an absolute symlink. */
+				new_path = resolved_path;
+			else
+				/* Otherwise back up over this component. */
+				while (*(--new_path) != '/')
+					;
+			/* Safe sex check. */
+			if (strlen(path) + n >= MAXPATHLEN) {
+				errno = ENAMETOOLONG;
+				return NULL;
+			}
+			/* Insert symlink contents into path. */
+			strcat(link_path, path);
+			strcpy(copy_path, link_path);
+			path = copy_path;
+		}
+#endif /* S_IFLNK */
+		*new_path++ = '/';
+	}
+	/* Delete trailing slash but don't whomp a lone slash. */
+	if (new_path != resolved_path + 1 && new_path[-1] == '/')
+		new_path--;
+	/* Make sure it's null terminated. */
+	*new_path = '\0';
+	return resolved_path;
+}
+# define HAS_REALPATH
+#endif /* WANT_REALPATH && not HAS_REALPATH */
 %}
 ! !
 !UnixOperatingSystem class methodsFor:'documentation'!
 ]
 								[exBegin]
 "
 ! !
 !UnixOperatingSystem class methodsFor:'initialization'!
 initialize
 "initialize the class"
 "Created: / 15.6.1996 / 15:22:37 / cg"
 "Modified: / 7.1.1997 / 19:36:11 / stefan"
 "Modified: / 11.12.1998 / 16:22:48 / cg"
 ! !
 !UnixOperatingSystem class methodsFor:'OS signal constants'!
 sigABRT
 "return the signal number for SIGABRT - 0 if not supported by OS
 (the numeric value is not the same across unix-systems)"
 OperatingSystem signalNamed:#SIGCHLD
 OperatingSystem signalNamed:#SIGXFSZ
 OperatingSystem signalNamed:#SIGSOUND
 "
 ! !
 !UnixOperatingSystem class methodsFor:'error messages'!
 currentErrorNumber
 "returns the OS's last error nr (i.e. the value of errno).
 "
 self errorNumberFor:#EOVERFLOW
 "
 ! !
 !UnixOperatingSystem class methodsFor:'executing OS commands-implementation'!
 exec:aCommandPathArg withArguments:argColl environment:environmentDictionary
 fileDescriptors:fdColl fork:doFork newPgrp:newPgrp inDirectory:aDirectory
 aCommandPath := self encodePath:aCommandPathArg.
 %{  /* STACK: 16000 */
 char **argv;
 int nargs, i, id;
 OBJ arg;
 #ifdef __osx__
 char **environ = _NSGetEnviron();
 #else
 extern char **environ;
 #endif
 "Modified: / 21.3.1997 / 10:04:35 / dq"
 "Modified: / 15.7.1997 / 16:03:51 / stefan"
 "Modified: / 5.6.1998 / 19:03:51 / cg"
 "Created: / 12.11.1998 / 14:39:20 / cg"
 ! !
 !UnixOperatingSystem class methodsFor:'executing OS commands-queries'!
 commandAndArgsForOSCommand:aCommandString
 "get a shell and shell arguments for command execution"
 "
 "Modified: / 5.6.1998 / 19:03:32 / cg"
 ! !
 !UnixOperatingSystem class methodsFor:'file access'!
 closeFd:anInteger
 "low level close of a filedescriptor"
 #endif
 %}.
 ^ self primitiveFailed
 ! !
 !UnixOperatingSystem class methodsFor:'file access rights'!
 accessMaskFor:aSymbol
 "return the access bits mask for numbers as returned by
 OperatingSystem>>accessModeOf:
 	RETURN ( true );
 }
 %}.
 ^ self primitiveFailed
 ! !
 !UnixOperatingSystem class methodsFor:'file locking'!
 lockFD:aFileDescriptor shared:isSharedReadLock blocking:blockIfLocked
 "set a lock on the file represented by aFileDescriptor.
 #endif
 }
 %}.
 ^ false
 ! !
 !UnixOperatingSystem class methodsFor:'file queries'!
 caseSensitiveFilenames
 "return true, if the OS has caseSensitive file naming.
 struct stat buf;
 int ret;
 if (__isStringLike(encodedPathName)) {
 # ifdef TRACE_STAT_CALLS
-	printf("stat on '%s' for isValidPath\n", __stringVal(encodedPathName));
+printf("stat on '%s' for isValidPath\n", __stringVal(encodedPathName));
 # endif
-	__BEGIN_INTERRUPTABLE__
+__BEGIN_INTERRUPTABLE__
-	do {
+do {
-	    ret = stat((char *) __stringVal(encodedPathName), &buf);
+ret = stat((char *) __stringVal(encodedPathName), &buf);
-	} while ((ret < 0) && (errno == EINTR));
+} while ((ret < 0) && (errno == EINTR));
-	__END_INTERRUPTABLE__
+__END_INTERRUPTABLE__
-	if (ret < 0) {
+if (ret < 0) {
-	    @global(LastErrorNumber) = __mkSmallInteger(errno);
+@global(LastErrorNumber) = __mkSmallInteger(errno);
-	    RETURN (false);
+RETURN (false);
-	}
+}
-	RETURN ( ret ? false : true );
+RETURN ( ret ? false : true );
 }
 %}.
 ^ self primitiveFailed
 "/ alternative:
 ^ ''
 "Modified: / 5.6.1998 / 18:38:11 / cg"
 ! !
 !UnixOperatingSystem class methodsFor:'interrupts & signals'!
 defaultSignal:signalNumber
 "revert to the default action on arrival of a (Unix-)signal.
 Dont confuse Unix signals with smalltalk signals.
 "Modified: / 28.12.1995 / 15:05:37 / stefan"
 "Created: / 23.4.1996 / 16:40:34 / stefan"
 "Modified: / 27.1.1998 / 20:05:59 / cg"
 ! !
 !UnixOperatingSystem class methodsFor:'ipc support'!
 makeBidirectionalPipe
 "make a socketPair, return array with two filedescriptors on success,
 nil on failure.
 }
 #endif
 %}.
 self primitiveFailed
 ! !
 !UnixOperatingSystem class methodsFor:'misc'!
 closeLeftOverFiles
 "a bad bad kludge and workaround for a big bug in the linux
 SlowFork := aBoolean
 "Modified: 22.4.1996 / 13:13:09 / cg"
 ! !
 !UnixOperatingSystem class methodsFor:'os queries'!
 executableFileExtensions
 "return a collection of extensions for executable program files.
 getEnvironment
 "answer the whole environment as a Dictionary"
 |resultArray error dict sz "{ Class: SmallInteger }"|
 %{
 #ifdef __osx__
 char **environ = _NSGetEnviron();
 #else
 extern char **environ;
 #endif
 "return an empty dictionary if proceed from error"
 ^  Dictionary new.
 ].
 "we prefer OrderedDictionary here, because we want to keep the
-order as defined in the OS. But OrderedDictionary is in libbasic2."
+order as defined in the OS."
-retDictionary := OrderedDictionary ? Dictionary new:noOfIf.
+retDictionary := OrderedDictionary new:noOfIf.
 1 to:noOfIf do:[:cnt|
 |macAddress|
 macAddress := addressArray at:cnt.
 macAddress ~= #[0 0 0 0 0 0] ifTrue:[
 OperatingSystem supportsSymbolicLinks
 "
 ! !
 !UnixOperatingSystem class methodsFor:'path queries'!
 decodePath:encodedPathName
 "decode the pathName as returned by system calls.
 E.g. linux system calls return sigle byte strings only,
 ^ OSProcessStatus
 "Created: / 12.6.1998 / 16:30:43 / cg"
 ! !
 !UnixOperatingSystem class methodsFor:'shared memory access'!
 shmAttach:id address:addr flags:flags
 "low level entry to shmat()-system call.
 Not supported on all operatingSystems"
 ^ self primitiveFailed
 "Modified: 22.4.1996 / 13:14:46 / cg"
 ! !
 !UnixOperatingSystem class methodsFor:'socket creation'!
 socketAccessor
 ^ SocketHandle
 is done. Both arguments must be symbols from one of
 #inet,#unix, #appletalk, #x25 .. and #stream, #datagram, #raw resp."
 ^ SocketHandle new domain:domainArg type:typeArg protocol:protocolArg
 ! !
 !UnixOperatingSystem class methodsFor:'time and date'!
 computeOSTimeFromUTCYear:y month:m day:d hour:h minute:min second:s millisecond:millis
 "return the OS-dependent time for the given time and day.
 "
 OperatingSystem timeInfoFromSeconds:0 localTime:false
 OperatingSystem timeInfoFromSeconds:3600 localTime:false
 "
 ! !
 !UnixOperatingSystem class methodsFor:'users & groups'!
 getEffectiveGroupID
 "{ Pragma: +optSpace }"
 OperatingSystem userInfoOf:'fooBar'
 OperatingSystem userInfoOf:(OperatingSystem getUserID)
 "
 ! !
 !UnixOperatingSystem class methodsFor:'waiting for events'!
 blockingChildProcessWait
 "return true, if childProcessWait: blocks, if no children are ready.
 On those systems, we must be somewhat careful when looking out for
 fd argument not integer or bad return code
 "
 ^ self primitiveFailed
 ! !
 !UnixOperatingSystem::FileDescriptorHandle class methodsFor:'change & update'!
 update:aspect with:argument from:anObject
 "one of our registered handles has been collected"
 ].
 "Created: 30.9.1997 / 12:57:35 / stefan"
 ! !
 !UnixOperatingSystem::FileDescriptorHandle class methodsFor:'initialization'!
 initialize
 OpenFiles := WeakArray new:10.
 OpenFiles addDependent:self.
 "Created: 26.9.1997 / 17:15:50 / stefan"
 "Modified: 30.9.1997 / 12:40:55 / stefan"
 ! !
 !UnixOperatingSystem::FileDescriptorHandle class methodsFor:'instance creation'!
 for:aFileDescriptor
 "create an instance of myself for a given fileDescriptor"
 ^ self new for:aFileDescriptor.
 "Created: 30.9.1997 / 14:00:00 / stefan"
 ! !
 !UnixOperatingSystem::FileDescriptorHandle methodsFor:'error handling'!
 error:anErrorSymbolOrErrno
 "got an error; arg is either a symbol specifying a primitive error
 	(UnixOperatingSystem errorHolderForNumber:anErrorSymbolOrErrno) reportError
 ].
 self primitiveFailed:anErrorSymbolOrErrno.
 ! !
 !UnixOperatingSystem::FileDescriptorHandle methodsFor:'file access'!
 close
 "close the descriptor"
 self invalidate.
 ^ OperatingSystem closeFd:desc.
 "Modified: 30.9.1997 / 13:06:55 / stefan"
 ! !
 !UnixOperatingSystem::FileDescriptorHandle methodsFor:'initialization'!
 for:aFileDescriptor
 "create a file for a handle"
 "Created: 26.9.1997 / 17:14:40 / stefan"
 "Modified: 30.9.1997 / 12:41:43 / stefan"
 "Modified (comment): / 16-03-2013 / 00:04:56 / Jan Vrany <jan.vrany@fit.cvut.cz>"
 ! !
 !UnixOperatingSystem::FileDescriptorHandle methodsFor:'input/output'!
 readBytes:count into:aByteBuffer startingAt:firstIndex
 "read count bytes into a byte-buffer;
 buff := '12345678901234567890'.
 n := h writeBytes:10 from:buff startingAt:1.
 "
 ! !
 !UnixOperatingSystem::FileDescriptorHandle methodsFor:'misc functions'!
 nextError
 "retrieve the pending error from the current fileDescriptor
 and raise an error exception.
 ^ self primitiveFailed
 ! !
 !UnixOperatingSystem::FileDescriptorHandle methodsFor:'private-accessing'!
 fileDescriptor
 "return the (integer) fileDescriptor"
 }
 %}
 ! !
 !UnixOperatingSystem::FileDescriptorHandle methodsFor:'queries'!
 canReadWithoutBlocking
 "return true, if data is available on a filedescriptor
 n := h numAvailableForRead.
 h close.
 n
 "
 ! !
 !UnixOperatingSystem::FileDescriptorHandle methodsFor:'registering'!
 register
 "register myself as an open file"
 "Created: 30.9.1997 / 12:51:48 / stefan"
 "Modified: 30.9.1997 / 12:58:37 / stefan"
 "Modified (comment): / 16-03-2013 / 00:04:38 / Jan Vrany <jan.vrany@fit.cvut.cz>"
 ! !
 !UnixOperatingSystem::FileDescriptorHandle methodsFor:'releasing'!
 invalidate
 "a file handle has become invalid"
 fd := nil.
 "Created: 30.9.1997 / 12:37:26 / stefan"
 "Modified: 30.9.1997 / 12:42:16 / stefan"
 ! !
 !UnixOperatingSystem::FileDescriptorHandle methodsFor:'waiting'!
 readWaitWithTimeoutMs:timeout
 "suspend the current process, until the receiver
 ].
 wasBlocked ifFalse:[OperatingSystem unblockInterrupts].
 ^ canWrite not
 ! !
 !UnixOperatingSystem::FilePointerHandle methodsFor:'release'!
 closeFile
 "close the underlying file"
 	fclose(f);
 }
 %}
 ! !
 !UnixOperatingSystem::FileStatusInfo class methodsFor:'instance creation'!
 type:t mode:m uid:u gid:g size:s id:i accessed:aT modified:mT statusChanged:sT path:lP numLinks:nL
 ^ self basicNew
 	type:t mode:m uid:u gid:g size:s id:i accessed:aT modified:mT statusChanged:sT path:lP numLinks:nL
 ! !
 !UnixOperatingSystem::FileStatusInfo methodsFor:'accessing'!
 accessTime
 "return accessed"
 "return uid"
 ^ uid
 ! !
 !UnixOperatingSystem::FileStatusInfo methodsFor:'accessing-vms'!
 fixedHeaderSize
 "return the fixedHeaderSize (VMS only; nil everywhere else)"
 recordSize
 "return the recordSize (VMS only; nil everywhere else)"
 ^ nil
 ! !
 !UnixOperatingSystem::FileStatusInfo methodsFor:'backward compatibility'!
 accessed
 <resource:#obsolete>
 <resource:#obsolete>
 self obsoleteMethodWarning:'use #statusChangeTime'.
 ^ self statusChangeTime
 ! !
 !UnixOperatingSystem::FileStatusInfo methodsFor:'private-accessing'!
 type:t mode:m uid:u gid:g size:s id:i accessed:aT modified:mT statusChanged:sT path:lP numLinks:nL
 type := t.
 statusChanged := sT.
 path := lP.
 numLinks := nL.
 ! !
 !UnixOperatingSystem::FileStatusInfo methodsFor:'queries-access'!
 isGroupExecutable
 ^ mode bitTest:8r10
 "
 '/etc/passwd' asFilename info isWorldWritable
 "
 ! !
 !UnixOperatingSystem::FileStatusInfo methodsFor:'queries-type'!
 isBlockSpecial
 ^ type == #blockSpecial
 !
 isUnknown
 ^ type == #unknown
 ! !
 !UnixOperatingSystem::MountInfo methodsFor:'accessing'!
 mountPointPath
 "return the value of the instance variable 'mountPointPath' (automatically generated)"
 deviceOrRemotePath := deviceOrRemotePathArg.
 fsType := fsTypeArg.
 attributeString := attributeStringArg.
 ! !
 !UnixOperatingSystem::MountInfo methodsFor:'printing'!
 printOn:aStream
 aStream
 	nextPutAll:'MountInfo for ';
 	nextPutAll:mountPointPath.
 ! !
 !UnixOperatingSystem::MountInfo methodsFor:'queries'!
 isRemote
 ^ fsType = 'nfs'
 ! !
 !UnixOperatingSystem::OSProcessStatus class methodsFor:'documentation'!
 documentation
 "
 [see also:]
 	OperatingSystem
 "
 ! !
 !UnixOperatingSystem::OSProcessStatus class methodsFor:'instance creation'!
 pid:pid status:status code:code core:core
 "private interface for UnixOperatingSystem"
 "Created: 28.12.1995 / 14:35:29 / stefan"
 "Modified: 30.4.1996 / 18:25:05 / cg"
 ! !
 !UnixOperatingSystem::OSProcessStatus methodsFor:'accessing'!
 code
 "return the exitcode / signalNumber"
 ^ status
 "Created: 28.12.1995 / 14:05:07 / stefan"
 "Modified: 30.4.1996 / 18:26:54 / cg"
 ! !
 !UnixOperatingSystem::OSProcessStatus methodsFor:'initialization'!
 pid:newPid status:newStatus code:newCode core:newCore
 pid := newPid.
 code := newCode.
 core := newCore.
 "Created: 28.12.1995 / 14:18:22 / stefan"
 ! !
 !UnixOperatingSystem::OSProcessStatus methodsFor:'printing & storing'!
 printOn:aStream
 aStream nextPutAll:', code='.
 code printOn:aStream.
 aStream nextPut:$).
 ! !
 !UnixOperatingSystem::OSProcessStatus methodsFor:'private-OS interface'!
 code:something
 "set the exitCode"
 status := something.
 "Created: 28.12.1995 / 14:05:07 / stefan"
 ! !
 !UnixOperatingSystem::OSProcessStatus methodsFor:'queries'!
 couldNotExecute
 "return true when a command could not be executed"
 ^ status == #exit and:[code = 0]
 "Created: 28.12.1995 / 14:13:05 / stefan"
 "Modified: 28.12.1995 / 14:13:41 / stefan"
 ! !
 !UnixOperatingSystem::SocketHandle class methodsFor:'constants'!
 protocolCodeOf:aNameOrNumber
 "convert a symbol to a numeric protocol code"
 self protocolSymbolOf:(self protocolCodeOf:#udp)
 self protocolSymbolOf:(self protocolCodeOf:#icmp)
 "
 ! !
 !UnixOperatingSystem::SocketHandle class methodsFor:'initialization'!
 reinitialize
 "clear the protocol cache, when the system has been restarted"
 ProtocolCache := nil.
 ! !
 !UnixOperatingSystem::SocketHandle class methodsFor:'queries'!
 XXgetAddressInfo:hostName serviceName:serviceNameArg domain:domainArg type:typeArg protocol:protoArg flags:flags
 "answer an Array of socket addresses for serviceName on hostName
 	^ error.
 ].
 ^ result.
 ! !
 !UnixOperatingSystem::SocketHandle methodsFor:'accepting'!
 acceptWithPeerAddressBuffer:peerOrNil
 "accept a connection on a server port.
 Returns a new SocketHandle or nil if the operation
 	^ self error:error.
 ].
 ^ self class for:newFd
 ! !
 !UnixOperatingSystem::SocketHandle methodsFor:'binding'!
 bindTo:socketAddress
 "low level bind -
 Set the local address of the socket"
 	 bindTo:(IPSocketAddress hostAddress:IPSocketAddress anyAddress port:9999)
 	 reuseAddress:false ;
 yourself
 "
 ! !
 !UnixOperatingSystem::SocketHandle methodsFor:'connecting'!
 cancelConnect
 "cancel an asynchronous connect in progress"
 		   withTimeout:nil.
 Socket newTCP connectTo:(IPSocketAddress hostAddress:#[1 2 3 4] port:7)
 		   withTimeout:nil.
 "
 ! !
 !UnixOperatingSystem::SocketHandle methodsFor:'datagram transmission'!
 receiveFrom:socketAddress buffer:aDataBuffer start:startIndex for:nBytes flags:flags
 "receive datagramm data - put address of originating host into
 err: ;
 %}.
 ^ self error:error.
 ! !
 !UnixOperatingSystem::SocketHandle methodsFor:'initialization'!
 domain:domainArg type:typeArg protocol:protocolArg
 "set up socket with domain, type and protocol number.
 This is a low level entry; no binding, listening or connect is done.
 "
 self new domain:#inet type:#stream protocol:nil
 "
 ! !
 !UnixOperatingSystem::SocketHandle methodsFor:'misc'!
 getOptionsLevel:level name:name
 "answer a ByteArray containing the socket option value
 named name at level"
 	^ self error:error
 ].
 ^ nil.
 ! !
 !UnixOperatingSystem::SocketHandle methodsFor:'queries'!
 getNameInto:socketAddress
 "answer the my own address (I am bound to this address).
 Note that this address may change after connect or accept."
 	^ self error:error
 ].
 ^ nil
 ! !
 !UnixOperatingSystem class methodsFor:'documentation'!
 version
-^ '$Header: /cvs/stx/stx/libbasic/UnixOperatingSystem.st,v 1.309 2013-04-22 15:51:25 stefan Exp $'
+^ '$Header: /cvs/stx/stx/libbasic/UnixOperatingSystem.st,v 1.312 2013-04-25 09:23:16 stefan Exp $'
 !
 version_CVS
-^ '$Header: /cvs/stx/stx/libbasic/UnixOperatingSystem.st,v 1.309 2013-04-22 15:51:25 stefan Exp $'
+^ '$Header: /cvs/stx/stx/libbasic/UnixOperatingSystem.st,v 1.312 2013-04-25 09:23:16 stefan Exp $'
 !
 version_HG
 ^ '$Changeset: <not expanded> $'
 ! !
+UnixOperatingSystem initialize!
 UnixOperatingSystem::FileDescriptorHandle initialize!
-UnixOperatingSystem initialize!

branch	jv
changeset 18053	e0683b878c4c
parent 18052	47b429933e0e
parent 15153	445368176cf3
child 18054	56594a8c6b83