home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / ocl150a.zip / OCL / Source / OMuxWaitSem.cpp < prev    next >
C/C++ Source or Header  |  1996-08-12  |  4KB  |  187 lines
  1. // OCL - OS/2 Class Library
  2. // (c) Cubus 1995
  3. // All Rights Reserved
  4. // OMuxWaitSem.cpp
  5.  
  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.  * 1. Redistributions of source code must retain the above copyright
  11.  *    notice, this list of conditions and the following disclaimer.
  12.  * 2. Neither the name Cubus nor the name Team OCL may be used to
  13.  *    endorse or promote products derived from this software
  14.  *    without specific prior written permission.
  15.  * 3. See OCL.INF for a detailed copyright notice.
  16.  *
  17.  *              THIS SOFTWARE IS PROVIDED ``AS IS'' AND
  18.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  19.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  20.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  21.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  22.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  23.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  24.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  25.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  26.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  27.  * SUCH DAMAGE.
  28.  */
  29.  
  30.  
  31. // $Header: W:/Projects/OCL/Source/rcs/OMuxWaitSem.cpp 1.50 1996/08/11 23:49:24 B.STEIN Release $
  32.  
  33. #define __OCL_SOURCE__
  34.  
  35. #define OINCL_OSTRING
  36. #define OINCL_BASE
  37.  
  38. #include <ocl.hpp>
  39. #include <OMuxWaitSem.hpp>
  40. #include <OMessage.hpp>
  41.  
  42.  
  43. OMuxWaitSem::OMuxWaitSem(HMUX handle) throw (OVioException&)
  44.   : hmux((HMUX)NULL),
  45.     muxwaitState(0)
  46. {
  47.  if (!openMuxWaitSem(handle))
  48.    throw OVioException(OCL::apierror(120, muxwaitState), muxwaitState);
  49. }
  50.  
  51.  
  52. OMuxWaitSem::OMuxWaitSem(PCSZ name, 
  53.                          ULONG numSem, 
  54.                          PSEMRECORD semArray,  
  55.                          ULONG action,
  56.                          ULONG attrib) throw (OVioException&)
  57.   : hmux((HMUX)NULL),
  58.     muxwaitState(0)
  59. {
  60.  switch(action)
  61.   {
  62.    case OMuxWaitSem::create: {
  63.     APIRET rc;
  64.  
  65.     if ((rc=DosCreateMuxWaitSem(name, &hmux, numSem, semArray, attrib))!=0)
  66.       throw OVioException(OCL::apierror(121, rc), rc);
  67.     break; }
  68.  
  69.    case OMuxWaitSem::open:
  70.     if (!openMuxWaitSem(name))
  71.       throw OVioException(OCL::apierror(122, muxwaitState), muxwaitState);
  72.     break;
  73.   }
  74. }
  75.  
  76.  
  77. OMuxWaitSem::~OMuxWaitSem()
  78. {
  79.  if (hmux)
  80.    closeMuxWaitSem();
  81. }
  82.  
  83.  
  84. PSZ OMuxWaitSem::isOfType() const
  85. { 
  86.  return("OMuxWaitSem"); 
  87. }
  88.  
  89.  
  90. ULONG OMuxWaitSem::waitMuxWaitSem(ULONG timeout)
  91. {
  92.  ULONG posted = 0;
  93.  
  94.  muxwaitState = DosWaitMuxWaitSem(hmux, timeout, &posted);
  95.  if (muxwaitState)
  96.    return(0);
  97.  return(posted);
  98. }
  99.  
  100.  
  101.  
  102. BOOL OMuxWaitSem::openMuxWaitSem(HMUX handle)
  103. {
  104.  muxwaitState = DosOpenMuxWaitSem((PSZ)NULL, &handle);
  105.  return(muxwaitState == 0);
  106. }
  107.  
  108.  
  109. BOOL OMuxWaitSem::openMuxWaitSem(PCSZ name)
  110. {
  111.  hmux = (HMUX)NULL;
  112.  muxwaitState = DosOpenMuxWaitSem((PSZ)name, &hmux);
  113.  return(muxwaitState == 0);
  114. }
  115.  
  116.  
  117.  
  118. BOOL OMuxWaitSem::addSemaphore(PSEMRECORD record)
  119. {
  120.  muxwaitState = DosAddMuxWaitSem(hmux, record);
  121.  return(muxwaitState == 0);
  122. }
  123.  
  124.  
  125. BOOL OMuxWaitSem::addSemaphore(ONSem *sema)
  126. {
  127.  SEMRECORD semRec;
  128.  
  129.  if (!sema) {
  130.    muxwaitState = ERROR_INVALID_PARAMETER;
  131.    return(FALSE); }
  132.  
  133.  semRec.hsemCur = (HSEM) sema->getSemHandle();
  134.  return(addSemaphore(&semRec));
  135. }
  136.  
  137.  
  138. BOOL OMuxWaitSem::addSemaphore(OMuxSem *sema)
  139. {
  140.  SEMRECORD semRec;
  141.  
  142.  if (!sema) {
  143.    muxwaitState = ERROR_INVALID_PARAMETER;
  144.    return(FALSE); }
  145.  
  146.  semRec.hsemCur = (HSEM) sema->getMuxSemHandle();
  147.  return(addSemaphore(&semRec));
  148. }
  149.  
  150.  
  151. BOOL OMuxWaitSem::delSemaphore(HSEM handle)
  152. {
  153.  muxwaitState = DosDeleteMuxWaitSem(hmux, handle);
  154.  return(muxwaitState == 0);
  155. }
  156.  
  157.  
  158. BOOL OMuxWaitSem::queryMuxWaitSem(PULONG num,
  159.                                   PSEMRECORD semArray,
  160.                                   PULONG attributes)
  161. {
  162.  muxwaitState = DosQueryMuxWaitSem(hmux, num, semArray, attributes);
  163.  return(muxwaitState == 0);
  164. }
  165.  
  166.  
  167. void OMuxWaitSem::setMuxWaitSemHandle(HMUX handle)
  168. {
  169.  hmux = handle;
  170. }
  171.  
  172.  
  173. HMUX OMuxWaitSem::getMuxWaitSemHandle()
  174. {
  175.  return(hmux);
  176. }
  177.  
  178.  
  179. BOOL OMuxWaitSem::closeMuxWaitSem()
  180. {
  181.  muxwaitState = DosCloseMuxWaitSem(hmux);
  182.  return(muxwaitState == 0);
  183. }
  184.  
  185.  
  186. // end of source
  187.