PipeStream.st
author Claus Gittinger <cg@exept.de>
Thu, 02 Sep 1999 23:44:11 +0200
changeset 4670 21eec331e1e9
parent 4616 64dd3a9bebf5
child 5203 a1a9869b2d24
permissions -rw-r--r--
checkin from browser
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
     1
"
5
67342904af11 *** empty log message ***
claus
parents: 3
diff changeset
     2
 COPYRIGHT (c) 1989 by Claus Gittinger
159
514c749165c3 *** empty log message ***
claus
parents: 99
diff changeset
     3
	      All Rights Reserved
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
     4
a27a279701f8 Initial revision
claus
parents:
diff changeset
     5
 This software is furnished under a license and may be used
a27a279701f8 Initial revision
claus
parents:
diff changeset
     6
 only in accordance with the terms of that license and with the
a27a279701f8 Initial revision
claus
parents:
diff changeset
     7
 inclusion of the above copyright notice.   This software may not
a27a279701f8 Initial revision
claus
parents:
diff changeset
     8
 be provided or otherwise made available to, or used by, any
a27a279701f8 Initial revision
claus
parents:
diff changeset
     9
 other person.  No title to or ownership of the software is
a27a279701f8 Initial revision
claus
parents:
diff changeset
    10
 hereby transferred.
a27a279701f8 Initial revision
claus
parents:
diff changeset
    11
"
a27a279701f8 Initial revision
claus
parents:
diff changeset
    12
269
93162487a94b *** empty log message ***
claus
parents: 255
diff changeset
    13
NonPositionableExternalStream subclass:#PipeStream
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
    14
	instanceVariableNames:'commandString pid exitStatus exitSema exitAction'
1295
83f594f05c52 documentation
Claus Gittinger <cg@exept.de>
parents: 1133
diff changeset
    15
	classVariableNames:'BrokenPipeSignal'
83f594f05c52 documentation
Claus Gittinger <cg@exept.de>
parents: 1133
diff changeset
    16
	poolDictionaries:''
83f594f05c52 documentation
Claus Gittinger <cg@exept.de>
parents: 1133
diff changeset
    17
	category:'Streams-External'
88
81dacba7a63a *** empty log message ***
claus
parents: 85
diff changeset
    18
!
2
claus
parents: 1
diff changeset
    19
217
a0400fdbc933 *** empty log message ***
claus
parents: 180
diff changeset
    20
!PipeStream primitiveDefinitions!
88
81dacba7a63a *** empty log message ***
claus
parents: 85
diff changeset
    21
%{
437
claus
parents: 410
diff changeset
    22
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
    23
#if defined(WIN32)
793
3d441d66beeb NT changes
Claus Gittinger <cg@exept.de>
parents: 613
diff changeset
    24
# undef UNIX_LIKE
3d441d66beeb NT changes
Claus Gittinger <cg@exept.de>
parents: 613
diff changeset
    25
# define MSDOS_LIKE
3d441d66beeb NT changes
Claus Gittinger <cg@exept.de>
parents: 613
diff changeset
    26
#endif
3d441d66beeb NT changes
Claus Gittinger <cg@exept.de>
parents: 613
diff changeset
    27
88
81dacba7a63a *** empty log message ***
claus
parents: 85
diff changeset
    28
#include <stdio.h>
437
claus
parents: 410
diff changeset
    29
#define _STDIO_H_INCLUDED_
claus
parents: 410
diff changeset
    30
88
81dacba7a63a *** empty log message ***
claus
parents: 85
diff changeset
    31
#include <errno.h>
437
claus
parents: 410
diff changeset
    32
#define _ERRNO_H_INCLUDED_
claus
parents: 410
diff changeset
    33
88
81dacba7a63a *** empty log message ***
claus
parents: 85
diff changeset
    34
#ifndef transputer
81dacba7a63a *** empty log message ***
claus
parents: 85
diff changeset
    35
# include <sys/types.h>
81dacba7a63a *** empty log message ***
claus
parents: 85
diff changeset
    36
# include <sys/stat.h>
81dacba7a63a *** empty log message ***
claus
parents: 85
diff changeset
    37
#endif
230
0300c6797890 interrupt & blocking close
claus
parents: 217
diff changeset
    38
0300c6797890 interrupt & blocking close
claus
parents: 217
diff changeset
    39
/*
0300c6797890 interrupt & blocking close
claus
parents: 217
diff changeset
    40
 * on some systems errno is a macro ... check for it here
0300c6797890 interrupt & blocking close
claus
parents: 217
diff changeset
    41
 */
0300c6797890 interrupt & blocking close
claus
parents: 217
diff changeset
    42
#ifndef errno
0300c6797890 interrupt & blocking close
claus
parents: 217
diff changeset
    43
 extern errno;
0300c6797890 interrupt & blocking close
claus
parents: 217
diff changeset
    44
#endif
0300c6797890 interrupt & blocking close
claus
parents: 217
diff changeset
    45
1663
dd111ec142da *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 1662
diff changeset
    46
#ifdef LINUX
dd111ec142da *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 1662
diff changeset
    47
# define BUGGY_STDIO_LIB
dd111ec142da *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 1662
diff changeset
    48
#endif
dd111ec142da *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 1662
diff changeset
    49
88
81dacba7a63a *** empty log message ***
claus
parents: 85
diff changeset
    50
%}
180
c488255bd0be *** empty log message ***
claus
parents: 159
diff changeset
    51
