📄 sockio_8h-source.html
字号:
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"><html><head><meta http-equiv="Content-Type" content="text/html;charset=iso-8859-1"><title>FastDB: sockio.h Source File</title><link href="doxygen.css" rel="stylesheet" type="text/css"></head><body><!-- Generated by Doxygen 1.3.5 --><div class="qindex"><a class="qindex" href="index.html">Main Page</a> | <a class="qindex" href="hierarchy.html">Class Hierarchy</a> | <a class="qindex" href="annotated.html">Class List</a> | <a class="qindex" href="files.html">File List</a> | <a class="qindex" href="functions.html">Class Members</a></div><h1>sockio.h</h1><div class="fragment"><pre>00001 <span class="comment">//-< SOCKIO.H >------------------------------------------------------*--------*</span>00002 <span class="comment">// FastDB Version 1.0 (c) 1999 GARRET * ? *</span>00003 <span class="comment">// (Main Memory Database Management System) * /\| *</span>00004 <span class="comment">// * / \ *</span>00005 <span class="comment">// Created: 7-Jan-97 K.A. Knizhnik * / [] \ *</span>00006 <span class="comment">// Last update: 23-Apr-97 K.A. Knizhnik * GARRET *</span>00007 <span class="comment">//-------------------------------------------------------------------*--------*</span>00008 <span class="comment">// Socket abstraction</span>00009 <span class="comment">//-------------------------------------------------------------------*--------*</span>00010 00011 <span class="preprocessor">#ifndef __SOCKIO_H__</span>00012 <span class="preprocessor"></span><span class="preprocessor">#define __SOCKIO_H__</span>00013 <span class="preprocessor"></span>00014 <span class="preprocessor">#include "stdtp.h"</span>00015 <span class="preprocessor">#include <time.h></span>00016 00017 <span class="preprocessor">#define DEFAULT_CONNECT_MAX_ATTEMPTS 100</span>00018 <span class="preprocessor"></span><span class="preprocessor">#define DEFAULT_RECONNECT_TIMEOUT 1</span>00019 <span class="preprocessor"></span><span class="preprocessor">#define DEFAULT_LISTEN_QUEUE_SIZE 5</span>00020 <span class="preprocessor"></span><span class="preprocessor">#define LINGER_TIME 10</span>00021 <span class="preprocessor"></span><span class="preprocessor">#define WAIT_FOREVER ((time_t)-1)</span>00022 <span class="preprocessor"></span>00023 00024 <span class="preprocessor">#ifndef REPLICATION_SUPPORT</span>00025 <span class="preprocessor"></span><span class="preprocessor">#define SOCK_NO_DELAY 1</span>00026 <span class="preprocessor"></span><span class="preprocessor">#define SOCK_SNDBUF_SIZE 1024*1024</span>00027 <span class="preprocessor"></span><span class="preprocessor">#else</span>00028 <span class="preprocessor"></span><span class="preprocessor">#define SOCK_NO_DELAY 0</span>00029 <span class="preprocessor"></span><span class="preprocessor">#define SOCK_SNDBUF_SIZE 0</span>00030 <span class="preprocessor"></span><span class="preprocessor">#endif</span>00031 <span class="preprocessor"></span>00032 00033 00034 <span class="comment">//</span>00035 <span class="comment">// Abstract socket interface</span>00036 <span class="comment">//</span>00037 <span class="keyword">class </span>FASTDB_DLL_ENTRY socket_t { 00038 <span class="keyword">public</span>: 00039 <span class="keywordtype">bool</span> read(<span class="keywordtype">void</span>* buf, size_t size) { 00040 <span class="keywordflow">return</span> read(buf, size, size) == (<span class="keywordtype">int</span>)size;00041 }00042 <span class="keyword">virtual</span> <span class="keywordtype">int</span> read(<span class="keywordtype">void</span>* buf, size_t min_size, size_t max_size, 00043 time_t timeout = WAIT_FOREVER) = 0;00044 <span class="keyword">virtual</span> <span class="keywordtype">bool</span> write(<span class="keywordtype">void</span> <span class="keyword">const</span>* buf, size_t size) = 0;00045 00046 <span class="keyword">virtual</span> <span class="keywordtype">bool</span> is_ok() = 0; 00047 <span class="keyword">virtual</span> <span class="keywordtype">void</span> get_error_text(<span class="keywordtype">char</span>* buf, size_t buf_size) = 0;00048 00049 <span class="comment">//</span>00050 <span class="comment">// This method is called by server to accept client connection</span>00051 <span class="comment">//</span>00052 <span class="keyword">virtual</span> socket_t* accept() = 0;00053 00054 <span class="comment">//</span>00055 <span class="comment">// Cancel accept operation and close socket</span>00056 <span class="comment">//</span>00057 <span class="keyword">virtual</span> <span class="keywordtype">bool</span> cancel_accept() = 0;00058 00059 <span class="comment">//</span>00060 <span class="comment">// Shutdown socket: prohibite write and read operations on socket</span>00061 <span class="comment">//</span>00062 <span class="keyword">virtual</span> <span class="keywordtype">bool</span> shutdown() = 0;00063 00064 <span class="comment">//</span>00065 <span class="comment">// Close socket</span>00066 <span class="comment">//</span>00067 <span class="keyword">virtual</span> <span class="keywordtype">bool</span> close() = 0;00068 00069 <span class="comment">//</span>00070 <span class="comment">// Get socket peer name.</span>00071 <span class="comment">// name is created using new char[]. If perr name can not be obtained NULL</span>00072 <span class="comment">// is returned and errcode is set.</span>00073 <span class="comment">//</span>00074 <span class="keyword">virtual</span> <span class="keywordtype">char</span>* get_peer_name() = 0;00075 00076 <span class="comment">//</span>00077 <span class="comment">// Create client socket connected to local or global server socket</span>00078 <span class="comment">//</span>00079 <span class="keyword">enum</span> socket_domain { 00080 sock_any_domain, <span class="comment">// domain is chosen automatically</span>00081 sock_local_domain, <span class="comment">// local domain (i.e. Unix domain socket) </span>00082 sock_global_domain <span class="comment">// global domain (i.e. INET sockets) </span>00083 };00084 00085 <span class="keyword">static</span> socket_t* connect(<span class="keywordtype">char</span> <span class="keyword">const</span>* address, 00086 socket_domain domain = sock_any_domain, 00087 <span class="keywordtype">int</span> max_attempts = DEFAULT_CONNECT_MAX_ATTEMPTS,00088 time_t timeout = DEFAULT_RECONNECT_TIMEOUT);00089 00090 <span class="comment">//</span>00091 <span class="comment">// Create local domain socket</span>00092 <span class="comment">//</span>00093 <span class="keyword">static</span> socket_t* create_local(<span class="keywordtype">char</span> <span class="keyword">const</span>* address,00094 <span class="keywordtype">int</span> listen_queue_size = 00095 DEFAULT_LISTEN_QUEUE_SIZE);00096 00097 <span class="comment">//</span>00098 <span class="comment">// Create global domain socket </span>00099 <span class="comment">//</span>00100 <span class="keyword">static</span> socket_t* create_global(<span class="keywordtype">char</span> <span class="keyword">const</span>* address,00101 <span class="keywordtype">int</span> listen_queue_size = 00102 DEFAULT_LISTEN_QUEUE_SIZE);00103 00104 <span class="keyword">virtual</span> <span class="keywordtype">int</span> get_handle() = 0;00105 00106 <span class="keyword">virtual</span> ~socket_t() {} 00107 socket_t() { state = ss_close; }00108 00109 <span class="keyword">protected</span>:00110 <span class="keyword">enum</span> { ss_open, ss_shutdown, ss_close } state;00111 };00112 00113 <span class="preprocessor">#endif</span>00114 <span class="preprocessor"></span>00115 00116 </pre></div><hr size="1"><address style="align: right;"><small>Generated on Thu Feb 12 13:04:48 2004 for FastDB by<a href="http://www.doxygen.org/index.html"><img src="doxygen.png" alt="doxygen" align="middle" border=0 > </a>1.3.5 </small></address></body></html>⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -