home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / ocl150a.zip / OCL / Source / OPipeSvr.cpp < prev    next >
C/C++ Source or Header  |  1996-08-12  |  6KB  |  235 lines
  1. // OCL - OS/2 Class Library
  2. // (c) Cubus 1995
  3. // All Rights Reserved
  4. // OPipeSvr.cpp
  5.  
  6. // members of OPipeSvr
  7.  
  8.  
  9. /*
  10.  * Redistribution and use in source and binary forms, with or without
  11.  * modification, are permitted provided that the following conditions
  12.  * are met:
  13.  * 1. Redistributions of source code must retain the above copyright
  14.  *    notice, this list of conditions and the following disclaimer.
  15.  * 2. Neither the name Cubus nor the name Team OCL may be used to
  16.  *    endorse or promote products derived from this software
  17.  *    without specific prior written permission.
  18.  * 3. See OCL.INF for a detailed copyright notice.
  19.  *
  20.  *              THIS SOFTWARE IS PROVIDED ``AS IS'' AND
  21.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  22.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  23.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  24.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  25.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  26.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  27.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  28.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  29.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  30.  * SUCH DAMAGE.
  31.  */
  32.  
  33. // $Header: W:/Projects/OCL/Source/rcs/OPipeSvr.cpp 1.50 1996/08/11 23:49:27 B.STEIN Release $
  34.  
  35. #define __OCL_SOURCE__
  36.  
  37. #define OINCL_OSTRING
  38. #define OINCL_BASE
  39.  
  40. #include <ocl.hpp>
  41. #include <OPipeSvr.hpp>
  42.  
  43. #if defined(__EMX__)
  44.   template class OThread<OPipeSvr>;
  45. #endif
  46.  
  47.  
  48. OPipeSvr::OPipeSvr(const ULONG inSize,
  49.                    const ULONG outSize,
  50.                    const ULONG Size,
  51.                    const ULONG openMode,
  52.                    const ULONG pipeMode,
  53.                    const ULONG timeout,
  54.                    const ULONG inst)
  55.   : pipeThread(this, &OPipeSvr::Pipe_IO)
  56. {
  57.  oMode = openMode;
  58.  pMode = pipeMode;
  59.  timeOut = timeout;
  60.  instances = inst;
  61.  inBuf = inSize;
  62.  outBuf = outSize;
  63.  BufSize = Size;
  64. }
  65.  
  66.  
  67. OPipeSvr::~OPipeSvr()
  68. {
  69.  destroyPipe();
  70.  pipes.reset();
  71. }
  72.  
  73.  
  74. PSZ OPipeSvr::isOfType() const
  75. { 
  76.  return("OPipeSvr"); 
  77. }
  78.  
  79.  
  80.  
  81. BOOL OPipeSvr::beginPiping(PCSZ pipeName)
  82. {
  83.  return(createPipe(pipeName)); 
  84. }
  85.  
  86.  
  87. BOOL OPipeSvr::stopPiping() 
  88. {
  89.  return(destroyPipe()); 
  90. }
  91.  
  92.  
  93. void OPipeSvr::setBufSizes(const ULONG in, const ULONG out, const ULONG Size)
  94. {
  95.  inBuf = in;
  96.  outBuf = out;
  97.  BufSize = Size;
  98. }
  99.  
  100.  
  101. BOOL OPipeSvr::createPipe(PCSZ pipeName)
  102. {
  103.  if ((!oMode) || (!pMode) || (!timeOut) || (!inBuf) || (!outBuf) || (!Buffer) || (!BufSize))
  104.    return(FALSE);
  105.  
  106.  pMode |= instances;
  107.  connectedClients = 0;
  108.  
  109.  for (ULONG i=0; i < instances; i++) {
  110.    pPipeStatus status = new PipeStatus;
  111.  
  112.    status->connected = FALSE;
  113.    if (DosCreateNPipe((PSZ) pipeName,  &status->pipe,  oMode, pMode, outBuf, inBuf, timeOut))
  114.      delete status;
  115.    else
  116.      pipes.addLast(status);
  117.   }
  118.  
  119.  if (pipes.isEmpty())
  120.    return(FALSE);
  121.  
  122.  return(pipeThread.run());
  123. }
  124.  
  125.  
  126. BOOL OPipeSvr::destroyPipe()
  127. {
  128.  close = TRUE;
  129.  pipeThread.waitFor();
  130.  actual = pipes.getFirst();
  131.  while(actual) {
  132.    actual->connected = FALSE;
  133.    DosDisConnectNPipe(actual->pipe);
  134.    DosClose(actual->pipe); 
  135.    actual = pipes.getNext(); }
  136.  return(TRUE);
  137. }
  138.  
  139.  
  140. BOOL OPipeSvr::getPipeData()
  141. {
  142.  ULONG read = 0;
  143.  if ((!actual->connected) || (DosRead(actual->pipe, Buffer, BufSize, &read)))
  144.    return(FALSE);
  145.  if (read == 0)
  146.    return(FALSE);
  147.  OPipeCommand(Buffer);
  148.  return(TRUE);
  149. }
  150.  
  151. BOOL OPipeSvr::postPipe(PVOID pvData, ULONG client)
  152. {
  153.  ULONG                written = 0;
  154.  pPipeStatus          postTo = NULL;
  155.  OListItem<PipeStatus> *tmp = (OListItem<PipeStatus>*)pipes.last();
  156.  
  157.  if (client == 0)
  158.   {
  159.    BOOL fSuccess = TRUE;
  160.  
  161.    for(ULONG client2post = 1; 
  162.       ((client2post <= connectedClients) && (fSuccess));
  163.       client2post++)
  164.      fSuccess = postPipe(pvData, client2post);
  165.    return(fSuccess);
  166.   }
  167.  
  168.  if ((pipes.isEmpty()) || (client < 1))
  169.    return(FALSE);
  170.  if (client > 1)
  171.   {
  172.    for (ULONG i=1; i < client; i++)
  173.     {
  174.      tmp = tmp->prev;
  175.      if (!tmp)
  176.        return(FALSE);
  177.     }
  178.   }
  179.  
  180.  if (tmp)
  181.    postTo = tmp->item;
  182.  
  183.  return((postTo != NULL) &&
  184.         (postTo->connected) && 
  185.         (!DosWrite(postTo->pipe, pvData, BufSize, &written)) && 
  186.         (written != 0)); 
  187. }
  188.  
  189.  
  190. void OPipeSvr::Pipe_IO()
  191. {
  192.  APIRET     rc;
  193.  
  194.  pipeThread.setPrty(PRTYC_IDLETIME, 0);  // initially run at idle priority
  195.  
  196.  actual = pipes.getFirst();
  197.  
  198.  while((!close) && (actual))
  199.   {
  200.    rc = DosConnectNPipe(actual->pipe);
  201.    switch(rc) 
  202.     {
  203.      case NO_ERROR:
  204.        if (actual->connected == FALSE) {
  205.            actual->connected = TRUE;
  206.            connectedClients++; }
  207.        if (connectedClients > 0)
  208.          pipeThread.setPrty(PRTYC_REGULAR, 0);
  209.        getPipeData();
  210.        break;
  211.  
  212.      case ERROR_BROKEN_PIPE:
  213.        actual->connected = FALSE;
  214.        connectedClients--;
  215.        DosDisConnectNPipe(actual->pipe);
  216.        if (connectedClients == 0)
  217.          pipeThread.setPrty(PRTYC_IDLETIME, 0);
  218.        break;
  219.  
  220.      case ERROR_PIPE_NOT_CONNECTED:
  221.        actual->connected = FALSE;
  222.        break;
  223.     }
  224.  
  225.    actual = pipes.getNext();
  226.    if (!actual) {
  227.       actual = pipes.getFirst();
  228.       DosSleep(100); }
  229.   }
  230.  
  231.  _endthread();
  232. }
  233.  
  234. // end of source
  235.