! !
88
81dacba7a63a *** empty log message ***
claus
parents: 85
diff changeset
    52
325
claus
parents: 308
diff changeset
    53
!PipeStream primitiveFunctions!
claus
parents: 308
diff changeset
    54
%{
claus
parents: 308
diff changeset
    55
claus
parents: 308
diff changeset
    56
/*
2925
1a64228425ca *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 2896
diff changeset
    57
 * no longer needed - popen is useless ...
1a64228425ca *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 2896
diff changeset
    58
 */
1a64228425ca *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 2896
diff changeset
    59
#undef NEED_POPEN_WITH_VFORK
1a64228425ca *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 2896
diff changeset
    60
1a64228425ca *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 2896
diff changeset
    61
1a64228425ca *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 2896
diff changeset
    62
/*
325
claus
parents: 308
diff changeset
    63
 * some systems (i.e. ultrix) use fork;
claus
parents: 308
diff changeset
    64
 * were better off with a popen based on vfork ...
claus
parents: 308
diff changeset
    65
 */
claus
parents: 308
diff changeset
    66
#ifdef NEED_POPEN_WITH_VFORK
claus
parents: 308
diff changeset
    67
claus
parents: 308
diff changeset
    68
static int popen_pid = 0;
claus
parents: 308
diff changeset
    69
claus
parents: 308
diff changeset
    70
FILE *
claus
parents: 308
diff changeset
    71
popen(command, type)
claus
parents: 308
diff changeset
    72
/* const */ char *command;
claus
parents: 308
diff changeset
    73
/* const */ char *type;
claus
parents: 308
diff changeset
    74
{
claus
parents: 308
diff changeset
    75
    int pipes[2];
claus
parents: 308
diff changeset
    76
    int itype = (strcmp(type, "w") == 0 ? 1 : 0);
claus
parents: 308
diff changeset
    77
claus
parents: 308
diff changeset
    78
    if (pipe(pipes) == -1)
326
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    79
	return NULL;
325
claus
parents: 308
diff changeset
    80
claus
parents: 308
diff changeset
    81
    switch (popen_pid = vfork()) {
claus
parents: 308
diff changeset
    82
    case -1:
326
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    83
	(void)close(pipes[0]);
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    84
	(void)close(pipes[1]);
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    85
	return NULL;
325
claus
parents: 308
diff changeset
    86
claus
parents: 308
diff changeset
    87
    case 0:
326
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    88
	if (itype) {
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    89
	    dup2(pipes[0], fileno(stdin));
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    90
	    close(pipes[1]);
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    91
	} else {
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    92
	    dup2(pipes[1], fileno(stdout));
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    93
	    close(pipes[0]);
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    94
	}
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    95
	execl("/bin/sh", "/bin/sh", "-c", command, 0);
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    96
	fprintf(stderr, "XRN Error: failed the execlp\n");
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    97
	_exit(-1);
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
    98
	/* NOTREACHED */
325
claus
parents: 308
diff changeset
    99
claus
parents: 308
diff changeset
   100
    default:
326
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   101
	    if (itype) {
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   102
		close(pipes[0]);
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   103
		return fdopen(pipes[1], "w");
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   104
	    } else {
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   105
		close(pipes[1]);
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   106
		return fdopen(pipes[0], "r");
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   107
	    }
325
claus
parents: 308
diff changeset
   108
    }
claus
parents: 308
diff changeset
   109
}
claus
parents: 308
diff changeset
   110
claus
parents: 308
diff changeset
   111
int
claus
parents: 308
diff changeset
   112
pclose(str)
claus
parents: 308
diff changeset
   113
FILE *str;
claus
parents: 308
diff changeset
   114
{
claus
parents: 308
diff changeset
   115
    int pd = 0;
claus
parents: 308
diff changeset
   116
    int status;
claus
parents: 308
diff changeset
   117
    int err;
claus
parents: 308
diff changeset
   118
claus
parents: 308
diff changeset
   119
    err = fclose(str);
claus
parents: 308
diff changeset
   120
claus
parents: 308
diff changeset
   121
    do {
326
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   122
	if ((pd = wait(&status)) == -1)
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   123
	{
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   124
		err = EOF;
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   125
		break;
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   126
	}
325
claus
parents: 308
diff changeset
   127
    } while (pd !=  popen_pid);
claus
parents: 308
diff changeset
   128
claus
parents: 308
diff changeset
   129
    if (err == EOF)
326
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   130
	return  -1;
325
claus
parents: 308
diff changeset
   131
claus
parents: 308
diff changeset
   132
    if (status)
326
d2902942491d *** empty log message ***
claus
parents: 325
diff changeset
   133
	status >>= 8;   /* exit status in high byte */
325
claus
parents: 308
diff changeset
   134
claus
parents: 308
diff changeset
   135
    return status;
claus
parents: 308
diff changeset
   136
}
claus
parents: 308
diff changeset
   137
2925
1a64228425ca *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 2896
diff changeset
   138
#endif /* NEED_POPEN_WITH_VFORK */
325
claus
parents: 308
diff changeset
   139
claus
parents: 308
diff changeset
   140
%}
claus
parents: 308
diff changeset
   141
