server_8h-source.html
来自「一个功能强大的内存数据库源代码,c++编写,有详细的注释」· HTML 代码 · 共 184 行
HTML
184 行
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN"><html><head><meta http-equiv="Content-Type" content="text/html;charset=iso-8859-1"><title>server.h Source File</title><link href="doxygen.css" rel="stylesheet" type="text/css"></head><body><!-- Generated by Doxygen 1.2.15 --><center><a class="qindex" href="index.html">Main Page</a> <a class="qindex" href="hierarchy.html">Class Hierarchy</a> <a class="qindex" href="annotated.html">Compound List</a> <a class="qindex" href="files.html">File List</a> <a class="qindex" href="functions.html">Compound Members</a> </center><hr><h1>server.h</h1><div class="fragment"><pre>00001 <font class="comment">//-< SERVER.CPP >----------------------------------------------------*--------*</font>00002 <font class="comment">// FastDB Version 1.0 (c) 1999 GARRET * ? *</font>00003 <font class="comment">// (Main Memory Database Management System) * /\| *</font>00004 <font class="comment">// * / \ *</font>00005 <font class="comment">// Created: 13-Jan-2000 K.A. Knizhnik * / [] \ *</font>00006 <font class="comment">// Last update: 13-Jan-2000 K.A. Knizhnik * GARRET *</font>00007 <font class="comment">//-------------------------------------------------------------------*--------*</font>00008 <font class="comment">// CLI multithreaded server class</font>00009 <font class="comment">//-------------------------------------------------------------------*--------*</font>00010 00011 <font class="preprocessor">#ifndef __SERVER_H__</font>00012 <font class="preprocessor"></font><font class="preprocessor">#define __SERVER_H__</font>00013 <font class="preprocessor"></font>00014 <font class="preprocessor">#include "sockio.h"</font>00015 00016 <font class="keyword">class </font>dbColumnBinding { 00017 <font class="keyword">public</font>:00018 dbColumnBinding* next;00019 <a class="code" href="classdbFieldDescriptor.html">dbFieldDescriptor</a>* fd;00020 <font class="keywordtype">int</font> cliType;00021 <font class="keywordtype">int</font> len;00022 <font class="keywordtype">char</font>* ptr;00023 00024 <font class="keywordtype">int</font> unpackArray(<font class="keywordtype">char</font>* dst, size_t offs);00025 <font class="keywordtype">void</font> unpackScalar(<font class="keywordtype">char</font>* dst);00026 00027 dbColumnBinding(<a class="code" href="classdbFieldDescriptor.html">dbFieldDescriptor</a>* field, <font class="keywordtype">int</font> type) { 00028 fd = field;00029 cliType = type;00030 next = NULL;00031 }00032 };00033 00034 <font class="keyword">struct </font>dbParameterBinding { 00035 <font class="keyword">union </font>{ 00036 int1 i1;00037 int2 i2;00038 int4 i4;00039 db_int8 i8;00040 real4 r4;00041 real8 r8;00042 oid_t oid;00043 <font class="keywordtype">bool</font> b;00044 <font class="keywordtype">char</font>* str;00045 } u;00046 <font class="keywordtype">int</font> type;00047 };00048 00049 <font class="keyword">const</font> <font class="keywordtype">int</font> dbQueryMaxIdLength = 256;00050 00051 <font class="keyword">class </font>dbQueryScanner { 00052 <font class="keyword">public</font>:00053 <font class="keywordtype">char</font>* p;00054 db_int8 ival;00055 real8 fval;00056 <font class="keywordtype">char</font> buf[dbQueryMaxIdLength];00057 <font class="keywordtype">char</font>* ident;00058 00059 <font class="keywordtype">int</font> get();00060 00061 <font class="keywordtype">void</font> reset(<font class="keywordtype">char</font>* stmt) { 00062 p = stmt;00063 }00064 };00065 00066 <font class="keyword">class </font>dbStatement { 00067 <font class="keyword">public</font>:00068 <font class="keywordtype">int</font> id;00069 <font class="keywordtype">bool</font> firstFetch;00070 dbStatement* next;00071 <a class="code" href="classdbAnyCursor.html">dbAnyCursor</a>* cursor; 00072 <a class="code" href="classdbQuery.html">dbQuery</a> query;00073 dbColumnBinding* columns;00074 <font class="keywordtype">char</font>* buf;00075 <font class="keywordtype">int</font> buf_size;00076 <font class="keywordtype">int</font> n_params;00077 <font class="keywordtype">int</font> n_columns;00078 dbParameterBinding* params;00079 <a class="code" href="classdbTableDescriptor.html">dbTableDescriptor</a>* table;00080 00081 <font class="keywordtype">void</font> reset();00082 00083 dbStatement(<font class="keywordtype">int</font> stmt_id) { 00084 id = stmt_id;00085 columns = NULL;00086 params = NULL;00087 buf = NULL;00088 buf_size = 0;00089 table = NULL;00090 cursor = NULL;00091 }00092 ~dbStatement() { 00093 reset(); 00094 <font class="keyword">delete</font>[] buf;00095 }00096 };00097 00098 <font class="keyword">class </font>dbSession { 00099 <font class="keyword">public</font>:00100 dbSession* next; 00101 dbStatement* stmts;00102 dbQueryScanner scanner;00103 socket_t* sock;00104 <font class="keywordtype">bool</font> in_transaction;00105 };00106 00107 <font class="keyword">class </font>dbServer { 00108 <font class="keyword">protected</font>:00109 <font class="keyword">static</font> dbServer* chain;00110 dbServer* next;00111 <font class="keywordtype">char</font>* URL;00112 dbSession* freeList;00113 dbSession* waitList;00114 dbSession* activeList;00115 <font class="keywordtype">int</font> optimalNumberOfThreads;00116 <font class="keywordtype">int</font> nActiveThreads;00117 <font class="keywordtype">int</font> nIdleThreads;00118 <font class="keywordtype">bool</font> cancelWait;00119 <font class="keywordtype">bool</font> cancelAccept;00120 <font class="keywordtype">bool</font> cancelSession;00121 dbMutex mutex;00122 dbLocalSemaphore go;00123 dbLocalSemaphore done;00124 socket_t* globalAcceptSock;00125 socket_t* localAcceptSock;00126 dbThread localAcceptThread;00127 dbThread globalAcceptThread;00128 <a class="code" href="classdbDatabase.html">dbDatabase</a>* db;00129 00130 <font class="keyword">static</font> <font class="keywordtype">void</font> thread_proc serverThread(<font class="keywordtype">void</font>* arg);00131 <font class="keyword">static</font> <font class="keywordtype">void</font> thread_proc acceptLocalThread(<font class="keywordtype">void</font>* arg);00132 <font class="keyword">static</font> <font class="keywordtype">void</font> thread_proc acceptGlobalThread(<font class="keywordtype">void</font>* arg);00133 00134 <font class="keywordtype">void</font> serveClient();00135 <font class="keywordtype">void</font> acceptConnection(socket_t* sock);00136 00137 <font class="keywordtype">bool</font> get_first(dbSession* session, <font class="keywordtype">int</font> stmt_id);00138 <font class="keywordtype">bool</font> get_last(dbSession* session, <font class="keywordtype">int</font> stmt_id);00139 <font class="keywordtype">bool</font> get_next(dbSession* session, <font class="keywordtype">int</font> stmt_id);00140 <font class="keywordtype">bool</font> get_prev(dbSession* session, <font class="keywordtype">int</font> stmt_id);00141 <font class="keywordtype">bool</font> fetch(dbSession* session, dbStatement* stmt);00142 <font class="keywordtype">bool</font> remove(dbSession* session, <font class="keywordtype">int</font> stmt_id);00143 <font class="keywordtype">bool</font> update(dbSession* session, <font class="keywordtype">int</font> stmt_id, <font class="keywordtype">char</font>* new_data);00144 <font class="keywordtype">bool</font> insert(dbSession* session, <font class="keywordtype">int</font> stmt_id, <font class="keywordtype">char</font>* data, <font class="keywordtype">bool</font> prepare);00145 <font class="keywordtype">bool</font> select(dbSession* session, <font class="keywordtype">int</font> stmt_id, <font class="keywordtype">char</font>* data, <font class="keywordtype">bool</font> prepare);00146 <font class="keywordtype">bool</font> show_tables(dbSession* session); 00147 <font class="keywordtype">bool</font> describe_table(dbSession* session, <font class="keywordtype">char</font> <font class="keyword">const</font>* table);00148 00149 <font class="keywordtype">char</font>* checkColumns(dbStatement* stmt, <font class="keywordtype">int</font> n_columns, 00150 <a class="code" href="classdbTableDescriptor.html">dbTableDescriptor</a>* desc, <font class="keywordtype">char</font>* data, 00151 int4& reponse);00152 00153 dbStatement* findStatement(dbSession* stmt, <font class="keywordtype">int</font> stmt_id);00154 00155 <font class="keyword">public</font>:00156 <font class="keyword">static</font> dbServer* find(<font class="keywordtype">char</font> <font class="keyword">const</font>* serverURL);00157 <font class="keyword">static</font> <font class="keywordtype">void</font> cleanup();00158 00159 <font class="keywordtype">void</font> stop();00160 <font class="keywordtype">void</font> start();00161 00162 dbServer(<a class="code" href="classdbDatabase.html">dbDatabase</a>* db,00163 <font class="keywordtype">char</font> <font class="keyword">const</font>* serverURL, 00164 <font class="keywordtype">int</font> optimalNumberOfThreads = 8, 00165 <font class="keywordtype">int</font> connectionQueueLen = 64);00166 ~dbServer();00167 };00168 00169 <font class="preprocessor">#endif</font></pre></div><hr><address align="right"><small>Generated on Fri Nov 15 21:06:29 2002 for FastDB by<a href="http://www.doxygen.org/index.html"><img src="doxygen.png" alt="doxygen" align="middle" border=0 width=110 height=53></a>1.2.15 </small></address></body></html>⌨️ 快捷键说明
复制代码Ctrl + C
搜索代码Ctrl + F
全屏模式F11
增大字号Ctrl + =
减小字号Ctrl + -
显示快捷键?