1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_sal.hxx"
26*b1cdbd2cSJim Jagielski
27*b1cdbd2cSJim Jagielski
28*b1cdbd2cSJim Jagielski #include <stdio.h>
29*b1cdbd2cSJim Jagielski #include <stdlib.h>
30*b1cdbd2cSJim Jagielski #include <string.h>
31*b1cdbd2cSJim Jagielski
32*b1cdbd2cSJim Jagielski #include <osl/pipe.h>
33*b1cdbd2cSJim Jagielski #include <osl/process.h>
34*b1cdbd2cSJim Jagielski #include <rtl/ustring.h>
35*b1cdbd2cSJim Jagielski
36*b1cdbd2cSJim Jagielski // eindeutiger Name f�r die Pipe
37*b1cdbd2cSJim Jagielski const char pszPipeName[] = "TestPipe";
38*b1cdbd2cSJim Jagielski const char szTestString[] = "This is a test";
39*b1cdbd2cSJim Jagielski char szBuffer[256];
40*b1cdbd2cSJim Jagielski
41*b1cdbd2cSJim Jagielski const char * cp;
42*b1cdbd2cSJim Jagielski Size_t n;
43*b1cdbd2cSJim Jagielski sSize_t nChars;
44*b1cdbd2cSJim Jagielski
45*b1cdbd2cSJim Jagielski // osl specific variables
46*b1cdbd2cSJim Jagielski oslPipe Pipe;
47*b1cdbd2cSJim Jagielski oslPipe C1Pipe;
48*b1cdbd2cSJim Jagielski oslProcess Process = NULL;
49*b1cdbd2cSJim Jagielski oslProcessError ProcessError;
50*b1cdbd2cSJim Jagielski oslProcessInfo ProcessInfo;
51*b1cdbd2cSJim Jagielski
fail(const char * pszText,int retval)52*b1cdbd2cSJim Jagielski void fail( const char * pszText, int retval )
53*b1cdbd2cSJim Jagielski {
54*b1cdbd2cSJim Jagielski fprintf( stderr, "TestPipe Server: %s", pszText );
55*b1cdbd2cSJim Jagielski fprintf( stderr, "TestPipe Server: test failed, ErrNo: %d.\n", retval );
56*b1cdbd2cSJim Jagielski
57*b1cdbd2cSJim Jagielski if( Process ) osl_freeProcessHandle( Process );
58*b1cdbd2cSJim Jagielski exit( retval );
59*b1cdbd2cSJim Jagielski }
60*b1cdbd2cSJim Jagielski
61*b1cdbd2cSJim Jagielski
62*b1cdbd2cSJim Jagielski
63*b1cdbd2cSJim Jagielski /*
64*b1cdbd2cSJim Jagielski * Teste die Pipe-Implementation in osl
65*b1cdbd2cSJim Jagielski */
66*b1cdbd2cSJim Jagielski
main(int argc,const char * argv[])67*b1cdbd2cSJim Jagielski int main (int argc, const char *argv[])
68*b1cdbd2cSJim Jagielski {
69*b1cdbd2cSJim Jagielski // erzeuge die Pipe
70*b1cdbd2cSJim Jagielski rtl_uString* ustrPipeName=0;
71*b1cdbd2cSJim Jagielski rtl_uString* ustrExeName=0;
72*b1cdbd2cSJim Jagielski
73*b1cdbd2cSJim Jagielski
74*b1cdbd2cSJim Jagielski rtl_uString_newFromAscii(&ustrPipeName,pszPipeName);
75*b1cdbd2cSJim Jagielski rtl_uString_newFromAscii(&ustrExeName, "//./tmp/testpip2.exe");
76*b1cdbd2cSJim Jagielski
77*b1cdbd2cSJim Jagielski Pipe = osl_createPipe( ustrPipeName, osl_Pipe_CREATE, 0 );
78*b1cdbd2cSJim Jagielski
79*b1cdbd2cSJim Jagielski if( !Pipe )
80*b1cdbd2cSJim Jagielski fail( "unable to create Pipe.\n",
81*b1cdbd2cSJim Jagielski osl_getLastPipeError(NULL));
82*b1cdbd2cSJim Jagielski
83*b1cdbd2cSJim Jagielski // starte client process
84*b1cdbd2cSJim Jagielski ProcessError = osl_executeProcess( ustrExeName,
85*b1cdbd2cSJim Jagielski NULL,
86*b1cdbd2cSJim Jagielski 0,
87*b1cdbd2cSJim Jagielski osl_Process_NORMAL,
88*b1cdbd2cSJim Jagielski 0,
89*b1cdbd2cSJim Jagielski NULL,
90*b1cdbd2cSJim Jagielski NULL,
91*b1cdbd2cSJim Jagielski 0,
92*b1cdbd2cSJim Jagielski NULL,
93*b1cdbd2cSJim Jagielski &Process );
94*b1cdbd2cSJim Jagielski
95*b1cdbd2cSJim Jagielski if( ProcessError != osl_Process_E_None )
96*b1cdbd2cSJim Jagielski fail( "unable to start client.\n", ProcessError );
97*b1cdbd2cSJim Jagielski
98*b1cdbd2cSJim Jagielski // wait for connection
99*b1cdbd2cSJim Jagielski C1Pipe = osl_acceptPipe( Pipe );
100*b1cdbd2cSJim Jagielski
101*b1cdbd2cSJim Jagielski if( !C1Pipe )
102*b1cdbd2cSJim Jagielski fail( "unable to connect to client.\n",
103*b1cdbd2cSJim Jagielski osl_getLastPipeError( Pipe ));
104*b1cdbd2cSJim Jagielski
105*b1cdbd2cSJim Jagielski
106*b1cdbd2cSJim Jagielski if( argc > 1 )
107*b1cdbd2cSJim Jagielski {
108*b1cdbd2cSJim Jagielski cp = argv[1];
109*b1cdbd2cSJim Jagielski n = strlen( cp ) + 1;
110*b1cdbd2cSJim Jagielski }
111*b1cdbd2cSJim Jagielski else
112*b1cdbd2cSJim Jagielski {
113*b1cdbd2cSJim Jagielski cp = szTestString;
114*b1cdbd2cSJim Jagielski n = sizeof(szTestString);
115*b1cdbd2cSJim Jagielski }
116*b1cdbd2cSJim Jagielski
117*b1cdbd2cSJim Jagielski // sende TestString zum Client
118*b1cdbd2cSJim Jagielski nChars = osl_sendPipe( C1Pipe, cp, n );
119*b1cdbd2cSJim Jagielski
120*b1cdbd2cSJim Jagielski if( nChars < 0 )
121*b1cdbd2cSJim Jagielski fail( "unable to write on pipe.\n",
122*b1cdbd2cSJim Jagielski osl_getLastPipeError( Pipe ) );
123*b1cdbd2cSJim Jagielski
124*b1cdbd2cSJim Jagielski // empfange Daten vom Server
125*b1cdbd2cSJim Jagielski nChars = osl_receivePipe( C1Pipe, szBuffer, 256 );
126*b1cdbd2cSJim Jagielski
127*b1cdbd2cSJim Jagielski if( nChars < 0 )
128*b1cdbd2cSJim Jagielski fail( "unable to read from pipe.\n",
129*b1cdbd2cSJim Jagielski osl_getLastPipeError( C1Pipe ) );
130*b1cdbd2cSJim Jagielski
131*b1cdbd2cSJim Jagielski printf( "TestPipe Server: received data: %s.\n", szBuffer );
132*b1cdbd2cSJim Jagielski
133*b1cdbd2cSJim Jagielski // warte bis das Client-Programm sich beendet
134*b1cdbd2cSJim Jagielski ProcessError = osl_joinProcess( Process );
135*b1cdbd2cSJim Jagielski
136*b1cdbd2cSJim Jagielski if( ProcessError != osl_Process_E_None )
137*b1cdbd2cSJim Jagielski fail( "unable to wait for client.\n",
138*b1cdbd2cSJim Jagielski ProcessError );
139*b1cdbd2cSJim Jagielski
140*b1cdbd2cSJim Jagielski // ermittle den R�ckgabewert des Client-Programms
141*b1cdbd2cSJim Jagielski ProcessInfo.Size = sizeof( ProcessInfo );
142*b1cdbd2cSJim Jagielski
143*b1cdbd2cSJim Jagielski ProcessError = osl_getProcessInfo( Process, osl_Process_EXITCODE, &ProcessInfo );
144*b1cdbd2cSJim Jagielski
145*b1cdbd2cSJim Jagielski if( ProcessError != osl_Process_E_None )
146*b1cdbd2cSJim Jagielski fail( "unable to receive return value of client process.\n",
147*b1cdbd2cSJim Jagielski ProcessError );
148*b1cdbd2cSJim Jagielski
149*b1cdbd2cSJim Jagielski if( ProcessInfo.Code != 0 )
150*b1cdbd2cSJim Jagielski fail( "client aborted.\n", ProcessInfo.Code );
151*b1cdbd2cSJim Jagielski
152*b1cdbd2cSJim Jagielski // gib das Handle fuer den Client-Prozess frei
153*b1cdbd2cSJim Jagielski osl_freeProcessHandle( Process );
154*b1cdbd2cSJim Jagielski
155*b1cdbd2cSJim Jagielski // schliesse die Pipes
156*b1cdbd2cSJim Jagielski osl_destroyPipe( C1Pipe );
157*b1cdbd2cSJim Jagielski osl_destroyPipe( Pipe );
158*b1cdbd2cSJim Jagielski
159*b1cdbd2cSJim Jagielski printf( "TestPipe Server: test passed.\n" );
160*b1cdbd2cSJim Jagielski return 0;
161*b1cdbd2cSJim Jagielski }
162*b1cdbd2cSJim Jagielski
163*b1cdbd2cSJim Jagielski
164*b1cdbd2cSJim Jagielski
165