! !
claus
parents: 308
diff changeset
   142
2266
a94af740c68a checkin from browser
Claus Gittinger <cg@exept.de>
parents: 2121
diff changeset
   143
!PipeStream class methodsFor:'documentation'!
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   144
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   145
copyright
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   146
"
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   147
 COPYRIGHT (c) 1989 by Claus Gittinger
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   148
	      All Rights Reserved
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   149
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   150
 This software is furnished under a license and may be used
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   151
 only in accordance with the terms of that license and with the
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   152
 inclusion of the above copyright notice.   This software may not
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   153
 be provided or otherwise made available to, or used by, any
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   154
 other person.  No title to or ownership of the software is
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   155
 hereby transferred.
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   156
"
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   157
!
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   158
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   159
documentation
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   160
"
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   161
    Pipestreams allow reading or writing from/to a unix command.
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   162
    For example, to get a stream reading the output of an 'ls -l'
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   163
    command, a PipeStream can be created with:
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   164
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   165
	PipeStream readingFrom:'ls -l'
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   166
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   167
    the characters of the commands output can be read using the
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   168
    standard stream messages as next, nextLine etc.
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   169
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   170
    If a writing pipeStream is written to, after the command has finished,
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   171
    UNIX will generate an error-signal (SIGPIPE), which will raise the BrokenPipeSignal. 
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   172
    Thus, to handle this condition correctly, the following code is suggested:
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   173
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   174
	|p|
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   175
	p := PipeStream writingTo:'echo hello'.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   176
	PipeStream brokenPipeSignal handle:[:ex |
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   177
	    'broken pipe' printNewline.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   178
	    p shutDown.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   179
	    ex return
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   180
	] do:[
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   181
	    p nextPutLine:'oops'.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   182
	   'after write' printNewline.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   183
	    p close.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   184
	   'after close' printNewline
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   185
	]
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   186
1663
dd111ec142da *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 1662
diff changeset
   187
    Notice, that iff the Stream is buffered, the Signal may occur some time after
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   188
    the write - or even at close time; to avoid a recursive signal in the exception
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   189
    handler, a #shutDown is useful there; if you use close in the handler, this would
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   190
    try to send any buffered output to the pipe, leading to another brokenPipe exception.
1295
83f594f05c52 documentation
Claus Gittinger <cg@exept.de>
parents: 1133
diff changeset
   191
1662
ce26ca3d837c linux stdio does not work with buffered pipes
Claus Gittinger <cg@exept.de>
parents: 1648
diff changeset
   192
    Buffered pipes do not work with Linux - the stdio library seems to be
ce26ca3d837c linux stdio does not work with buffered pipes
Claus Gittinger <cg@exept.de>
parents: 1648
diff changeset
   193
    buggy (trying to restart the read ...)
ce26ca3d837c linux stdio does not work with buffered pipes
Claus Gittinger <cg@exept.de>
parents: 1648
diff changeset
   194
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   195
    Currently, no filtering pipeStreams (i.e. both reading AND writing) are provided.
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   196
    However, if you look at how things are setup, this can be implemented using the
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   197
    low level primitives #mapePipe and #executeCommand from the OS class protocol.
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   198
1295
83f594f05c52 documentation
Claus Gittinger <cg@exept.de>
parents: 1133
diff changeset
   199
    [author:]
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   200
	Claus Gittinger
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   201
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   202
    [see also:]
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   203
	ExternalStream FileStream Socket
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   204
	OperatingSystem
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   205
"
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   206
! !
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   207
2266
a94af740c68a checkin from browser
Claus Gittinger <cg@exept.de>
parents: 2121
diff changeset
   208
!PipeStream class methodsFor:'initialization'!
2
claus
parents: 1
diff changeset
   209
claus
parents: 1
diff changeset
   210
initialize
claus
parents: 1
diff changeset
   211
    "setup the signal"
claus
parents: 1
diff changeset
   212
57
db9677479d35 *** empty log message ***
claus
parents: 49
diff changeset
   213
    BrokenPipeSignal isNil ifTrue:[
582
21f08116b28d BrokenPipeSignal now a child of WriteErrorSignal
Claus Gittinger <cg@exept.de>
parents: 530
diff changeset
   214
	BrokenPipeSignal := WriteErrorSignal newSignalMayProceed:true.
159
514c749165c3 *** empty log message ***
claus
parents: 99
diff changeset
   215
	BrokenPipeSignal nameClass:self message:#brokenPipeSignal.
514c749165c3 *** empty log message ***
claus
parents: 99
diff changeset
   216
	BrokenPipeSignal notifierString:'write on a pipe with no one to read'.
57
db9677479d35 *** empty log message ***
claus
parents: 49
diff changeset
   217
    ]
