ncbi_conn_stream.cpp File Reference

#include <ncbi_pch.hpp>
#include "ncbi_ansi_ext.h"
#include "ncbi_conn_streambuf.hpp"
#include "ncbi_priv.h"
#include "ncbi_servicep.h"
#include "ncbi_socketp.h"
#include <connect/error_codes.hpp>
#include <connect/ncbi_conn_exception.hpp>
#include <connect/ncbi_conn_stream.hpp>
#include <connect/ncbi_file_connector.h>
#include <stdlib.h>

Include dependency graph for ncbi_conn_stream.cpp:

Go to the source code of this file.

Go to the SVN repository for this file.

Classes
struct	Deleter< SConnNetInfo >
class	CConn_FileStream

Macros
#define	NCBI_USE_ERRCODE_X   Connect_Stream
#define	GET_CONN(sb)   ((sb) ? (sb)->GetCONN() : 0)

Typedefs
typedef AutoPtr< char, CDeleter< char > >	TTempCharPtr

Functions
static CConn_IOStream::TConnector	s_SocketConnectorBuilder (const string &ahost, unsigned short aport, unsigned short max_try, const void *data, size_t size, TSOCK_Flags flgs)
static SOCK	s_GrabSOCK (CSocket &socket)
static CConn_IOStream::TConnector	s_SocketConnectorBuilder (const SConnNetInfo *net_info, const STimeout *timeout, const void *data, size_t size, TSOCK_Flags flgs)
static CConn_IOStream::TConnector	s_HttpConnectorBuilder (const SConnNetInfo *net_info, EReqMethod method, const char *url, const char *host, unsigned short port, const char *path, const char *args, const char *user_header, void *x_data, FHTTP_Adjust x_adjust, FHTTP_Cleanup x_cleanup, FHTTP_ParseHeader x_parse_header, THTTP_Flags flgs, const STimeout *timeout, void **user_data_ptr, FHTTP_Cleanup *user_cleanup_ptr, void *user_data=0, FHTTP_Cleanup user_cleanup=0)
static CConn_IOStream::TConnector	s_ServiceConnectorBuilder (const char *service, TSERV_Type types, const SConnNetInfo *net_info, const char *user_header, const SSERVICE_Extra *extra, void *x_data, SSERVICE_Extra *x_extra, FSERVICE_Reset x_reset, FHTTP_Adjust x_adjust, FSERVICE_Cleanup x_cleanup, FHTTP_ParseHeader x_parse_header, FSERVICE_GetNextInfo x_get_next_info, const STimeout *timeout)
static CConn_IOStream::TConnector	s_PipeConnectorBuilder (const string &cmd, const vector< string > &args, CPipe::TCreateFlags flgs, size_t pipe_size, CPipe *&pipe)
static CConn_IOStream::TConnector	s_FtpConnectorBuilder (const char *host, unsigned short port, const char *user, const char *pass, const char *path, const SConnNetInfo *net_info, TFTP_Flags flgs, const SFTP_Callback *cmcb, void *x_data, SFTP_Callback *x_cmcb, FFTP_Callback x_func, const STimeout *timeout)
static bool	x_IsIdentifier (const string &str)
CConn_IOStream *	NcbiOpenURL (const string &url, size_t buf_size)
	Given a URL, open the data source and make it available for _reading_. More...

Macro Definition Documentation

GET_CONN

#define GET_CONN

(

sb

)

((sb) ? (sb)->GetCONN() : 0)

Definition at line 93 of file ncbi_conn_stream.cpp.

NCBI_USE_ERRCODE_X

#define NCBI_USE_ERRCODE_X   Connect_Stream

Definition at line 47 of file ncbi_conn_stream.cpp.

Typedef Documentation

TTempCharPtr

typedef AutoPtr< char, CDeleter<char> > TTempCharPtr

Definition at line 56 of file ncbi_conn_stream.cpp.

Function Documentation

s_FtpConnectorBuilder()

static CConn_IOStream::TConnector s_FtpConnectorBuilder ( const char *  host, unsigned short  port, const char *  user, const char *  pass, const char *  path, const SConnNetInfo *  net_info, TFTP_Flags  flgs, const SFTP_Callback *  cmcb, void *  x_data, SFTP_Callback *  x_cmcb, FFTP_Callback  x_func, const STimeout *  timeout  )

static

Definition at line 1214 of file ncbi_conn_stream.cpp.

References ConnNetInfo_Clone(), ConnNetInfo_Destroy(), SFTP_Callback::data, eUnknown, FTP_CreateConnector(), FTP_CreateConnectorSimple(), SFTP_Callback::func, kDefaultTimeout, NCBI_THROW, and SConnNetInfo::timeout.

s_GrabSOCK()

static SOCK s_GrabSOCK ( CSocket &  socket )

static

Definition at line 338 of file ncbi_conn_stream.cpp.

References eCopyTimeoutsFromSOCK, eNoOwnership, CSocket::GetSOCK(), NCBI_THROW, CSocket::Reset(), and CSocket::SetOwnership().

s_HttpConnectorBuilder()

