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 29*cdf0e10cSrcweir #include <vos/pipe.hxx> 30*cdf0e10cSrcweir #include <vos/diagnose.hxx> 31*cdf0e10cSrcweir 32*cdf0e10cSrcweir using namespace vos; 33*cdf0e10cSrcweir 34*cdf0e10cSrcweir /////////////////////////////////////////////////////////////////////////////// 35*cdf0e10cSrcweir // Pipe 36*cdf0e10cSrcweir 37*cdf0e10cSrcweir 38*cdf0e10cSrcweir VOS_IMPLEMENT_CLASSINFO(VOS_CLASSNAME(OPipe, vos), 39*cdf0e10cSrcweir VOS_NAMESPACE(OPipe, vos), 40*cdf0e10cSrcweir VOS_NAMESPACE(OObject, vos), 0); 41*cdf0e10cSrcweir 42*cdf0e10cSrcweir /*****************************************************************************/ 43*cdf0e10cSrcweir // OPipe() 44*cdf0e10cSrcweir /*****************************************************************************/ 45*cdf0e10cSrcweir OPipe::OPipe() 46*cdf0e10cSrcweir { 47*cdf0e10cSrcweir m_pPipeRef= 0; 48*cdf0e10cSrcweir } 49*cdf0e10cSrcweir 50*cdf0e10cSrcweir /*****************************************************************************/ 51*cdf0e10cSrcweir // OPipe() 52*cdf0e10cSrcweir /*****************************************************************************/ 53*cdf0e10cSrcweir 54*cdf0e10cSrcweir OPipe::OPipe( const rtl::OUString& strName, TPipeOption Options) 55*cdf0e10cSrcweir { 56*cdf0e10cSrcweir m_pPipeRef = 57*cdf0e10cSrcweir new PipeRef( osl_createPipe(strName.pData, 58*cdf0e10cSrcweir (oslPipeOptions)Options, 59*cdf0e10cSrcweir NULL) ); 60*cdf0e10cSrcweir 61*cdf0e10cSrcweir VOS_POSTCOND(m_pPipeRef != 0, "OPipe(): new failed.\n"); 62*cdf0e10cSrcweir VOS_POSTCOND((*m_pPipeRef)(), "OPipe(): creation of pipe failed!\n"); 63*cdf0e10cSrcweir } 64*cdf0e10cSrcweir 65*cdf0e10cSrcweir /*****************************************************************************/ 66*cdf0e10cSrcweir // OPipe() 67*cdf0e10cSrcweir /*****************************************************************************/ 68*cdf0e10cSrcweir 69*cdf0e10cSrcweir OPipe::OPipe( const rtl::OUString& strName, 70*cdf0e10cSrcweir TPipeOption Options, 71*cdf0e10cSrcweir const OSecurity& rSecurity) 72*cdf0e10cSrcweir { 73*cdf0e10cSrcweir m_pPipeRef= 74*cdf0e10cSrcweir new PipeRef(osl_createPipe(strName.pData, 75*cdf0e10cSrcweir (oslPipeOptions)Options, 76*cdf0e10cSrcweir (oslSecurity)rSecurity)); 77*cdf0e10cSrcweir 78*cdf0e10cSrcweir VOS_POSTCOND(m_pPipeRef != 0, "OPipe(): new failed.\n"); 79*cdf0e10cSrcweir VOS_POSTCOND((*m_pPipeRef)(), "OPipe(): creation of pipe failed!\n"); 80*cdf0e10cSrcweir } 81*cdf0e10cSrcweir 82*cdf0e10cSrcweir /*****************************************************************************/ 83*cdf0e10cSrcweir // OPipe() 84*cdf0e10cSrcweir /*****************************************************************************/ 85*cdf0e10cSrcweir OPipe::OPipe(const OPipe& pipe) : 86*cdf0e10cSrcweir OReference(), OObject() 87*cdf0e10cSrcweir { 88*cdf0e10cSrcweir 89*cdf0e10cSrcweir VOS_ASSERT(pipe.m_pPipeRef != 0); 90*cdf0e10cSrcweir 91*cdf0e10cSrcweir m_pPipeRef= pipe.m_pPipeRef; 92*cdf0e10cSrcweir 93*cdf0e10cSrcweir m_pPipeRef->acquire(); 94*cdf0e10cSrcweir } 95*cdf0e10cSrcweir 96*cdf0e10cSrcweir /*****************************************************************************/ 97*cdf0e10cSrcweir // OPipe() 98*cdf0e10cSrcweir /*****************************************************************************/ 99*cdf0e10cSrcweir OPipe::OPipe(oslPipe Pipe) 100*cdf0e10cSrcweir { 101*cdf0e10cSrcweir m_pPipeRef = new PipeRef(Pipe); 102*cdf0e10cSrcweir } 103*cdf0e10cSrcweir 104*cdf0e10cSrcweir 105*cdf0e10cSrcweir /*****************************************************************************/ 106*cdf0e10cSrcweir // ~OPipe() 107*cdf0e10cSrcweir /*****************************************************************************/ 108*cdf0e10cSrcweir OPipe::~OPipe() 109*cdf0e10cSrcweir { 110*cdf0e10cSrcweir close(); 111*cdf0e10cSrcweir } 112*cdf0e10cSrcweir 113*cdf0e10cSrcweir /*****************************************************************************/ 114*cdf0e10cSrcweir // create 115*cdf0e10cSrcweir /*****************************************************************************/ 116*cdf0e10cSrcweir sal_Bool OPipe::create( const rtl::OUString& strName, TPipeOption Options ) 117*cdf0e10cSrcweir { 118*cdf0e10cSrcweir // if this was a valid pipe, decrease reference 119*cdf0e10cSrcweir if ((m_pPipeRef) && (m_pPipeRef->release() == 0)) 120*cdf0e10cSrcweir { 121*cdf0e10cSrcweir osl_releasePipe((*m_pPipeRef)()); 122*cdf0e10cSrcweir delete m_pPipeRef; 123*cdf0e10cSrcweir m_pPipeRef= 0; 124*cdf0e10cSrcweir } 125*cdf0e10cSrcweir 126*cdf0e10cSrcweir m_pPipeRef= 127*cdf0e10cSrcweir new PipeRef(osl_createPipe(strName.pData, 128*cdf0e10cSrcweir (oslPipeOptions)Options, 129*cdf0e10cSrcweir NULL)); 130*cdf0e10cSrcweir 131*cdf0e10cSrcweir VOS_POSTCOND(m_pPipeRef != 0, "OPipe(): new failed.\n"); 132*cdf0e10cSrcweir 133*cdf0e10cSrcweir return (*m_pPipeRef)() != 0; 134*cdf0e10cSrcweir } 135*cdf0e10cSrcweir 136*cdf0e10cSrcweir /*****************************************************************************/ 137*cdf0e10cSrcweir // create 138*cdf0e10cSrcweir /*****************************************************************************/ 139*cdf0e10cSrcweir sal_Bool OPipe::create( const rtl::OUString& strName, 140*cdf0e10cSrcweir TPipeOption Options, 141*cdf0e10cSrcweir const vos::OSecurity& rSecurity ) 142*cdf0e10cSrcweir { 143*cdf0e10cSrcweir // if this was a valid pipe, decrease reference 144*cdf0e10cSrcweir if ((m_pPipeRef) && (m_pPipeRef->release() == 0)) 145*cdf0e10cSrcweir { 146*cdf0e10cSrcweir osl_releasePipe((*m_pPipeRef)()); 147*cdf0e10cSrcweir delete m_pPipeRef; 148*cdf0e10cSrcweir m_pPipeRef= 0; 149*cdf0e10cSrcweir } 150*cdf0e10cSrcweir 151*cdf0e10cSrcweir m_pPipeRef= 152*cdf0e10cSrcweir new PipeRef(osl_createPipe(strName.pData, 153*cdf0e10cSrcweir (oslPipeOptions)Options, 154*cdf0e10cSrcweir (oslSecurity)rSecurity)); 155*cdf0e10cSrcweir 156*cdf0e10cSrcweir VOS_POSTCOND(m_pPipeRef != 0, "OPipe(): new failed.\n"); 157*cdf0e10cSrcweir 158*cdf0e10cSrcweir return (*m_pPipeRef)() != 0; 159*cdf0e10cSrcweir } 160*cdf0e10cSrcweir 161*cdf0e10cSrcweir /*****************************************************************************/ 162*cdf0e10cSrcweir // operator= 163*cdf0e10cSrcweir /*****************************************************************************/ 164*cdf0e10cSrcweir OPipe& OPipe::operator= (const OPipe& pipe) 165*cdf0e10cSrcweir { 166*cdf0e10cSrcweir VOS_PRECOND(pipe.m_pPipeRef != 0, "OPipe::operator=: tried to assign an empty/invalid pipe\n"); 167*cdf0e10cSrcweir 168*cdf0e10cSrcweir if (m_pPipeRef == pipe.m_pPipeRef) 169*cdf0e10cSrcweir return *this; 170*cdf0e10cSrcweir 171*cdf0e10cSrcweir // if this was a valid pipe, decrease reference 172*cdf0e10cSrcweir if ((m_pPipeRef) && (m_pPipeRef->release() == 0)) 173*cdf0e10cSrcweir { 174*cdf0e10cSrcweir osl_releasePipe((*m_pPipeRef)()); 175*cdf0e10cSrcweir delete m_pPipeRef; 176*cdf0e10cSrcweir m_pPipeRef= 0; 177*cdf0e10cSrcweir } 178*cdf0e10cSrcweir 179*cdf0e10cSrcweir m_pPipeRef= pipe.m_pPipeRef; 180*cdf0e10cSrcweir 181*cdf0e10cSrcweir m_pPipeRef->acquire(); 182*cdf0e10cSrcweir 183*cdf0e10cSrcweir return *this; 184*cdf0e10cSrcweir } 185*cdf0e10cSrcweir 186*cdf0e10cSrcweir /*****************************************************************************/ 187*cdf0e10cSrcweir // operator oslPipe() 188*cdf0e10cSrcweir /*****************************************************************************/ 189*cdf0e10cSrcweir OPipe::operator oslPipe() const 190*cdf0e10cSrcweir { 191*cdf0e10cSrcweir VOS_ASSERT(m_pPipeRef); 192*cdf0e10cSrcweir return (*m_pPipeRef)(); 193*cdf0e10cSrcweir } 194*cdf0e10cSrcweir 195*cdf0e10cSrcweir /*****************************************************************************/ 196*cdf0e10cSrcweir // isValid() 197*cdf0e10cSrcweir /*****************************************************************************/ 198*cdf0e10cSrcweir sal_Bool OPipe::isValid() const 199*cdf0e10cSrcweir { 200*cdf0e10cSrcweir return m_pPipeRef != 0 && (*m_pPipeRef)() != 0; 201*cdf0e10cSrcweir } 202*cdf0e10cSrcweir 203*cdf0e10cSrcweir 204*cdf0e10cSrcweir /*****************************************************************************/ 205*cdf0e10cSrcweir // close 206*cdf0e10cSrcweir /*****************************************************************************/ 207*cdf0e10cSrcweir void OPipe::close() 208*cdf0e10cSrcweir { 209*cdf0e10cSrcweir if (m_pPipeRef && (m_pPipeRef->release() == 0)) 210*cdf0e10cSrcweir { 211*cdf0e10cSrcweir osl_releasePipe((*m_pPipeRef)()); 212*cdf0e10cSrcweir delete m_pPipeRef; 213*cdf0e10cSrcweir } 214*cdf0e10cSrcweir m_pPipeRef= 0; 215*cdf0e10cSrcweir } 216*cdf0e10cSrcweir 217*cdf0e10cSrcweir /*****************************************************************************/ 218*cdf0e10cSrcweir // accept 219*cdf0e10cSrcweir /*****************************************************************************/ 220*cdf0e10cSrcweir OPipe::TPipeError OPipe::accept(OStreamPipe& Connection) 221*cdf0e10cSrcweir { 222*cdf0e10cSrcweir if ( isValid() ) 223*cdf0e10cSrcweir { 224*cdf0e10cSrcweir Connection = osl_acceptPipe((*m_pPipeRef)()); 225*cdf0e10cSrcweir 226*cdf0e10cSrcweir if(Connection.isValid()) 227*cdf0e10cSrcweir return E_None; 228*cdf0e10cSrcweir } 229*cdf0e10cSrcweir 230*cdf0e10cSrcweir return getError(); 231*cdf0e10cSrcweir } 232*cdf0e10cSrcweir 233*cdf0e10cSrcweir /*****************************************************************************/ 234*cdf0e10cSrcweir // recv 235*cdf0e10cSrcweir /*****************************************************************************/ 236*cdf0e10cSrcweir sal_Int32 OPipe::recv(void* pBuffer, sal_uInt32 BytesToRead) 237*cdf0e10cSrcweir { 238*cdf0e10cSrcweir if ( isValid() ) 239*cdf0e10cSrcweir return osl_receivePipe((*m_pPipeRef)(), 240*cdf0e10cSrcweir pBuffer, 241*cdf0e10cSrcweir BytesToRead); 242*cdf0e10cSrcweir else 243*cdf0e10cSrcweir return -1; 244*cdf0e10cSrcweir 245*cdf0e10cSrcweir } 246*cdf0e10cSrcweir 247*cdf0e10cSrcweir /*****************************************************************************/ 248*cdf0e10cSrcweir // send 249*cdf0e10cSrcweir /*****************************************************************************/ 250*cdf0e10cSrcweir sal_Int32 OPipe::send(const void* pBuffer, sal_uInt32 BytesToSend) 251*cdf0e10cSrcweir { 252*cdf0e10cSrcweir if ( isValid() ) 253*cdf0e10cSrcweir return osl_sendPipe((*m_pPipeRef)(), 254*cdf0e10cSrcweir pBuffer, 255*cdf0e10cSrcweir BytesToSend); 256*cdf0e10cSrcweir else 257*cdf0e10cSrcweir return -1; 258*cdf0e10cSrcweir } 259*cdf0e10cSrcweir 260*cdf0e10cSrcweir /*****************************************************************************/ 261*cdf0e10cSrcweir // getError 262*cdf0e10cSrcweir /*****************************************************************************/ 263*cdf0e10cSrcweir OPipe::TPipeError OPipe::getError() const 264*cdf0e10cSrcweir { 265*cdf0e10cSrcweir if (m_pPipeRef) 266*cdf0e10cSrcweir return (TPipeError)osl_getLastPipeError((*m_pPipeRef)()); 267*cdf0e10cSrcweir else 268*cdf0e10cSrcweir return (TPipeError)osl_getLastPipeError(NULL); 269*cdf0e10cSrcweir } 270*cdf0e10cSrcweir 271*cdf0e10cSrcweir 272*cdf0e10cSrcweir 273*cdf0e10cSrcweir VOS_IMPLEMENT_CLASSINFO(VOS_CLASSNAME(OStreamPipe, vos), 274*cdf0e10cSrcweir VOS_NAMESPACE(OStreamPipe, vos), 275*cdf0e10cSrcweir VOS_NAMESPACE(OPipe, vos), 0); 276*cdf0e10cSrcweir 277*cdf0e10cSrcweir 278*cdf0e10cSrcweir 279*cdf0e10cSrcweir /*****************************************************************************/ 280*cdf0e10cSrcweir // OStreamPipe 281*cdf0e10cSrcweir /*****************************************************************************/ 282*cdf0e10cSrcweir OStreamPipe::OStreamPipe() 283*cdf0e10cSrcweir { 284*cdf0e10cSrcweir } 285*cdf0e10cSrcweir 286*cdf0e10cSrcweir /*****************************************************************************/ 287*cdf0e10cSrcweir // OStreamPipe 288*cdf0e10cSrcweir /*****************************************************************************/ 289*cdf0e10cSrcweir OStreamPipe::OStreamPipe(oslPipe Pipe) : 290*cdf0e10cSrcweir OPipe(Pipe) 291*cdf0e10cSrcweir { 292*cdf0e10cSrcweir } 293*cdf0e10cSrcweir 294*cdf0e10cSrcweir /*****************************************************************************/ 295*cdf0e10cSrcweir // OStreamPipe 296*cdf0e10cSrcweir // copy constructor 297*cdf0e10cSrcweir /*****************************************************************************/ 298*cdf0e10cSrcweir OStreamPipe::OStreamPipe(const OStreamPipe& pipe) : 299*cdf0e10cSrcweir OPipe(), IStream() 300*cdf0e10cSrcweir { 301*cdf0e10cSrcweir VOS_ASSERT(pipe.m_pPipeRef != 0); 302*cdf0e10cSrcweir 303*cdf0e10cSrcweir m_pPipeRef= pipe.m_pPipeRef; 304*cdf0e10cSrcweir 305*cdf0e10cSrcweir m_pPipeRef->acquire(); 306*cdf0e10cSrcweir } 307*cdf0e10cSrcweir 308*cdf0e10cSrcweir /*****************************************************************************/ 309*cdf0e10cSrcweir // ~OStreamPipe 310*cdf0e10cSrcweir /*****************************************************************************/ 311*cdf0e10cSrcweir OStreamPipe::~OStreamPipe() 312*cdf0e10cSrcweir { 313*cdf0e10cSrcweir } 314*cdf0e10cSrcweir 315*cdf0e10cSrcweir /*****************************************************************************/ 316*cdf0e10cSrcweir // operator=(oslPipe) 317*cdf0e10cSrcweir /*****************************************************************************/ 318*cdf0e10cSrcweir OStreamPipe& OStreamPipe::operator=(oslPipe Pipe) 319*cdf0e10cSrcweir { 320*cdf0e10cSrcweir 321*cdf0e10cSrcweir // if this was a valid pipe, decrease reference 322*cdf0e10cSrcweir if (m_pPipeRef && (m_pPipeRef->release() == 0)) 323*cdf0e10cSrcweir { 324*cdf0e10cSrcweir osl_releasePipe((*m_pPipeRef)()); 325*cdf0e10cSrcweir delete m_pPipeRef; 326*cdf0e10cSrcweir m_pPipeRef= 0; 327*cdf0e10cSrcweir } 328*cdf0e10cSrcweir 329*cdf0e10cSrcweir m_pPipeRef= new PipeRef(Pipe); 330*cdf0e10cSrcweir 331*cdf0e10cSrcweir VOS_POSTCOND(m_pPipeRef != 0, "OPipe(): new failed.\n"); 332*cdf0e10cSrcweir 333*cdf0e10cSrcweir return *this; 334*cdf0e10cSrcweir } 335*cdf0e10cSrcweir 336*cdf0e10cSrcweir /*****************************************************************************/ 337*cdf0e10cSrcweir // operator=OPipe 338*cdf0e10cSrcweir /*****************************************************************************/ 339*cdf0e10cSrcweir 340*cdf0e10cSrcweir OStreamPipe& OStreamPipe::operator= (const OPipe& pipe) 341*cdf0e10cSrcweir { 342*cdf0e10cSrcweir OPipe::operator= ( pipe ); 343*cdf0e10cSrcweir return *this; 344*cdf0e10cSrcweir } 345*cdf0e10cSrcweir 346*cdf0e10cSrcweir /*****************************************************************************/ 347*cdf0e10cSrcweir // read 348*cdf0e10cSrcweir /*****************************************************************************/ 349*cdf0e10cSrcweir sal_Int32 OStreamPipe::read(void* pBuffer, sal_uInt32 n) const 350*cdf0e10cSrcweir { 351*cdf0e10cSrcweir VOS_ASSERT(m_pPipeRef && (*m_pPipeRef)()); 352*cdf0e10cSrcweir 353*cdf0e10cSrcweir /* loop until all desired bytes were read or an error occured */ 354*cdf0e10cSrcweir sal_Int32 BytesRead= 0; 355*cdf0e10cSrcweir sal_Int32 BytesToRead= n; 356*cdf0e10cSrcweir while (BytesToRead > 0) 357*cdf0e10cSrcweir { 358*cdf0e10cSrcweir sal_Int32 RetVal; 359*cdf0e10cSrcweir RetVal= osl_receivePipe((*m_pPipeRef)(), 360*cdf0e10cSrcweir pBuffer, 361*cdf0e10cSrcweir BytesToRead); 362*cdf0e10cSrcweir 363*cdf0e10cSrcweir /* error occured? */ 364*cdf0e10cSrcweir if(RetVal <= 0) 365*cdf0e10cSrcweir { 366*cdf0e10cSrcweir break; 367*cdf0e10cSrcweir } 368*cdf0e10cSrcweir 369*cdf0e10cSrcweir BytesToRead -= RetVal; 370*cdf0e10cSrcweir BytesRead += RetVal; 371*cdf0e10cSrcweir pBuffer= (sal_Char*)pBuffer + RetVal; 372*cdf0e10cSrcweir } 373*cdf0e10cSrcweir 374*cdf0e10cSrcweir return BytesRead; 375*cdf0e10cSrcweir } 376*cdf0e10cSrcweir 377*cdf0e10cSrcweir /*****************************************************************************/ 378*cdf0e10cSrcweir // write 379*cdf0e10cSrcweir /*****************************************************************************/ 380*cdf0e10cSrcweir sal_Int32 OStreamPipe::write(const void* pBuffer, sal_uInt32 n) 381*cdf0e10cSrcweir { 382*cdf0e10cSrcweir VOS_ASSERT(m_pPipeRef && (*m_pPipeRef)()); 383*cdf0e10cSrcweir 384*cdf0e10cSrcweir /* loop until all desired bytes were send or an error occured */ 385*cdf0e10cSrcweir sal_Int32 BytesSend= 0; 386*cdf0e10cSrcweir sal_Int32 BytesToSend= n; 387*cdf0e10cSrcweir while (BytesToSend > 0) 388*cdf0e10cSrcweir { 389*cdf0e10cSrcweir sal_Int32 RetVal; 390*cdf0e10cSrcweir 391*cdf0e10cSrcweir RetVal= osl_sendPipe((*m_pPipeRef)(), 392*cdf0e10cSrcweir pBuffer, 393*cdf0e10cSrcweir BytesToSend); 394*cdf0e10cSrcweir 395*cdf0e10cSrcweir /* error occured? */ 396*cdf0e10cSrcweir if(RetVal <= 0) 397*cdf0e10cSrcweir { 398*cdf0e10cSrcweir break; 399*cdf0e10cSrcweir } 400*cdf0e10cSrcweir 401*cdf0e10cSrcweir BytesToSend -= RetVal; 402*cdf0e10cSrcweir BytesSend += RetVal; 403*cdf0e10cSrcweir pBuffer= (sal_Char*)pBuffer + RetVal; 404*cdf0e10cSrcweir } 405*cdf0e10cSrcweir 406*cdf0e10cSrcweir return BytesSend; 407*cdf0e10cSrcweir } 408*cdf0e10cSrcweir 409*cdf0e10cSrcweir sal_Bool OStreamPipe::isEof() const 410*cdf0e10cSrcweir { 411*cdf0e10cSrcweir return isValid(); 412*cdf0e10cSrcweir } 413*cdf0e10cSrcweir 414*cdf0e10cSrcweir 415*cdf0e10cSrcweir 416*cdf0e10cSrcweir 417