2
claus
parents: 1
diff changeset
   218
! !
claus
parents: 1
diff changeset
   219
2266
a94af740c68a checkin from browser
Claus Gittinger <cg@exept.de>
parents: 2121
diff changeset
   220
!PipeStream class methodsFor:'instance creation'!
2
claus
parents: 1
diff changeset
   221
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   222
readingFrom:commandString
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   223
    "create and return a new pipeStream which can read from the unix command
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   224
     given by command. 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   225
     The commands error output is send to my own error output."
2
claus
parents: 1
diff changeset
   226
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   227
    ^ self 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   228
	readingFrom:commandString 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   229
	errorDisposition:#stderr 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   230
	inDirectory:nil
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   231
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   232
    "unix:
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   233
	PipeStream readingFrom:'ls -l'.
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   234
    "
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   235
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   236
    "
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   237
	p := PipeStream readingFrom:'ls -l'.
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   238
	Transcript showCR:p nextLine.
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   239
	p close
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   240
    "
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   241
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   242
    "
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   243
	|s|
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   244
	s := PipeStream readingFrom:'sh -c sleep\ 600'.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   245
	(Delay forSeconds:2) wait.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   246
	s shutDown
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   247
    "
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   248
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   249
    "vms:
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   250
	PipeStream readingFrom:'dir'.
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   251
    "
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   252
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   253
    "
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   254
	|p|
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   255
	p := PipeStream readingFrom:'dir'.
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   256
	Transcript showCR:p nextLine.
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   257
	p close
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   258
    "
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   259
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   260
    "msdos:
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   261
	PipeStream readingFrom:'dir'.
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   262
    "
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   263
    "
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   264
	|p|
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   265
	p := PipeStream readingFrom:'dir'.
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   266
	Transcript showCR:p nextLine.
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   267
	p close
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   268
    "
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   269
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   270
    "Modified: 24.4.1996 / 09:09:25 / stefan"
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   271
!
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
   272
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   273
readingFrom:commandString errorDisposition:errorDisposition inDirectory:aDirectory
2985
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   274
    "similar to #readingFrom, but changes the directory while
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   275
     executing the command. Use this if a command is to be
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   276
     executed in another directory, to avoid any OS dependencies
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   277
     in your code.
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   278
     errorDisposition may be one of #discard, #inline or #stderr (default).
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   279
     #discard causes stderr to be discarded (/dev/null), 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   280
     #inline causes it to be merged into the PipeStream and
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   281
     #stderr causes it to be written to smalltalks own stderr.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   282
     Nil is treated like #stderr"
2985
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   283
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   284
    ^ self basicNew
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   285
	openPipeFor:commandString 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   286
	withMode:'r' 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   287
	errorDisposition:errorDisposition 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   288
	inDirectory:aDirectory
2985
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   289
!
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   290
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   291
readingFrom:commandString inDirectory:aDirectory
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   292
    "similar to #readingFrom, but changes the directory while
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   293
     executing the command. Use this if a command is to be
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   294
     executed in another directory, to avoid any OS dependencies
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   295
     in your code.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   296
     The commands error output is send to my own error output."
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   297
3563
16ccd4cefcbe *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3533
diff changeset
   298
     ^ self 
16ccd4cefcbe *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3533
diff changeset
   299
	readingFrom:commandString
16ccd4cefcbe *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3533
diff changeset
   300
	errorDisposition:#stderr 
16ccd4cefcbe *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3533
diff changeset
   301
	inDirectory:aDirectory
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   302
2985
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   303
    "Modified: 24.9.1997 / 09:33:48 / stefan"
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   304
!
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   305
2
claus
parents: 1
diff changeset
   306
writingTo:commandString
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
   307
    "create and return a new pipeStream which can write to the unix command
a27a279701f8 Initial revision
claus
parents:
diff changeset
   308
     given by command."
a27a279701f8 Initial revision
claus
parents:
diff changeset
   309
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   310
    ^ self 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   311
	writingTo:commandString errorDisposition:#stderr inDirectory:nil
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
   312
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   313
    "unix:
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   314
	 PipeStream writingTo:'sort'
2966
856dfc8a294a lots of VMS changes
Claus Gittinger <cg@exept.de>
parents: 2961
diff changeset
   315
    "
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   316
!
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   317
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   318
writingTo:commandString errorDisposition:errorDisposition inDirectory:aDirectory
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   319
    "similar to #writingTo, but changes the directory while
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   320
     executing the command. Use this if a command is to be
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   321
     executed in another directory, to avoid any OS dependencies
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   322
     in your code.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   323
     errorDisposition may be one of #discard, #inline or #stderr (default).
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   324
     #discard causes stderr to be discarded (/dev/null), 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   325
     #inline causes it to be written to smalltalks own stdout and
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   326
     #stderr causes it to be written to smalltalks own stderr.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   327
     Nil is treated like #stderr"
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   328
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   329
    ^ self basicNew
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   330
	openPipeFor:commandString 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   331
	withMode:'w' 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   332
	errorDisposition:errorDisposition 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   333
	inDirectory:aDirectory
