hg/stx-libbasic: comparison FileStream.st

equal deleted inserted replaced

-:bc474f9c0180
+:33b0edbb1920
 #include <errno.h>
 #define _ERRNO_H_INCLUDED_
 #ifdef transputer
 # include <iocntrl.h>
 # ifndef fileno
 /* kludge: inmos forgot fileno */
 #  define fileno(f)     ((f)->__file)
 # endif
-#else
+#else /* not transputer */
 # include <sys/types.h>
 # include <sys/stat.h>
-#endif
+#endif /* not transputer */
 #ifdef hpux
 # define fileno(f)      ((f->__fileH << 8) | (f->__fileL))
 #endif
 */
 # include <rms.h>
 #endif
 #ifndef WIN32
 extern long ftell(), lseek();
+# define HFILE FILE *
 #endif
+#ifdef WIN32
+# define NO_STDIO
+# ifdef i386
+#  define _X86_
+# endif
+# undef INT
+# undef Array
+# undef Number
+# undef Method
+# undef Point
+# undef Rectangle
+# undef Block
+# undef Time
+# undef Date
+# define NOATOM
+# define NOGDICAPMASKS
+# define NOMETAFILE
+# define NOMINMAX
+//# define NOOPENFILE
+# define NOSOUND
+# define NOWH
+//# define NOCOMM
+# define NOKANJI
+# define NOCRYPT
+//# define NOMCX
+# define WIN32_LEAN_AND_MEAN
+# include <windows.h>
+# include <winsock.h> /* */
+# if !defined(__BORLANDC__)
+#  define stat _stat
+# endif
+# ifdef __DEF_Array
+#  define Array __DEF_Array
+# endif
+# ifdef __DEF_Number
+#  define Number __DEF_Number
+# endif
+# ifdef __DEF_Method
+#  define Method __DEF_Method
+# endif
+# ifdef __DEF_Point
+#  define Point __DEF_Point
+# endif
+# ifdef __DEF_Block
+#  define Block __DEF_Block
+# endif
+# ifdef __DEF_Time
+#  define Time __DEF_Time
+# endif
+# ifdef __DEF_Date
+#  define Date __DEF_Date
+# endif
+# define INT int
+# ifdef NO_STDIO
+/*#  define HFILE HANDLE*/
+#  define HFILE FILE *
+//#  define fileno(f) f
+#  define TELL(currentPosition,f,buffered)                       \
+if (buffered) {                                             \
+	currentPosition = ftell(f);                             \
+} else {                                                    \
+	OBJ rA = __INST(readAhead);                             \
+	if (rA != nil) {                                        \
+	    __INST(readAhead) = nil;                            \
+	    currentPosition = lseek(fileno(f), -1L, SEEK_CUR);  \
+	} else {                                                \
+	  currentPosition = lseek(fileno(f), 0L, SEEK_CUR);     \
+	}                                                       \
+}
+#  define SEEK(ret,f,nP,buffered)                        \
+if (buffered) {                                     \
+	ret = fseek(f, nP, SEEK_SET);                   \
+} else {                                            \
+	OBJ rA = __INST(readAhead);                     \
+	if (rA != nil) {                                \
+	    __INST(readAhead) = nil;                    \
+	}                                               \
+	ret = lseek(fileno(f), nP, SEEK_SET);           \
+}
+#  define TOEND(ret,f,buffered)                          \
+if (buffered) {                                     \
+	ret = fseek(f, 0L, SEEK_END);                   \
+} else {                                            \
+	OBJ rA = __INST(readAhead);                     \
+	if (rA != nil) {                                \
+	    __INST(readAhead) = nil;                    \
+	}                                               \
+	ret = lseek(fileno(f), 0L, SEEK_END);           \
+}
+# else /* use STDIO */
+#  define HFILE FILE *
+#  define TELL(currentPosition,f,buffered)                 \
+if (buffered) {                                       \
+	currentPosition = ftell(f);                       \
+} else {                                              \
+	currentPosition = lseek(fileno(f), 0L, SEEK_CUR); \
+}
+#  define SEEK(ret,f,nP,buffered)                        \
+if (buffered) {                                     \
+	ret = fseek(f, nP, SEEK_SET);                   \
+} else {                                            \
+	ret = lseek(fileno(f), nP, SEEK_SET);           \
+}
+#  define TOEND(ret,f,buffered)                          \
+if (buffered) {                                     \
+	ret = fseek(f, 0L, SEEK_END);                   \
+} else {                                            \
+	ret = lseek(fileno(f), 0L, SEEK_END);           \
+}
+extern long ftell(), lseek();
+# endif /* use STDIO */
+#endif /* WIN32 */
 /*
 * on some systems errno is a macro ... check for it here
 */
 #ifndef errno
 Therefore, the instance variable canPosition is set according to
 this and an error is raised, if a position: is attemted.
 I know, this is ugly, but what else could we do ?
 [instance variables:]
