indchan.h
上传用户:hzhsqp
上传日期:2007-01-06
资源大小:1600k
文件大小:10k
源码类别:

IP电话/视频会议

开发平台:

Visual C++

  1. /*
  2.  * indchan.h
  3.  *
  4.  * Indirect I/O channel class.
  5.  *
  6.  * Portable Windows Library
  7.  *
  8.  * Copyright (c) 1993-1998 Equivalence Pty. Ltd.
  9.  *
  10.  * The contents of this file are subject to the Mozilla Public License
  11.  * Version 1.0 (the "License"); you may not use this file except in
  12.  * compliance with the License. You may obtain a copy of the License at
  13.  * http://www.mozilla.org/MPL/
  14.  *
  15.  * Software distributed under the License is distributed on an "AS IS"
  16.  * basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
  17.  * the License for the specific language governing rights and limitations
  18.  * under the License.
  19.  *
  20.  * The Original Code is Portable Windows Library.
  21.  *
  22.  * The Initial Developer of the Original Code is Equivalence Pty. Ltd.
  23.  *
  24.  * Portions are Copyright (C) 1993 Free Software Foundation, Inc.
  25.  * All Rights Reserved.
  26.  *
  27.  * Contributor(s): ______________________________________.
  28.  *
  29.  * $Log: indchan.h,v $
  30.  * Revision 1.5  1999/06/17 13:38:11  robertj
  31.  * Fixed race condition on indirect channel close, mutex needed in PIndirectChannel.
  32.  *
  33.  * Revision 1.4  1999/03/09 02:59:49  robertj
  34.  * Changed comments to doc++ compatible documentation.
  35.  *
  36.  * Revision 1.3  1999/02/16 08:12:00  robertj
  37.  * MSVC 6.0 compatibility changes.
  38.  *
  39.  * Revision 1.2  1998/09/23 06:20:41  robertj
  40.  * Added open source copyright license.
  41.  *
  42.  * Revision 1.1  1996/09/14 13:00:56  robertj
  43.  * Initial revision
  44.  *
  45.  */
  46. #ifndef _PINDIRECTCHANNEL
  47. #define _PINDIRECTCHANNEL
  48. #ifdef __GNUC__
  49. #pragma interface
  50. #endif
  51. /**This is a channel that operates indirectly through another channel(s). This
  52.    allows for a protocol to operate through a "channel" mechanism and for its
  53.    low level byte exchange (Read and Write) to operate via a completely
  54.    different channel, eg TCP or Serial port etc.
  55.  */
  56. class PIndirectChannel : public PChannel
  57. {
  58.   PCLASSINFO(PIndirectChannel, PChannel);
  59.   public:
  60.   /**@name Construction */
  61.   //@{
  62.     /**Create a new indirect channel without any channels to redirect to. If
  63.        an attempt to read or write is made before Open() is called the the
  64.        functions will assert.
  65.      */
  66.     PIndirectChannel();
  67.     /// Close the indirect channel, deleting read/write channels if desired.
  68.     ~PIndirectChannel();
  69.   //@}
  70.   /**@name Overrides from class PObject */
  71.   //@{
  72.     /**Determine if the two objects refer to the same indirect channel. This
  73.        actually compares the channel pointers.
  74.        @return
  75.        EqualTo if channel pointer identical.
  76.      */
  77.     Comparison Compare(
  78.       const PObject & obj   /// Another indirect channel to compare against.
  79.     ) const;
  80.   //@}
  81.   /**@name Overrides from class PChannel */
  82.   //@{
  83.     /**Get the name of the channel. This is a combination of the channel
  84.        pointers names (or simply the channel pointers name if the read and
  85.        write channels are the same) or empty string if both null.
  86.     
  87.        @return
  88.        string for the channel names.
  89.      */
  90.     virtual PString GetName() const;
  91.     /**Close the channel. This will detach itself from the read and write
  92.        channels and delete both of them if they are auto delete.
  93.        @return
  94.        TRUE if the channel is closed.
  95.      */
  96.     virtual BOOL Close();
  97.     /**Determine if the channel is currently open and read and write operations
  98.        can be executed on it. For example, in the #PFile# class it returns
  99.        if the file is currently open.
  100.        @return
  101.        TRUE if the channel is open.
  102.      */
  103.     virtual BOOL IsOpen() const;
  104.     /**Low level read from the channel. This function may block until the
  105.        requested number of characters were read or the read timeout was
  106.        reached. The GetLastReadCount() function returns the actual number
  107.        of bytes read.
  108.        This will use the #readChannel# pointer to actually do the
  109.        read. If #readChannel# is null the this asserts.
  110.        The GetErrorCode() function should be consulted after Read() returns
  111.        FALSE to determine what caused the failure.
  112.        @return
  113.        TRUE indicates that at least one character was read from the channel.
  114.        FALSE means no bytes were read due to timeout or some other I/O error.
  115.      */
  116.     virtual BOOL Read(
  117.       void * buf,   /// Pointer to a block of memory to receive the read bytes.
  118.       PINDEX len    /// Maximum number of bytes to read into the buffer.
  119.     );
  120.     /**Low level write to the channel. This function will block until the
  121.        requested number of characters are written or the write timeout is
  122.        reached. The GetLastWriteCount() function returns the actual number
  123.        of bytes written.
  124.        This will use the #writeChannel# pointer to actually do the
  125.        write. If #writeChannel# is null the this asserts.
  126.        The GetErrorCode() function should be consulted after Write() returns
  127.        FALSE to determine what caused the failure.
  128.        @return
  129.        TRUE if at least len bytes were written to the channel.
  130.      */
  131.     virtual BOOL Write(
  132.       const void * buf, /// Pointer to a block of memory to write.
  133.       PINDEX len        /// Number of bytes to write.
  134.     );
  135.     /**Close one or both of the data streams associated with a channel.
  136.        The behavour here is to pass the shutdown on to its read and write
  137.        channels.
  138.        @return
  139.        TRUE if the shutdown was successfully performed.
  140.      */
  141.     virtual BOOL Shutdown(
  142.       ShutdownValue option   /// Flag for shut down of read, write or both.
  143.     );
  144.     /**This function returns the eventual base channel for reading of a series
  145.        of indirect channels provided by descendents of #PIndirectChannel#.
  146.        The behaviour for this function is to return "this".
  147.        
  148.        @return
  149.        Pointer to base I/O channel for the indirect channel.
  150.      */
  151.     virtual PChannel * GetBaseReadChannel() const;
  152.     /**This function returns the eventual base channel for writing of a series
  153.        of indirect channels provided by descendents of #PIndirectChannel#.
  154.        The behaviour for this function is to return "this".
  155.        
  156.        @return
  157.        Pointer to base I/O channel for the indirect channel.
  158.      */
  159.     virtual PChannel * GetBaseWriteChannel() const;
  160.   //@}
  161.   /**@name Channel establish functions */
  162.   //@{
  163.     /**Set the channel for both read and write operations. This then checks
  164.        that they are open and then calls the OnOpen() virtual function. If
  165.        it in turn returns TRUE then the Open() function returns success.
  166.        @return
  167.        TRUE if both channels are set, open and OnOpen() returns TRUE.
  168.      */
  169.     BOOL Open(
  170.       PChannel & channel
  171.         /// Channel to be used for both read and write operations.
  172.     );
  173.     /**Set the channel for both read and write operations. This then checks
  174.        that they are open and then calls the OnOpen() virtual function. If
  175.        it in turn returns TRUE then the Open() function returns success.
  176.        The channel pointed to by #channel# may be automatically deleted
  177.        when the PIndirectChannel is destroyed or a new subchannel opened.
  178.        @return
  179.        TRUE if both channels are set, open and OnOpen() returns TRUE.
  180.      */
  181.     BOOL Open(
  182.       PChannel * channel,
  183.         /// Channel to be used for both read and write operations.
  184.       BOOL autoDelete = TRUE   /// Automatically delete the channel
  185.     );
  186.     /**Set the channel for both read and write operations. This then checks
  187.        that they are open and then calls the OnOpen() virtual function. If
  188.        it in turn returns TRUE then the Open() function returns success.
  189.        The channels pointed to by #readChannel# and #writeChannel# may be
  190.        automatically deleted when the PIndirectChannel is destroyed or a
  191.        new subchannel opened.
  192.        @return
  193.        TRUE if both channels are set, open and OnOpen() returns TRUE.
  194.      */
  195.     BOOL Open(
  196.       PChannel * readChannel,
  197.         // Channel to be used for both read operations.
  198.       PChannel * writeChannel,
  199.         // Channel to be used for both write operations.
  200.       BOOL autoDeleteRead = TRUE,  // Automatically delete the read channel
  201.       BOOL autoDeleteWrite = TRUE  // Automatically delete the write channel
  202.     );
  203.     /**Get the channel used for read operations.
  204.     
  205.        @return
  206.        pointer to the read channel.
  207.      */
  208.     PChannel * GetReadChannel() const;
  209.     /**Set the channel for read operations.
  210.        @return
  211.        Returns TRUE if both channels are set and are both open.
  212.      */
  213.     BOOL SetReadChannel(
  214.       PChannel * channel,
  215.         /// Channel to be used for both read operations.
  216.       BOOL autoDelete = TRUE   /// Automatically delete the channel
  217.     );
  218.     /**Get the channel used for write operations.
  219.     
  220.        @return
  221.        pointer to the write channel.
  222.      */
  223.     PChannel * GetWriteChannel() const;
  224.     /**Set the channel for read operations.
  225.        @return
  226.        Returns TRUE if both channels are set and are both open.
  227.     */
  228.     BOOL SetWriteChannel(
  229.       PChannel * channel,
  230.         /// Channel to be used for both write operations.
  231.       BOOL autoDelete = TRUE   /// Automatically delete the channel
  232.     );
  233.   //@}
  234.   protected:
  235.     /**This callback is executed when the Open() function is called with
  236.        open channels. It may be used by descendent channels to do any
  237.        handshaking required by the protocol that channel embodies.
  238.        The default behaviour is to simply return TRUE.
  239.        @return
  240.        Returns TRUE if the protocol handshaking is successful.
  241.      */
  242.     virtual BOOL OnOpen();
  243.   // Member variables
  244.     /// Channel for read operations.
  245.     PChannel * readChannel;
  246.     /// Automatically delete read channel on destruction.
  247.     BOOL readAutoDelete;
  248.     /// Channel for write operations.
  249.     PChannel * writeChannel;
  250.     /// Automatically delete write channel on destruction.
  251.     BOOL writeAutoDelete;
  252.     /// Race condition prevention on closing channel
  253.     PReadWriteMutex channelPointerMutex;
  254. };
  255. #endif // _PINDIRECTCHANNEL