4526
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   334
!
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   335
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   336
writingTo:commandString inDirectory:aDirectory
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   337
    "create and return a new pipeStream which can write to the unix command
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   338
     given by command. The command is executed in the given directory."
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   339
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   340
    ^ self 
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   341
	writingTo:commandString errorDisposition:#stderr inDirectory:aDirectory
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   342
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   343
    "unix:
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   344
	 PipeStream writingTo:'sort'
a42dc8e09586 errorOpen renamed to errorAlreadyOpen
Claus Gittinger <cg@exept.de>
parents: 4202
diff changeset
   345
    "
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   346
! !
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   347
2266
a94af740c68a checkin from browser
Claus Gittinger <cg@exept.de>
parents: 2121
diff changeset
   348
!PipeStream class methodsFor:'Signal constants'!
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
   349
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   350
brokenPipeSignal
2985
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   351
    "return the signal used to handle SIGPIPE unix-signals.
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   352
     Since SIGPIPE is asynchronous, we can't decide which smalltalk process
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   353
     should handle BrokenPipeSignal. So the system doesn't raise 
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   354
     BrokenPipeSignal for SIGPIPE any longer."
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
   355
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   356
    ^ BrokenPipeSignal
2985
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   357
eff9e86dd2f9 New method #readingFrom:errorDisposition:inDirectory.
Stefan Vogel <sv@exept.de>
parents: 2976
diff changeset
   358
    "Modified: 24.9.1997 / 09:43:23 / stefan"
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
   359
! !
a27a279701f8 Initial revision
claus
parents:
diff changeset
   360
99
afba01fbe15c added access method for commandString
claus
parents: 93
diff changeset
   361
!PipeStream methodsFor:'accessing'!
afba01fbe15c added access method for commandString
claus
parents: 93
diff changeset
   362
afba01fbe15c added access method for commandString
claus
parents: 93
diff changeset
   363
commandString
afba01fbe15c added access method for commandString
claus
parents: 93
diff changeset
   364
    "return the command string"
afba01fbe15c added access method for commandString
claus
parents: 93
diff changeset
   365
afba01fbe15c added access method for commandString
claus
parents: 93
diff changeset
   366
    ^ commandString
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   367
!
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   368
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   369
exitStatus
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   370
    "return exitStatus"
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   371
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   372
    ^ exitStatus
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   373
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   374
    "Created: 28.12.1995 / 14:54:41 / stefan"
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   375
!
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   376
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   377
pid
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   378
    "return pid"
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   379
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   380
    ^ pid
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   381
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   382
    "Created: 28.12.1995 / 14:54:30 / stefan"
99
afba01fbe15c added access method for commandString
claus
parents: 93
diff changeset
   383
! !
afba01fbe15c added access method for commandString
claus
parents: 93
diff changeset
   384
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
   385
!PipeStream methodsFor:'instance release'!
a27a279701f8 Initial revision
claus
parents:
diff changeset
   386
a27a279701f8 Initial revision
claus
parents:
diff changeset
   387
closeFile
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   388
    "low level close
230
0300c6797890 interrupt & blocking close
claus
parents: 217
diff changeset
   389
     This waits for the command to finish. 
0300c6797890 interrupt & blocking close
claus
parents: 217
diff changeset
   390
     Use shutDown for a fast (nonBlocking) close."
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
   391
3834
93ec07316a98 oops - must nil pid when terminating the process
Claus Gittinger <cg@exept.de>
parents: 3833
diff changeset
   392
    |tpid|
93ec07316a98 oops - must nil pid when terminating the process
Claus Gittinger <cg@exept.de>
parents: 3833
diff changeset
   393
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   394
    filePointer notNil ifTrue:[
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   395
	(tpid := pid) notNil ifTrue:[
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   396
	    OperatingSystem isMSDOSlike ifTrue:[
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   397
		OperatingSystem terminateProcess:tpid.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   398
		OperatingSystem terminateProcessGroup:tpid.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   399
		pid := nil.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   400
	    ]
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   401
	].
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   402
	super closeFile.
3834
93ec07316a98 oops - must nil pid when terminating the process
Claus Gittinger <cg@exept.de>
parents: 3833
diff changeset
   403
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   404
	filePointer := nil.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   405
	pid notNil ifTrue:[
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   406
	    [
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   407
		pid notNil ifTrue:[
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   408
		    exitSema wait.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   409
		]
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   410
	    ] valueUninterruptably
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   411
	].
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   412
    ].