-	pathName	<String>	the files path (if known)
+	pathName        <String>        the files path (if known)
-	canPosition	<Boolean>	positionable - read above comment
+	canPosition     <Boolean>       positionable - read above comment
 [author:]
 	Claus Gittinger
 [see also:]
 !FileStream class methodsFor:'initialization'!
 initialize
 OpenErrorSignal isNil ifTrue:[
-"/
+	"/
-"/ this is temporary - for now allow an openError to
+	"/ this is temporary - for now allow an openError to
-"/ be unhandled and proceed by returning a nil from the
+	"/ be unhandled and proceed by returning a nil from the
-"/ stream creation method.
+	"/ stream creation method.
-"/ In the future, this will be a hard signal.
+	"/ In the future, this will be a hard signal.
-"/
+	"/
-OpenErrorSignal := QuerySignal new.
+	OpenErrorSignal := QuerySignal new.
-OpenErrorSignal parent:(super openErrorSignal) mayProceed:true.
+	OpenErrorSignal parent:(super openErrorSignal) mayProceed:true.
-OpenErrorSignal nameClass:self message:#openErrorSignal.
+	OpenErrorSignal nameClass:self message:#openErrorSignal.
-OpenErrorSignal notifierString:'open error'.
+	OpenErrorSignal notifierString:'open error'.
-UserInitiatedFileSaveQuerySignal := QuerySignal new defaultAnswer:true.
+	UserInitiatedFileSaveQuerySignal := QuerySignal new defaultAnswer:true.
-UserInitiatedFileSaveQuerySignal nameClass:self message:#userInitiatedFileSaveQuerySignal.
+	UserInitiatedFileSaveQuerySignal nameClass:self message:#userInitiatedFileSaveQuerySignal.
 ]
 "Modified: 8.10.1997 / 11:56:39 / cg"
 ! !
 closeFile
 "low level close - may be redefined in subclasses"
 super closeFile.
 removeOnClose == true ifTrue:[
-pathName asFilename remove.
+	pathName asFilename remove.
 ]
 "Created: / 13.8.1998 / 12:11:22 / cg"
 ! !
 "return the read/write position in the file -
 notice, in smalltalk indices start at 1 so begin of file is 1"
 %{
-FILE *f;
+HFILE f;
 long currentPosition;
 if (__INST(filePointer) != nil) {
 	f = __FILEVal(__INST(filePointer));
 	do {
+#ifdef WIN32
+	    TELL(currentPosition,f,__INST(buffered) == true);
+#else
 	    if (__INST(buffered) == true) {
 		currentPosition = ftell(f);
 	    } else {
 		currentPosition = lseek(fileno(f), 0L, SEEK_CUR);
 	    }
+#endif
 	} while ((currentPosition < 0) && (errno == EINTR));
 	if (currentPosition >= 0) {
 	    /*
 	     * notice: Smalltalk index starts at 1
 	     */
 position:newPos
 "set the read/write position in the file"
 %{
-FILE *f;
+HFILE f;
 long ret;
 OBJ fp;
 long nP;
 if ((__INST(canPosition) != false)
 || (newPos == __MKSMALLINT(1))) {
-if ((fp = __INST(filePointer)) != nil) {
+	if ((fp = __INST(filePointer)) != nil) {
 	    if (__isSmallInteger(newPos)) {
-	        f = __FILEVal(fp);
+		f = __FILEVal(fp);
-	        nP = (long)__intVal(newPos);
+		nP = (long)__intVal(newPos);
-	        /*
+		/*
-	         * notice: Smalltalk index starts at 1
+		 * notice: Smalltalk index starts at 1
-	         */
+		 */
-	        nP--;
+		nP--;
-	        do {
+		do {
+#ifdef WIN32
+		    SEEK(ret,f,nP,__INST(buffered) == true);
+#else
 		    if (__INST(buffered) == true) {
-		        ret = fseek(f, nP, SEEK_SET);
+			ret = fseek(f, nP, SEEK_SET);
 		    } else {
-		        ret = lseek(fileno(f), nP, SEEK_SET);
+			ret = lseek(fileno(f), nP, SEEK_SET);
 		    }
-	        } while ((ret < 0) && (errno == EINTR));
+#endif
-	        if (ret >= 0) {
+		} while ((ret < 0) && (errno == EINTR));
+		if (ret >= 0) {
 		    __INST(position) = newPos;
 		    /*
 		     * just to make certain ...
 		     */
 		    __INST(hitEOF) = false;
 		    RETURN ( self );
-	        }
+		}
-	        __INST(lastErrorNumber) = __MKSMALLINT(errno);
+		__INST(lastErrorNumber) = __MKSMALLINT(errno);
 	    }
 	}
 }
 %}.
 canPosition == false ifTrue:[
 setToEnd
 "set the read/write position in the file to be at the end of the file"
 %{
-FILE *f;
+HFILE f;
 long ret;
 if (__INST(filePointer) != nil) {
 	f = __FILEVal(__INST(filePointer));
 	__INST(position) = nil;
 	do {
+#ifdef WIN32
+	    TOEND(ret,f,__INST(buffered) == true);
+#else
 	    if (__INST(buffered) == true) {
 		ret = fseek(f, 0L, SEEK_END);
 	    } else {
 		ret = lseek(fileno(f), 0L, SEEK_END);
 	    }
+#endif
 	} while ((ret < 0) && (errno == EINTR));
 	if (ret >= 0) {
 	    RETURN ( self );
 	}
 	__INST(lastErrorNumber) = __MKSMALLINT(errno);
 "position the file by re-reading everything up-to newPos.
 The effect is the same as that of #position:, but its much slower.
 This is required to reposition nonPositionable streams, such
 as tape-streams or variable-record-RMS files under VMS.
 Caveat:
-This should really be done transparently by the stdio library."
+	 This should really be done transparently by the stdio library."
 |buffer amount|
 self isReadable ifFalse:[
 	"/ sorry
 buffer := ByteArray new:8*1024.
 (position isNil "/ i.e. unknown
 or:[newPos < position]) ifTrue:[
-self reset.
+	self reset.
 ].
 [position < newPos] whileTrue:[
 	amount := (buffer size) min:(newPos-position).
 	(self nextBytes:amount into:buffer startingAt:1) ~~ amount ifTrue:[
 	    ^ self positionError
 from which a copy can be reconstructed later."
 aStream nextPutAll:'(FileStream oldFileNamed:'.
 aStream nextPutAll:pathName storeString.
 (self position ~~ 1) ifTrue:[
-aStream nextPutAll:'; position:'.
+	aStream nextPutAll:'; position:'.
-self position storeOn:aStream
+	self position storeOn:aStream
 ].
 aStream nextPut:$)
 "Modified: 30.7.1997 / 16:43:50 / cg"
 ! !
 |ok|
 filePointer notNil ifTrue:[^ self errorAlreadyOpen].
 ok := false.
 %{
-FILE *f;
+HFILE f;
-FILE *fopen();
+HFILE fopen();
 OBJ path, fp;
 int pass = 0;
 retry:
 path = __INST(pathName);
 if (__isNonNilObject(path) && (__qClass(path)==String)) {
 #ifdef __VMS__
-do {
+	do {
-/*
+	    /*
-* allow passing additional RMS arguments.
+	     * allow passing additional RMS arguments.
-* stupid: DEC does not seem to offer an interface for passing a char **.
+	     * stupid: DEC does not seem to offer an interface for passing a char **.
-*/
+	     */
-errno = 0;
+	    errno = 0;
-{
+	    {
-if (__isArray(attributeSpec)) {
+		if (__isArray(attributeSpec)) {
-OBJ *ap = __ArrayInstPtr(attributeSpec)->a_element;
+		    OBJ *ap = __ArrayInstPtr(attributeSpec)->a_element;
-int numAttrib = 0;
+		    int numAttrib = 0;
-int i;
+		    int i;
-numAttrib = __arraySize(attributeSpec);
+		    numAttrib = __arraySize(attributeSpec);
-for (i=0; i<numAttrib;i++) {
+		    for (i=0; i<numAttrib;i++) {
-if (! __isString(ap[i])) {
+			if (! __isString(ap[i])) {
-f = NULL;
+			    f = NULL;
-errno = EINVAL; /* invalid argument */
+			    errno = EINVAL; /* invalid argument */
-goto getOutOfHere;
+			    goto getOutOfHere;
-}
+			}
-}
+		    }
-switch (numAttrib) {
+		    switch (numAttrib) {
-case 0:
+			case 0:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode));
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-case 1:
+			case 1:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
-__stringVal(ap[0]));
+				      __stringVal(ap[0]));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-case 2:
+			case 2:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
-__stringVal(ap[0]), __stringVal(ap[1]));
+				      __stringVal(ap[0]), __stringVal(ap[1]));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-case 3:
+			case 3:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
-__stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]));
+				      __stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-case 4:
+			case 4:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
-__stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
+				      __stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
-__stringVal(ap[3]));
+				      __stringVal(ap[3]));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-case 5:
+			case 5:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
-__stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
+				      __stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
-__stringVal(ap[3]), __stringVal(ap[4]));
+				      __stringVal(ap[3]), __stringVal(ap[4]));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-case 6:
+			case 6:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
-__stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
+				      __stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
-__stringVal(ap[3]), __stringVal(ap[4]), __stringVal(ap[5]));
+				      __stringVal(ap[3]), __stringVal(ap[4]), __stringVal(ap[5]));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-case 7:
+			case 7:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
-__stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
+				      __stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
-__stringVal(ap[3]), __stringVal(ap[4]), __stringVal(ap[5]),
+				      __stringVal(ap[3]), __stringVal(ap[4]), __stringVal(ap[5]),
-__stringVal(ap[6]));
+				      __stringVal(ap[6]));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-case 8:
+			case 8:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
-__stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
+				      __stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
-__stringVal(ap[3]), __stringVal(ap[4]), __stringVal(ap[5]),
+				      __stringVal(ap[3]), __stringVal(ap[4]), __stringVal(ap[5]),
-__stringVal(ap[6]), __stringVal(ap[7]));
+				      __stringVal(ap[6]), __stringVal(ap[7]));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-case 9:
+			case 9:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
-__stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
+				      __stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
-__stringVal(ap[3]), __stringVal(ap[4]), __stringVal(ap[5]),
+				      __stringVal(ap[3]), __stringVal(ap[4]), __stringVal(ap[5]),
-__stringVal(ap[6]), __stringVal(ap[7]), __stringVal(ap[8]));
+				      __stringVal(ap[6]), __stringVal(ap[7]), __stringVal(ap[8]));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-case 10:
+			case 10:
-__BEGIN_INTERRUPTABLE__
+			    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
+			    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode),
-__stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
+				      __stringVal(ap[0]), __stringVal(ap[1]), __stringVal(ap[2]),
-__stringVal(ap[3]), __stringVal(ap[4]), __stringVal(ap[5]),
+				      __stringVal(ap[3]), __stringVal(ap[4]), __stringVal(ap[5]),
-__stringVal(ap[6]), __stringVal(ap[7]), __stringVal(ap[8]),
+				      __stringVal(ap[6]), __stringVal(ap[7]), __stringVal(ap[8]),
-__stringVal(ap[9]));
+				      __stringVal(ap[9]));
-__END_INTERRUPTABLE__
+			    __END_INTERRUPTABLE__
-break;
+			    break;
-default:
+			default:
-f = NULL;
+			    f = NULL;
-errno = E2BIG; /* too many args */
+			    errno = E2BIG; /* too many args */
-goto getOutOfHere;
+			    goto getOutOfHere;
-}
+		    }
-} else if (attributeSpec != nil) {
+		} else if (attributeSpec != nil) {
-f = NULL;
+		    f = NULL;
-errno = EINVAL; /* invalid argument */
+		    errno = EINVAL; /* invalid argument */
-goto getOutOfHere;
+		    goto getOutOfHere;
-} else {
+		} else {
-/*
+		    /*
-* create file as sequential streamLF by default.
+		     * create file as sequential streamLF by default.
-*/
+		     */
-__BEGIN_INTERRUPTABLE__
+		    __BEGIN_INTERRUPTABLE__
-f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode), "rfm=stmlf");
+		    f = fopen((char *)__stringVal(path), (char *)__stringVal(openmode), "rfm=stmlf");
-__END_INTERRUPTABLE__
+		    __END_INTERRUPTABLE__
-}
+		}
-}
+	    }
-/* must refetch - could be GC'd */
+	    /* must refetch - could be GC'd */
-path = __INST(pathName);
+	    path = __INST(pathName);
-} while ((f == NULL) && (errno == EINTR));
+	} while ((f == NULL) && (errno == EINTR));
-#else
-do {
+#else /* not VMS */
-__BEGIN_INTERRUPTABLE__
-# ifdef LINUX
+# ifdef WIN32
-/*
-* LINUX may ret a non-NULL f even when interrupted.
+	do {
-* Therefore, check errno and fake a null-ret.
+#  ifdef NO_STDIO
-*/
+	    /*printf("open %s mode=%s\n",__stringVal(path),__stringVal(openmode)); */
-errno = 0;
+#   ifdef DO_WRAP_CALLS
-f = fopen((char *) __stringVal(path), (char *) __stringVal(openmode));
+	    f = __STX_C_CALL2((void*)fopen,(void *)__stringVal(path), (void *)__stringVal(openmode));
-if (errno == EINTR)
+#   else
-f = NULL;
+	    f = fopen((char *) __stringVal(path), (char *) __stringVal(openmode));
-# else
+#   endif
-f = fopen((char *) __stringVal(path), (char *) __stringVal(openmode));
+#  else /* use_STDIO */
-# endif
+	    __BEGIN_INTERRUPTABLE__
-__END_INTERRUPTABLE__
+	    f = fopen((char *) __stringVal(path), (char *) __stringVal(openmode));
-/* must refetch - could be GC'd */
+	    __END_INTERRUPTABLE__
-path = __INST(pathName);
+#  endif /* use_STDIO */
-} while ((f == NULL) && (errno == EINTR));
+	    /* must refetch - could be GC'd */
-#endif
+	    path = __INST(pathName);
+	} while ((f == NULL) && (errno == EINTR));
-if (f == NULL) {
-/*
+# else /* not WIN32 */
-* If no filedescriptors available, try to finalize
-* possibly collected fd's and try again.
+	do {
-*/
+	    __BEGIN_INTERRUPTABLE__
-if (pass == 0 && (errno == ENFILE || errno == EMFILE)) {
+#  ifdef LINUX
-pass = 1;
+	    /*
-__SSEND0(@global(ObjectMemory), @symbol(scavenge), 0);
+	     * LINUX may ret a non-NULL f even when interrupted.
-__SSEND0(@global(ObjectMemory), @symbol(finalize), 0);
+	     * Therefore, check errno and fake a null-ret.
-goto retry;
+	     */
-}
+	    errno = 0;
-getOutOfHere: ;
+	    f = fopen((char *) __stringVal(path), (char *) __stringVal(openmode));
-__INST(lastErrorNumber) = __MKSMALLINT(errno);
+	    if (errno == EINTR)
-__INST(position) = nil;
+		f = NULL;
-} else {
+#  else /* not LINUX */
+	    f = fopen((char *) __stringVal(path), (char *) __stringVal(openmode));
+#  endif /* not LINUX */
+	    __END_INTERRUPTABLE__
+	    /* must refetch - could be GC'd */
+	    path = __INST(pathName);
+	} while ((f == NULL) && (errno == EINTR));
+# endif /* not WIN32 */
+#endif /* not VMS */
+	if (f == NULL) {
+	    /*
+	     * If no filedescriptors available, try to finalize
+	     * possibly collected fd's and try again.
+	     */
+	    if (pass == 0 && (errno == ENFILE || errno == EMFILE)) {
+		pass = 1;
+		__SSEND0(@global(ObjectMemory), @symbol(scavenge), 0);
+		__SSEND0(@global(ObjectMemory), @symbol(finalize), 0);
+		goto retry;
+	    }
+	getOutOfHere: ;
+	    __INST(lastErrorNumber) = __MKSMALLINT(errno);
+	    __INST(position) = nil;
+	} else {
 #ifdef __VMS__
-/*
+	    /*
-* check to see if this is positionable ...
+	     * check to see if this is positionable ...
-*/
+	     */
-__INST(canPosition) = false;
+	    __INST(canPosition) = false;
 # ifndef _POSIX_C_SOURCE
-{
+	    {
-struct stat statBuffer;
+		struct stat statBuffer;
-if (fstat(fileno(f), &statBuffer) >= 0) {
+		if (fstat(fileno(f), &statBuffer) >= 0) {
-switch (statBuffer.st_fab_rfm) {
+		    switch (statBuffer.st_fab_rfm) {
-case FAB$C_UDF: /* undefined (also stream binary)   */
+			case FAB$C_UDF: /* undefined (also stream binary)   */
-case FAB$C_VAR: /* variable length records          */
+			case FAB$C_VAR: /* variable length records          */
-case FAB$C_VFC: /* variable fixed control           */
+			case FAB$C_VFC: /* variable fixed control           */
-case FAB$C_STM: /* RMS-11 stream (valid only for sequen> */
+			case FAB$C_STM: /* RMS-11 stream (valid only for sequen> */
-default:
+			default:
-__INST(canPosition) = false;
+			    __INST(canPosition) = false;
-break;
+			    break;
-case FAB$C_FIX: /* fixed length records             */
+			case FAB$C_FIX: /* fixed length records             */
-case FAB$C_STMLF: /* LF stream (valid only for sequential> */
+			case FAB$C_STMLF: /* LF stream (valid only for sequential> */
-case FAB$C_STMCR: /* CR stream (valid only for sequential> */
+			case FAB$C_STMCR: /* CR stream (valid only for sequential> */
-__INST(canPosition) = true;
+			    __INST(canPosition) = true;
-break;
+			    break;
-}
+		    }
-}
+		}
-}
+	    }
 # endif
 #else /* not VMS */
-__INST(canPosition) = true;
+	    __INST(canPosition) = true;
 #endif /* poor VMS */
-__INST(filePointer) = fp = __MKOBJ((INT)f); __STORE(self, fp);
+	    __INST(filePointer) = fp = __MKOBJ((INT)f); __STORE(self, fp);
-__INST(position) = __MKSMALLINT(1);
+	    __INST(position) = __MKSMALLINT(1);
-ok = true;
+	    ok = true;
-}
+	}
 }
 %}.
 ok ifFalse:[
-"
+	"
-the open failed for some reason ...
+	 the open failed for some reason ...
-"
+	"
-^ self openError
+	^ self openError
 ].
 buffered := true.       "default is buffered"
 Lobby register:self.
 !
 	    "/ the file is no longer present or accessable ..."
 	    (self class name , ' [warning]: could not reOpen file: ', pathName) errorPrintCR.
 	] ifFalse:[
 	    oldPos notNil ifTrue:[
-	        self position:oldPos.
+		self position:oldPos.
 	    ]
 	]
 ]
 "Modified: 10.1.1997 / 17:50:51 / cg"
 fileSize
 "return the size in bytes of the file"
 %{
+HFILE f;
 #ifdef transputer
-FILE *f;
 int size;
 if (__INST(filePointer) != nil) {
 	f = __FILEVal(__INST(filePointer));
 	if ((size = filesize(fileno(f))) >= 0) {
 	    RETURN ( __MKSMALLINT(size) );
 	}
 }
 #else
-FILE *f;
 struct stat buf;
 int ret;
 int fd;
 if (__INST(filePointer) != nil) {
 ! !
 !FileStream class methodsFor:'documentation'!
 version
-^ '$Header: /cvs/stx/stx/libbasic/FileStream.st,v 1.67 1999-10-13 12:25:40 cg Exp $'
+^ '$Header: /cvs/stx/stx/libbasic/FileStream.st,v 1.68 1999-10-14 23:51:01 cg Exp $'
 ! !
 FileStream initialize!

changeset 4910	33b0edbb1920
parent 4907	0b09209a95c8
child 5120	13143fbcbdf8