static CConn_IOStream::TConnector s_HttpConnectorBuilder ( const SConnNetInfo *  net_info, EReqMethod  method, const char *  url, const char *  host, unsigned short  port, const char *  path, const char *  args, const char *  user_header, void *  x_data, FHTTP_Adjust  x_adjust, FHTTP_Cleanup  x_cleanup, FHTTP_ParseHeader  x_parse_header, THTTP_Flags  flgs, const STimeout *  timeout, void **  user_data_ptr, FHTTP_Cleanup *  user_cleanup_ptr, void *  user_data = 0, FHTTP_Cleanup  user_cleanup = 0  )

static

Definition at line 527 of file ncbi_conn_stream.cpp.

References ConnNetInfo_Clone(), ConnNetInfo_CreateInternal(), ConnNetInfo_OverrideUserHeader(), ConnNetInfo_ParseURL(), ConnNetInfo_SetArgs(), ConnNetInfo_SetPath(), eNoOwnership, eReqMethod_Connect, eReqMethod_v1, eTakeOwnership, eUnknown, AutoPtr< X, Del >::get(), HTTP_CreateConnectorEx(), kDefaultTimeout, len, NCBI_THROW, and NcbiMessagePlusError().

s_PipeConnectorBuilder()

static CConn_IOStream::TConnector s_PipeConnectorBuilder ( const string &  cmd, const vector< string > &  args, CPipe::TCreateFlags  flgs, size_t  pipe_size, CPipe *&  pipe  )

static

Definition at line 1153 of file ncbi_conn_stream.cpp.

References cmd, eNoOwnership, and PIPE_CreateConnector().

s_ServiceConnectorBuilder()

static CConn_IOStream::TConnector s_ServiceConnectorBuilder ( const char *  service, TSERV_Type  types, const SConnNetInfo *  net_info, const char *  user_header, const SSERVICE_Extra *  extra, void *  x_data, SSERVICE_Extra *  x_extra, FSERVICE_Reset  x_reset, FHTTP_Adjust  x_adjust, FSERVICE_Cleanup  x_cleanup, FHTTP_ParseHeader  x_parse_header, FSERVICE_GetNextInfo  x_get_next_info, const STimeout *  timeout  )

static

Definition at line 848 of file ncbi_conn_stream.cpp.

References _ASSERT, SSERVICE_Extra::adjust, SSERVICE_Extra::cleanup, ConnNetInfo_Clone(), ConnNetInfo_Create(), ConnNetInfo_OverrideUserHeader(), SSERVICE_Extra::data, eNoOwnership, eTakeOwnership, eUnknown, SSERVICE_Extra::flags, AutoPtr< X, Del >::get(), SSERVICE_Extra::get_next_info, kDefaultTimeout, NCBI_THROW, NcbiMessagePlusError(), SSERVICE_Extra::parse_header, SSERVICE_Extra::reset, SERVICE_CreateConnectorEx(), and types.

s_SocketConnectorBuilder() [1/2]

static CConn_IOStream::TConnector s_SocketConnectorBuilder ( const SConnNetInfo *  net_info, const STimeout *  timeout, const void *  data, size_t  size, TSOCK_Flags  flgs  )

static

Definition at line 379 of file ncbi_conn_stream.cpp.

References _ASSERT, ConnNetInfo_Clone(), ConnNetInfo_Log(), ConnNetInfo_SetUserHeader(), CORE_GetLOG(), CORE_LOCK_READ, CORE_UNLOCK, SConnNetInfo::credentials, data, SConnNetInfo::debug_printout, eDebugPrintout_Data, eIO_Success, eLOG_Note, eReqMethod_Any, eURL_Unspec, fHTTP_NoAutoRetry, fProxy_Http, free(), fSOCK_LogDefault, fSOCK_LogOn, AutoPtr< X, Del >::get(), SConnNetInfo::host, HTTP_CreateTunnel(), SConnNetInfo::http_proxy_host, SConnNetInfo::http_proxy_leak, SConnNetInfo::http_proxy_mask, SConnNetInfo::http_proxy_port, init(), kDefaultTimeout, SConnNetInfo::port, ncbi::grid::netcache::search::fields::size, SOCK_Abort(), SOCK_Close(), SOCK_CreateConnectorOnTopEx(), SOCK_CreateInternal(), SOCK_CreateOnTopInternal(), SOCK_Destroy, SConnNetInfo::timeout, and NStr::UIntToString().

s_SocketConnectorBuilder() [2/2]

static CConn_IOStream::TConnector s_SocketConnectorBuilder ( const string &  ahost, unsigned short  aport, unsigned short  max_try, const void *  data, size_t  size, TSOCK_Flags  flgs  )

static

Definition at line 271 of file ncbi_conn_stream.cpp.

References data, NStr::fConvErr_NoThrow, isdigit(), len, NCBI_HasSpaces(), NCBI_THROW, NStr::NumericToString(), ncbi::grid::netcache::search::fields::size, SOCK_CreateConnectorEx(), NStr::SplitInTwo(), and NStr::StringToUInt().

x_IsIdentifier()

static bool x_IsIdentifier ( const string &  str )

static

Definition at line 1505 of file ncbi_conn_stream.cpp.

References isalnum(), isalpha(), and str().

Referenced by NcbiOpenURL().