3833
3ae90f8da01a terminate process BEFORE closing the pipe under win32
Claus Gittinger <cg@exept.de>
parents: 3791
diff changeset
   413
3834
93ec07316a98 oops - must nil pid when terminating the process
Claus Gittinger <cg@exept.de>
parents: 3833
diff changeset
   414
    "Modified: / 12.9.1998 / 16:51:04 / cg"
369
claus
parents: 362
diff changeset
   415
!
claus
parents: 362
diff changeset
   416
claus
parents: 362
diff changeset
   417
closeFileDescriptor
claus
parents: 362
diff changeset
   418
    "alternative very low level close 
claus
parents: 362
diff changeset
   419
     This closes the underlying OS-fileDescriptor 
claus
parents: 362
diff changeset
   420
     - and will NOT write any buffered data to the stream.
claus
parents: 362
diff changeset
   421
     You have been warned."
claus
parents: 362
diff changeset
   422
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   423
    |action|
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   424
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   425
%{  
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   426
#if !defined(transputer)
369
claus
parents: 362
diff changeset
   427
    OBJ fp;
claus
parents: 362
diff changeset
   428
    FILE *f;
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   429
    extern close();
369
claus
parents: 362
diff changeset
   430
1133
961f2b095c22 underline cleanup
Claus Gittinger <cg@exept.de>
parents: 793
diff changeset
   431
    if ((fp = __INST(filePointer)) != nil) {
961f2b095c22 underline cleanup
Claus Gittinger <cg@exept.de>
parents: 793
diff changeset
   432
	__INST(filePointer) = nil;
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   433
	f = __FILEVal(fp);
3744
e2c57149f3b4 *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3563
diff changeset
   434
#ifdef WIN32
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   435
	__STX_C_CALL1((void*)close, (void*)fileno(f));
3744
e2c57149f3b4 *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3563
diff changeset
   436
#else
369
claus
parents: 362
diff changeset
   437
	__BEGIN_INTERRUPTABLE__
claus
parents: 362
diff changeset
   438
	close(fileno(f));
claus
parents: 362
diff changeset
   439
	__END_INTERRUPTABLE__
3744
e2c57149f3b4 *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3563
diff changeset
   440
#endif
369
claus
parents: 362
diff changeset
   441
    }
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   442
#endif /* not transputer  */
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   443
%}.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   444
    exitAction notNil ifTrue:[
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   445
	action := exitAction.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   446
	exitAction := nil.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   447
	action value.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   448
    ]
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   449
!
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   450
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   451
disposed
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   452
    "redefined to avoid blocking in close."
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   453
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   454
    self shutDown
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   455
!
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   456
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   457
shutDown
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   458
    "close the Stream, ignoring any broken-pipe errors.
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   459
     Terminate the command"
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   460
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   461
    BrokenPipeSignal catch:[
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   462
	|tpid|
3833
3ae90f8da01a terminate process BEFORE closing the pipe under win32
Claus Gittinger <cg@exept.de>
parents: 3791
diff changeset
   463
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   464
	Lobby unregister:self.
3833
3ae90f8da01a terminate process BEFORE closing the pipe under win32
Claus Gittinger <cg@exept.de>
parents: 3791
diff changeset
   465
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   466
	"/ terminate first under windows.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   467
	(tpid := pid) notNil ifTrue:[      "copy pid to avoid race"
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   468
	    OperatingSystem isMSDOSlike ifTrue:[
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   469
		OperatingSystem terminateProcess:tpid.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   470
		OperatingSystem terminateProcessGroup:tpid.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   471
		pid := nil.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   472
	    ].
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   473
	].
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   474
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   475
	self closeFileDescriptor.
3834
93ec07316a98 oops - must nil pid when terminating the process
Claus Gittinger <cg@exept.de>
parents: 3833
diff changeset
   476
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   477
	"/ terminate last under unix.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   478
	(tpid := pid) notNil ifTrue:[      "copy pid to avoid race"
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   479
	    "/
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   480
	    "/ Terminate both the process and group, just in case the
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   481
	    "/ operating system does not support process groups.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   482
	    "/
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   483
	    OperatingSystem terminateProcess:tpid.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   484
	    OperatingSystem terminateProcessGroup:tpid.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   485
	    pid := nil.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   486
	].
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   487
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   488
    ]
1648
faa891d2c1b0 Use OperatingSystem executeCommand:... instead of popen().
Stefan Vogel <sv@exept.de>
parents: 1295
diff changeset
   489
3833
3ae90f8da01a terminate process BEFORE closing the pipe under win32
Claus Gittinger <cg@exept.de>
parents: 3791
diff changeset
   490
    "Modified: / 23.5.1996 / 09:15:41 / stefan"
3834
93ec07316a98 oops - must nil pid when terminating the process
Claus Gittinger <cg@exept.de>
parents: 3833
diff changeset
   491
    "Modified: / 12.9.1998 / 16:50:18 / cg"
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
   492
! !
a27a279701f8 Initial revision
claus
parents:
diff changeset
   493
a27a279701f8 Initial revision
claus
parents:
diff changeset
   494
