开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数值算法/人工智能 > 生物技术 > 查看源码
ncbi_conn_stream.cpp
资源名称：ncbi_cxx_win--Jul_08_2004.zip　[点击查看]
上传用户：yhdzpy8989
上传日期：2007-06-13
资源大小：13604k
文件大小：14k
源码类别：

生物技术

开发平台：

C/C++

ncbi_conn_stream.cpp：源码内容
  1. /*
  2.  * ===========================================================================
  3.  * PRODUCTION $Log: ncbi_conn_stream.cpp,v $
  4.  * PRODUCTION Revision 1000.4  2004/06/01 18:44:41  gouriano
  5.  * PRODUCTION PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R6.31
  6.  * PRODUCTION
  7.  * ===========================================================================
  8.  */
  10. /*  $Id: ncbi_conn_stream.cpp,v 1000.4 2004/06/01 18:44:41 gouriano Exp $
  11.  * ===========================================================================
  12.  *
  13.  *                            PUBLIC DOMAIN NOTICE
  14.  *               National Center for Biotechnology Information
  15.  *
  16.  *  This software/database is a "United States Government Work" under the
  17.  *  terms of the United States Copyright Act.  It was written as part of
  18.  *  the author's official duties as a United States Government employee and
  19.  *  thus cannot be copyrighted.  This software/database is freely available
  20.  *  to the public for use. The National Library of Medicine and the U.S.
  21.  *  Government have not placed any restriction on its use or reproduction.
  22.  *
  23.  *  Although all reasonable efforts have been taken to ensure the accuracy
  24.  *  and reliability of the software and data, the NLM and the U.S.
  25.  *  Government do not and cannot warrant the performance or results that
  26.  *  may be obtained by using this software or data. The NLM and the U.S.
  27.  *  Government disclaim all warranties, express or implied, including
  28.  *  warranties of performance, merchantability or fitness for any particular
  29.  *  purpose.
  30.  *
  31.  *  Please cite the author in any work or product based on this material.
  32.  *
  33.  * ===========================================================================
  34.  *
  35.  * Authors:  Anton Lavrentiev,  Denis Vakatov
  36.  *
  37.  * File Description:
  38.  *   CONN-based C++ streams
  39.  *
  40.  *   See file <connect/ncbi_conn_stream.hpp> for more detailed information.
  41.  *
  42.  */
  44. #include <ncbi_pch.hpp>
  45. #include "ncbi_ansi_ext.h"
  46. #include "ncbi_conn_streambuf.hpp"
  47. #include <connect/ncbi_conn_stream.hpp>
  48. #include <connect/ncbi_core_cxx.hpp>
  49. #include <corelib/ncbithr.hpp>
  50. #include <memory>
  53. BEGIN_NCBI_SCOPE
  56. CConn_IOStream::CConn_IOStream(CONNECTOR connector, const STimeout* timeout,
  57.                                streamsize buf_size, bool do_tie) :
  58.     CNcbiIostream(0), m_CSb(0)
  59. {
  60.     auto_ptr<CConn_Streambuf>
  61.         csb(new CConn_Streambuf(connector, timeout, buf_size, do_tie));
  62.     if ( csb->GetCONN() ) {
  63.         init(csb.get());
  64.         m_CSb = csb.release();
  65.     } else
  66.         init(0); // according to the standard (27.4.4.1.3), badbit is set here
  67. }
  70. CConn_IOStream::~CConn_IOStream()
  71. {
  72.     Cleanup();
  73. }
  76. CONN CConn_IOStream::GetCONN(void) const
  77. {
  78.     return m_CSb ? m_CSb->GetCONN() : 0;
  79. }
  82. void CConn_IOStream::Cleanup(void)
  83. {
  84.     streambuf* sb = rdbuf();
  85.     delete sb;
  86.     if (sb != m_CSb)
  87.         delete m_CSb;
  88.     m_CSb = 0;
  89. #ifdef AUTOMATIC_STREAMBUF_DESTRUCTION
  90.     rdbuf(0);
  91. #endif
  92. }
  95. CConn_SocketStream::CConn_SocketStream(const string&   host,
  96.                                        unsigned short  port,
  97.                                        unsigned int    max_try,
  98.                                        const STimeout* timeout,
  99.                                        streamsize      buf_size)
  100.     : CConn_IOStream(SOCK_CreateConnector(host.c_str(), port, max_try),
  101.                      timeout, buf_size)
  102. {
  103.     return;
  104. }
  107. CConn_SocketStream::CConn_SocketStream(SOCK            sock,
  108.                                        unsigned int    max_try,
  109.                                        const STimeout* timeout,
  110.                                        streamsize      buf_size)
  111.     : CConn_IOStream(SOCK_CreateConnectorOnTop(sock, max_try),
  112.                      timeout, buf_size)
  113. {
  114.     return;
  115. }
  118. static CONNECTOR s_HttpConnectorBuilder(const SConnNetInfo* net_info_in,
  119.                                         const char*         url,
  120.                                         const char*         host,
  121.                                         unsigned short      port,
  122.                                         const char*         path,
  123.                                         const char*         args,
  124.                                         const char*         user_hdr,
  125.                                         THCC_Flags          flags,
  126.                                         const STimeout*     timeout)
  127. {
  128.     SConnNetInfo* net_info = net_info_in ?
  129.         ConnNetInfo_Clone(net_info_in) : ConnNetInfo_Create(0);
  130.     if (!net_info)
  131.         return 0;
  132.     if (url && !ConnNetInfo_ParseURL(net_info, url))
  133.         return 0;
  134.     if (host) {
  135.         strncpy0(net_info->host, host, sizeof(net_info->host) - 1);
  136.         net_info->port = port;
  137.     }
  138.     if (path)
  139.         strncpy0(net_info->path, path, sizeof(net_info->path) - 1);
  140.     if (args)
  141.         strncpy0(net_info->args, args, sizeof(net_info->args) - 1);
  142.     if (timeout && timeout != kDefaultTimeout) {
  143.         net_info->tmo     = *timeout;
  144.         net_info->timeout = &net_info->tmo;
  145.     } else if (!timeout)
  146.         net_info->timeout = 0;
  147.     CONNECTOR c = HTTP_CreateConnector(net_info, user_hdr, flags);
  148.     ConnNetInfo_Destroy(net_info);
  149.     return c;
  150. }
  153. CConn_HttpStream::CConn_HttpStream(const string&   host,
  154.                                    const string&   path,
  155.                                    const string&   args,
  156.                                    const string&   user_header,
  157.                                    unsigned short  port,
  158.                                    THCC_Flags      flags,
  159.                                    const STimeout* timeout,
  160.                                    streamsize      buf_size)
  161.     : CConn_IOStream(s_HttpConnectorBuilder(0,
  162.                                             0,
  163.                                             host.c_str(),
  164.                                             port,
  165.                                             path.c_str(),
  166.                                             args.c_str(),
  167.                                             user_header.c_str(),
  168.                                             flags,
  169.                                             timeout),
  170.                      timeout, buf_size)
  171. {
  172.     return;
  173. }
  176. CConn_HttpStream::CConn_HttpStream(const string&       url,
  177.                                    THCC_Flags          flags,
  178.                                    const STimeout*     timeout,
  179.                                    streamsize          buf_size)
  180.     : CConn_IOStream(s_HttpConnectorBuilder(0,
  181.                                             url.c_str(),
  182.                                             0,
  183.                                             0,
  184.                                             0,
  185.                                             0,
  186.                                             0,
  187.                                             flags,
  188.                                             timeout),
  189.                      timeout, buf_size)
  190. {
  191.     return;
  192. }
  195. CConn_HttpStream::CConn_HttpStream(const SConnNetInfo* net_info,
  196.                                    const string&       user_header,
  197.                                    THCC_Flags          flags,
  198.                                    const STimeout*     timeout,
  199.                                    streamsize          buf_size)
  200.     : CConn_IOStream(s_HttpConnectorBuilder(net_info,
  201.                                             0,
  202.                                             0,
  203.                                             0,
  204.                                             0,
  205.                                             0,
  206.                                             user_header.c_str(),
  207.                                             flags,
  208.                                             timeout),
  209.                      timeout, buf_size)
  210. {
  211.     return;
  212. }
  215. static CONNECTOR s_ServiceConnectorBuilder(const char*           service,
  216.                                            TSERV_Type            types,
  217.                                            const SConnNetInfo*   net_info_in,
  218.                                            const SSERVICE_Extra* params,
  219.                                            const STimeout*       timeout)
  220. {
  221.     SConnNetInfo* net_info = net_info_in ?
  222.         ConnNetInfo_Clone(net_info_in) : ConnNetInfo_Create(service);
  223.     if (!net_info)
  224.         return 0;
  225.     if (timeout && timeout != kDefaultTimeout) {
  226.         net_info->tmo     = *timeout;
  227.         net_info->timeout = &net_info->tmo;
  228.     } else if (!timeout)
  229.         net_info->timeout = 0;
  230.     CONNECTOR c = SERVICE_CreateConnectorEx(service, types, net_info, params);
  231.     ConnNetInfo_Destroy(net_info);
  232.     return c;
  233. }
  236. CConn_ServiceStream::CConn_ServiceStream(const string&         service,
  237.                                          TSERV_Type            types,
  238.                                          const SConnNetInfo*   net_info,
  239.                                          const SSERVICE_Extra* params,
  240.                                          const STimeout*       timeout,
  241.                                          streamsize            buf_size)
  242.     : CConn_IOStream(s_ServiceConnectorBuilder(service.c_str(),
  243.                                                types,
  244.                                                net_info,
  245.                                                params,
  246.                                                timeout),
  247.                      timeout, buf_size)
  248. {
  249.     return;
  250. }
  253. CConn_MemoryStream::CConn_MemoryStream(CRWLock*   lk,
  254.                                        bool       pass_lk_ownership,
  255.                                        streamsize buf_size)
  256.     : CConn_IOStream(MEMORY_CreateConnector
  257.                      (MT_LOCK_cxx2c(lk, pass_lk_ownership)),
  258.                      0, buf_size)
  259. {
  260.     return;
  261. }
  264. CConn_PipeStream::CConn_PipeStream(const string&         cmd,
  265.                                    const vector<string>& args,
  266.                                    CPipe::TCreateFlags   create_flags,
  267.                                    const STimeout*       timeout,
  268.                                    streamsize            buf_size)
  269.     : CConn_IOStream(PIPE_CreateConnector(cmd, args, create_flags, &m_Pipe),
  270.                      timeout, buf_size), m_Pipe()
  271. {
  272.     return;
  273. }
  276. CConn_PipeStream::~CConn_PipeStream()
  277. {
  278.     // Explicitly call Cleanup() to avoid using dead m_Pipe otherwise.
  279.     Cleanup();
  280. #ifndef AUTOMATIC_STREAMBUF_DESTRUCTION
  281.     rdbuf(0);
  282. #endif
  283. }
  286. CConn_NamedPipeStream::CConn_NamedPipeStream(const string&   pipename,
  287.                                              size_t          pipebufsize,
  288.                                              const STimeout* timeout,
  289.                                              streamsize      buf_size)
  290.     : CConn_IOStream(NAMEDPIPE_CreateConnector(pipename, pipebufsize),
  291.                      timeout, buf_size)
  292. {
  293.     return;
  294. }
  297. END_NCBI_SCOPE
  300. /*
  301.  * ---------------------------------------------------------------------------
  302.  * $Log: ncbi_conn_stream.cpp,v $
  303.  * Revision 1000.4  2004/06/01 18:44:41  gouriano
  304.  * PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R6.31
  305.  *
  306.  * Revision 6.31  2004/05/17 20:58:13  gorelenk
  307.  * Added include of PCH ncbi_pch.hpp
  308.  *
  309.  * Revision 6.30  2004/03/22 16:54:32  ivanov
  310.  * Cosmetic changes
  311.  *
  312.  * Revision 6.29  2004/01/20 20:36:05  lavr
  313.  * Cease using HAVE_BUGGY_IOS_CALLBACKS in this file
  314.  *
  315.  * Revision 6.28  2003/11/12 17:45:08  lavr
  316.  * Change log fixed to reflect real changes in previous commit
  317.  *
  318.  * Revision 6.27  2003/11/12 16:37:50  ivanov
  319.  * CConn_PipeStream:: dtor added
  320.  *
  321.  * Revision 6.26  2003/10/23 12:16:27  lavr
  322.  * CConn_IOStream:: base class is now CNcbiIostream
  323.  *
  324.  * Revision 6.25  2003/09/23 21:05:23  lavr
  325.  * +CConn_PipeStream, +CConn_NamedPipeStream
  326.  *
  327.  * Revision 6.24  2003/08/25 14:40:43  lavr
  328.  * Employ new k..Timeout constants
  329.  *
  330.  * Revision 6.23  2003/05/20 19:08:28  lavr
  331.  * Do not use clear() in constructor ('cause it may throw an exception)
  332.  *
  333.  * Revision 6.22  2003/05/20 16:57:56  lavr
  334.  * Fix typo in log
  335.  *
  336.  * Revision 6.21  2003/05/20 16:47:19  lavr
  337.  * GetCONN() to check for NULL; constructor to init(0) if connection is bad
  338.  *
  339.  * Revision 6.20  2003/05/12 18:32:27  lavr
  340.  * Modified not to throw exceptions from stream buffer; few more improvements
  341.  *
  342.  * Revision 6.19  2003/04/29 19:58:24  lavr
  343.  * Constructor taking a URL added in CConn_HttpStream
  344.  *
  345.  * Revision 6.18  2003/04/14 21:08:15  lavr
  346.  * Take advantage of HAVE_BUGGY_IOS_CALLBACKS
  347.  *
  348.  * Revision 6.17  2003/04/11 17:57:29  lavr
  349.  * Take advantage of HAVE_IOS_XALLOC
  350.  *
  351.  * Revision 6.16  2003/03/25 22:17:18  lavr
  352.  * Set timeouts from ctors in SConnNetInfo, too, for display unambigously
  353.  *
  354.  * Revision 6.15  2002/10/28 15:42:18  lavr
  355.  * Use "ncbi_ansi_ext.h" privately and use strncpy0()
  356.  *
  357.  * Revision 6.14  2002/06/06 19:02:32  lavr
  358.  * Some housekeeping: log moved to the end
  359.  *
  360.  * Revision 6.13  2002/02/21 18:04:25  lavr
  361.  * +class CConn_MemoryStream
  362.  *
  363.  * Revision 6.12  2002/02/05 22:04:12  lavr
  364.  * Included header files rearranged
  365.  *
  366.  * Revision 6.11  2002/02/05 16:05:26  lavr
  367.  * List of included header files revised
  368.  *
  369.  * Revision 6.10  2002/01/28 21:29:25  lavr
  370.  * Use iostream(0) as a base class constructor
  371.  *
  372.  * Revision 6.9  2002/01/28 20:19:11  lavr
  373.  * Clean destruction of streambuf sub-object; no exception throw in GetCONN()
  374.  *
  375.  * Revision 6.8  2001/12/10 19:41:18  vakatov
  376.  * + CConn_SocketStream::CConn_SocketStream(SOCK sock, ....)
  377.  *
  378.  * Revision 6.7  2001/12/07 22:58:01  lavr
  379.  * GetCONN(): throw exception if the underlying streambuf is not CONN-based
  380.  *
  381.  * Revision 6.6  2001/09/24 20:26:17  lavr
  382.  * +SSERVICE_Extra* parameter for CConn_ServiceStream::CConn_ServiceStream()
  383.  *
  384.  * Revision 6.5  2001/01/12 23:49:19  lavr
  385.  * Timeout and GetCONN method added
  386.  *
  387.  * Revision 6.4  2001/01/11 23:04:06  lavr
  388.  * Bugfixes; tie is now done at streambuf level, not in iostream
  389.  *
  390.  * Revision 6.3  2001/01/11 17:22:41  thiessen
  391.  * fix args copy in s_HttpConnectorBuilder()
  392.  *
  393.  * Revision 6.2  2001/01/10 21:41:10  lavr
  394.  * Added classes: CConn_SocketStream, CConn_HttpStream, CConn_ServiceStream.
  395.  * Everything is now wordly documented.
  396.  *
  397.  * Revision 6.1  2001/01/09 23:35:25  vakatov
  398.  * Initial revision (draft, not tested in run-time)
  399.  *
  400.  * ===========================================================================
  401.  */