"

 COPYRIGHT (c) 1989 by Claus Gittinger

	      All Rights Reserved

 This software is furnished under a license and may be used

 only in accordance with the terms of that license and with the

 inclusion of the above copyright notice.   This software may not

 be provided or otherwise made available to, or used by, any

 other person.  No title to or ownership of the software is

 hereby transferred.

"

ExternalStream subclass:#FileStream

!

!FileStream primitiveDefinitions!

%{

#include <stdio.h>

#define _STDIO_H_INCLUDED_

#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

# include <sys/types.h>

# include <sys/stat.h>

#endif

#ifdef hpux

# define fileno(f)      ((f->__fileH << 8) | (f->__fileL))

#endif

#ifndef SEEK_SET

# define SEEK_SET       0

#endif

#ifndef SEEK_CUR

# define SEEK_CUR       1

#endif

#ifndef SEEK_END

# define SEEK_END       2

#endif

/*

 * on some systems errno is a macro ... check for it here

 */

#ifndef errno

 extern errno;

#endif

%}

! !

!FileStream class methodsFor:'instance creation'!

    |newStream|

    newStream := self new pathName:filename.

    ^ newStream

!

     The file is opened for read/write access."

!

newFileForWritingNamed:filename

    "return a FileStream for new file named filename, aString.

     If the file exists, it is truncated, otherwise created.

     The file is opened for writeonly access."

    |newStream|

    newStream := self new pathName:filename.

    newStream createForWriting isNil ifTrue:[^nil].

    ^ newStream

!

newFileForWritingNamed:filename in:aDirectory

    "return a FileStream for new file named filename, aString

     in aDirectory, a FileDirectory.

     If the file exists, it is truncated, otherwise created.

     The file is opened for writeonly access."

    |newStream|

    newStream := self new pathName:filename in:aDirectory.

    newStream createForWriting isNil ifTrue:[^nil].

    ^ newStream

!

oldFileNamed:filename

    "return a FileStream for existing file named filename, aString.

     The file is opened for read/write access."

    |newStream|

    (OperatingSystem isReadable:filename) ifFalse:[^nil].

    newStream := self new pathName:filename.

    newStream readwrite.

    newStream openForReadWrite isNil ifTrue:[^nil].

"

    this is not a good idea; someone else might be appending ...

    newStream readLimit:(newStream size).

"

    ^ newStream

!

oldFileNamed:filename in:aDirectory

    "return a FileStream for existing file named filename, aString

     in aDirectory, a FileDirectory.

     The file is opened for read/write access."

    |newStream|

    newStream := self new pathName:filename in:aDirectory.

    newStream openForReadWrite isNil ifTrue:[^nil].

"

    this is not a good idea; someone else might be appending ...

    newStream readLimit:(newStream size).

"

    ^ newStream

!

readonlyFileNamed:filename

    "return a readonly FileStream for existing file named filename, aString"

    |newStream|

    (OperatingSystem isReadable:filename) ifFalse:[^nil].

    newStream := self new pathName:filename.

    newStream openForReading isNil ifTrue:[^nil].

"

    this is not a good idea; someone else might be appending ...

    newStream readLimit:(newStream size).

"

    ^ newStream

!

readonlyFileNamed:filename in:aDirectory

    "return a readonly FileStream for existing file named filename, aString

     in aDirectory, a FileDirectory"

    |newStream|

    newStream := self new pathName:filename in:aDirectory.

    newStream openForReading isNil ifTrue:[^nil].

"

    this is not a good idea; someone else might be appending ...

    newStream readLimit:(newStream size).

"

    ^ newStream

! !

!FileStream methodsFor:'accessing'!

directoryName

    "return the name of the directory I'm in"

    |path lastIndex index|

    path := pathName.

    lastIndex := 0.

    index := path indexOf:$/.

    [index ~~ 0] whileTrue:[

	lastIndex := index.

	index := path indexOf:$/ startingAt:(index + 1)

    ].

    (lastIndex == 0) ifTrue:[^ '.'].

    (lastIndex == 1) ifTrue:[^ '/'].

    ^ path copyTo:(lastIndex - 1)

!

name

    "return my name without leading direcory-path"

    |lastIndex index|

    lastIndex := 1.

    [true] whileTrue:[

	index := pathName indexOf:$/ startingAt:lastIndex.

	(index == 0) ifTrue:[

	    ^ pathName copyFrom:lastIndex

	].

	lastIndex := index + 1

    ]

!

pathName

    "return the pathname"

    ^ pathName

! !

!FileStream methodsFor:'private'!

!

!

open

    "open the file"

    pathName isNil ifTrue:[^nil].

    (mode == #readonly) ifTrue: [

	didWrite := false.

	^ self openWithMode:'r'

    ].

    (mode == #writeonly) ifTrue: [

	didWrite := true.

	^ self openWithMode:'w'

    ].

    ^ self openWithMode:'r+'

!

openWithMode:openmode

    "open the file; openmode is the string defining the way to open"

    |retVal|

    filePointer notNil ifTrue:[^ self errorOpen].

%{

    FILE *f;

    OBJ path, fp;

    path = _INST(pathName);

    if (__isNonNilObject(path) && (__qClass(path)==String)) {

	__BEGIN_INTERRUPTABLE__

	do {

#ifdef LINUX

	    /* LINUX returns a non-NULL f even when interrupted */

	    errno = 0;

	    f = (FILE *) fopen((char *) _stringVal(path), (char *) _stringVal(openmode));

	    if (errno == EINTR)

		f = NULL;

#else

	    f = (FILE *) fopen((char *) _stringVal(path), (char *) _stringVal(openmode));

#endif

	} while ((f == NULL) && (errno == EINTR));

	__END_INTERRUPTABLE__

	if (f == NULL) {

	    _INST(lastErrorNumber) = _MKSMALLINT(errno);

	    _INST(position) = nil;

	} else {

	    _INST(filePointer) = fp = __MKOBJ((int)f); __STORE(self, fp);

	    _INST(position) = _MKSMALLINT(1);

	    retVal = self;

	}

    }

%}.

    retVal notNil ifTrue:[

	buffered := true.       "default is buffered"

	Lobby register:self

    ].

    lastErrorNumber notNil ifTrue:[

	"

	 the open failed for some reason ...

	"

	^ self openError

    ].

    ^ retVal

!

!

!

reOpen

    "sent after snapin to reopen streams"

    |oldPos|

    filePointer notNil ifTrue:[

	"it was open, when snapped-out"

	filePointer := nil.

	Lobby unregister:self.