1*cdf0e10cSrcweir /************************************************************************* 2*cdf0e10cSrcweir * 3*cdf0e10cSrcweir * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4*cdf0e10cSrcweir * 5*cdf0e10cSrcweir * Copyright 2000, 2010 Oracle and/or its affiliates. 6*cdf0e10cSrcweir * 7*cdf0e10cSrcweir * OpenOffice.org - a multi-platform office productivity suite 8*cdf0e10cSrcweir * 9*cdf0e10cSrcweir * This file is part of OpenOffice.org. 10*cdf0e10cSrcweir * 11*cdf0e10cSrcweir * OpenOffice.org is free software: you can redistribute it and/or modify 12*cdf0e10cSrcweir * it under the terms of the GNU Lesser General Public License version 3 13*cdf0e10cSrcweir * only, as published by the Free Software Foundation. 14*cdf0e10cSrcweir * 15*cdf0e10cSrcweir * OpenOffice.org is distributed in the hope that it will be useful, 16*cdf0e10cSrcweir * but WITHOUT ANY WARRANTY; without even the implied warranty of 17*cdf0e10cSrcweir * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 18*cdf0e10cSrcweir * GNU Lesser General Public License version 3 for more details 19*cdf0e10cSrcweir * (a copy is included in the LICENSE file that accompanied this code). 20*cdf0e10cSrcweir * 21*cdf0e10cSrcweir * You should have received a copy of the GNU Lesser General Public License 22*cdf0e10cSrcweir * version 3 along with OpenOffice.org. If not, see 23*cdf0e10cSrcweir * <http://www.openoffice.org/license.html> 24*cdf0e10cSrcweir * for a copy of the LGPLv3 License. 25*cdf0e10cSrcweir * 26*cdf0e10cSrcweir ************************************************************************/ 27*cdf0e10cSrcweir 28*cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove 29*cdf0e10cSrcweir #include "precompiled_sal.hxx" 30*cdf0e10cSrcweir 31*cdf0e10cSrcweir //------------------------------------------------------------------------ 32*cdf0e10cSrcweir // include files 33*cdf0e10cSrcweir //------------------------------------------------------------------------ 34*cdf0e10cSrcweir 35*cdf0e10cSrcweir #include "cppunit/TestAssert.h" 36*cdf0e10cSrcweir #include "cppunit/TestFixture.h" 37*cdf0e10cSrcweir #include "cppunit/extensions/HelperMacros.h" 38*cdf0e10cSrcweir #include "cppunit/plugin/TestPlugIn.h" 39*cdf0e10cSrcweir #include "test/uniquepipename.hxx" 40*cdf0e10cSrcweir #include <sal/types.h> 41*cdf0e10cSrcweir #include <rtl/ustring.hxx> 42*cdf0e10cSrcweir 43*cdf0e10cSrcweir #ifndef _OSL_THREAD_HXX 44*cdf0e10cSrcweir #include <osl/thread.hxx> 45*cdf0e10cSrcweir #endif 46*cdf0e10cSrcweir 47*cdf0e10cSrcweir #ifndef _OSL_MUTEX_HXX 48*cdf0e10cSrcweir #include <osl/mutex.hxx> 49*cdf0e10cSrcweir #endif 50*cdf0e10cSrcweir 51*cdf0e10cSrcweir #ifndef _OSL_MUTEX_HXX 52*cdf0e10cSrcweir #include <osl/pipe.hxx> 53*cdf0e10cSrcweir #endif 54*cdf0e10cSrcweir #include <osl/time.h> 55*cdf0e10cSrcweir 56*cdf0e10cSrcweir #ifdef UNX 57*cdf0e10cSrcweir #include <unistd.h> 58*cdf0e10cSrcweir #endif 59*cdf0e10cSrcweir #include <string.h> 60*cdf0e10cSrcweir 61*cdf0e10cSrcweir using namespace osl; 62*cdf0e10cSrcweir using namespace rtl; 63*cdf0e10cSrcweir 64*cdf0e10cSrcweir //------------------------------------------------------------------------ 65*cdf0e10cSrcweir // helper functions 66*cdf0e10cSrcweir //------------------------------------------------------------------------ 67*cdf0e10cSrcweir 68*cdf0e10cSrcweir /** print Boolean value. 69*cdf0e10cSrcweir */ 70*cdf0e10cSrcweir inline void printBool( sal_Bool bOk ) 71*cdf0e10cSrcweir { 72*cdf0e10cSrcweir printf("#printBool# " ); 73*cdf0e10cSrcweir ( sal_True == bOk ) ? printf("YES!\n" ): printf("NO!\n" ); 74*cdf0e10cSrcweir } 75*cdf0e10cSrcweir 76*cdf0e10cSrcweir /** print a UNI_CODE String. 77*cdf0e10cSrcweir */ 78*cdf0e10cSrcweir inline void printUString( const ::rtl::OUString & str ) 79*cdf0e10cSrcweir { 80*cdf0e10cSrcweir rtl::OString aString; 81*cdf0e10cSrcweir 82*cdf0e10cSrcweir printf("#printUString_u# " ); 83*cdf0e10cSrcweir aString = ::rtl::OUStringToOString( str, RTL_TEXTENCODING_ASCII_US ); 84*cdf0e10cSrcweir printf("%s\n", aString.getStr( ) ); 85*cdf0e10cSrcweir } 86*cdf0e10cSrcweir 87*cdf0e10cSrcweir /** print last error of pipe system. 88*cdf0e10cSrcweir */ 89*cdf0e10cSrcweir inline void printPipeError( ::osl::Pipe aPipe ) 90*cdf0e10cSrcweir { 91*cdf0e10cSrcweir oslPipeError nError = aPipe.getError( ); 92*cdf0e10cSrcweir printf("#printPipeError# " ); 93*cdf0e10cSrcweir switch ( nError ) { 94*cdf0e10cSrcweir case osl_Pipe_E_None: 95*cdf0e10cSrcweir printf("Success!\n" ); 96*cdf0e10cSrcweir break; 97*cdf0e10cSrcweir case osl_Pipe_E_NotFound: 98*cdf0e10cSrcweir printf("The returned error is: Not found!\n" ); 99*cdf0e10cSrcweir break; 100*cdf0e10cSrcweir case osl_Pipe_E_AlreadyExists: 101*cdf0e10cSrcweir printf("The returned error is: Already exist!\n" ); 102*cdf0e10cSrcweir break; 103*cdf0e10cSrcweir case osl_Pipe_E_NoProtocol: 104*cdf0e10cSrcweir printf("The returned error is: No protocol!\n" ); 105*cdf0e10cSrcweir break; 106*cdf0e10cSrcweir case osl_Pipe_E_NetworkReset: 107*cdf0e10cSrcweir printf("The returned error is: Network reset!\n" ); 108*cdf0e10cSrcweir break; 109*cdf0e10cSrcweir case osl_Pipe_E_ConnectionAbort: 110*cdf0e10cSrcweir printf("The returned error is: Connection aborted!\n" ); 111*cdf0e10cSrcweir break; 112*cdf0e10cSrcweir case osl_Pipe_E_ConnectionReset: 113*cdf0e10cSrcweir printf("The returned error is: Connection reset!\n" ); 114*cdf0e10cSrcweir break; 115*cdf0e10cSrcweir case osl_Pipe_E_NoBufferSpace: 116*cdf0e10cSrcweir printf("The returned error is: No buffer space!\n" ); 117*cdf0e10cSrcweir break; 118*cdf0e10cSrcweir case osl_Pipe_E_TimedOut: 119*cdf0e10cSrcweir printf("The returned error is: Timeout!\n" ); 120*cdf0e10cSrcweir break; 121*cdf0e10cSrcweir case osl_Pipe_E_ConnectionRefused: 122*cdf0e10cSrcweir printf("The returned error is: Connection refused!\n" ); 123*cdf0e10cSrcweir break; 124*cdf0e10cSrcweir case osl_Pipe_E_invalidError: 125*cdf0e10cSrcweir printf("The returned error is: Invalid error!\n" ); 126*cdf0e10cSrcweir break; 127*cdf0e10cSrcweir default: 128*cdf0e10cSrcweir printf("The returned error is: Number %d, Unknown Error\n", nError ); 129*cdf0e10cSrcweir break; 130*cdf0e10cSrcweir } 131*cdf0e10cSrcweir } 132*cdf0e10cSrcweir 133*cdf0e10cSrcweir 134*cdf0e10cSrcweir 135*cdf0e10cSrcweir //------------------------------------------------------------------------ 136*cdf0e10cSrcweir // pipe name and transfer contents 137*cdf0e10cSrcweir //------------------------------------------------------------------------ 138*cdf0e10cSrcweir const rtl::OUString aTestPipeName = rtl::OUString::createFromAscii( "testpipe2" ); 139*cdf0e10cSrcweir const rtl::OUString aTestPipe1 = rtl::OUString::createFromAscii( "testpipe1" ); 140*cdf0e10cSrcweir const rtl::OUString aTestString = rtl::OUString::createFromAscii( "Sun Microsystems" ); 141*cdf0e10cSrcweir 142*cdf0e10cSrcweir const OString m_pTestString1("Sun Microsystems"); 143*cdf0e10cSrcweir const OString m_pTestString2("test pipe PASS/OK"); 144*cdf0e10cSrcweir 145*cdf0e10cSrcweir //------------------------------------------------------------------------ 146*cdf0e10cSrcweir // test code start here 147*cdf0e10cSrcweir //------------------------------------------------------------------------ 148*cdf0e10cSrcweir 149*cdf0e10cSrcweir namespace osl_Pipe 150*cdf0e10cSrcweir { 151*cdf0e10cSrcweir 152*cdf0e10cSrcweir //------------------------------------------------------------------------ 153*cdf0e10cSrcweir // most return value -1 denote a fail of operation. 154*cdf0e10cSrcweir //------------------------------------------------------------------------ 155*cdf0e10cSrcweir #define OSL_PIPE_FAIL -1 156*cdf0e10cSrcweir 157*cdf0e10cSrcweir /** testing the methods: 158*cdf0e10cSrcweir inline Pipe(); 159*cdf0e10cSrcweir inline Pipe(const ::rtl::OUString& strName, oslPipeOptions Options); 160*cdf0e10cSrcweir inline Pipe(const ::rtl::OUString& strName, oslPipeOptions Options,const Security & rSecurity); 161*cdf0e10cSrcweir inline Pipe(const Pipe& pipe); 162*cdf0e10cSrcweir inline Pipe(oslPipe pipe, __sal_NoAcquire noacquire ); 163*cdf0e10cSrcweir inline Pipe(oslPipe Pipe); 164*cdf0e10cSrcweir */ 165*cdf0e10cSrcweir class ctors : public CppUnit::TestFixture 166*cdf0e10cSrcweir { 167*cdf0e10cSrcweir public: 168*cdf0e10cSrcweir sal_Bool bRes, bRes1; 169*cdf0e10cSrcweir 170*cdf0e10cSrcweir void setUp( ) 171*cdf0e10cSrcweir { 172*cdf0e10cSrcweir } 173*cdf0e10cSrcweir 174*cdf0e10cSrcweir void tearDown( ) 175*cdf0e10cSrcweir { 176*cdf0e10cSrcweir } 177*cdf0e10cSrcweir 178*cdf0e10cSrcweir void ctors_none( ) 179*cdf0e10cSrcweir { 180*cdf0e10cSrcweir ::osl::Pipe aPipe; 181*cdf0e10cSrcweir bRes = aPipe.is( ); 182*cdf0e10cSrcweir 183*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test constructor with no parameter, yet no case to test.", 184*cdf0e10cSrcweir sal_False == bRes ); 185*cdf0e10cSrcweir } 186*cdf0e10cSrcweir 187*cdf0e10cSrcweir void ctors_name_option( ) 188*cdf0e10cSrcweir { 189*cdf0e10cSrcweir /// create a named pipe. 190*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 191*cdf0e10cSrcweir ::osl::Pipe aAssignPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_OPEN ); 192*cdf0e10cSrcweir 193*cdf0e10cSrcweir bRes = aPipe.is( ) && aAssignPipe.is( ); 194*cdf0e10cSrcweir 195*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test constructor with name and option.", 196*cdf0e10cSrcweir sal_True == bRes ); 197*cdf0e10cSrcweir } 198*cdf0e10cSrcweir 199*cdf0e10cSrcweir void ctors_name_option_security( ) 200*cdf0e10cSrcweir { 201*cdf0e10cSrcweir /// create a security pipe. 202*cdf0e10cSrcweir const ::osl::Security rSecurity; 203*cdf0e10cSrcweir ::osl::Pipe aSecurityPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE, rSecurity ); 204*cdf0e10cSrcweir 205*cdf0e10cSrcweir bRes = aSecurityPipe.is( ); 206*cdf0e10cSrcweir 207*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test constructor with name, option and security, the test of security is not implemented yet.", 208*cdf0e10cSrcweir sal_True == bRes ); 209*cdf0e10cSrcweir } 210*cdf0e10cSrcweir 211*cdf0e10cSrcweir void ctors_copy( ) 212*cdf0e10cSrcweir { 213*cdf0e10cSrcweir /// create a pipe. 214*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 215*cdf0e10cSrcweir /// create a pipe using copy constructor. 216*cdf0e10cSrcweir ::osl::Pipe aCopyPipe( aPipe ); 217*cdf0e10cSrcweir 218*cdf0e10cSrcweir bRes = aCopyPipe.is( ) && aCopyPipe == aPipe; 219*cdf0e10cSrcweir 220*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test copy constructor.", 221*cdf0e10cSrcweir sal_True == bRes ); 222*cdf0e10cSrcweir } 223*cdf0e10cSrcweir 224*cdf0e10cSrcweir /** tester comment: 225*cdf0e10cSrcweir 226*cdf0e10cSrcweir When test the following two constructors, don't know how to test the 227*cdf0e10cSrcweir acquire and no acquire action. possible plans: 228*cdf0e10cSrcweir 1.release one handle and check the other( did not success since the 229*cdf0e10cSrcweir other still exist and valid. ) 230*cdf0e10cSrcweir 2. release one handle twice to see getLastError( )(the getLastError 231*cdf0e10cSrcweir always returns invalidError(LINUX)). 232*cdf0e10cSrcweir */ 233*cdf0e10cSrcweir 234*cdf0e10cSrcweir void ctors_no_acquire( ) 235*cdf0e10cSrcweir { 236*cdf0e10cSrcweir /// create a pipe. 237*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 238*cdf0e10cSrcweir /// constructs a pipe reference without acquiring the handle. 239*cdf0e10cSrcweir ::osl::Pipe aNoAcquirePipe( aPipe.getHandle( ), SAL_NO_ACQUIRE ); 240*cdf0e10cSrcweir 241*cdf0e10cSrcweir bRes = aNoAcquirePipe.is( ); 242*cdf0e10cSrcweir ///aPipe.clear( ); 243*cdf0e10cSrcweir ///bRes1 = aNoAcquirePipe.is( ); 244*cdf0e10cSrcweir 245*cdf0e10cSrcweir 246*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test constructor with no aquire of handle, only validation test, do not know how to test no acquire.", 247*cdf0e10cSrcweir sal_True == bRes ); 248*cdf0e10cSrcweir } 249*cdf0e10cSrcweir 250*cdf0e10cSrcweir void ctors_acquire( ) 251*cdf0e10cSrcweir { 252*cdf0e10cSrcweir /// create a base pipe. 253*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 254*cdf0e10cSrcweir /// constructs two pipes without acquiring the handle on the base pipe. 255*cdf0e10cSrcweir ::osl::Pipe aAcquirePipe( aPipe.getHandle( ) ); 256*cdf0e10cSrcweir ::osl::Pipe aAcquirePipe1( NULL ); 257*cdf0e10cSrcweir 258*cdf0e10cSrcweir bRes = aAcquirePipe.is( ); 259*cdf0e10cSrcweir bRes1 = aAcquirePipe1.is( ); 260*cdf0e10cSrcweir 261*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test constructor with no aquire of handle.only validation test, do not know how to test no acquire.", 262*cdf0e10cSrcweir sal_True == bRes && sal_False == bRes1 ); 263*cdf0e10cSrcweir } 264*cdf0e10cSrcweir 265*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( ctors ); 266*cdf0e10cSrcweir CPPUNIT_TEST( ctors_none ); 267*cdf0e10cSrcweir CPPUNIT_TEST( ctors_name_option ); 268*cdf0e10cSrcweir CPPUNIT_TEST( ctors_name_option_security ); 269*cdf0e10cSrcweir CPPUNIT_TEST( ctors_copy ); 270*cdf0e10cSrcweir CPPUNIT_TEST( ctors_no_acquire ); 271*cdf0e10cSrcweir CPPUNIT_TEST( ctors_acquire ); 272*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 273*cdf0e10cSrcweir }; // class ctors 274*cdf0e10cSrcweir 275*cdf0e10cSrcweir 276*cdf0e10cSrcweir /** testing the method: 277*cdf0e10cSrcweir inline sal_Bool SAL_CALL is() const; 278*cdf0e10cSrcweir */ 279*cdf0e10cSrcweir class is : public CppUnit::TestFixture 280*cdf0e10cSrcweir { 281*cdf0e10cSrcweir public: 282*cdf0e10cSrcweir void is_001( ) 283*cdf0e10cSrcweir { 284*cdf0e10cSrcweir ::osl::Pipe aPipe; 285*cdf0e10cSrcweir 286*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test is(), check if the pipe is a valid one.", sal_False == aPipe.is( ) ); 287*cdf0e10cSrcweir } 288*cdf0e10cSrcweir 289*cdf0e10cSrcweir void is_002( ) 290*cdf0e10cSrcweir { 291*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 292*cdf0e10cSrcweir 293*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test is(), a normal pipe creation.", sal_True == aPipe.is( ) ); 294*cdf0e10cSrcweir } 295*cdf0e10cSrcweir 296*cdf0e10cSrcweir void is_003( ) 297*cdf0e10cSrcweir { 298*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 299*cdf0e10cSrcweir aPipe.clear( ); 300*cdf0e10cSrcweir 301*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test is(), an invalid case.", sal_False == aPipe.is( ) ); 302*cdf0e10cSrcweir } 303*cdf0e10cSrcweir 304*cdf0e10cSrcweir void is_004( ) 305*cdf0e10cSrcweir { 306*cdf0e10cSrcweir ::osl::Pipe aPipe( NULL ); 307*cdf0e10cSrcweir 308*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test is(), an invalid constructor.", sal_False == aPipe.is( ) ); 309*cdf0e10cSrcweir } 310*cdf0e10cSrcweir 311*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( is ); 312*cdf0e10cSrcweir CPPUNIT_TEST( is_001 ); 313*cdf0e10cSrcweir CPPUNIT_TEST( is_002 ); 314*cdf0e10cSrcweir CPPUNIT_TEST( is_003 ); 315*cdf0e10cSrcweir CPPUNIT_TEST( is_004 ); 316*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 317*cdf0e10cSrcweir }; // class is 318*cdf0e10cSrcweir 319*cdf0e10cSrcweir 320*cdf0e10cSrcweir /** testing the methods: 321*cdf0e10cSrcweir inline sal_Bool create( const ::rtl::OUString & strName, 322*cdf0e10cSrcweir oslPipeOptions Options, const Security &rSec ); 323*cdf0e10cSrcweir nline sal_Bool create( const ::rtl::OUString & strName, 324*cdf0e10cSrcweir oslPipeOptions Options = osl_Pipe_OPEN ); 325*cdf0e10cSrcweir */ 326*cdf0e10cSrcweir class create : public CppUnit::TestFixture 327*cdf0e10cSrcweir { 328*cdf0e10cSrcweir public: 329*cdf0e10cSrcweir sal_Bool bRes, bRes1; 330*cdf0e10cSrcweir 331*cdf0e10cSrcweir /** tester comment: 332*cdf0e10cSrcweir 333*cdf0e10cSrcweir security create only be tested creation, security section is 334*cdf0e10cSrcweir untested yet. 335*cdf0e10cSrcweir */ 336*cdf0e10cSrcweir 337*cdf0e10cSrcweir void create_named_security_001( ) 338*cdf0e10cSrcweir { 339*cdf0e10cSrcweir const Security rSec; 340*cdf0e10cSrcweir ::osl::Pipe aPipe; 341*cdf0e10cSrcweir bRes = aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE, rSec ); 342*cdf0e10cSrcweir bRes1 = aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE, rSec ); 343*cdf0e10cSrcweir aPipe.clear( ); 344*cdf0e10cSrcweir 345*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test creation.", 346*cdf0e10cSrcweir sal_True == bRes && sal_False == bRes1); 347*cdf0e10cSrcweir } 348*cdf0e10cSrcweir 349*cdf0e10cSrcweir void create_named_security_002( ) 350*cdf0e10cSrcweir { 351*cdf0e10cSrcweir const Security rSec; 352*cdf0e10cSrcweir ::osl::Pipe aPipe, aPipe1; 353*cdf0e10cSrcweir bRes = aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE, rSec ); 354*cdf0e10cSrcweir bRes1 = aPipe1.create( test::uniquePipeName(aTestPipeName), osl_Pipe_OPEN, rSec ); 355*cdf0e10cSrcweir aPipe.clear( ); 356*cdf0e10cSrcweir 357*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test creation and open.", 358*cdf0e10cSrcweir sal_True == bRes && sal_True == bRes1); 359*cdf0e10cSrcweir } 360*cdf0e10cSrcweir 361*cdf0e10cSrcweir void create_named_001( ) 362*cdf0e10cSrcweir { 363*cdf0e10cSrcweir ::osl::Pipe aPipe; 364*cdf0e10cSrcweir bRes = aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 365*cdf0e10cSrcweir bRes1 = aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 366*cdf0e10cSrcweir aPipe.clear( ); 367*cdf0e10cSrcweir 368*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test creation.", 369*cdf0e10cSrcweir sal_True == bRes && sal_False == bRes1); 370*cdf0e10cSrcweir } 371*cdf0e10cSrcweir 372*cdf0e10cSrcweir void create_named_002( ) 373*cdf0e10cSrcweir { 374*cdf0e10cSrcweir ::osl::Pipe aPipe, aPipe1; 375*cdf0e10cSrcweir bRes = aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 376*cdf0e10cSrcweir bRes1 = aPipe1.create( test::uniquePipeName(aTestPipeName), osl_Pipe_OPEN ); 377*cdf0e10cSrcweir aPipe.clear( ); 378*cdf0e10cSrcweir 379*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test creation and open.", 380*cdf0e10cSrcweir sal_True == bRes && sal_True == bRes1); 381*cdf0e10cSrcweir } 382*cdf0e10cSrcweir 383*cdf0e10cSrcweir void create_named_003( ) 384*cdf0e10cSrcweir { 385*cdf0e10cSrcweir ::osl::Pipe aPipe; 386*cdf0e10cSrcweir bRes = aPipe.create( test::uniquePipeName(aTestPipeName) ); 387*cdf0e10cSrcweir aPipe.clear( ); 388*cdf0e10cSrcweir 389*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test default option is open.", 390*cdf0e10cSrcweir sal_False == bRes ); 391*cdf0e10cSrcweir } 392*cdf0e10cSrcweir 393*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( create ); 394*cdf0e10cSrcweir CPPUNIT_TEST( create_named_security_001 ); 395*cdf0e10cSrcweir CPPUNIT_TEST( create_named_security_002 ); 396*cdf0e10cSrcweir CPPUNIT_TEST( create_named_001 ); 397*cdf0e10cSrcweir CPPUNIT_TEST( create_named_002 ); 398*cdf0e10cSrcweir CPPUNIT_TEST( create_named_003 ); 399*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 400*cdf0e10cSrcweir }; // class create 401*cdf0e10cSrcweir 402*cdf0e10cSrcweir 403*cdf0e10cSrcweir /** testing the method: 404*cdf0e10cSrcweir inline void SAL_CALL clear(); 405*cdf0e10cSrcweir */ 406*cdf0e10cSrcweir class clear : public CppUnit::TestFixture 407*cdf0e10cSrcweir { 408*cdf0e10cSrcweir public: 409*cdf0e10cSrcweir sal_Bool bRes, bRes1; 410*cdf0e10cSrcweir 411*cdf0e10cSrcweir void clear_001( ) 412*cdf0e10cSrcweir { 413*cdf0e10cSrcweir ::osl::Pipe aPipe; 414*cdf0e10cSrcweir aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 415*cdf0e10cSrcweir aPipe.clear( ); 416*cdf0e10cSrcweir bRes = aPipe.is( ); 417*cdf0e10cSrcweir 418*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test clear.", 419*cdf0e10cSrcweir sal_False == bRes ); 420*cdf0e10cSrcweir } 421*cdf0e10cSrcweir 422*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( clear ); 423*cdf0e10cSrcweir CPPUNIT_TEST( clear_001 ); 424*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 425*cdf0e10cSrcweir }; // class clear 426*cdf0e10cSrcweir 427*cdf0e10cSrcweir 428*cdf0e10cSrcweir /** testing the methods: 429*cdf0e10cSrcweir inline Pipe& SAL_CALL operator= (const Pipe& pipe); 430*cdf0e10cSrcweir inline Pipe& SAL_CALL operator= (const oslPipe pipe ); 431*cdf0e10cSrcweir */ 432*cdf0e10cSrcweir class assign : public CppUnit::TestFixture 433*cdf0e10cSrcweir { 434*cdf0e10cSrcweir public: 435*cdf0e10cSrcweir sal_Bool bRes, bRes1; 436*cdf0e10cSrcweir 437*cdf0e10cSrcweir void assign_ref( ) 438*cdf0e10cSrcweir { 439*cdf0e10cSrcweir ::osl::Pipe aPipe, aPipe1; 440*cdf0e10cSrcweir aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 441*cdf0e10cSrcweir aPipe1 = aPipe; 442*cdf0e10cSrcweir bRes = aPipe1.is( ); 443*cdf0e10cSrcweir bRes1 = aPipe == aPipe1; 444*cdf0e10cSrcweir aPipe.close( ); 445*cdf0e10cSrcweir aPipe1.close( ); 446*cdf0e10cSrcweir 447*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test assign with reference.", 448*cdf0e10cSrcweir sal_True == bRes && sal_True == bRes1 ); 449*cdf0e10cSrcweir } 450*cdf0e10cSrcweir 451*cdf0e10cSrcweir void assign_handle( ) 452*cdf0e10cSrcweir { 453*cdf0e10cSrcweir ::osl::Pipe aPipe, aPipe1; 454*cdf0e10cSrcweir aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 455*cdf0e10cSrcweir aPipe1 = aPipe.getHandle( ); 456*cdf0e10cSrcweir bRes = aPipe1.is( ); 457*cdf0e10cSrcweir bRes1 = aPipe == aPipe1; 458*cdf0e10cSrcweir aPipe.close( ); 459*cdf0e10cSrcweir aPipe1.close( ); 460*cdf0e10cSrcweir 461*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test assign with handle.", 462*cdf0e10cSrcweir sal_True == bRes && sal_True == bRes1 ); 463*cdf0e10cSrcweir } 464*cdf0e10cSrcweir 465*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( assign ); 466*cdf0e10cSrcweir CPPUNIT_TEST( assign_ref ); 467*cdf0e10cSrcweir CPPUNIT_TEST( assign_handle ); 468*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 469*cdf0e10cSrcweir }; // class assign 470*cdf0e10cSrcweir 471*cdf0e10cSrcweir 472*cdf0e10cSrcweir /** testing the method: 473*cdf0e10cSrcweir inline sal_Bool SAL_CALL isValid() const; 474*cdf0e10cSrcweir isValid( ) has not been implemented under the following platforms, please refer to osl/pipe.hxx 475*cdf0e10cSrcweir */ 476*cdf0e10cSrcweir /*class isValid : public CppUnit::TestFixture 477*cdf0e10cSrcweir { 478*cdf0e10cSrcweir public: 479*cdf0e10cSrcweir sal_Bool bRes, bRes1; 480*cdf0e10cSrcweir 481*cdf0e10cSrcweir void isValid_001( ) 482*cdf0e10cSrcweir { 483*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: isValid() has not been implemented on all platforms.", 484*cdf0e10cSrcweir sal_False ); 485*cdf0e10cSrcweir } 486*cdf0e10cSrcweir 487*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( isValid ); 488*cdf0e10cSrcweir CPPUNIT_TEST( isValid_001 ); 489*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 490*cdf0e10cSrcweir };*/ // class isValid 491*cdf0e10cSrcweir 492*cdf0e10cSrcweir 493*cdf0e10cSrcweir /** testing the method: 494*cdf0e10cSrcweir inline sal_Bool SAL_CALL operator==( const Pipe& rPipe ) const; 495*cdf0e10cSrcweir */ 496*cdf0e10cSrcweir class isEqual : public CppUnit::TestFixture 497*cdf0e10cSrcweir { 498*cdf0e10cSrcweir public: 499*cdf0e10cSrcweir sal_Bool bRes, bRes1; 500*cdf0e10cSrcweir 501*cdf0e10cSrcweir void isEqual_001( ) 502*cdf0e10cSrcweir { 503*cdf0e10cSrcweir ::osl::Pipe aPipe; 504*cdf0e10cSrcweir aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 505*cdf0e10cSrcweir bRes = aPipe == aPipe; 506*cdf0e10cSrcweir aPipe.close( ); 507*cdf0e10cSrcweir 508*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test isEqual(), compare its self.", 509*cdf0e10cSrcweir sal_True == bRes ); 510*cdf0e10cSrcweir } 511*cdf0e10cSrcweir 512*cdf0e10cSrcweir void isEqual_002( ) 513*cdf0e10cSrcweir { 514*cdf0e10cSrcweir ::osl::Pipe aPipe, aPipe1, aPipe2; 515*cdf0e10cSrcweir aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 516*cdf0e10cSrcweir 517*cdf0e10cSrcweir aPipe1 = aPipe; 518*cdf0e10cSrcweir aPipe2.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 519*cdf0e10cSrcweir 520*cdf0e10cSrcweir bRes = aPipe == aPipe1; 521*cdf0e10cSrcweir bRes1 = aPipe == aPipe2; 522*cdf0e10cSrcweir aPipe.close( ); 523*cdf0e10cSrcweir aPipe1.close( ); 524*cdf0e10cSrcweir aPipe2.close( ); 525*cdf0e10cSrcweir 526*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test isEqual(),create one copy instance, and compare.", 527*cdf0e10cSrcweir sal_True == bRes && sal_False == bRes1 ); 528*cdf0e10cSrcweir } 529*cdf0e10cSrcweir 530*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( isEqual ); 531*cdf0e10cSrcweir CPPUNIT_TEST( isEqual_001 ); 532*cdf0e10cSrcweir CPPUNIT_TEST( isEqual_002 ); 533*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 534*cdf0e10cSrcweir }; // class isEqual 535*cdf0e10cSrcweir 536*cdf0e10cSrcweir 537*cdf0e10cSrcweir /** testing the method: 538*cdf0e10cSrcweir inline void SAL_CALL close(); 539*cdf0e10cSrcweir */ 540*cdf0e10cSrcweir class close : public CppUnit::TestFixture 541*cdf0e10cSrcweir { 542*cdf0e10cSrcweir public: 543*cdf0e10cSrcweir sal_Bool bRes, bRes1; 544*cdf0e10cSrcweir 545*cdf0e10cSrcweir void close_001( ) 546*cdf0e10cSrcweir { 547*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipe1), osl_Pipe_CREATE ); 548*cdf0e10cSrcweir aPipe.close( ); 549*cdf0e10cSrcweir bRes = aPipe.is( ); 550*cdf0e10cSrcweir 551*cdf0e10cSrcweir aPipe.clear( ); 552*cdf0e10cSrcweir bRes1 = aPipe.is( ); 553*cdf0e10cSrcweir 554*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: difference between close and clear.", 555*cdf0e10cSrcweir sal_True == bRes && sal_False == bRes1); 556*cdf0e10cSrcweir } 557*cdf0e10cSrcweir 558*cdf0e10cSrcweir void close_002( ) 559*cdf0e10cSrcweir { 560*cdf0e10cSrcweir ::osl::StreamPipe aPipe( test::uniquePipeName(aTestPipe1), osl_Pipe_CREATE ); 561*cdf0e10cSrcweir aPipe.close( ); 562*cdf0e10cSrcweir int nRet = aPipe.send( m_pTestString1.getStr(), 3 ); 563*cdf0e10cSrcweir 564*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: use after close.", 565*cdf0e10cSrcweir OSL_PIPE_FAIL == nRet ); 566*cdf0e10cSrcweir } 567*cdf0e10cSrcweir 568*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( close ); 569*cdf0e10cSrcweir CPPUNIT_TEST( close_001 ); 570*cdf0e10cSrcweir CPPUNIT_TEST( close_002 ); 571*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 572*cdf0e10cSrcweir }; // class close 573*cdf0e10cSrcweir 574*cdf0e10cSrcweir 575*cdf0e10cSrcweir /** testing the method: 576*cdf0e10cSrcweir inline oslPipeError SAL_CALL accept(StreamPipe& Connection); 577*cdf0e10cSrcweir please refer to StreamPipe::recv 578*cdf0e10cSrcweir */ 579*cdf0e10cSrcweir /* class accept : public CppUnit::TestFixture 580*cdf0e10cSrcweir { 581*cdf0e10cSrcweir public: 582*cdf0e10cSrcweir sal_Bool bRes, bRes1; 583*cdf0e10cSrcweir 584*cdf0e10cSrcweir void accept_001( ) 585*cdf0e10cSrcweir { 586*cdf0e10cSrcweir 587*cdf0e10cSrcweir // CPPUNIT_ASSERT_MESSAGE( "#test comment#: accept, untested.", 1 == 1 ); 588*cdf0e10cSrcweir //CPPUNIT_ASSERT_STUB(); 589*cdf0e10cSrcweir } 590*cdf0e10cSrcweir 591*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( accept ); 592*cdf0e10cSrcweir CPPUNIT_TEST( accept_001 ); 593*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 594*cdf0e10cSrcweir };*/ // class accept 595*cdf0e10cSrcweir 596*cdf0e10cSrcweir 597*cdf0e10cSrcweir /** testing the method: 598*cdf0e10cSrcweir inline oslPipeError SAL_CALL getError() const; 599*cdf0e10cSrcweir */ 600*cdf0e10cSrcweir class getError : public CppUnit::TestFixture 601*cdf0e10cSrcweir { 602*cdf0e10cSrcweir public: 603*cdf0e10cSrcweir sal_Bool bRes, bRes1; 604*cdf0e10cSrcweir /* 605*cdf0e10cSrcweir PipeError[]= { 606*cdf0e10cSrcweir { 0, osl_Pipe_E_None }, // no error 607*cdf0e10cSrcweir { EPROTOTYPE, osl_Pipe_E_NoProtocol }, // Protocol wrong type for socket 608*cdf0e10cSrcweir { ENOPROTOOPT, osl_Pipe_E_NoProtocol }, // Protocol not available 609*cdf0e10cSrcweir { EPROTONOSUPPORT, osl_Pipe_E_NoProtocol }, // Protocol not supported 610*cdf0e10cSrcweir { ESOCKTNOSUPPORT, osl_Pipe_E_NoProtocol }, // Socket type not supported 611*cdf0e10cSrcweir { EPFNOSUPPORT, osl_Pipe_E_NoProtocol }, // Protocol family not supported 612*cdf0e10cSrcweir { EAFNOSUPPORT, osl_Pipe_E_NoProtocol }, // Address family not supported by 613*cdf0e10cSrcweir // protocol family 614*cdf0e10cSrcweir { ENETRESET, osl_Pipe_E_NetworkReset }, // Network dropped connection because 615*cdf0e10cSrcweir // of reset 616*cdf0e10cSrcweir { ECONNABORTED, osl_Pipe_E_ConnectionAbort }, // Software caused connection abort 617*cdf0e10cSrcweir { ECONNRESET, osl_Pipe_E_ConnectionReset }, // Connection reset by peer 618*cdf0e10cSrcweir { ENOBUFS, osl_Pipe_E_NoBufferSpace }, // No buffer space available 619*cdf0e10cSrcweir { ETIMEDOUT, osl_Pipe_E_TimedOut }, // Connection timed out 620*cdf0e10cSrcweir { ECONNREFUSED, osl_Pipe_E_ConnectionRefused }, // Connection refused 621*cdf0e10cSrcweir { -1, osl_Pipe_E_invalidError } 622*cdf0e10cSrcweir }; 623*cdf0e10cSrcweir did not define osl_Pipe_E_NotFound, osl_Pipe_E_AlreadyExists 624*cdf0e10cSrcweir */ 625*cdf0e10cSrcweir 626*cdf0e10cSrcweir void getError_001( ) 627*cdf0e10cSrcweir { 628*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_OPEN ); 629*cdf0e10cSrcweir oslPipeError nError = aPipe.getError( ); 630*cdf0e10cSrcweir printPipeError( aPipe ); 631*cdf0e10cSrcweir aPipe.clear( ); 632*cdf0e10cSrcweir 633*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: open a non-exist pipe.", 634*cdf0e10cSrcweir nError != osl_Pipe_E_None ); 635*cdf0e10cSrcweir } 636*cdf0e10cSrcweir 637*cdf0e10cSrcweir void getError_002( ) 638*cdf0e10cSrcweir { 639*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 640*cdf0e10cSrcweir ::osl::Pipe aPipe1( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 641*cdf0e10cSrcweir oslPipeError nError = aPipe.getError( ); 642*cdf0e10cSrcweir printPipeError( aPipe ); 643*cdf0e10cSrcweir aPipe.clear( ); 644*cdf0e10cSrcweir aPipe1.clear( ); 645*cdf0e10cSrcweir 646*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: create an already exist pipe.", 647*cdf0e10cSrcweir nError != osl_Pipe_E_None ); 648*cdf0e10cSrcweir } 649*cdf0e10cSrcweir 650*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( getError ); 651*cdf0e10cSrcweir CPPUNIT_TEST( getError_001 ); 652*cdf0e10cSrcweir CPPUNIT_TEST( getError_002 ); 653*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 654*cdf0e10cSrcweir }; // class getError 655*cdf0e10cSrcweir 656*cdf0e10cSrcweir 657*cdf0e10cSrcweir /** testing the method: 658*cdf0e10cSrcweir inline oslPipe SAL_CALL getHandle() const; 659*cdf0e10cSrcweir */ 660*cdf0e10cSrcweir class getHandle : public CppUnit::TestFixture 661*cdf0e10cSrcweir { 662*cdf0e10cSrcweir public: 663*cdf0e10cSrcweir sal_Bool bRes, bRes1; 664*cdf0e10cSrcweir 665*cdf0e10cSrcweir void getHandle_001( ) 666*cdf0e10cSrcweir { 667*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_OPEN ); 668*cdf0e10cSrcweir bRes = aPipe == aPipe.getHandle( ); 669*cdf0e10cSrcweir aPipe.clear( ); 670*cdf0e10cSrcweir 671*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: one pipe should equal to its handle.", 672*cdf0e10cSrcweir sal_True == bRes ); 673*cdf0e10cSrcweir } 674*cdf0e10cSrcweir 675*cdf0e10cSrcweir void getHandle_002( ) 676*cdf0e10cSrcweir { 677*cdf0e10cSrcweir ::osl::Pipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 678*cdf0e10cSrcweir ::osl::Pipe aPipe1( aPipe.getHandle( ) ); 679*cdf0e10cSrcweir bRes = aPipe == aPipe1; 680*cdf0e10cSrcweir aPipe.clear( ); 681*cdf0e10cSrcweir aPipe1.clear( ); 682*cdf0e10cSrcweir 683*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: one pipe derived from another pipe's handle.", 684*cdf0e10cSrcweir sal_True == bRes ); 685*cdf0e10cSrcweir } 686*cdf0e10cSrcweir 687*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( getHandle ); 688*cdf0e10cSrcweir CPPUNIT_TEST( getHandle_001 ); 689*cdf0e10cSrcweir CPPUNIT_TEST( getHandle_002 ); 690*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 691*cdf0e10cSrcweir }; // class getHandle 692*cdf0e10cSrcweir 693*cdf0e10cSrcweir 694*cdf0e10cSrcweir // ----------------------------------------------------------------------------- 695*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::ctors); 696*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::is); 697*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::create); 698*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::clear); 699*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::assign); 700*cdf0e10cSrcweir //CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::isValid); 701*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::isEqual); 702*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::close); 703*cdf0e10cSrcweir //CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::accept); 704*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::getError); 705*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_Pipe::getHandle); 706*cdf0e10cSrcweir // ----------------------------------------------------------------------------- 707*cdf0e10cSrcweir 708*cdf0e10cSrcweir } // namespace osl_Pipe 709*cdf0e10cSrcweir 710*cdf0e10cSrcweir 711*cdf0e10cSrcweir namespace osl_StreamPipe 712*cdf0e10cSrcweir { 713*cdf0e10cSrcweir 714*cdf0e10cSrcweir /** testing the methods: 715*cdf0e10cSrcweir inline StreamPipe(); 716*cdf0e10cSrcweir inline StreamPipe(oslPipe Pipe);; 717*cdf0e10cSrcweir inline StreamPipe(const StreamPipe& Pipe); 718*cdf0e10cSrcweir inline StreamPipe(const ::rtl::OUString& strName, oslPipeOptions Options = osl_Pipe_OPEN); 719*cdf0e10cSrcweir inline StreamPipe(const ::rtl::OUString& strName, oslPipeOptions Options, const Security &rSec ); 720*cdf0e10cSrcweir inline StreamPipe( oslPipe pipe, __sal_NoAcquire noacquire ); 721*cdf0e10cSrcweir */ 722*cdf0e10cSrcweir class ctors : public CppUnit::TestFixture 723*cdf0e10cSrcweir { 724*cdf0e10cSrcweir public: 725*cdf0e10cSrcweir sal_Bool bRes, bRes1; 726*cdf0e10cSrcweir 727*cdf0e10cSrcweir void ctors_none( ) 728*cdf0e10cSrcweir { 729*cdf0e10cSrcweir // create a pipe. 730*cdf0e10cSrcweir ::osl::StreamPipe aStreamPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 731*cdf0e10cSrcweir // create an unattached pipe. 732*cdf0e10cSrcweir ::osl::StreamPipe aStreamPipe1; 733*cdf0e10cSrcweir bRes = aStreamPipe1.is( ); 734*cdf0e10cSrcweir 735*cdf0e10cSrcweir // assign it and check. 736*cdf0e10cSrcweir aStreamPipe1 = aStreamPipe; 737*cdf0e10cSrcweir bRes1 = aStreamPipe1.is( ); 738*cdf0e10cSrcweir aStreamPipe.clear( ); 739*cdf0e10cSrcweir aStreamPipe1.clear( ); 740*cdf0e10cSrcweir 741*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test constructor with no parameter, before and after assign.", 742*cdf0e10cSrcweir sal_False == bRes && sal_True == bRes1 ); 743*cdf0e10cSrcweir } 744*cdf0e10cSrcweir 745*cdf0e10cSrcweir void ctors_handle( ) 746*cdf0e10cSrcweir { 747*cdf0e10cSrcweir // create a pipe. 748*cdf0e10cSrcweir ::osl::StreamPipe aStreamPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 749*cdf0e10cSrcweir // create a pipe with last handle. 750*cdf0e10cSrcweir ::osl::StreamPipe aStreamPipe1( aStreamPipe.getHandle( ) ); 751*cdf0e10cSrcweir bRes = aStreamPipe1.is( ) && aStreamPipe == aStreamPipe1; 752*cdf0e10cSrcweir aStreamPipe.clear( ); 753*cdf0e10cSrcweir aStreamPipe1.clear( ); 754*cdf0e10cSrcweir 755*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test constructor with other's handle.", 756*cdf0e10cSrcweir sal_True == bRes ); 757*cdf0e10cSrcweir } 758*cdf0e10cSrcweir 759*cdf0e10cSrcweir void ctors_copy( ) 760*cdf0e10cSrcweir { 761*cdf0e10cSrcweir // create a pipe. 762*cdf0e10cSrcweir ::osl::StreamPipe aStreamPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 763*cdf0e10cSrcweir // create an unattached pipe. 764*cdf0e10cSrcweir ::osl::StreamPipe aStreamPipe1( aStreamPipe ); 765*cdf0e10cSrcweir bRes = aStreamPipe1.is( ) && aStreamPipe == aStreamPipe1; 766*cdf0e10cSrcweir aStreamPipe.clear( ); 767*cdf0e10cSrcweir aStreamPipe1.clear( ); 768*cdf0e10cSrcweir 769*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test copy constructor.", 770*cdf0e10cSrcweir sal_True == bRes ); 771*cdf0e10cSrcweir } 772*cdf0e10cSrcweir 773*cdf0e10cSrcweir void ctors_name_option( ) 774*cdf0e10cSrcweir { 775*cdf0e10cSrcweir // create a pipe. 776*cdf0e10cSrcweir ::osl::StreamPipe aStreamPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 777*cdf0e10cSrcweir // create an unattached pipe. 778*cdf0e10cSrcweir ::osl::StreamPipe aStreamPipe1( test::uniquePipeName(aTestPipeName), osl_Pipe_OPEN ); 779*cdf0e10cSrcweir bRes = aStreamPipe1.is( ) && aStreamPipe.is( ); 780*cdf0e10cSrcweir aStreamPipe.clear( ); 781*cdf0e10cSrcweir aStreamPipe1.clear( ); 782*cdf0e10cSrcweir 783*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test constructor with name and option.", 784*cdf0e10cSrcweir sal_True == bRes ); 785*cdf0e10cSrcweir } 786*cdf0e10cSrcweir 787*cdf0e10cSrcweir void ctors_name_option_security( ) 788*cdf0e10cSrcweir { 789*cdf0e10cSrcweir /// create a security pipe. 790*cdf0e10cSrcweir const ::osl::Security rSecurity; 791*cdf0e10cSrcweir ::osl::StreamPipe aSecurityPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE, rSecurity ); 792*cdf0e10cSrcweir 793*cdf0e10cSrcweir bRes = aSecurityPipe.is( ); 794*cdf0e10cSrcweir aSecurityPipe.clear( ); 795*cdf0e10cSrcweir 796*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test constructor with name, option and security, the test of security is not implemented yet.", 797*cdf0e10cSrcweir sal_True == bRes ); 798*cdf0e10cSrcweir } 799*cdf0e10cSrcweir 800*cdf0e10cSrcweir /** tester comment: 801*cdf0e10cSrcweir 802*cdf0e10cSrcweir When test the following constructor, don't know how to test the 803*cdf0e10cSrcweir acquire and no acquire action. possible plans: 804*cdf0e10cSrcweir 1.release one handle and check the other( did not success since the 805*cdf0e10cSrcweir other still exist and valid. ) 806*cdf0e10cSrcweir 2. release one handle twice to see getLastError( )(the getLastError 807*cdf0e10cSrcweir always returns invalidError(LINUX)). 808*cdf0e10cSrcweir */ 809*cdf0e10cSrcweir 810*cdf0e10cSrcweir void ctors_no_acquire( ) 811*cdf0e10cSrcweir { 812*cdf0e10cSrcweir // create a pipe. 813*cdf0e10cSrcweir ::osl::StreamPipe aPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 814*cdf0e10cSrcweir // constructs a pipe reference without acquiring the handle. 815*cdf0e10cSrcweir ::osl::StreamPipe aNoAcquirePipe( aPipe.getHandle( ), SAL_NO_ACQUIRE ); 816*cdf0e10cSrcweir 817*cdf0e10cSrcweir bRes = aNoAcquirePipe.is( ); 818*cdf0e10cSrcweir aPipe.clear( ); 819*cdf0e10cSrcweir // bRes1 = aNoAcquirePipe.is( ); 820*cdf0e10cSrcweir 821*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test constructor with no aquire of handle, only validation test, do not know how to test no acquire.", 822*cdf0e10cSrcweir sal_True == bRes ); 823*cdf0e10cSrcweir } 824*cdf0e10cSrcweir 825*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( ctors ); 826*cdf0e10cSrcweir CPPUNIT_TEST( ctors_none ); 827*cdf0e10cSrcweir CPPUNIT_TEST( ctors_handle ); 828*cdf0e10cSrcweir CPPUNIT_TEST( ctors_copy ); 829*cdf0e10cSrcweir CPPUNIT_TEST( ctors_name_option ); 830*cdf0e10cSrcweir CPPUNIT_TEST( ctors_name_option_security ); 831*cdf0e10cSrcweir CPPUNIT_TEST( ctors_no_acquire ); 832*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 833*cdf0e10cSrcweir }; // class ctors 834*cdf0e10cSrcweir 835*cdf0e10cSrcweir 836*cdf0e10cSrcweir /** testing the methods: 837*cdf0e10cSrcweir inline StreamPipe & SAL_CALL operator=(oslPipe Pipe); 838*cdf0e10cSrcweir inline StreamPipe& SAL_CALL operator=(const Pipe& pipe); 839*cdf0e10cSrcweir mindy: not implementated in osl/pipe.hxx, so remove the cases 840*cdf0e10cSrcweir */ 841*cdf0e10cSrcweir /* 842*cdf0e10cSrcweir class assign : public CppUnit::TestFixture 843*cdf0e10cSrcweir { 844*cdf0e10cSrcweir public: 845*cdf0e10cSrcweir sal_Bool bRes, bRes1; 846*cdf0e10cSrcweir 847*cdf0e10cSrcweir void assign_ref( ) 848*cdf0e10cSrcweir { 849*cdf0e10cSrcweir ::osl::StreamPipe aPipe, aPipe1; 850*cdf0e10cSrcweir aPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 851*cdf0e10cSrcweir aPipe1 = aPipe; 852*cdf0e10cSrcweir bRes = aPipe1.is( ); 853*cdf0e10cSrcweir bRes1 = aPipe == aPipe1; 854*cdf0e10cSrcweir aPipe.close( ); 855*cdf0e10cSrcweir aPipe1.close( ); 856*cdf0e10cSrcweir 857*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test assign with reference.", 858*cdf0e10cSrcweir sal_True == bRes && sal_True == bRes1 ); 859*cdf0e10cSrcweir } 860*cdf0e10cSrcweir 861*cdf0e10cSrcweir void assign_handle( ) 862*cdf0e10cSrcweir { 863*cdf0e10cSrcweir ::osl::StreamPipe * pPipe = new ::osl::StreamPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 864*cdf0e10cSrcweir ::osl::StreamPipe * pAssignPipe = new ::osl::StreamPipe; 865*cdf0e10cSrcweir *pAssignPipe = pPipe->getHandle( ); 866*cdf0e10cSrcweir 867*cdf0e10cSrcweir bRes = pAssignPipe->is( ); 868*cdf0e10cSrcweir bRes1 = ( *pPipe == *pAssignPipe ); 869*cdf0e10cSrcweir pPipe->close( ); 870*cdf0e10cSrcweir 871*cdf0e10cSrcweir delete pAssignPipe; 872*cdf0e10cSrcweir 873*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "#test comment#: test assign with handle., seems not implemented under (LINUX)(W32)", 874*cdf0e10cSrcweir sal_True == bRes && sal_True == bRes1 ); 875*cdf0e10cSrcweir } 876*cdf0e10cSrcweir 877*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( assign ); 878*cdf0e10cSrcweir CPPUNIT_TEST( assign_ref ); 879*cdf0e10cSrcweir CPPUNIT_TEST( assign_handle ); 880*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 881*cdf0e10cSrcweir };*/ // class assign 882*cdf0e10cSrcweir 883*cdf0e10cSrcweir 884*cdf0e10cSrcweir /** wait _nSec seconds. 885*cdf0e10cSrcweir */ 886*cdf0e10cSrcweir void thread_sleep( sal_Int32 _nSec ) 887*cdf0e10cSrcweir { 888*cdf0e10cSrcweir /// print statement in thread process must use fflush() to force display. 889*cdf0e10cSrcweir // printf("wait %d seconds. ", _nSec ); 890*cdf0e10cSrcweir fflush(stdout); 891*cdf0e10cSrcweir 892*cdf0e10cSrcweir #ifdef WNT //Windows 893*cdf0e10cSrcweir Sleep( _nSec * 1000 ); 894*cdf0e10cSrcweir #endif 895*cdf0e10cSrcweir #if ( defined UNX ) || ( defined OS2 ) //Unix 896*cdf0e10cSrcweir sleep( _nSec ); 897*cdf0e10cSrcweir #endif 898*cdf0e10cSrcweir // printf("done\n" ); 899*cdf0e10cSrcweir } 900*cdf0e10cSrcweir // test read/write & send/recv data to pipe 901*cdf0e10cSrcweir // ----------------------------------------------------------------------------- 902*cdf0e10cSrcweir 903*cdf0e10cSrcweir class Pipe_DataSink_Thread : public Thread 904*cdf0e10cSrcweir { 905*cdf0e10cSrcweir public: 906*cdf0e10cSrcweir sal_Char buf[256]; 907*cdf0e10cSrcweir Pipe_DataSink_Thread( ) { } 908*cdf0e10cSrcweir 909*cdf0e10cSrcweir ~Pipe_DataSink_Thread( ) 910*cdf0e10cSrcweir { 911*cdf0e10cSrcweir } 912*cdf0e10cSrcweir protected: 913*cdf0e10cSrcweir void SAL_CALL run( ) 914*cdf0e10cSrcweir { 915*cdf0e10cSrcweir sal_Int32 nChars = 0; 916*cdf0e10cSrcweir 917*cdf0e10cSrcweir printf("open pipe\n"); 918*cdf0e10cSrcweir ::osl::StreamPipe aSenderPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_OPEN ); // test::uniquePipeName(aTestPipeName) is a string = "TestPipe" 919*cdf0e10cSrcweir if ( aSenderPipe.is() == sal_False ) 920*cdf0e10cSrcweir { 921*cdf0e10cSrcweir printf("pipe open failed! \n"); 922*cdf0e10cSrcweir } 923*cdf0e10cSrcweir else 924*cdf0e10cSrcweir { 925*cdf0e10cSrcweir printf("read\n"); 926*cdf0e10cSrcweir nChars = aSenderPipe.read( buf, m_pTestString1.getLength() + 1 ); 927*cdf0e10cSrcweir if ( nChars < 0 ) 928*cdf0e10cSrcweir { 929*cdf0e10cSrcweir printf("read failed! \n"); 930*cdf0e10cSrcweir return; 931*cdf0e10cSrcweir } 932*cdf0e10cSrcweir printf("buffer is %s \n", buf); 933*cdf0e10cSrcweir printf("send\n"); 934*cdf0e10cSrcweir nChars = aSenderPipe.send( m_pTestString2.getStr(), m_pTestString2.getLength() + 1 ); 935*cdf0e10cSrcweir if ( nChars < 0 ) 936*cdf0e10cSrcweir { 937*cdf0e10cSrcweir printf("client send failed! \n"); 938*cdf0e10cSrcweir return; 939*cdf0e10cSrcweir } 940*cdf0e10cSrcweir } 941*cdf0e10cSrcweir } 942*cdf0e10cSrcweir 943*cdf0e10cSrcweir }; 944*cdf0e10cSrcweir 945*cdf0e10cSrcweir // ----------------------------------------------------------------------------- 946*cdf0e10cSrcweir 947*cdf0e10cSrcweir class Pipe_DataSource_Thread : public Thread 948*cdf0e10cSrcweir { 949*cdf0e10cSrcweir public: 950*cdf0e10cSrcweir sal_Char buf[256]; 951*cdf0e10cSrcweir //::osl::StreamPipe aListenPipe; //( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 952*cdf0e10cSrcweir ::osl::Pipe aListenPipe; 953*cdf0e10cSrcweir ::osl::StreamPipe aConnectionPipe; 954*cdf0e10cSrcweir Pipe_DataSource_Thread( ) 955*cdf0e10cSrcweir { 956*cdf0e10cSrcweir printf("create pipe\n"); 957*cdf0e10cSrcweir aListenPipe.create( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 958*cdf0e10cSrcweir } 959*cdf0e10cSrcweir ~Pipe_DataSource_Thread( ) 960*cdf0e10cSrcweir { 961*cdf0e10cSrcweir aListenPipe.close(); 962*cdf0e10cSrcweir } 963*cdf0e10cSrcweir protected: 964*cdf0e10cSrcweir void SAL_CALL run( ) 965*cdf0e10cSrcweir { 966*cdf0e10cSrcweir //create pipe. 967*cdf0e10cSrcweir sal_Int32 nChars; 968*cdf0e10cSrcweir //::osl::StreamPipe aListenPipe( test::uniquePipeName(aTestPipeName), osl_Pipe_CREATE ); 969*cdf0e10cSrcweir printf("listen\n"); 970*cdf0e10cSrcweir if ( aListenPipe.is() == sal_False ) 971*cdf0e10cSrcweir { 972*cdf0e10cSrcweir printf("pipe create failed! \n"); 973*cdf0e10cSrcweir } 974*cdf0e10cSrcweir else 975*cdf0e10cSrcweir { 976*cdf0e10cSrcweir //::osl::StreamPipe aConnectionPipe; 977*cdf0e10cSrcweir 978*cdf0e10cSrcweir //start server and wait for connection. 979*cdf0e10cSrcweir printf("accept\n"); 980*cdf0e10cSrcweir if ( osl_Pipe_E_None != aListenPipe.accept( aConnectionPipe ) ) 981*cdf0e10cSrcweir { 982*cdf0e10cSrcweir printf("pipe accept failed!"); 983*cdf0e10cSrcweir return; 984*cdf0e10cSrcweir } 985*cdf0e10cSrcweir printf("write\n"); 986*cdf0e10cSrcweir // write to pipe 987*cdf0e10cSrcweir nChars = aConnectionPipe.write( m_pTestString1.getStr(), m_pTestString1.getLength() + 1 ); 988*cdf0e10cSrcweir if ( nChars < 0) 989*cdf0e10cSrcweir { 990*cdf0e10cSrcweir printf("server write failed! \n"); 991*cdf0e10cSrcweir return; 992*cdf0e10cSrcweir } 993*cdf0e10cSrcweir printf("recv\n"); 994*cdf0e10cSrcweir nChars = aConnectionPipe.recv( buf, 256 ); 995*cdf0e10cSrcweir 996*cdf0e10cSrcweir if ( nChars < 0) 997*cdf0e10cSrcweir { 998*cdf0e10cSrcweir printf("server receive failed! \n"); 999*cdf0e10cSrcweir return; 1000*cdf0e10cSrcweir } 1001*cdf0e10cSrcweir //thread_sleep( 2 ); 1002*cdf0e10cSrcweir printf("received message is: %s\n", buf ); 1003*cdf0e10cSrcweir //aConnectionPipe.close(); 1004*cdf0e10cSrcweir } 1005*cdf0e10cSrcweir } 1006*cdf0e10cSrcweir }; 1007*cdf0e10cSrcweir 1008*cdf0e10cSrcweir /** testing the method: read/write/send/recv and Pipe::accept 1009*cdf0e10cSrcweir */ 1010*cdf0e10cSrcweir class recv : public CppUnit::TestFixture 1011*cdf0e10cSrcweir { 1012*cdf0e10cSrcweir public: 1013*cdf0e10cSrcweir sal_Bool bRes, bRes1; 1014*cdf0e10cSrcweir 1015*cdf0e10cSrcweir void recv_001( ) 1016*cdf0e10cSrcweir { 1017*cdf0e10cSrcweir //launch threads. 1018*cdf0e10cSrcweir Pipe_DataSource_Thread myDataSourceThread; 1019*cdf0e10cSrcweir Pipe_DataSink_Thread myDataSinkThread; 1020*cdf0e10cSrcweir myDataSourceThread.create( ); 1021*cdf0e10cSrcweir thread_sleep( 1 ); 1022*cdf0e10cSrcweir myDataSinkThread.create( ); 1023*cdf0e10cSrcweir 1024*cdf0e10cSrcweir //wait until the thread terminate 1025*cdf0e10cSrcweir myDataSinkThread.join( ); 1026*cdf0e10cSrcweir myDataSourceThread.join( ); 1027*cdf0e10cSrcweir 1028*cdf0e10cSrcweir int nCompare1 = strcmp( myDataSinkThread.buf, m_pTestString1.getStr() ); 1029*cdf0e10cSrcweir int nCompare2 = strcmp( myDataSourceThread.buf, m_pTestString2.getStr() ); 1030*cdf0e10cSrcweir CPPUNIT_ASSERT_MESSAGE( "test send/recv/write/read.", nCompare1 == 0 && nCompare2 == 0 ); 1031*cdf0e10cSrcweir } 1032*cdf0e10cSrcweir //close pipe when accept 1033*cdf0e10cSrcweir void recv_002() 1034*cdf0e10cSrcweir { 1035*cdf0e10cSrcweir thread_sleep( 1 ); 1036*cdf0e10cSrcweir 1037*cdf0e10cSrcweir Pipe_DataSource_Thread myDataSourceThread; 1038*cdf0e10cSrcweir Pipe_DataSink_Thread myDataSinkThread; 1039*cdf0e10cSrcweir myDataSourceThread.create( ); 1040*cdf0e10cSrcweir thread_sleep( 1 ); 1041*cdf0e10cSrcweir myDataSourceThread.aListenPipe.close(); 1042*cdf0e10cSrcweir myDataSourceThread.join( ); 1043*cdf0e10cSrcweir //no condition judgement here, if the case could finish excuting within 1 or 2 seconds, it passes. 1044*cdf0e10cSrcweir } 1045*cdf0e10cSrcweir 1046*cdf0e10cSrcweir CPPUNIT_TEST_SUITE( recv ); 1047*cdf0e10cSrcweir CPPUNIT_TEST( recv_001 ); 1048*cdf0e10cSrcweir CPPUNIT_TEST( recv_002 ); 1049*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_END( ); 1050*cdf0e10cSrcweir }; // class recv 1051*cdf0e10cSrcweir 1052*cdf0e10cSrcweir // ----------------------------------------------------------------------------- 1053*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_StreamPipe::ctors); 1054*cdf0e10cSrcweir //CPPUNIT_TEST_SUITE_REGISTRATION(osl_StreamPipe::assign); 1055*cdf0e10cSrcweir CPPUNIT_TEST_SUITE_REGISTRATION(osl_StreamPipe::recv); 1056*cdf0e10cSrcweir // ----------------------------------------------------------------------------- 1057*cdf0e10cSrcweir 1058*cdf0e10cSrcweir } // namespace osl_StreamPipe 1059*cdf0e10cSrcweir 1060*cdf0e10cSrcweir CPPUNIT_PLUGIN_IMPLEMENT(); 1061