Collaboration diagram for Connectors:
|
Classes | |
| struct | SCONN_Callback |
| struct | SMetaConnector |
| struct | SConnectorTag |
| struct | SFileConnAttr |
| struct | SSERVICE_Extra |
Defines | |
| #define | CONN_N_CALLBACKS 1 |
| #define | CONN_TWO2ONE(a, b) a##b |
| #define | CONN_SET_METHOD(meta, method, function, connector) |
| #define | CONN_SET_DEFAULT_TIMEOUT(meta, timeout) |
| #define | SERVICE_CreateConnector(service) SERVICE_CreateConnectorEx(service, fSERV_Any, 0, 0) |
Typedefs | |
| typedef SConnectionTag * | CONN |
| typedef void(* | FConnCallback )(CONN conn, ECONN_Callback type, void *data) |
| typedef SConnectorTag * | CONNECTOR |
| typedef const char *(* | FConnectorGetType )(CONNECTOR connector) |
| typedef char *(* | FConnectorDescr )(CONNECTOR connector) |
| typedef EIO_Status(* | FConnectorOpen )(CONNECTOR connector, const STimeout *timeout) |
| typedef EIO_Status(* | FConnectorWait )(CONNECTOR connector, EIO_Event event, const STimeout *timeout) |
| typedef EIO_Status(* | FConnectorWrite )(CONNECTOR connector, const void *buf, size_t size, size_t *n_written, const STimeout *timeout) |
| typedef EIO_Status(* | FConnectorFlush )(CONNECTOR connector, const STimeout *timeout) |
| typedef EIO_Status(* | FConnectorRead )(CONNECTOR connector, void *buf, size_t size, size_t *n_read, const STimeout *timeout) |
| typedef EIO_Status(* | FConnectorStatus )(CONNECTOR connector, EIO_Event direction) |
| typedef EIO_Status(* | FConnectorClose )(CONNECTOR connector, const STimeout *timeout) |
| typedef void(* | FSetupVTable )(SMetaConnector *meta, CONNECTOR connector) |
| typedef void(* | FDestroy )(CONNECTOR connector) |
| typedef SConnectorTag | SConnector |
| typedef unsigned int | TFCDC_Flags |
| typedef unsigned int | THCC_Flags |
| typedef int(* | FHttpParseHTTPHeader )(const char *http_header, void *adjust_data, int server_error) |
| typedef int(* | FHttpAdjustNetInfo )(SConnNetInfo *net_info, void *adjust_data, unsigned int failure_count) |
| typedef void(* | FHttpAdjustCleanup )(void *adjust_data) |
| typedef void(* | FHTTP_NcbiMessageHook )(const char *message) |
| typedef const SSERV_Info *(* | FSERVICE_GetNextInfo )(SERV_ITER iter, void *data) |
| typedef void(* | FSERVICE_CleanupData )(void *data) |
| typedef void(* | FSERVICE_ResetData )(void *data) |
Enumerations | |
| enum | ECONN_Callback { eCONN_OnClose = 0 } |
| enum | EFileConnMode { eFCM_Truncate, eFCM_Seek, eFCM_Append } |
| enum | EFCDC_Flags { fFCDC_LogControl = 1, fFCDC_LogData = 2, fFCDC_LogAll = fFCDC_LogControl | fFCDC_LogData } |
| enum | EFCDC_OldFlags { eFCDC_LogControl = fFCDC_LogControl, eFCDC_LogData = fFCDC_LogData, eFCDC_LogAll = fFCDC_LogAll } |
| enum | EHCC_Flags { fHCC_AutoReconnect = 0x1, fHCC_SureFlush = 0x2, fHCC_KeepHeader = 0x4, fHCC_UrlDecodeInput = 0x8, fHCC_UrlEncodeOutput = 0x10, fHCC_UrlCodec = 0x18, fHCC_UrlEncodeArgs = 0x20, fHCC_DropUnread = 0x40, fHCC_NoUpread = 0x80, fHCC_Flushable = 0x100, fHCC_InsecureRedirect = 0x200, fHCC_NoAutoRetry = 0x400 } |
| enum | ESCC_Flags { fSCC_DebugPrintout = fSOCK_LogOn, fSCC_Secure = fSOCK_Secure, fSCC_SetReadOnWrite = fSOCK_ReadOnWrite } |
Functions | |
| EIO_Status | CONN_Create (CONNECTOR connector, CONN *conn) |
| EIO_Status | CONN_ReInit (CONN conn, CONNECTOR connector) |
| const char * | CONN_GetType (CONN conn) |
| char * | CONN_Description (CONN conn) |
| EIO_Status | CONN_SetTimeout (CONN conn, EIO_Event event, const STimeout *new_timeout) |
| const STimeout * | CONN_GetTimeout (CONN conn, EIO_Event event) |
| EIO_Status | CONN_Wait (CONN conn, EIO_Event event, const STimeout *timeout) |
| EIO_Status | CONN_Write (CONN conn, const void *buf, size_t size, size_t *n_written, EIO_WriteMethod how) |
| EIO_Status | CONN_PushBack (CONN conn, const void *buf, size_t size) |
| EIO_Status | CONN_Flush (CONN conn) |
| EIO_Status | CONN_Read (CONN conn, void *buf, size_t size, size_t *n_read, EIO_ReadMethod how) |
| EIO_Status | CONN_ReadLine (CONN conn, char *line, size_t size, size_t *n_read) |
| EIO_Status | CONN_Status (CONN conn, EIO_Event dir) |
| EIO_Status | CONN_Close (CONN conn) |
| EIO_Status | CONN_SetCallback (CONN conn, ECONN_Callback type, const SCONN_Callback *new_cb, SCONN_Callback *old_cb) |
| EIO_Status | METACONN_Add (SMetaConnector *meta, CONNECTOR connector) |
| EIO_Status | METACONN_Remove (SMetaConnector *meta, CONNECTOR connector) |
| CONNECTOR | FILE_CreateConnector (const char *in_file_name, const char *out_file_name) |
| CONNECTOR | FILE_CreateConnectorEx (const char *in_file_name, const char *out_file_name, const SFileConnAttr *attr) |
| CONNECTOR | FTP_CreateDownloadConnector (const char *host, unsigned short port, const char *user, const char *pass, const char *path, TFCDC_Flags flag) |
| CONNECTOR | HTTP_CreateConnector (const SConnNetInfo *net_info, const char *user_header, THCC_Flags flags) |
| CONNECTOR | HTTP_CreateConnectorEx (const SConnNetInfo *net_info, THCC_Flags flags, FHttpParseHTTPHeader parse_http_hdr, FHttpAdjustNetInfo adjust_net_info, void *adjust_data, FHttpAdjustCleanup adjust_cleanup) |
| void | HTTP_SetNcbiMessageHook (FHTTP_NcbiMessageHook) |
| CONNECTOR | MEMORY_CreateConnector (void) |
| CONNECTOR | MEMORY_CreateConnectorEx (BUF buf) |
| CONNECTOR | NAMEDPIPE_CreateConnector (const string &pipename, size_t pipebufsize=0) |
| Create CNamedPipe-based CONNECTOR. | |
| CONNECTOR | PIPE_CreateConnector (const string &cmd, const vector< string > &args, CPipe::TCreateFlags create_flags=0, CPipe *pipe=0) |
| Create CPipe-based CONNECTOR. | |
| CONNECTOR | SERVICE_CreateConnectorEx (const char *service, TSERV_Type types, const SConnNetInfo *net_info, const SSERVICE_Extra *params) |
| CONNECTOR | SOCK_CreateConnector (const char *host, unsigned short port, unsigned int max_try) |
| CONNECTOR | SOCK_CreateConnectorEx (const char *host, unsigned short port, unsigned int max_try, const void *init_data, size_t init_size, TSOCK_Flags flags) |
| CONNECTOR | SOCK_CreateConnectorOnTop (SOCK sock, unsigned int max_try) |
| CONNECTOR | SOCK_CreateConnectorOnTopEx (SOCK sock, unsigned int max_try, TSOCK_Flags flags) |
|
|
Definition at line 272 of file ncbi_connection.h. Referenced by CONN_SetCallback(). |
|
|
Value: do { \ if (timeout) { \ meta->default_timeout = &meta->default_tmo; \ meta->default_tmo = *timeout; \ } else \ meta->default_timeout = 0; \ } while (0); Definition at line 202 of file ncbi_connector.h. Referenced by s_Setup(). |
|
|
Value: do { \ meta->method = function; \ meta->CONN_TWO2ONE(c_,method) = connector; \ } while (0); Definition at line 195 of file ncbi_connector.h. Referenced by s_Reset(), s_Setup(), and s_VT_Open(). |
|
|
Definition at line 193 of file ncbi_connector.h. |
|
|
Definition at line 75 of file ncbi_service_connector.h. |
|
|
Definition at line 63 of file ncbi_connection.h. |
|
|
Definition at line 54 of file ncbi_connector.h. |
|
|
Definition at line 274 of file ncbi_connection.h. |
|
|
Definition at line 166 of file ncbi_connector.h. |
|
|
Definition at line 80 of file ncbi_connector.h. |
|
|
Definition at line 127 of file ncbi_connector.h. |
|
|
Definition at line 73 of file ncbi_connector.h. |
|
|
Definition at line 88 of file ncbi_connector.h. |
|
|
Definition at line 140 of file ncbi_connector.h. |
|
|
Definition at line 155 of file ncbi_connector.h. |
|
|
Definition at line 100 of file ncbi_connector.h. |
|
|
Definition at line 114 of file ncbi_connector.h. |
|
|
Definition at line 243 of file ncbi_connector.h. |
|
|
Definition at line 220 of file ncbi_http_connector.h. |
|
|
Definition at line 201 of file ncbi_http_connector.h. |
|
|
Definition at line 195 of file ncbi_http_connector.h. |
|
|
Definition at line 189 of file ncbi_http_connector.h. |
|
|
Definition at line 55 of file ncbi_service_connector.h. |
|
|
Definition at line 54 of file ncbi_service_connector.h. |
|
|
Definition at line 56 of file ncbi_service_connector.h. |
|
|
Definition at line 233 of file ncbi_connector.h. |
|
|
|
|
|
Definition at line 59 of file ncbi_ftp_connector.h. |
|
|
Definition at line 166 of file ncbi_http_connector.h. |
|
|
Definition at line 269 of file ncbi_connection.h. |
|
|
Definition at line 54 of file ncbi_ftp_connector.h. |
|
|
Definition at line 61 of file ncbi_ftp_connector.h. |
|
|
Definition at line 64 of file ncbi_file_connector.h. |
|
|
Definition at line 152 of file ncbi_http_connector.h. |
|
|
Definition at line 64 of file ncbi_socket_connector.h. |
|
|
Definition at line 827 of file ncbi_connection.c. References BUF_Destroy(), SConnectionTag::cbs, CONN_NOT_NULL, CONN_ReInit(), SCONN_Callback::data, eCONN_OnClose, eCONN_Unusable, eIO_Success, free(), SCONN_Callback::func, and SConnectionTag::state. Referenced by s_Open(), s_Resolve(), and CConn_Streambuf::x_Cleanup(). |
|
||||||||||||
|
Definition at line 133 of file ncbi_connection.c. References SConnectionTag::c_timeout, calloc(), CONN_ReInit(), eCONN_Unusable, eIO_Success, eIO_Unknown, free(), kDefaultTimeout, SConnectionTag::o_timeout, SConnectionTag::r_timeout, SConnectionTag::state, and SConnectionTag::w_timeout. Referenced by CConn_Streambuf::CConn_Streambuf(), CreateAsnConn_ServiceEx(), s_Open(), and s_Resolve(). |
|
|
Definition at line 280 of file ncbi_connection.c. References SMetaConnector::c_descr, CONN_NOT_NULL_EX, SMetaConnector::descr, eCONN_Unusable, SMetaConnector::list, SConnectionTag::meta, and SConnectionTag::state. Referenced by CReaderServiceConnector::GetConnDescription(), and CId2FetchApp::x_InitConnection(). |
|
|
Definition at line 558 of file ncbi_connection.c. References SMetaConnector::c_flush, CONN_LOG, CONN_NOT_NULL, SMetaConnector::default_timeout, eCONN_Open, eCONN_Unusable, eIO_InvalidArg, eIO_Success, eLOG_Warning, SMetaConnector::flush, kDefaultTimeout, SMetaConnector::list, SConnectionTag::meta, s_Open(), SConnectionTag::state, and SConnectionTag::w_timeout. Referenced by CConn_Streambuf::overflow(), s_Open(), and s_Resolve(). |
|
||||||||||||
|
Definition at line 345 of file ncbi_connection.c. References SConnectionTag::c_timeout, CONN_LOG_EX, CONN_NOT_NULL_EX, eIO_Close, eIO_Open, eIO_Read, eIO_ReadWrite, eIO_Write, eLOG_Error, eLOG_Warning, SConnectionTag::o_timeout, SConnectionTag::r_timeout, and SConnectionTag::w_timeout. Referenced by CRPCClient< TRequest, TReply >::GetTimeout(), and CConn_Streambuf::showmanyc(). |
|
|
Definition at line 271 of file ncbi_connection.c. References SMetaConnector::c_get_type, CONN_NOT_NULL_EX, eCONN_Unusable, SMetaConnector::get_type, SMetaConnector::list, SConnectionTag::meta, and SConnectionTag::state. |
|
||||||||||||||||
|
Definition at line 544 of file ncbi_connection.c. References SConnectionTag::buf, BUF_PushBack(), CONN_NOT_NULL, eCONN_Open, eIO_Closed, eIO_Success, eIO_Unknown, and SConnectionTag::state. Referenced by s_CONN_IO(). |
|
||||||||||||||||||||||||
|
||||||||||||||||||||
|
Definition at line 737 of file ncbi_connection.c. References SConnectionTag::buf, BUF_Size(), SMetaConnector::c_flush, CONN_NOT_NULL, SMetaConnector::default_timeout, eCONN_Open, eIO_InvalidArg, eIO_Success, SMetaConnector::flush, kDefaultTimeout, len, SMetaConnector::list, SConnectionTag::meta, SConnectionTag::r_timeout, ReadLine(), s_CONN_Read(), s_Open(), and SConnectionTag::state. |
|
||||||||||||
|
Definition at line 157 of file ncbi_connection.c. References SConnectionTag::buf, BUF_Read(), BUF_Size(), SMetaConnector::c_close, SMetaConnector::c_flush, SConnectionTag::c_timeout, SMetaConnector::close, CONN_LOG, CONN_NOT_NULL, SMetaConnector::default_timeout, eCONN_Closed, eCONN_Open, eCONN_Unusable, eIO_InvalidArg, eIO_ReadWrite, eIO_Success, eIO_Unknown, eLOG_Error, eLOG_Warning, SMetaConnector::flush, kDefaultTimeout, SMetaConnector::list, SConnectionTag::meta, METACONN_Add(), METACONN_Remove(), SConnectorTag::next, SConnectionTag::state, and verify. Referenced by CONN_Close(), and CONN_Create(). |
|
||||||||||||||||||||
|
Definition at line 854 of file ncbi_connection.c. References SConnectionTag::cbs, CONN_N_CALLBACKS, CONN_NOT_NULL, eIO_InvalidArg, and eIO_Success. Referenced by CConn_Streambuf::CConn_Streambuf(), s_CloseAsnConn(), and s_SetAsnConn_CloseCb(). |
|
||||||||||||||||
|
||||||||||||
|
Definition at line 807 of file ncbi_connection.c. References SMetaConnector::c_status, CONN_NOT_NULL, eCONN_Closed, eCONN_Unusable, eIO_Closed, eIO_InvalidArg, eIO_NotSupported, eIO_Read, eIO_Unknown, eIO_Write, SMetaConnector::list, SConnectionTag::meta, SConnectionTag::state, and SMetaConnector::status. |
|
||||||||||||||||
|
Definition at line 383 of file ncbi_connection.c. References SConnectionTag::buf, BUF_Size(), SMetaConnector::c_wait, CONN_LOG, CONN_NOT_NULL, eCONN_Open, eCONN_Unusable, eIO_Closed, eIO_Interrupt, eIO_InvalidArg, eIO_NotSupported, eIO_Read, eIO_Success, eIO_Timeout, eIO_Write, eLOG_Error, eLOG_Trace, eLOG_Warning, kDefaultTimeout, SMetaConnector::list, SConnectionTag::meta, s_Open(), STimeoutTag::sec, SConnectionTag::state, STimeoutTag::usec, and SMetaConnector::wait. Referenced by CReaderServiceConnector::Connect(), CConn_Streambuf::showmanyc(), and CId2FetchApp::x_InitConnection(). |
|
||||||||||||||||||||||||
|
Definition at line 507 of file ncbi_connection.c. References CONN_NOT_NULL, eCONN_Open, eCONN_Unusable, eIO_InvalidArg, eIO_Success, eIO_Unknown, eIO_WritePersist, eIO_WritePlain, SMetaConnector::list, SConnectionTag::meta, s_CONN_Write(), s_CONN_WritePersist(), s_Open(), SConnectionTag::state, and Write(). Referenced by CConn_Streambuf::overflow(), and s_AsnWrite(). |
|
||||||||||||
|
Definition at line 288 of file ncbi_file_connector.c. References eFCM_Truncate, and FILE_CreateConnectorEx(). |
|
||||||||||||||||
|
Definition at line 298 of file ncbi_file_connector.c. References SConnectorTag::destroy, SConnectorTag::handle, malloc(), SConnectorTag::meta, SConnectorTag::next, s_Destroy(), s_Setup(), SConnectorTag::setup, and strdup. Referenced by FILE_CreateConnector(). |
|
||||||||||||||||||||||||||||
|
Definition at line 724 of file ncbi_ftp_connector.c. References SConnectorTag::destroy, eIO_Success, fFCDC_LogAll, SConnectorTag::handle, malloc(), SConnectorTag::meta, SConnectorTag::next, s_Destroy(), s_Setup(), SConnectorTag::setup, and strdup. |
|
||||||||||||||||
|
Definition at line 1296 of file ncbi_http_connector.c. References s_CreateConnector(). |
|
||||||||||||||||||||||||||||
|
Definition at line 1305 of file ncbi_http_connector.c. References s_CreateConnector(). Referenced by s_HttpConnectorBuilder(), s_Open(), and s_Resolve(). |
|
|
Definition at line 1317 of file ncbi_http_connector.c. References s_MessageHook, and s_MessageIssued. |
|
|
Definition at line 234 of file ncbi_memory_connector.c. References MEMORY_CreateConnectorEx(). |
|
|
Definition at line 240 of file ncbi_memory_connector.c. References buf, SConnectorTag::destroy, SConnectorTag::handle, malloc(), SConnectorTag::meta, SConnectorTag::next, s_Destroy(), s_Setup(), and SConnectorTag::setup. Referenced by MEMORY_CreateConnector(). |
|
||||||||||||
|
Definition at line 85 of file ncbi_connector.c. References eIO_Success, eIO_Unknown, eLOG_Error, SMetaConnector::list, SConnectorTag::meta, METACONN_LOG, SConnectorTag::next, and SConnectorTag::setup. Referenced by CONN_ReInit(), and s_VT_Open(). |
|
||||||||||||
|
Definition at line 50 of file ncbi_connector.c. References SConnectorTag::destroy, eIO_Success, eIO_Unknown, eLOG_Error, SMetaConnector::list, SConnectorTag::meta, METACONN_LOG, and SConnectorTag::next. Referenced by CONN_ReInit(), and s_Close(). |
|
||||||||||||
|
Create CNamedPipe-based CONNECTOR. Create new CONNECTOR structure to handle a data transfer between two process over nemed pipe. Return NULL on error. Definition at line 242 of file ncbi_namedpipe_connector.cpp. References SConnectorTag::destroy, SConnectorTag::handle, SNamedPipeConnector::is_open, malloc(), SConnectorTag::meta, SConnectorTag::next, SNamedPipeConnector::pipe, SNamedPipeConnector::pipebufsize, SNamedPipeConnector::pipename, s_Destroy(), s_Setup(), and SConnectorTag::setup. |
|
||||||||||||||||||||
|
Create CPipe-based CONNECTOR. Create new CONNECTOR structure to handle data transfer between two processes over interprocess pipe. Return NULL on error. Definition at line 250 of file ncbi_pipe_connector.cpp. References SPipeConnector::args, SPipeConnector::cmd, SConnectorTag::destroy, SPipeConnector::flags, SConnectorTag::handle, SPipeConnector::is_open, SPipeConnector::is_own_pipe, malloc(), SConnectorTag::meta, SConnectorTag::next, SPipeConnector::pipe, s_Destroy(), s_Setup(), and SConnectorTag::setup. |
|
||||||||||||||||||||
|
Definition at line 849 of file ncbi_service_connector.c. References calloc(), ConnNetInfo_Clone(), ConnNetInfo_Create(), ConnNetInfo_SetupStandardArgs(), SConnectorTag::destroy, free(), fSERV_Firewall, fSERV_Stateless, SConnectorTag::handle, malloc(), SConnectorTag::meta, SConnectorTag::next, s_Destroy(), s_OpenDispatcher(), s_Setup(), SERV_ServiceName(), and SConnectorTag::setup. Referenced by CreateAsnConn_ServiceEx(), and s_ServiceConnectorBuilder(). |
|
||||||||||||||||
|
Definition at line 328 of file ncbi_socket_connector.c. References fSOCK_LogDefault, and s_Init(). |
|
||||||||||||||||||||||||||||
|
Definition at line 337 of file ncbi_socket_connector.c. References s_Init(). Referenced by s_Open(). |
|
||||||||||||
|
Definition at line 349 of file ncbi_socket_connector.c. References fSOCK_LogDefault, and s_Init(). |
|
||||||||||||||||
|
Definition at line 357 of file ncbi_socket_connector.c. References s_Init(). |
1.4.6
Modified on Wed Dec 09 08:20:18 2009 by modify_doxy.py rev. 173732