AIXPlatformUtils.cpp
上传用户:zhuqijet
上传日期:2013-06-25
资源大小:10074k
文件大小:17k
源码类别:

词法分析

开发平台:

Visual C++

  1. /*
  2.  * The Apache Software License, Version 1.1
  3.  *
  4.  * Copyright (c) 1999-2002 The Apache Software Foundation.  All rights
  5.  * reserved.
  6.  *
  7.  * Redistribution and use in source and binary forms, with or without
  8.  * modification, are permitted provided that the following conditions
  9.  * are met:
  10.  *
  11.  * 1. Redistributions of source code must retain the above copyright
  12.  *    notice, this list of conditions and the following disclaimer.
  13.  *
  14.  * 2. Redistributions in binary form must reproduce the above copyright
  15.  *    notice, this list of conditions and the following disclaimer in
  16.  *    the documentation and/or other materials provided with the
  17.  *    distribution.
  18.  *
  19.  * 3. The end-user documentation included with the redistribution,
  20.  *    if any, must include the following acknowledgment:
  21.  *       "This product includes software developed by the
  22.  *        Apache Software Foundation (http://www.apache.org/)."
  23.  *    Alternately, this acknowledgment may appear in the software itself,
  24.  *    if and wherever such third-party acknowledgments normally appear.
  25.  *
  26.  * 4. The names "Xerces" and "Apache Software Foundation" must
  27.  *    not be used to endorse or promote products derived from this
  28.  *    software without prior written permission. For written
  29.  *    permission, please contact apache@apache.org.
  30.  *
  31.  * 5. Products derived from this software may not be called "Apache",
  32.  *    nor may "Apache" appear in their name, without prior written
  33.  *    permission of the Apache Software Foundation.
  34.  *
  35.  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
  36.  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  37.  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
  38.  * DISCLAIMED.  IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
  39.  * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  40.  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  41.  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
  42.  * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
  43.  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
  44.  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
  45.  * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  46.  * SUCH DAMAGE.
  47.  * ====================================================================
  48.  *
  49.  * This software consists of voluntary contributions made by many
  50.  * individuals on behalf of the Apache Software Foundation, and was
  51.  * originally based on software copyright (c) 1999, International
  52.  * Business Machines, Inc., http://www.ibm.com .  For more information
  53.  * on the Apache Software Foundation, please see
  54.  * <http://www.apache.org/>.
  55.  */
  56. /*
  57.  * $Id: AIXPlatformUtils.cpp,v 1.16 2003/05/16 15:52:51 peiyongz Exp $
  58.  */
  59. // ---------------------------------------------------------------------------
  60. //  Includes
  61. // ---------------------------------------------------------------------------
  62. #ifndef APP_NO_THREADS
  63. #  if defined(XML_USE_DCE)
  64. #    include    <dce/pthread.h>
  65. #  else
  66. #    include    <pthread.h>
  67. #  endif // XML_USE_DCE
  68. #include    <sys/atomic_op.h>
  69. #endif
  70. #include    <stdio.h>
  71. #include    <stdlib.h>
  72. #include    <errno.h>
  73. #include    <libgen.h>
  74. #include    <sys/timeb.h>
  75. #include    <string.h>
  76. #include    <unistd.h>
  77. #include    <limits.h>
  78. #include    <sys/ldr.h>
  79. #include    <xercesc/util/PlatformUtils.hpp>
  80. #include    <xercesc/util/RuntimeException.hpp>
  81. #include    <xercesc/util/Janitor.hpp>
  82. #include    <xercesc/util/XMLString.hpp>
  83. #include    <xercesc/util/XMLUniDefs.hpp>
  84. #include    <xercesc/util/PanicHandler.hpp>
  85. #if defined (XML_USE_ICU_TRANSCODER)
  86.     #include <xercesc/util/Transcoders/ICU/ICUTransService.hpp>
  87. #else   // use native transcoder
  88.     #include <xercesc/util/Transcoders/Iconv/IconvTransService.hpp>
  89. #endif
  90. #if defined (XML_USE_ICU_MESSAGELOADER)
  91.     #include <xercesc/util/MsgLoaders/ICU/ICUMsgLoader.hpp>
  92. #elif defined (XML_USE_ICONV_MESSAGELOADER)
  93.     #include <xercesc/util/MsgLoaders/MsgCatalog/MsgCatalogLoader.hpp>
  94. #else   // use In-memory message loader
  95.     #include <xercesc/util/MsgLoaders/InMemory/InMemMsgLoader.hpp>   //hint for the user to include this file.
  96. #endif
  97. #if defined (XML_USE_NETACCESSOR_SOCKET)
  98.     #include <xercesc/util/NetAccessors/Socket/SocketNetAccessor.hpp>
  99. #endif
  100. XERCES_CPP_NAMESPACE_BEGIN
  101. // ---------------------------------------------------------------------------
  102. //  XMLPlatformUtils: Platform init method
  103. // ---------------------------------------------------------------------------
  104. void XMLPlatformUtils::platformInit()
  105. {
  106. }
  107. XMLNetAccessor* XMLPlatformUtils::makeNetAccessor()
  108. {
  109. #if defined (XML_USE_NETACCESSOR_SOCKET)
  110.     return new SocketNetAccessor();
  111. #else
  112.     return 0;
  113. #endif
  114. }
  115. //
  116. //  This method is called very early in the bootstrapping process. This guy
  117. //  must create a transcoding service and return it. It cannot use any string
  118. //  methods, any transcoding services, throw any exceptions, etc... It just
  119. //  makes a transcoding service and returns it, or returns zero on failure.
  120. //
  121. XMLTransService* XMLPlatformUtils::makeTransService()
  122. #if defined (XML_USE_ICU_TRANSCODER)
  123. {
  124.     return new ICUTransService;
  125. }
  126. #else
  127. {
  128.     return new IconvTransService;
  129. }
  130. #endif
  131. //
  132. //  This method is called by the platform independent part of this class
  133. //  when client code asks to have one of the supported message sets loaded.
  134. //  In our case, we use the ICU based message loader mechanism.
  135. //
  136. XMLMsgLoader* XMLPlatformUtils::loadAMsgSet(const XMLCh* const msgDomain)
  137. {
  138.     XMLMsgLoader* retVal;
  139.     try
  140.     {
  141. #if defined (XML_USE_ICU_MESSAGELOADER)
  142.         retVal = new ICUMsgLoader(msgDomain);
  143. #elif defined (XML_USE_ICONV_MESSAGELOADER)
  144.         retVal = new MsgCatalogLoader(msgDomain);
  145. #else
  146.         retVal = new InMemMsgLoader(msgDomain);
  147. #endif
  148.     }
  149.     catch(...)
  150.     {
  151.          panic(PanicHandler::Panic_CantLoadMsgDomain);
  152.     }
  153.     return retVal;
  154. }
  155. // ---------------------------------------------------------------------------
  156. //  XMLPlatformUtils: The panic method
  157. // ---------------------------------------------------------------------------
  158. void XMLPlatformUtils::panic(const PanicHandler::PanicReasons reason)
  159. {
  160.     fgUserPanicHandler? fgUserPanicHandler->panic(reason) : fgDefaultPanicHandler->panic(reason);
  161. }
  162. // ---------------------------------------------------------------------------
  163. //  XMLPlatformUtils: File Methods
  164. // ---------------------------------------------------------------------------
  165. unsigned int XMLPlatformUtils::curFilePos(FileHandle theFile)
  166. {
  167.     // Get the current position
  168.     int curPos = ftell( (FILE*)theFile);
  169.     if (curPos == -1)
  170.     ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotGetSize);
  171.     return (unsigned int)curPos;
  172. }
  173. void XMLPlatformUtils::closeFile(FileHandle theFile)
  174. {
  175.     if (fclose((FILE*)theFile))
  176.     ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotCloseFile);
  177. }
  178. unsigned int XMLPlatformUtils::fileSize(FileHandle theFile)
  179. {
  180.     // Get the current position
  181.     long  int curPos = ftell((FILE*)theFile);
  182.     if (curPos == -1)
  183.         ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotGetCurPos);
  184.     // Seek to the end and save that value for return
  185.      if (fseek( (FILE*)theFile, 0, SEEK_END) )
  186.         ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotSeekToEnd);
  187.     long int retVal = ftell( (FILE*)theFile);
  188.     if (retVal == -1)
  189.         ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotSeekToEnd);
  190.     // And put the pointer back
  191.     if (fseek( (FILE*)theFile, curPos, SEEK_SET) )
  192.         ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotSeekToPos);
  193.     return (unsigned int)retVal;
  194. }
  195. FileHandle XMLPlatformUtils::openFile(const XMLCh* const fileName)
  196. {
  197.     const char* tmpFileName = XMLString::transcode(fileName, fgMemoryManager);
  198.     ArrayJanitor<char> janText((char*)tmpFileName, fgMemoryManager);
  199.     FileHandle retVal = (FILE*)fopen( tmpFileName , "rb" );
  200.     if (retVal == NULL)
  201.         return 0;
  202.     return retVal;
  203. }
  204. FileHandle XMLPlatformUtils::openFile(const char* const fileName)
  205. {
  206.     FileHandle retVal = (FILE*)fopen( fileName , "rb" );
  207.     if (retVal == NULL)
  208.         return 0;
  209.     return retVal;
  210. }
  211. FileHandle XMLPlatformUtils::openFileToWrite(const XMLCh* const fileName)
  212. {
  213.     const char* tmpFileName = XMLString::transcode(fileName, fgMemoryManager);
  214.     ArrayJanitor<char> janText((char*)tmpFileName, fgMemoryManager);
  215.     return fopen( tmpFileName , "wb" );
  216. }
  217. FileHandle XMLPlatformUtils::openFileToWrite(const char* const fileName)
  218. {
  219.     return fopen( fileName , "wb" );
  220. }
  221. unsigned int
  222. XMLPlatformUtils::readFileBuffer(  FileHandle      theFile
  223.                                 , const unsigned int    toRead
  224.                                 , XMLByte* const  toFill)
  225. {
  226.     size_t noOfItemsRead = fread( (void*) toFill, 1, toRead, (FILE*)theFile);
  227.     if(ferror((FILE*)theFile))
  228.     {
  229.         ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotReadFromFile);
  230.     }
  231.     return (unsigned int)noOfItemsRead;
  232. }
  233. void
  234. XMLPlatformUtils::writeBufferToFile( FileHandle     const  theFile
  235.                                    , long                  toWrite
  236.                                    , const XMLByte* const  toFlush)
  237. {
  238.     if (!theFile        ||
  239.         (toWrite <= 0 ) ||
  240.         !toFlush         )
  241.         return;
  242.     const XMLByte* tmpFlush = (const XMLByte*) toFlush;
  243.     size_t bytesWritten = 0;
  244.     while (true)
  245.     {
  246.         bytesWritten=fwrite(tmpFlush, sizeof(XMLByte), toWrite, (FILE*)theFile);
  247.         if(ferror((FILE*)theFile))
  248.         {
  249.             ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotWriteToFile);
  250.         }
  251.         if (bytesWritten < toWrite) //incomplete write
  252.         {
  253.             tmpFlush+=bytesWritten;
  254.             toWrite-=bytesWritten;
  255.             bytesWritten=0;
  256.         }
  257.         else
  258.             return;
  259.     }
  260.     return;
  261. }
  262. void XMLPlatformUtils::resetFile(FileHandle theFile)
  263. {
  264.     // Seek to the start of the file
  265.     if (fseek((FILE*)theFile, 0, SEEK_SET) )
  266.         ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotResetFile);
  267. }
  268. // ---------------------------------------------------------------------------
  269. //  XMLPlatformUtils: File system methods
  270. // ---------------------------------------------------------------------------
  271. XMLCh* XMLPlatformUtils::getFullPath(const XMLCh* const srcPath,
  272.                                      MemoryManager* const manager)
  273. {
  274.     //
  275.     //  NOTE: THe path provided has always already been opened successfully,
  276.     //  so we know that its not some pathological freaky path. It comes in
  277.     //  in native format, and goes out as Unicode always
  278.     //
  279.     char* newSrc = XMLString::transcode(srcPath, fgMemoryManager);
  280.     ArrayJanitor<char> janText(newSrc, fgMemoryManager);
  281.     // Use a local buffer that is big enough for the largest legal path
  282.     char absPath[PATH_MAX + 1];
  283.     //get the absolute path
  284.     char* retPath = realpath(newSrc, &absPath[0]);
  285.     if (!retPath)
  286.     {
  287.         ThrowXML(XMLPlatformUtilsException,
  288.                  XMLExcepts::File_CouldNotGetBasePathName);
  289.     }
  290.     return XMLString::transcode(absPath, manager);
  291. }
  292. bool XMLPlatformUtils::isRelative(const XMLCh* const toCheck)
  293. {
  294.     // Check for pathological case of empty path
  295.     if (!toCheck[0])
  296.         return false;
  297.     //
  298.     //  If it starts with a slash, then it cannot be relative. This covers
  299.     //  both something like "TestFile.xml" and an NT Lan type remote path
  300.     //  that starts with a node like "\MyNodeTestFile.xml".
  301.     //
  302.     if (toCheck[0] == XMLCh('/'))
  303.         return false;
  304.     // Else assume its a relative path
  305.     return true;
  306. }
  307. XMLCh* XMLPlatformUtils::getCurrentDirectory(MemoryManager* const manager)
  308. {
  309.     char  dirBuf[PATH_MAX + 1];
  310.     char  *curDir = getcwd(&dirBuf[0], PATH_MAX + 1);
  311.     if (!curDir)
  312.     {
  313.         ThrowXML(XMLPlatformUtilsException,
  314.                  XMLExcepts::File_CouldNotGetBasePathName);
  315.     }
  316.     return XMLString::transcode(curDir, manager);
  317. }
  318. inline bool XMLPlatformUtils::isAnySlash(XMLCh c) 
  319. {
  320.     return ( chBackSlash == c || chForwardSlash == c);
  321. }
  322. // ---------------------------------------------------------------------------
  323. //  XMLPlatformUtils: Timing Methods
  324. // ---------------------------------------------------------------------------
  325. unsigned long XMLPlatformUtils::getCurrentMillis()
  326. {
  327.     timeb aTime;
  328.     ftime(&aTime);
  329.     return (unsigned long)(aTime.time*1000 + aTime.millitm);
  330. }
  331. // -----------------------------------------------------------------------
  332. //  Mutex methods
  333. // -----------------------------------------------------------------------
  334. #ifndef APP_NO_THREADS
  335. void XMLPlatformUtils::closeMutex(void* const mtxHandle)
  336. {
  337.     if (mtxHandle == NULL)
  338.         return;
  339.     if (pthread_mutex_destroy( (pthread_mutex_t*)mtxHandle))
  340.     {
  341.         ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotDestroy);
  342.     }
  343.     if ( (pthread_mutex_t*)mtxHandle)
  344.         delete (pthread_mutex_t*) mtxHandle;
  345. }
  346. void XMLPlatformUtils::lockMutex(void* const mtxHandle)
  347. {
  348.     if (mtxHandle == NULL)
  349.         return;
  350.     if (pthread_mutex_lock( (pthread_mutex_t*)mtxHandle))
  351.     {
  352.         ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotLock);
  353.     }
  354. }
  355. void* XMLPlatformUtils::makeMutex()
  356. {
  357.     pthread_mutex_t* mutex = new pthread_mutex_t;
  358.     if (mutex ==  NULL)
  359.     {
  360.         ThrowXML(XMLPlatformUtilsException,
  361.                  XMLExcepts::Mutex_CouldNotCreate);
  362.     }
  363.     pthread_mutexattr_t*  attr = new pthread_mutexattr_t;
  364. #if defined(XML_USE_DCE)
  365.     pthread_mutexattr_create(attr);
  366.     pthread_mutexattr_setkind_np(attr, MUTEX_RECURSIVE_NP);
  367.     if (pthread_mutex_init(mutex, *attr))
  368.     {
  369.           ThrowXML(XMLPlatformUtilsException,
  370.                    XMLExcepts::Mutex_CouldNotCreate);
  371.     }
  372.     pthread_mutexattr_delete(attr);
  373. #else
  374.     pthread_mutexattr_init(attr);
  375.     #if defined(XML_AIX43)
  376.         pthread_mutexattr_settype(attr, PTHREAD_MUTEX_RECURSIVE);
  377.     #else
  378.         pthread_mutexattr_setkind_np(attr, MUTEX_RECURSIVE_NP);
  379.     #endif
  380.     if (pthread_mutex_init(mutex, attr))
  381.     {
  382.         ThrowXML(XMLPlatformUtilsException,
  383.                  XMLExcepts::Mutex_CouldNotCreate);
  384.     }
  385.     pthread_mutexattr_destroy(attr);
  386. #endif
  387.     delete attr;
  388.     return (void*)(mutex);
  389. }
  390. void XMLPlatformUtils::unlockMutex(void* const mtxHandle)
  391. {
  392.     if (mtxHandle == NULL)
  393.         return;
  394.     if (pthread_mutex_unlock( (pthread_mutex_t*)mtxHandle))
  395.     {
  396.         ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotUnlock);
  397.     }
  398. }
  399. #else // #ifndef APP_NO_THREADS
  400. void XMLPlatformUtils::closeMutex(void* const mtxHandle)
  401. {
  402. }
  403. void XMLPlatformUtils::lockMutex(void* const mtxHandle)
  404. {
  405. }
  406. void* XMLPlatformUtils::makeMutex()
  407. {
  408.         return 0;
  409. }
  410. void XMLPlatformUtils::unlockMutex(void* const mtxHandle)
  411. {
  412. }
  413. #endif // APP_NO_THREADS
  414. #ifndef APP_NO_THREADS
  415. // -----------------------------------------------------------------------
  416. //  Miscellaneous synchronization methods
  417. // -----------------------------------------------------------------------
  418. void* XMLPlatformUtils::compareAndSwap ( void**      toFill ,
  419.                     const void* const newValue ,
  420.                     const void* const toCompare)
  421. {
  422. #if defined (XML_BITSTOBUILD_64)
  423.     boolean_t boolVar = compare_and_swaplp((atomic_l)toFill, (long*)&toCompare, (long)newValue );
  424. #else
  425.     boolean_t boolVar = compare_and_swap((atomic_p)toFill, (int *)&toCompare, (int)newValue );
  426. #endif
  427.     return (void *)toCompare;
  428. }
  429. int XMLPlatformUtils::atomicIncrement(int &location)
  430. {
  431.     int retVal = fetch_and_add( (atomic_p)&location, 1);
  432.     return retVal+1;
  433. }
  434. int XMLPlatformUtils::atomicDecrement(int &location)
  435. {
  436.     int retVal = fetch_and_add( (atomic_p)&location, -1);
  437.     return retVal-1;
  438. }
  439. #else
  440. // -----------------------------------------------------------------------
  441. //  Miscellaneous synchronization methods
  442. // -----------------------------------------------------------------------
  443. void* XMLPlatformUtils::compareAndSwap ( void**      toFill,
  444.                                    const void* const newValue,
  445.                                    const void* const toCompare)
  446. {
  447.     void *retVal = *toFill;
  448.     if (*toFill == toCompare)
  449.        *toFill = (void *)newValue;
  450.     return retVal;
  451. }
  452. int XMLPlatformUtils::atomicIncrement(int &location)
  453. {
  454.     return ++location;
  455. }
  456. int XMLPlatformUtils::atomicDecrement(int &location)
  457. {
  458.     return --location;
  459. }
  460. #endif // APP_NO_THREADS
  461. FileHandle XMLPlatformUtils::openStdInHandle()
  462. {
  463.     return (FileHandle)fdopen(dup(0), "rb");
  464. }
  465. void XMLPlatformUtils::platformTerm()
  466. {
  467.     // We don't have any termination requirements at this time
  468. }
  469. /**************** Beginning of code attic *******************************
  470. void XMLPlatformUtils::platformInit()
  471. {
  472. }
  473. ********************* End of code attic *******************************/
  474. #include <xercesc/util/LogicalPath.c>
  475. XERCES_CPP_NAMESPACE_END