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

词法分析

开发平台:

Visual C++

  1. /*
  2.  * The Apache Software License, Version 1.1
  3.  *
  4.  * Copyright (c) 1999-2000 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: Tru64PlatformUtils.cpp,v 1.10 2003/05/15 18:37:49 knoaman Exp $
  58.  */
  59. // ---------------------------------------------------------------------------
  60. //  Includes
  61. // ---------------------------------------------------------------------------
  62. #if !defined (APP_NO_THREADS)
  63. #include    <pthread.h>
  64. #endif // APP_NO_THREADS
  65. #include <stdio.h>
  66. #include <stdlib.h>
  67. #include <time.h>
  68. #include <unistd.h>
  69. #include    <xercesc/util/Janitor.hpp>
  70. #include    <xercesc/util/PlatformUtils.hpp>
  71. #include    <xercesc/util/RuntimeException.hpp>
  72. #include    <xercesc/util/Mutexes.hpp>
  73. #include    <xercesc/util/XMLString.hpp>
  74. #include    <xercesc/util/XMLUni.hpp>
  75. #include    <xercesc/util/XMLUniDefs.hpp>
  76. #include    <xercesc/util/PanicHandler.hpp>
  77. //
  78. //  These control which transcoding service is used by the Tru64 version.
  79. //  They allow this to be controlled from the build process by just defining
  80. //  one of these values.
  81. //
  82. #if defined (XML_USE_ICU_TRANSCODER)
  83. #include <xercesc/util/Transcoders/ICU/ICUTransService.hpp>
  84. #else   // use native transcoder
  85. #include <xercesc/util/Transcoders/Iconv/IconvTransService.hpp>
  86. #endif
  87. //
  88. //  These control which message loading service is used by the Tru64 version.
  89. //  They allow this to be controlled from the build process by just defining
  90. //  one of these values.
  91. //
  92. #if defined (XML_USE_ICU_MESSAGELOADER)
  93. #include <xercesc/util/MsgLoaders/ICU/ICUMsgLoader.hpp>
  94. #elif defined (XML_USE_ICONV_MESSAGELOADER)
  95. #include <xercesc/util/MsgLoaders/MsgCatalog/MsgCatalogLoader.hpp>
  96. #else   // use In-memory message loader
  97. #include <xercesc/util/MsgLoaders/InMemory/InMemMsgLoader.hpp>
  98. #endif
  99. #if defined (XML_USE_NETACCESSOR_LIBWWW)
  100. #include <xercesc/util/NetAccessors/libWWW/LibWWWNetAccessor.hpp>
  101. #elif defined (XML_USE_NETACCESSOR_SOCKET)
  102. #include <xercesc/util/NetAccessors/Socket/SocketNetAccessor.hpp>
  103. #endif
  104. XERCES_CPP_NAMESPACE_BEGIN
  105. // ---------------------------------------------------------------------------
  106. //  XMLPlatformUtils: Private Static Methods
  107. // ---------------------------------------------------------------------------
  108. XMLNetAccessor* XMLPlatformUtils::makeNetAccessor()
  109. #if defined (XML_USE_NETACCESSOR_LIBWWW)
  110. {
  111.     return new LibWWWNetAccessor();
  112. }
  113. #elif defined (XML_USE_NETACCESSOR_SOCKET)
  114. {
  115.     return new SocketNetAccessor();
  116. }
  117. #else
  118. {
  119.     return 0;
  120. }
  121. #endif
  122. //
  123. //  This method is called by the platform independent part of this class
  124. //  when client code asks to have one of the supported message sets loaded.
  125. //  In our case, we use the ICU based message loader mechanism.
  126. //
  127. XMLMsgLoader* XMLPlatformUtils::loadAMsgSet(const XMLCh* const msgDomain)
  128. {
  129.   XMLMsgLoader* retVal;
  130.   try
  131.   {
  132. #if defined (XML_USE_ICU_MESSAGELOADER)
  133.     retVal = new ICUMsgLoader(msgDomain);
  134. #elif defined (XML_USE_ICONV_MESSAGELOADER)
  135.     retVal = new MsgCatalogLoader(msgDomain);
  136. #else
  137.     retVal = new InMemMsgLoader(msgDomain);
  138. #endif
  139.   }
  140.   catch(...)
  141.   {
  142.     panic(PanicHandler::Panic_CantLoadMsgDomain);
  143.   }
  144.   return retVal;
  145. }
  146. //
  147. //  This method is called very early in the bootstrapping process. This guy
  148. //  must create a transcoding service and return it. It cannot use any string
  149. //  methods, any transcoding services, throw any exceptions, etc... It just
  150. //  makes a transcoding service and returns it, or returns zero on failure.
  151. //
  152. XMLTransService* XMLPlatformUtils::makeTransService()
  153. #if defined (XML_USE_ICU_TRANSCODER)
  154. {
  155.   return new ICUTransService;
  156. }
  157. #elif defined (XML_USE_ICONV_TRANSCODER)
  158. {
  159.   return new IconvTransService;
  160. }
  161. #else // Use Native transcoding service
  162. {
  163.   return new IconvTransService;
  164. }
  165. #endif
  166. // ---------------------------------------------------------------------------
  167. //  XMLPlatformUtils: The panic method
  168. // ---------------------------------------------------------------------------
  169. void XMLPlatformUtils::panic(const PanicHandler::PanicReasons reason)
  170. {
  171.     fgUserPanicHandler? fgUserPanicHandler->panic(reason) : fgDefaultPanicHandler->panic(reason);
  172. }
  173. // ---------------------------------------------------------------------------
  174. //  XMLPlatformUtils: File Methods
  175. // ---------------------------------------------------------------------------
  176. unsigned int XMLPlatformUtils::curFilePos(FileHandle theFile)
  177. {
  178.   // Get the current position
  179.   int curPos = ftell( (FILE*)theFile);
  180.   if (curPos == -1)
  181.     ThrowXML(XMLPlatformUtilsException,
  182.      XMLExcepts::File_CouldNotGetSize);
  183.   return (unsigned int)curPos;
  184. }
  185. void XMLPlatformUtils::closeFile(FileHandle theFile)
  186. {
  187.   if (fclose((FILE*) theFile))
  188.     ThrowXML(XMLPlatformUtilsException,
  189.      XMLExcepts::File_CouldNotCloseFile);
  190. }
  191. unsigned int XMLPlatformUtils::fileSize(FileHandle theFile)
  192. {
  193.   // Get the current position
  194.   long  int curPos = ftell((FILE*) theFile);
  195.   if (curPos == -1)
  196.     ThrowXML(XMLPlatformUtilsException,
  197.      XMLExcepts::File_CouldNotGetCurPos);
  198.   // Seek to the end and save that value for return
  199.   if (fseek( (FILE*) theFile, 0, SEEK_END) )
  200.     ThrowXML(XMLPlatformUtilsException,
  201.      XMLExcepts::File_CouldNotSeekToEnd);
  202.   long int retVal = ftell((FILE*) theFile);
  203.   if (retVal == -1)
  204.     ThrowXML(XMLPlatformUtilsException,
  205.      XMLExcepts::File_CouldNotSeekToEnd);
  206.   // And put the pointer back
  207.   if (fseek((FILE*) theFile, curPos, SEEK_SET))
  208.     ThrowXML(XMLPlatformUtilsException,
  209.      XMLExcepts::File_CouldNotSeekToPos);
  210.   return (unsigned int)retVal;
  211. }
  212. FileHandle XMLPlatformUtils::openFile(const char* const fileName)
  213. {
  214.   FileHandle retVal = (FILE*)fopen( fileName , "rb" );
  215.   if (retVal == NULL)
  216.     return 0;
  217.   return retVal;
  218. }
  219. FileHandle XMLPlatformUtils::openFile(const XMLCh* const fileName)
  220. {
  221.   const char* tmpFileName = XMLString::transcode(fileName, fgMemoryManager);
  222.   ArrayJanitor<char> janText((char*)tmpFileName, fgMemoryManager);
  223.   FileHandle retVal = (FILE*)fopen( tmpFileName , "rb" );
  224.   if (retVal == NULL)
  225.     return 0;
  226.   return retVal;
  227. }
  228. FileHandle XMLPlatformUtils::openFileToWrite(const XMLCh* const fileName)
  229. {
  230.     const char* tmpFileName = XMLString::transcode(fileName, fgMemoryManager);
  231.     ArrayJanitor<char> janText((char*)tmpFileName, fgMemoryManager);
  232.     return fopen( tmpFileName , "wb" );
  233. }
  234. FileHandle XMLPlatformUtils::openFileToWrite(const char* const fileName)
  235. {
  236.     return fopen( fileName , "wb" );
  237. }
  238. unsigned int XMLPlatformUtils::readFileBuffer(FileHandle theFile,
  239.       const unsigned int toRead,
  240.       XMLByte* const toFill)
  241. {
  242.   size_t noOfItemsRead =
  243.     fread((void*) toFill, 1, toRead, (FILE*) theFile);
  244.   if(ferror((FILE*) theFile))
  245.   {
  246.     ThrowXML(XMLPlatformUtilsException,
  247.      XMLExcepts::File_CouldNotReadFromFile);
  248.   }
  249.   return (unsigned int) noOfItemsRead;
  250. }
  251. void
  252. XMLPlatformUtils::writeBufferToFile( FileHandle     const  theFile
  253.                                    , long                  toWrite
  254.                                    , const XMLByte* const  toFlush)
  255. {
  256.     if (!theFile        ||
  257.         (toWrite <= 0 ) ||
  258.         !toFlush         )
  259.         return;
  260.     const XMLByte* tmpFlush = (const XMLByte*) toFlush;
  261.     size_t bytesWritten = 0;
  262.     while (true)
  263.     {
  264.         bytesWritten=fwrite(tmpFlush, sizeof(XMLByte), toWrite, (FILE*)theFile);
  265.         if(ferror((FILE*)theFile))
  266.         {
  267.             ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotWriteToFile);
  268.         }
  269.         if (bytesWritten < toWrite) //incomplete write
  270.         {
  271.             tmpFlush+=bytesWritten;
  272.             toWrite-=bytesWritten;
  273.             bytesWritten=0;
  274.         }
  275.         else
  276.             return;
  277.     }
  278.     return;
  279. }
  280. void XMLPlatformUtils::resetFile(FileHandle theFile)
  281. {
  282.   // Seek to the start of the file
  283.   if (fseek((FILE*) theFile, 0, SEEK_SET))
  284.     ThrowXML(XMLPlatformUtilsException,
  285.      XMLExcepts::File_CouldNotResetFile);
  286. }
  287. // ---------------------------------------------------------------------------
  288. //  XMLPlatformUtils: File system methods
  289. // ---------------------------------------------------------------------------
  290. XMLCh* XMLPlatformUtils::getFullPath(const XMLCh* const srcPath,
  291.                                      MemoryManager* const manager)
  292. {
  293.   //
  294.   //  NOTE: THe path provided has always already been opened successfully,
  295.   //  so we know that its not some pathological freaky path. It comes in
  296.   //  in native format, and goes out as Unicode always
  297.   //
  298.   char* newSrc = XMLString::transcode(srcPath, fgMemoryManager);
  299.   ArrayJanitor<char> janText(newSrc, fgMemoryManager);
  300.   // Use a local buffer that is big enough for the largest legal path
  301.   char absPath[PATH_MAX + 1];
  302.   //get the absolute path
  303.   char* retPath = realpath(newSrc, &absPath[0]);
  304.   if (!retPath)
  305.   {
  306.     ThrowXML(XMLPlatformUtilsException,
  307.      XMLExcepts::File_CouldNotGetBasePathName);
  308.   }
  309.   return XMLString::transcode(absPath, manager);
  310. }
  311. bool XMLPlatformUtils::isRelative(const XMLCh* const toCheck)
  312. {
  313.   // Check for pathological case of empty path
  314.   if (!toCheck[0])
  315.     return false;
  316.   //
  317.   //  If it starts with a slash, then it cannot be relative. This covers
  318.   //  both something like "TestFile.xml" and an NT Lan type remote path
  319.   //  that starts with a node like "\MyNodeTestFile.xml".
  320.   //
  321.   if (toCheck[0] == XMLCh('/'))
  322.     return false;
  323.   // Else assume its a relative path
  324.   return true;
  325. }
  326. XMLCh* XMLPlatformUtils::getCurrentDirectory(MemoryManager* const manager)
  327. {
  328.     char  dirBuf[PATH_MAX + 1];
  329.     char  *curDir = getcwd(&dirBuf[0], PATH_MAX + 1);
  330.     if (!curDir)
  331.     {
  332.         ThrowXML(XMLPlatformUtilsException,
  333.                  XMLExcepts::File_CouldNotGetBasePathName);
  334.     }
  335.     return XMLString::transcode(curDir, manager);
  336. }
  337. inline bool XMLPlatformUtils::isAnySlash(XMLCh c) 
  338. {
  339.     return ( chBackSlash == c || chForwardSlash == c);
  340. }
  341. // ---------------------------------------------------------------------------
  342. //  XMLPlatformUtils: Timing Methods
  343. // ---------------------------------------------------------------------------
  344. unsigned long XMLPlatformUtils::getCurrentMillis()
  345. {
  346.   timespec ts;
  347.   clock_gettime (CLOCK_REALTIME, &ts);
  348.   return (unsigned long) ((ts.tv_sec * 1000) + (ts.tv_nsec / 1000000));
  349. }
  350. #if !defined (APP_NO_THREADS)
  351. // ---------------------------------------------------------------------------
  352. //  XMLPlatformUtils: Platform init method
  353. // ---------------------------------------------------------------------------
  354. static pthread_mutex_t* gAtomicOpMutex =0 ;
  355. void XMLPlatformUtils::platformInit()
  356. {
  357.   //
  358.   // The gAtomicOpMutex mutex needs to be created
  359.   // because compareAndSwap and incrementlocation and decrementlocation
  360.   // does not have the atomic system calls for usage
  361.   // Normally, mutexes are created on first use, but there is a
  362.   // circular dependency between compareAndExchange() and
  363.   // mutex creation that must be broken.
  364.   gAtomicOpMutex = new pthread_mutex_t;
  365.   if (pthread_mutex_init(gAtomicOpMutex, NULL)) {
  366. delete gAtomicOpMutex;
  367. gAtomicOpMutex = 0;
  368.     panic( PanicHandler::Panic_SystemInit );
  369.   }
  370. }
  371. // -----------------------------------------------------------------------
  372. //  Mutex methods
  373. // -----------------------------------------------------------------------
  374. class  RecursiveMutex
  375. {
  376. public:
  377.   pthread_mutex_t   mutex;
  378.   int               recursionCount;
  379.   pthread_t         tid;
  380.   RecursiveMutex()
  381.   {
  382.     if (pthread_mutex_init(&mutex, NULL))
  383.       ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotCreate);
  384.     recursionCount = 0;
  385.     tid = 0;
  386.   };
  387.   ~RecursiveMutex()
  388.   {
  389.     if (pthread_mutex_destroy(&mutex))
  390.       ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotDestroy);
  391.   };
  392.   void lock()
  393.   {
  394.     if (pthread_equal(tid, pthread_self()))
  395.     {
  396.       recursionCount++;
  397.       return;
  398.     }
  399.     if (pthread_mutex_lock(&mutex) != 0)
  400.       ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotLock);
  401.     tid = pthread_self();
  402.     recursionCount = 1;
  403.   };
  404.   void unlock()
  405.   {
  406.     if (--recursionCount > 0)
  407.       return;
  408.     if (pthread_mutex_unlock(&mutex) != 0)
  409.       ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotUnlock);
  410.     tid = 0;
  411.   };
  412. };
  413. void* XMLPlatformUtils::makeMutex()
  414. {
  415.   return new RecursiveMutex;
  416. };
  417. void XMLPlatformUtils::closeMutex(void* const mtxHandle)
  418. {
  419.   if (mtxHandle == NULL)
  420.     return;
  421.   RecursiveMutex *rm = (RecursiveMutex *)mtxHandle;
  422.   delete rm;
  423. };
  424. void XMLPlatformUtils::lockMutex(void* const mtxHandle)
  425. {
  426.   if (mtxHandle == NULL)
  427.     return;
  428.   RecursiveMutex *rm = (RecursiveMutex *)mtxHandle;
  429.   rm->lock();
  430. }
  431. void XMLPlatformUtils::unlockMutex(void* const mtxHandle)
  432. {
  433.   if (mtxHandle == NULL)
  434.     return;
  435.   RecursiveMutex *rm = (RecursiveMutex *)mtxHandle;
  436.   rm->unlock();
  437. }
  438. // -----------------------------------------------------------------------
  439. //  Miscellaneous synchronization methods
  440. // -----------------------------------------------------------------------
  441. //atomic system calls in Solaris is only restricted to kernel libraries
  442. //So, to make operations thread safe we implement static mutex and lock
  443. //the atomic operations. It makes the process slow but what's the alternative!
  444. void* XMLPlatformUtils::compareAndSwap (void** toFill,
  445. const void* const newValue,
  446. const void* const toCompare)
  447. {
  448.   //return ((void*)cas32( (uint32_t*)toFill,  (uint32_t)toCompare, (uint32_t)newValue) );
  449.   // the below calls are temporarily made till the above functions are part of user library
  450.   // Currently its supported only in the kernel mode
  451.   if (pthread_mutex_lock( gAtomicOpMutex))
  452.     panic(PanicHandler::Panic_SynchronizationErr);
  453.   void *retVal = *toFill;
  454.   if (*toFill == toCompare)
  455.     *toFill = (void *)newValue;
  456.   if (pthread_mutex_unlock( gAtomicOpMutex))
  457.     panic(PanicHandler::Panic_SynchronizationErr);
  458.   return retVal;
  459. }
  460. int XMLPlatformUtils::atomicIncrement(int &location)
  461. {
  462.   //return (int)atomic_add_32_nv( (uint32_t*)&location, 1);
  463.   if (pthread_mutex_lock( gAtomicOpMutex))
  464.     panic(PanicHandler::Panic_SynchronizationErr);
  465.   int tmp = ++location;
  466.   if (pthread_mutex_unlock( gAtomicOpMutex))
  467.     panic(PanicHandler::Panic_SynchronizationErr);
  468.   return tmp;
  469. }
  470. int XMLPlatformUtils::atomicDecrement(int &location)
  471. {
  472.   //return (int)atomic_add_32_nv( (uint32_t*)&location, -1);
  473.   if (pthread_mutex_lock( gAtomicOpMutex))
  474.     panic(PanicHandler::Panic_SynchronizationErr);
  475.   int tmp = --location;
  476.   if (pthread_mutex_unlock( gAtomicOpMutex))
  477.     panic(PanicHandler::Panic_SynchronizationErr);
  478.   return tmp;
  479. }
  480. #else // #if !defined (APP_NO_THREADS)
  481. void XMLPlatformUtils::platformInit()
  482. {
  483.    // do nothing
  484. }
  485. void XMLPlatformUtils::closeMutex(void* const mtxHandle)
  486. {
  487. }
  488. void XMLPlatformUtils::lockMutex(void* const mtxHandle)
  489. {
  490. }
  491. void* XMLPlatformUtils::makeMutex()
  492. {
  493.   return 0;
  494. }
  495. void XMLPlatformUtils::unlockMutex(void* const mtxHandle)
  496. {
  497. }
  498. void* XMLPlatformUtils::compareAndSwap ( void**      toFill,
  499.                                    const void* const newValue,
  500.                                    const void* const toCompare)
  501. {
  502.   void *retVal = *toFill;
  503.   if (*toFill == toCompare)
  504.     *toFill = (void *)newValue;
  505.   return retVal;
  506. }
  507. int XMLPlatformUtils::atomicIncrement(int &location)
  508. {
  509.   return ++location;
  510. }
  511. int XMLPlatformUtils::atomicDecrement(int &location)
  512. {
  513.   return --location;
  514. }
  515. #endif // APP_NO_THREADS
  516. FileHandle XMLPlatformUtils::openStdInHandle()
  517. {
  518.   return (FileHandle)fdopen(dup(0), "rb");
  519. }
  520. void XMLPlatformUtils::platformTerm()
  521. {
  522. #if !defined (APP_NO_THREADS)
  523. pthread_mutex_destroy(gAtomicOpMutex);
  524. delete gAtomicOpMutex;
  525. gAtomicOpMutex = 0;
  526. #endif
  527. }
  528. #include <xercesc/util/LogicalPath.c>
  529. XERCES_CPP_NAMESPACE_END