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

词法分析

开发平台:

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: OS400PlatformUtils.cpp,v 1.11 2003/05/15 18:37:49 knoaman Exp $
  58.  */
  59. // ---------------------------------------------------------------------------
  60. //  Includes
  61. // ---------------------------------------------------------------------------
  62. #define MY_XP_CPLUSPLUS
  63. #include    "OS400PlatformUtils.hpp"
  64. #include    <pthread.h>
  65. #include    <xercesc/util/PlatformUtils.hpp>
  66. #include    <xercesc/util/RuntimeException.hpp>
  67. #include    <xercesc/util/Janitor.hpp>
  68. #include    <xercesc/util/XMLString.hpp>
  69. #include    <xercesc/util/XMLUniDefs.hpp>
  70. #include    <xercesc/util/PanicHandler.hpp>
  71. #include    <stdio.h>
  72. #include    <stdlib.h>
  73. #include    <errno.h>
  74. #include    <unistd.h>
  75. #include    <qp0z1170.h>
  76. #include    <mimchint.h>
  77. #include    <string.h>
  78. #include    <qmhsndpm.h>
  79. #include    <except.h>
  80. #include <mih/cmpswp.h>
  81. #if defined (XML_USE_ICONV400_TRANSCODER)
  82.     #include <xercesc/util/Transcoders/Iconv400/Iconv400TransService.hpp>
  83. void cleanupDefaultConverter();
  84. #elif defined (XML_USE_ICU_TRANSCODER)
  85.     #include <xercesc/util/Transcoders/ICU/ICUTransService.hpp>
  86. #else
  87.  Transcoder not Specified - For OS/400 must be either ICU or Iconv400
  88. #endif
  89. #if defined(XML_USE_MSGFILE_MESSAGELOADER)
  90.  #include <xercesc/util/MsgLoaders/MsgFile/MsgLoader.hpp>
  91. #elif defined(XML_USE_INMEM_MESSAGELOADER)
  92.  #include <xercesc/util/MsgLoaders/InMemory/InMemMsgLoader.hpp>
  93. #else
  94.  #include <xercesc/util/MsgLoaders/ICU/ICUMsgLoader.hpp>
  95. #endif
  96. #if defined (XML_USE_NETACCESSOR_SOCKET)
  97.     #include <xercesc/util/NetAccessors/Socket/SocketNetAccessor.hpp>
  98. #endif
  99. XERCES_CPP_NAMESPACE_BEGIN
  100. char* PackingRepText(const char * const repText1,
  101.      const char * const repText2,
  102.      const char * const repText3,
  103.      const char * const repText4);
  104. // ---------------------------------------------------------------------------
  105. //  XMLPlatformUtils: Platform init method
  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. #elif defined (XML_USE_ICONV400_TRANSCODER)
  127. {
  128.     return new Iconv400TransService;
  129. }
  130. #else
  131. {
  132.     return new IconvTransService;
  133. }
  134. #endif
  135. //
  136. //  This method is called by the platform independent part of this class
  137. //  when client code asks to have one of the supported message sets loaded.
  138. //  In our case, we use the ICU based message loader mechanism.
  139. //
  140. XMLMsgLoader* XMLPlatformUtils::loadAMsgSet(const XMLCh* const msgDomain)
  141. {
  142.     XMLMsgLoader* retVal;
  143.     try
  144.     {
  145. #if defined(XML_USE_MSGFILE_MESSAGELOADER)
  146.         #include <xercesc/util/MsgLoaders/MsgFile/MsgLoader.hpp>
  147.         retVal = new MsgCatalogLoader(msgDomain);
  148. #elif defined (XML_USE_ICU_MESSAGELOADER)
  149. retVal = new ICUMsgLoader(msgDomain);
  150. #elif defined (XML_USE_ICONV_MESSAGELOADER)
  151. retVal = new MsgCatalogLoader(msgDomain);
  152. #else
  153. retVal = new InMemMsgLoader(msgDomain);
  154. #endif
  155.     }
  156.     catch(...)
  157.     {
  158.         panic( PanicHandler::Panic_CantLoadMsgDomain );
  159.     }
  160.     return retVal;
  161. }
  162. // ---------------------------------------------------------------------------
  163. //  XMLPlatformUtils: The panic method
  164. // ---------------------------------------------------------------------------
  165. void XMLPlatformUtils::panic(const PanicHandler::PanicReasons reason)
  166. {
  167.     if (fgUserPanicHandler)
  168.     {
  169.      fgUserPanicHandler->panic(reason);
  170.     }
  171.  
  172.     //
  173.     //  We just print a message and exit, Note we are currently dependent on
  174.     // the number of reasons being under 10 for this teo work
  175.     //
  176.     else
  177.     {
  178.         struct reason_code
  179.         {
  180.             char reason_char;
  181.             char endofstring;
  182.         }reason_code;
  183.         reason_code.reason_char = '0';
  184.         reason_code.endofstring = '';
  185.         reason_code.reason_char = reason_code.reason_char + reason;
  186.         send_message((char*)&reason_code,GENERAL_PANIC_MESSAGE,'e');
  187.     }
  188. }
  189. // ---------------------------------------------------------------------------
  190. //  XMLPlatformUtils: File Methods
  191. // ---------------------------------------------------------------------------
  192. unsigned int XMLPlatformUtils::curFilePos(FileHandle theFile)
  193. {
  194.     // Get the current position
  195.     int curPos = ftell( (FILE*)theFile);
  196.     if (curPos == -1)
  197. ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotGetSize);
  198.     return (unsigned int)curPos;
  199. }
  200. void XMLPlatformUtils::closeFile(FileHandle theFile)
  201. {
  202.     if (fclose((FILE*)theFile))
  203. ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotCloseFile);
  204. }
  205. unsigned int XMLPlatformUtils::fileSize(FileHandle theFile)
  206. {
  207.     // Get the current position
  208.     long  int curPos = ftell((FILE*)theFile);
  209.     if (curPos == -1)
  210. ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotGetCurPos);
  211.     // Seek to the end and save that value for return
  212.      if (fseek( (FILE*)theFile, 0, SEEK_END) )
  213. ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotSeekToEnd);
  214.     long int retVal = ftell( (FILE*)theFile);
  215.     if (retVal == -1)
  216. ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotSeekToEnd);
  217.     // And put the pointer back
  218.     if (fseek( (FILE*)theFile, curPos, SEEK_SET) )
  219. ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotSeekToPos);
  220.     return (unsigned int)retVal;
  221. }
  222. #include <qmhrtvm.h>
  223. #include <qusec.h>
  224. FileHandle XMLPlatformUtils::openFile(const XMLCh* const fileName)
  225. {   char errno_id[7];
  226.     const char* tmpFileName = XMLString::transcode(fileName, fgMemoryManager);
  227.     ArrayJanitor<char> janText((char*)tmpFileName, fgMemoryManager);
  228.     errno = 0;
  229.     FileHandle retVal = (FILE*)fopen( tmpFileName , "rb" );
  230.     if (retVal == NULL)
  231.     {
  232.      send_message((char*)tmpFileName,FILE_OPEN_PROBLEMS,'d');
  233.      convert_errno(errno_id,errno);
  234.      send_message(NULL,errno_id,'d');
  235.         return 0;
  236.     }
  237.     return retVal;
  238. }
  239. FileHandle XMLPlatformUtils::openFile(const char* const fileName)
  240. {   char errno_id[7];
  241.     errno = 0;
  242.     FileHandle retVal = (FILE*)fopen( fileName , "rb" );
  243.     if (retVal == NULL)
  244.     {
  245.      send_message((char*)fileName,FILE_OPEN_PROBLEMS,'d');
  246.      convert_errno(errno_id,errno);
  247.      send_message(NULL,errno_id,'d');
  248.         return 0;
  249.     }
  250.     return retVal;
  251. }
  252. FileHandle XMLPlatformUtils::openFileToWrite(const XMLCh* const fileName)
  253. {
  254.     const char* tmpFileName = XMLString::transcode(fileName, fgMemoryManager);
  255.     ArrayJanitor<char> janText((char*)tmpFileName, fgMemoryManager);
  256.     return openFileToWrite(tmpFileName);
  257. }
  258. FileHandle XMLPlatformUtils::openFileToWrite(const char* const fileName)
  259. {
  260.     char errno_id[7];
  261.     errno = 0;
  262.     FileHandle retVal = (FILE*)fopen( fileName , "wb" );
  263.     if (retVal == NULL)
  264.     {
  265.      send_message((char*)fileName,FILE_OPEN_PROBLEMS,'d');
  266.      convert_errno(errno_id,errno);
  267.      send_message(NULL,errno_id,'d');
  268.         return 0;
  269.     }
  270.     return retVal;
  271. }
  272. unsigned int
  273. XMLPlatformUtils::readFileBuffer(  FileHandle      theFile
  274.                                 , const unsigned int    toRead
  275.                                 , XMLByte* const  toFill)
  276. {
  277.     size_t noOfItemsRead = fread( (void*) toFill, 1, toRead, (FILE*)theFile);
  278.     if(ferror((FILE*)theFile))
  279.     {
  280. ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotReadFromFile);
  281.     }
  282.     return (unsigned int)noOfItemsRead;
  283. }
  284. void
  285. XMLPlatformUtils::writeBufferToFile( FileHandle     const  theFile
  286.                                    , long                  toWrite
  287.                                    , const XMLByte* const  toFlush)
  288. {
  289.     if (!theFile        ||
  290.         (toWrite <= 0 ) ||
  291.         !toFlush         )
  292.         return;
  293.     const XMLByte* tmpFlush = (const XMLByte*) toFlush;
  294.     size_t bytesWritten = 0;
  295.     while (true)
  296.     {
  297.         bytesWritten=fwrite(tmpFlush, sizeof(XMLByte), toWrite, (FILE*)theFile);
  298.         if(ferror((FILE*)theFile))
  299.         {
  300.             ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotWriteToFile);
  301.         }
  302.         if (bytesWritten < toWrite) //incomplete write
  303.         {
  304.             tmpFlush+=bytesWritten;
  305.             toWrite-=bytesWritten;
  306.             bytesWritten=0;
  307.         }
  308.         else
  309.             return;
  310.     }
  311.     return;
  312. }
  313. void XMLPlatformUtils::resetFile(FileHandle theFile)
  314. {
  315.     // Seek to the start of the file
  316.     if (fseek((FILE*)theFile, 0, SEEK_SET) )
  317. ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotResetFile);
  318. }
  319. // ---------------------------------------------------------------------------
  320. //  XMLPlatformUtils: File system methods
  321. // ---------------------------------------------------------------------------
  322. /* since we do not have the realpath function on AS/400 and it appears
  323. to no be important that we convert the name to the real path we will
  324. only verify that the path exists  - note that this may make AS/400 output a different error for the pathname but customer should
  325. be able to determine what the name is suppose to be*/
  326. #include <unistd.h>
  327. #include <errno.h>
  328. #include <string.h>
  329. char *realpath(const char *file_name, char *resolved_name)
  330. {
  331.  if (file_name== NULL)
  332.  {
  333.    errno = EINVAL;
  334.    return(NULL);
  335.  }
  336.  if (access(file_name,F_OK)) /* verify that the file exists*/
  337.  {
  338.   errno = EACCES;
  339.   return(NULL);
  340.  }
  341.  else
  342.  /* code says that we make a copy of the file name so do it */
  343.   strcpy(resolved_name,file_name);
  344.   return(resolved_name);
  345. }
  346. XMLCh* XMLPlatformUtils::getFullPath(const XMLCh* const srcPath,
  347.                                      MemoryManager* const manager)
  348. {
  349.     //
  350.     //  NOTE: THe path provided has always already been opened successfully,
  351.     //  so we know that its not some pathological freaky path. It comes in
  352.     //  in native format, and goes out as Unicode always
  353.     //
  354.     char* newSrc = XMLString::transcode(srcPath, fgMemoryManager);
  355.      ArrayJanitor<char> janText(newSrc, fgMemoryManager);
  356.     // Use a local buffer that is big enough for the largest legal path
  357.     char absPath[PATH_MAX + 1];
  358. //get the absolute path
  359.     char* retPath = realpath(newSrc, &absPath[0]);
  360.     if (!retPath)
  361.     {
  362. ThrowXML(XMLPlatformUtilsException, XMLExcepts::File_CouldNotGetBasePathName);
  363.     }
  364.     return XMLString::transcode(absPath, manager);
  365. }
  366. bool XMLPlatformUtils::isRelative(const XMLCh* const toCheck)
  367. {
  368.     // Check for pathological case of empty path
  369.     if (!toCheck[0])
  370.         return false;
  371.     //
  372.     //  If it starts with a slash, then it cannot be relative. This covers
  373.     //  both something like "TestFile.xml" and an NT Lan type remote path
  374.     //  that starts with a node like "\MyNodeTestFile.xml".
  375.     //
  376.     if (*toCheck == chForwardSlash)
  377.         return false;
  378.     // Else assume its a relative path
  379.     return true;
  380. }
  381. XMLCh* XMLPlatformUtils::getCurrentDirectory(MemoryManager* const manager)
  382. {
  383.     char  dirBuf[PATH_MAX + 1];
  384.     char  *curDir = getcwd(&dirBuf[0], PATH_MAX + 1);
  385.     if (!curDir)
  386.     {
  387.         ThrowXML(XMLPlatformUtilsException,
  388.                  XMLExcepts::File_CouldNotGetBasePathName);
  389.     }
  390.     return XMLString::transcode(curDir, manager);
  391. }
  392. inline bool XMLPlatformUtils::isAnySlash(XMLCh c) 
  393. {
  394.     return ( chBackSlash == c || chForwardSlash == c);
  395. }
  396. void send_message (char * text, char * messageid, char type)
  397. {
  398.            short textsize;
  399.            char* buffer;
  400.            char* anchor;
  401.            char* id;
  402.            char message_id[8] = "CPF9897";/* id for raw txt
  403.                                              message                */
  404.            char message_file_name[21];
  405.            char message_type[11] ="*DIAG     ";/* send diagnostic
  406.                                                            message   */
  407.            char call_stack[11] ="*         " ;/* current callstack*/
  408.            int call_stack_counter= 0;/* sent to current call stack */
  409.            char message_key[4]; /* return value - not used          */
  410.             struct {
  411.              int bytes_available;
  412.              int bytes_used;
  413.              char exception_id[7];
  414.              char reserved;
  415.              char exception_data[1];
  416.                     } error_code;
  417.            int msg_size;
  418.           char* msg_type;
  419.          error_code.bytes_available = sizeof(error_code);
  420. /* check input parameters and set up the message information */
  421.          if (messageid != 0)  /* was a message id passed   */
  422.  {
  423.            if (strncmp(messageid,"CPF",3) &&
  424.                strncmp(messageid,"CPE",3))
  425.              strcpy(message_file_name,"QXMLMSG   *LIBL     ");
  426.            else
  427.              strcpy(message_file_name,"QCPFMSG   QSYS      ");
  428.            id = messageid; /* yes - use the id, will be
  429.                            in QCPFMSG                              */
  430.  }
  431.          else  /* just use what we have for immediate text          */
  432.  {
  433.            id = &message_id[0];
  434.            strcpy(message_file_name,"QCPFMSG   QSYS      ");
  435.  }
  436.          if (type == 'e')  /* is this the terminating exception     */
  437.               msg_type = "*COMP      ";/* set it as completion      */
  438.          else            /* currently all other messages are
  439.                              diagnostics                             */
  440.               msg_type = "*DIAG      ";
  441.          if (text != 0)                  /* was a text field passed           */
  442.          {
  443.           textsize = strlen(text);
  444.           msg_size = textsize + sizeof(short);
  445.           buffer = (char*)malloc(msg_size);
  446.           anchor = buffer;
  447.           memcpy(buffer, (void*)&textsize, sizeof(short));
  448.           buffer +=sizeof(short);
  449.           memcpy(buffer, text, textsize);
  450.          }
  451.          else
  452.            msg_size = 0;
  453.          #pragma exception_handler(jsendprob, 0, _C1_ALL, _C2_ALL,_CTLA_HANDLE)
  454.               QMHSNDPM((char *)id,&message_file_name,anchor,
  455.                      msg_size,(char*)msg_type,(char*)&call_stack,
  456.                      call_stack_counter,&message_key,&error_code);
  457.    jsendprob:
  458. #pragma disable_handler
  459.     return ;
  460. }
  461. void abnormal_termination(int termcode)
  462. {
  463.    send_message(NULL,"CPF9899",'e'); /* send final exception that we have terminated*/
  464. }
  465. // ---------------------------------------------------------------------------
  466. //  XMLPlatformUtils: Timing Methods
  467. // ---------------------------------------------------------------------------
  468. unsigned long XMLPlatformUtils::getCurrentMillis()
  469. {
  470.  _MI_Time mt;
  471.          struct timeval tv;
  472.          int rc;
  473.          mattod(mt);
  474.    rc = Qp0zCvtToTimeval(&tv, mt, QP0Z_CVTTIME_TO_TIMESTAMP);
  475.    return((tv.tv_sec*1000 )+ (tv.tv_usec/1000));
  476. }
  477. // -----------------------------------------------------------------------
  478. //  Mutex methods
  479. // -----------------------------------------------------------------------
  480. #if !defined (APP_NO_THREADS)
  481. static pthread_mutex_t* gAtomicOpMutex =0 ;
  482. void XMLPlatformUtils::platformInit()
  483. {
  484.     //
  485.     // The gAtomicOpMutex mutex needs to be created
  486. // because compareAndSwap and incrementlocation and decrementlocation
  487. // does not have the atomic system calls for usage
  488.     // Normally, mutexes are created on first use, but there is a
  489.     // circular dependency between compareAndExchange() and
  490.     // mutex creation that must be broken.
  491.     gAtomicOpMutex = new pthread_mutex_t;
  492.     if (pthread_mutex_init(gAtomicOpMutex, NULL)) {
  493. delete gAtomicOpMutex;
  494. gAtomicOpMutex = 0;
  495.         panic( PanicHandler::Panic_SystemInit );
  496. }
  497. }
  498. class  RecursiveMutex : public XMemory
  499. {
  500. public:
  501.     pthread_mutex_t   mutex;
  502.     int               recursionCount;
  503.     pthread_t         tid;
  504.     RecursiveMutex() {
  505.        if (pthread_mutex_init(&mutex, NULL))
  506.     ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotCreate);
  507.                        recursionCount = 0;
  508.                        tid.reservedHiId = 0;
  509.        tid.reservedLoId = 0;
  510.                        tid.reservedHandle = 0;
  511.                      };
  512.     ~RecursiveMutex() {
  513. if (pthread_mutex_destroy(&mutex))
  514.     ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotDestroy);
  515.                       };
  516.      void lock()      {
  517.   if (pthread_equal(tid, pthread_self()))
  518.   {
  519.       recursionCount++;
  520.       return;
  521.   }
  522.   if (pthread_mutex_lock(&mutex) != 0)
  523.       ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotLock);
  524.   tid = pthread_self();
  525.   recursionCount = 1;
  526.       };
  527.      void unlock()    {
  528.                           if (--recursionCount > 0)
  529.                               return;
  530.   if (pthread_mutex_unlock(&mutex) != 0)
  531.       ThrowXML(XMLPlatformUtilsException, XMLExcepts::Mutex_CouldNotUnlock);
  532.                           tid.reservedHandle= 0;
  533.   tid.reservedHiId = 0;
  534.   tid.reservedLoId = 0;
  535.                        };
  536.    };
  537. void* XMLPlatformUtils::makeMutex()
  538. {
  539.     return new RecursiveMutex;
  540. };
  541. void XMLPlatformUtils::closeMutex(void* const mtxHandle)
  542. {
  543.     if (mtxHandle == NULL)
  544.         return;
  545.     RecursiveMutex *rm = (RecursiveMutex *)mtxHandle;
  546.     delete rm;
  547. };
  548. void XMLPlatformUtils::lockMutex(void* const mtxHandle)
  549. {
  550.     if (mtxHandle == NULL)
  551.         return;
  552.     RecursiveMutex *rm = (RecursiveMutex *)mtxHandle;
  553.     rm->lock();
  554. }
  555. void XMLPlatformUtils::unlockMutex(void* const mtxHandle)
  556. {
  557.     if (mtxHandle == NULL)
  558.         return;
  559.     RecursiveMutex *rm = (RecursiveMutex *)mtxHandle;
  560.     rm->unlock();
  561. }
  562. // -----------------------------------------------------------------------
  563. //  Miscellaneous synchronization methods
  564. // -----------------------------------------------------------------------
  565. //atomic system calls in Solaris is only restricted to kernel libraries
  566. //So, to make operations thread safe we implement static mutex and lock
  567. //the atomic operations. It makes the process slow but what's the alternative!
  568. void* XMLPlatformUtils::compareAndSwap ( void**      toFill ,
  569.                     const void* const newValue ,
  570.                     const void* const toCompare)
  571. {
  572.     //return ((void*)cas32( (uint32_t*)toFill,  (uint32_t)toCompare, (uint32_t)newValue) );
  573.     // the below calls are temporarily made till the above functions are part of user library
  574.     // Currently its supported only in the kernel mode
  575.     if (pthread_mutex_lock( gAtomicOpMutex))
  576.         panic(PanicHandler::Panic_SynchronizationErr);
  577.     void *retVal = *toFill;
  578.     if (*toFill == toCompare)
  579.               *toFill = (void *)newValue;
  580.     if (pthread_mutex_unlock( gAtomicOpMutex))
  581.         panic(PanicHandler::Panic_SynchronizationErr);
  582.     return retVal;
  583. }
  584. int XMLPlatformUtils::atomicIncrement(int &location)
  585. {
  586.     int current = location;
  587.     int new_loc = current+1;
  588.     while (_CMPSWP(&current,
  589.                    &location,
  590.                    new_loc) == 0)
  591.         new_loc = current+1;
  592.     int tmp = new_loc;
  593.     return tmp;
  594. }
  595. int XMLPlatformUtils::atomicDecrement(int &location)
  596. {
  597.     int current = location;
  598.     int new_loc = current-1;
  599.     while (_CMPSWP(&current,
  600.                    &location,
  601.                    new_loc) == 0)
  602.         new_loc = current-1;
  603.     int tmp = new_loc;
  604.     return tmp;
  605. }
  606. #else // #if !defined (APP_NO_THREADS)
  607. void XMLPlatformUtils::platformInit()
  608. {
  609.    // do nothing
  610. }
  611. void XMLPlatformUtils::closeMutex(void* const mtxHandle)
  612. {
  613. }
  614. void XMLPlatformUtils::lockMutex(void* const mtxHandle)
  615. {
  616. }
  617. void* XMLPlatformUtils::makeMutex()
  618. {
  619.         return 0;
  620. }
  621. void XMLPlatformUtils::unlockMutex(void* const mtxHandle)
  622. {
  623. }
  624. void* XMLPlatformUtils::compareAndSwap ( void**      toFill,
  625.                                    const void* const newValue,
  626.                                    const void* const toCompare)
  627. {
  628.     void *retVal = *toFill;
  629.     if (*toFill == toCompare)
  630.        *toFill = (void *)newValue;
  631.     return retVal;
  632. }
  633. int XMLPlatformUtils::atomicIncrement(int &location)
  634. {
  635.     return ++location;
  636. }
  637. int XMLPlatformUtils::atomicDecrement(int &location)
  638. {
  639.     return --location;
  640. }
  641. #endif // APP_NO_THREADS
  642. /*
  643.  * convert the errno value to a cpf message identifier by converting the
  644.  * error to its decimal equivalent and appending "CPE" to the front
  645.  * note that the caller passes the storage for the message id as a parm
  646.  */
  647. void convert_errno(char* errno_id,int errnum)
  648.       {
  649. sprintf(errno_id,"CPE%d04" ,errnum );
  650. return;
  651.       }
  652. FileHandle XMLPlatformUtils::openStdInHandle()
  653. {
  654.     return (FileHandle)fdopen(dup(0), "rb");
  655. }
  656. void XMLPlatformUtils::platformTerm()
  657. {
  658. #if !defined (APP_NO_THREADS)
  659. pthread_mutex_destroy(gAtomicOpMutex);
  660.     delete gAtomicOpMutex;
  661. gAtomicOpMutex = 0;
  662. #endif
  663. #if defined (XML_USE_ICONV400_TRANSCODER)
  664. cleanupDefaultConverter();
  665. #endif
  666. }
  667. #include <xercesc/util/LogicalPath.c>
  668. XERCES_CPP_NAMESPACE_END