home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / ocl150a.zip / OCL / Source / OPipeCli.cpp < prev    next >
C/C++ Source or Header  |  1996-08-12  |  4KB  |  168 lines
  1. // OCL - OS/2 Class Library
  2. // (c) Cubus 1995
  3. // All Rights Reserved
  4. // OPipeCli.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/OPipeCli.cpp 1.50 1996/08/11 23:49:27 B.STEIN Release $
  32.  
  33. #define __OCL_SOURCE__
  34.  
  35. #define OINCL_OSTRING
  36. #define OINCL_BASE
  37.  
  38. #include <ocl.hpp>
  39. #include <OPipeCli.hpp>
  40.  
  41. #if defined(__EMX__)
  42.   template class OThread<OPipeCli>;
  43. #endif
  44.  
  45.  
  46. // members of OPipeCli
  47.  
  48.  
  49. OPipeCli::OPipeCli(const ULONG Size,
  50.                    const ULONG openMode,
  51.                    const ULONG pipeMode,
  52.                    const ULONG timeout,
  53.                    const BOOL  waitFor)
  54.   : pipeThread(this, &OPipeCli::Pipe_IO)
  55. {
  56.  oMode = openMode;
  57.  pMode = pipeMode;
  58.  timeOut = timeout;
  59.  BufSize = Size;
  60.  waitForInstance = waitFor;
  61.  connected = FALSE;
  62.  Pipe = (HPIPE)NULL;
  63. }
  64.  
  65.  
  66.  
  67. OPipeCli::~OPipeCli()
  68. {
  69.  if (connected) disconnectPipe();
  70. }
  71.  
  72.  
  73. PSZ OPipeCli::isOfType() const
  74. { 
  75.  return("OPipeCli"); 
  76. }
  77.  
  78.  
  79. BOOL OPipeCli::beginPiping(PCSZ pipeName) 
  80. {
  81.  return(connectPipe(pipeName)); 
  82. }
  83.  
  84.  
  85. BOOL OPipeCli::stopPiping() 
  86. {
  87.  return(disconnectPipe()); 
  88. }
  89.  
  90.  
  91. void OPipeCli::setSize(const ULONG Size) 
  92. {
  93.  BufSize = Size; 
  94. }
  95.  
  96.  
  97. BOOL OPipeCli::connectPipe(PCSZ pipeName)
  98. {
  99.  ULONG     Action;
  100.  APIRET    rc;
  101.  
  102.  if ((!oMode) || (connected) || (!Buffer) || (!BufSize))
  103.    return(FALSE);
  104.  
  105.  while(!close)
  106.   {
  107.    rc = DosOpen((PSZ)pipeName, (PHFILE)&Pipe, &Action, 0L, 0L, 
  108.                 OPEN_ACTION_OPEN_IF_EXISTS, oMode, NULL);
  109.    switch(rc)
  110.     {
  111.      case NO_ERROR:
  112.        connected = TRUE;
  113.        return(pipeThread.run());
  114.  
  115.      case ERROR_PIPE_BUSY:
  116.        if (!waitForInstance)
  117.          return(FALSE);
  118.        DosWaitNPipe((PSZ)pipeName, 0);
  119.        break;
  120.     }
  121.   }
  122.  return(FALSE);
  123. }
  124.  
  125. BOOL OPipeCli::disconnectPipe()
  126. {
  127.  close = TRUE;
  128.  DosClose(Pipe);
  129.  connected = FALSE;
  130.  if (pipeThread.isRunning())
  131.    pipeThread.stop();
  132.  return(TRUE);
  133. }
  134.  
  135. BOOL OPipeCli::postPipe(PVOID pvData, ULONG client)
  136. {
  137.  ULONG written = 0;
  138.  
  139.  return((connected) && 
  140.         (!DosWrite(Pipe, pvData, BufSize, &written)) &&
  141.         (written != 0));
  142. #ifdef __BCPLUSPLUS__
  143.   #pragma warn -par
  144. #endif
  145. }
  146. #ifdef __BCPLUSPLUS__
  147.   #pragma warn .par
  148. #endif
  149.  
  150.  
  151. void OPipeCli::Pipe_IO()
  152. {
  153.  ULONG read = 0;
  154.  
  155.  while (!close)
  156.    {
  157.     if (!DosRead(Pipe, Buffer, BufSize, &read) && read > 0)
  158.       OPipeCommand(Buffer); 
  159.     else
  160.       DosSleep(100); 
  161.    }
  162.  
  163.  connected = FALSE;
  164.  _endthread();
  165. }
  166.  
  167. // end of source
  168.