!PipeStream methodsFor:'private'!
a27a279701f8 Initial revision
claus
parents:
diff changeset
   495
2969
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   496
exitAction:aBlock
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   497
    "define a block to be evaluated when the pipe is closed.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   498
     This is only used with VMS, to remove any temporary COM file.
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   499
     (see readingFrom:inDirectory:)"
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   500
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   501
    exitAction := aBlock
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   502
!
1fcf6dfb6004 VMS pipes in another directory
Claus Gittinger <cg@exept.de>
parents: 2966
diff changeset
   503
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   504
openPipeFor:aCommandString withMode:rwMode errorDisposition:err inDirectory:aDirectory
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   505
    "open a pipe to the OS command in commandString; 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   506
     rwMode may be 'r' or 'w'"
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   507
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   508
    |blocked pipeFdArray execFdArray execFd myFd shellAndArgs
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   509
     shellPath shellArgs closeFdArray mbx mbxName 
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   510
     realCmd execDirectory tmpComFile nullOutput|
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   511
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   512
    filePointer notNil ifTrue:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   513
	"the pipe was already open ...
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   514
	 this should (can) not happen."
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   515
	^ self errorAlreadyOpen
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   516
    ].
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   517
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   518
    rwMode = 'r' ifTrue:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   519
	mode := #readonly. didWrite := false.
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   520
    ] ifFalse:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   521
	mode := #writeonly. didWrite := true.
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   522
    ].
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   523
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   524
    lastErrorNumber := nil.
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   525
    exitStatus := nil.
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   526
    exitSema := Semaphore new name:'pipe exitSema'.
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   527
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   528
    realCmd := aCommandString.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   529
    execDirectory := aDirectory.
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   530
3791
76ea6c85ca1f *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3773
diff changeset
   531
    OperatingSystem isVMSlike ifTrue:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   532
	"/
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   533
	"/ the generated COM-file includes a 'set default'
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   534
	"/
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   535
	tmpComFile := OperatingSystem createCOMFileForVMSCommand:aCommandString in:aDirectory.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   536
	realCmd := '@' , tmpComFile osName.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   537
	execDirectory := nil.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   538
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   539
	mbx := OperatingSystem createMailBox.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   540
	mbx isNil ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   541
	    lastErrorNumber := OperatingSystem currentErrorNumber.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   542
	    tmpComFile delete.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   543
	    ^ self openError
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   544
	].
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   545
	mbxName := OperatingSystem mailBoxNameOf:mbx.
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   546
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   547
	"/ 'mailBox is ' print. mbx print. ' name is ' print. mbxName printCR.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   548
	shellPath := ''.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   549
	shellArgs := realCmd.
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   550
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   551
	rwMode = 'r' ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   552
	    execFdArray := Array with:0 with:mbx with:2.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   553
	    (err == #inline or:[err == #stdout]) ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   554
		execFdArray at:3 put:mbx
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   555
	    ]
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   556
	] ifFalse:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   557
	    execFdArray := Array with:mbx with:1 with:2.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   558
	    (err == #inline or:[err == #stdout]) ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   559
		execFdArray at:3 put:1
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   560
	    ]
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   561
	].
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   562
	closeFdArray := nil.
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   563
    ] ifFalse:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   564
	OperatingSystem isUNIXlike ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   565
	    aDirectory notNil ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   566
		"/ unix - prepend a 'cd' to the command
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   567
		realCmd := 'cd ' , aDirectory asFilename name, '; ' , aCommandString.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   568
	    ] ifFalse:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   569
		realCmd := aCommandString
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   570
	    ].
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   571
	    execDirectory := nil.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   572
	].
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   573
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   574
	pipeFdArray := OperatingSystem makePipe.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   575
	pipeFdArray isNil ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   576
	    lastErrorNumber := OperatingSystem currentErrorNumber.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   577
	    ^ self openError
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   578
	].
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   579
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   580
	shellAndArgs := OperatingSystem commandAndArgsForOSCommand:realCmd.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   581
	shellPath := shellAndArgs at:1.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   582
	shellArgs := shellAndArgs at:2.
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   583
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   584
	rwMode = 'r' ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   585
	    myFd := pipeFdArray at:1.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   586
	    execFd := pipeFdArray at:2.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   587
	    execFdArray := Array with:0 with:execFd with:2.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   588
	    (err == #inline or:[err == #stdout]) ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   589
		execFdArray at:3 put:execFd
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   590
	    ]
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   591
	] ifFalse:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   592
	    myFd := pipeFdArray at:2.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   593
	    execFd := pipeFdArray at:1.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   594
	    execFdArray := Array with:execFd with:1 with:2.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   595
	    (err == #inline or:[err == #stdout]) ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   596
		execFdArray at:3 put:1
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   597
	    ]
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   598
	].
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   599
	closeFdArray := Array with:myFd.
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   600
    ].
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   601
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   602
    err == #discard ifTrue:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   603
	nullOutput := Filename nullDevice writeStream.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   604
	execFdArray at:3 put:nullOutput fileDescriptor
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   605
    ].
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   606
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   607
    "/ must block here, to avoid races due to early finishing
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   608
    "/ subprocesses ...
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   609
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   610
    blocked := OperatingSystem blockInterrupts.
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   611
3563
16ccd4cefcbe *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3533
diff changeset
   612
    pid := Processor 
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   613
	       monitor:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   614
		  OperatingSystem 
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   615
		      exec:shellPath
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   616
		      withArguments:shellArgs
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   617
		      fileDescriptors:execFdArray
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   618
		      closeDescriptors:closeFdArray
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   619
		      fork:true
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   620
		      newPgrp:true
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   621
		      inDirectory:execDirectory.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   622
	       ]
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   623
	       action:[:status |
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   624
		  status stillAlive ifFalse:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   625
		      exitStatus := status.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   626
		      OperatingSystem closePid:pid.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   627
		      pid := nil.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   628
		      exitSema signal.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   629
		  ].
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   630
	       ].
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   631
3791
76ea6c85ca1f *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3773
diff changeset
   632
    OperatingSystem isVMSlike ifFalse:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   633
	OperatingSystem closeFd:execFd.
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   634
    ].
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   635
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   636
    nullOutput notNil ifTrue:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   637
	nullOutput closeFile
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   638
    ].
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   639
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   640
    pid notNil ifTrue:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   641
	OperatingSystem isVMSlike ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   642
	    "/
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   643
	    "/ reopen the mailbox as a file ...
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   644
	    "/
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   645
	    mbxName := OperatingSystem mailBoxNameOf:mbx.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   646
	    mbxName notNil ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   647
		super open:mbxName withMode:rwMode.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   648
		exitAction := [tmpComFile delete].
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   649
	    ].
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   650
	] ifFalse:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   651
	    self setFileDescriptor:myFd mode:rwMode.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   652
	]
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   653
    ] ifFalse:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   654
	lastErrorNumber := OperatingSystem currentErrorNumber.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   655
	OperatingSystem isVMSlike ifTrue:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   656
	    OperatingSystem destroyMailBox:mbx.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   657
	    tmpComFile delete.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   658
	] ifFalse:[
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   659
	    OperatingSystem closeFd:myFd.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   660
	].
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   661
    ].
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   662
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   663
    blocked ifFalse:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   664
	OperatingSystem unblockInterrupts
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   665
    ].
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   666
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   667
    lastErrorNumber notNil ifTrue:[
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   668
	"
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   669
	 the pipe open failed for some reason ...
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   670
	 ... this may be either due to an invalid command string,
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   671
	 or due to the system running out of memory (when forking
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   672
	 the unix process)
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   673
	"
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   674
	exitAction value.
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   675
	^ self openError
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   676
    ].
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   677
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   678
    commandString := realCmd.
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   679
%{
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   680
    /* LINUX stdio is corrupt here ... */
3744
e2c57149f3b4 *** empty log message ***
Claus Gittinger <cg@exept.de>
parents: 3563
diff changeset
   681
#if defined(BUGGY_STDIO_LIB) || defined(WIN32)
3296
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   682
    __INST(buffered) = false;
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   683
#else
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   684
    __INST(buffered) = true;
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   685
#endif
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   686
%}.
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   687
    position := 1.
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   688
    hitEOF := false.
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   689
    binary := false.
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   690
    Lobby register:self.
bd2da537678b md's WIN32 changes
Claus Gittinger <cg@exept.de>
parents: 3196
diff changeset
   691
4202
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   692
    "Modified: / 23.4.1996 / 17:05:59 / stefan"
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   693
    "Modified: / 28.1.1998 / 14:47:34 / md"
b9f85ebd2e38 generalized errorDisposition (for other OS's);
Claus Gittinger <cg@exept.de>
parents: 4125
diff changeset
   694
    "Created: / 19.5.1999 / 12:28:54 / cg"
1
a27a279701f8 Initial revision
claus
parents:
diff changeset
   695
! !
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   696
2266
a94af740c68a checkin from browser
Claus Gittinger <cg@exept.de>
parents: 2121
diff changeset
   697
!PipeStream class methodsFor:'documentation'!
1295
83f594f05c52 documentation
Claus Gittinger <cg@exept.de>
parents: 1133
diff changeset
   698
83f594f05c52 documentation
Claus Gittinger <cg@exept.de>
parents: 1133
diff changeset
   699
version
4616
64dd3a9bebf5 *** empty log message ***
ps
parents: 4526
diff changeset
   700
    ^ '$Header: /cvs/stx/stx/libbasic/PipeStream.st,v 1.80 1999-08-20 09:15:28 ps Exp $'
1295
83f594f05c52 documentation
Claus Gittinger <cg@exept.de>
parents: 1133
diff changeset
   701
! !
613
0af19c3594fc checkin from browser
Claus Gittinger <cg@exept.de>
parents: 582
diff changeset
   702
PipeStream initialize!