From 71bedf497cde8b0b38afbb366828b3df9c2803d6 Mon Sep 17 00:00:00 2001 From: brain Date: Mon, 19 Dec 2005 18:04:22 +0000 Subject: git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@2578 e03df62e-2008-0410-955e-edbf42e46eb7 --- docs/module-doc/socket_8cpp-source.html | 491 ++++++++++++++++---------------- 1 file changed, 245 insertions(+), 246 deletions(-) (limited to 'docs/module-doc/socket_8cpp-source.html') diff --git a/docs/module-doc/socket_8cpp-source.html b/docs/module-doc/socket_8cpp-source.html index 933d1eae5..5278c5d50 100644 --- a/docs/module-doc/socket_8cpp-source.html +++ b/docs/module-doc/socket_8cpp-source.html @@ -41,253 +41,252 @@ 00032 #include "socket.h" 00033 #include "inspircd.h" 00034 #include "inspircd_io.h" -00035 #include "inspircd_util.h" -00036 #include "inspstring.h" -00037 #include "helperfuncs.h" -00038 #include "socketengine.h" +00035 #include "inspstring.h" +00036 #include "helperfuncs.h" +00037 #include "socketengine.h" +00038 00039 -00040 extern SocketEngine* SE; -00041 -00042 extern int boundPortCount; -00043 extern int openSockfd[MAXSOCKS]; -00044 extern time_t TIME; -00045 -00046 InspSocket* socket_ref[65535]; -00047 -00048 InspSocket::InspSocket() -00049 { -00050 this->state = I_DISCONNECTED; -00051 } -00052 -00053 InspSocket::InspSocket(int newfd, char* ip) -00054 { -00055 this->fd = newfd; -00056 this->state = I_CONNECTED; -00057 this->IP = ip; -00058 SE->AddFd(this->fd,true,X_ESTAB_MODULE); -00059 socket_ref[this->fd] = this; -00060 } -00061 -00062 InspSocket::InspSocket(std::string host, int port, bool listening, unsigned long maxtime) -00063 { -00064 if (listening) { -00065 if ((this->fd = OpenTCPSocket()) == ERROR) -00066 { -00067 this->fd = -1; -00068 this->state = I_ERROR; -00069 this->OnError(I_ERR_SOCKET); -00070 log(DEBUG,"OpenTCPSocket() error"); -00071 return; -00072 } -00073 else -00074 { -00075 if (BindSocket(this->fd,this->client,this->server,port,(char*)host.c_str()) == ERROR) -00076 { -00077 this->Close(); -00078 this->fd = -1; -00079 this->state = I_ERROR; -00080 this->OnError(I_ERR_BIND); -00081 log(DEBUG,"BindSocket() error %s",strerror(errno)); -00082 return; -00083 } -00084 else -00085 { -00086 this->state = I_LISTENING; -00087 SE->AddFd(this->fd,true,X_ESTAB_MODULE); -00088 socket_ref[this->fd] = this; -00089 log(DEBUG,"New socket now in I_LISTENING state"); -00090 return; -00091 } -00092 } -00093 } else { -00094 char* ip; -00095 this->host = host; -00096 hostent* hoste = gethostbyname(host.c_str()); -00097 if (!hoste) { -00098 ip = (char*)host.c_str(); -00099 } else { -00100 struct in_addr* ia = (in_addr*)hoste->h_addr; -00101 ip = inet_ntoa(*ia); -00102 } -00103 -00104 this->IP = ip; -00105 -00106 timeout_end = time(NULL)+maxtime; -00107 timeout = false; -00108 if ((this->fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) -00109 { -00110 this->state = I_ERROR; -00111 this->OnError(I_ERR_SOCKET); -00112 return; -00113 } -00114 this->port = port; -00115 inet_aton(ip,&addy); -00116 addr.sin_family = AF_INET; -00117 addr.sin_addr = addy; -00118 addr.sin_port = htons(this->port); -00119 -00120 int flags; -00121 flags = fcntl(this->fd, F_GETFL, 0); -00122 fcntl(this->fd, F_SETFL, flags | O_NONBLOCK); -00123 -00124 if(connect(this->fd, (sockaddr*)&this->addr,sizeof(this->addr)) == -1) -00125 { -00126 if (errno != EINPROGRESS) -00127 { -00128 this->Close(); -00129 this->OnError(I_ERR_CONNECT); -00130 this->state = I_ERROR; -00131 return; -00132 } -00133 } -00134 this->state = I_CONNECTING; -00135 SE->AddFd(this->fd,false,X_ESTAB_MODULE); -00136 socket_ref[this->fd] = this; -00137 return; -00138 } -00139 } -00140 -00141 void InspSocket::Close() -00142 { -00143 if (this->fd != -1) -00144 { -00145 this->OnClose(); -00146 shutdown(this->fd,2); -00147 close(this->fd); -00148 socket_ref[this->fd] = NULL; -00149 this->fd = -1; -00150 } -00151 } -00152 -00153 std::string InspSocket::GetIP() -00154 { -00155 return this->IP; -00156 } -00157 -00158 char* InspSocket::Read() -00159 { -00160 int n = recv(this->fd,this->ibuf,sizeof(this->ibuf),0); -00161 if (n > 0) -00162 { -00163 ibuf[n] = 0; -00164 return ibuf; -00165 } -00166 else -00167 { -00168 log(DEBUG,"EOF or error on socket"); -00169 return NULL; -00170 } -00171 } -00172 -00173 // There are two possible outcomes to this function. -00174 // It will either write all of the data, or an undefined amount. -00175 // If an undefined amount is written the connection has failed -00176 // and should be aborted. -00177 int InspSocket::Write(std::string data) -00178 { -00179 char* d = (char*)data.c_str(); -00180 unsigned int written = 0; -00181 int n = 0; -00182 int s = data.length(); -00183 while ((written < data.length()) && (n >= 0)) -00184 { -00185 n = send(this->fd,d,s,0); -00186 if (n > 0) -00187 { -00188 // If we didnt write everything, advance -00189 // the pointers so that when we retry -00190 // the next time around the loop, we try -00191 // to write what we failed to write before. -00192 written += n; -00193 s -= n; -00194 d += n; -00195 } -00196 } -00197 return written; -00198 } -00199 -00200 bool InspSocket::Timeout(time_t current) -00201 { -00202 if ((this->state == I_CONNECTING) && (current > timeout_end)) -00203 { -00204 // for non-listening sockets, the timeout can occur -00205 // which causes termination of the connection after -00206 // the given number of seconds without a successful -00207 // connection. -00208 this->OnTimeout(); -00209 this->OnError(I_ERR_TIMEOUT); -00210 timeout = true; -00211 this->state = I_ERROR; -00212 return true; -00213 } -00214 return false; -00215 } -00216 -00217 bool InspSocket::Poll() -00218 { -00219 int incoming = -1; -00220 -00221 switch (this->state) -00222 { -00223 case I_CONNECTING: -00224 this->SetState(I_CONNECTED); -00225 /* Our socket was in write-state, so delete it and re-add it -00226 * in read-state. -00227 */ -00228 SE->DelFd(this->fd); -00229 SE->AddFd(this->fd,true,X_ESTAB_MODULE); -00230 return this->OnConnected(); -00231 break; -00232 case I_LISTENING: -00233 length = sizeof (client); -00234 incoming = accept (this->fd, (sockaddr*)&client,&length); -00235 this->OnIncomingConnection(incoming,inet_ntoa(client.sin_addr)); -00236 return true; -00237 break; -00238 case I_CONNECTED: -00239 return this->OnDataReady(); -00240 break; -00241 default: -00242 break; -00243 } -00244 -00245 return true; -00246 } -00247 -00248 void InspSocket::SetState(InspSocketState s) -00249 { -00250 log(DEBUG,"Socket state change"); -00251 this->state = s; -00252 } -00253 -00254 InspSocketState InspSocket::GetState() -00255 { -00256 return this->state; -00257 } -00258 -00259 int InspSocket::GetFd() -00260 { -00261 return this->fd; -00262 } -00263 -00264 bool InspSocket::OnConnected() { return true; } -00265 void InspSocket::OnError(InspSocketError e) { return; } -00266 int InspSocket::OnDisconnect() { return 0; } -00267 int InspSocket::OnIncomingConnection(int newfd, char* ip) { return 0; } -00268 bool InspSocket::OnDataReady() { return true; } -00269 void InspSocket::OnTimeout() { return; } -00270 void InspSocket::OnClose() { return; } -00271 -00272 InspSocket::~InspSocket() -00273 { -00274 this->Close(); -00275 } -00276 -00277 /* -00278 int BindSocket (int sockfd, struct sockaddr_in client, struct sockaddr_in server, int port, char* addr) -00279 int OpenTCPSocket (void) -00280 */ -
Generated on Thu Dec 15 11:14:14 2005 for InspIRCd by  +00040 extern InspIRCd* ServerInstance; +00041 extern time_t TIME; +00042 +00043 InspSocket* socket_ref[65535]; +00044 +00045 InspSocket::InspSocket() +00046 { +00047 this->state = I_DISCONNECTED; +00048 } +00049 +00050 InspSocket::InspSocket(int newfd, char* ip) +00051 { +00052 this->fd = newfd; +00053 this->state = I_CONNECTED; +00054 this->IP = ip; +00055 ServerInstance->SE->AddFd(this->fd,true,X_ESTAB_MODULE); +00056 socket_ref[this->fd] = this; +00057 } +00058 +00059 InspSocket::InspSocket(std::string host, int port, bool listening, unsigned long maxtime) +00060 { +00061 if (listening) { +00062 if ((this->fd = OpenTCPSocket()) == ERROR) +00063 { +00064 this->fd = -1; +00065 this->state = I_ERROR; +00066 this->OnError(I_ERR_SOCKET); +00067 log(DEBUG,"OpenTCPSocket() error"); +00068 return; +00069 } +00070 else +00071 { +00072 if (BindSocket(this->fd,this->client,this->server,port,(char*)host.c_str()) == ERROR) +00073 { +00074 this->Close(); +00075 this->fd = -1; +00076 this->state = I_ERROR; +00077 this->OnError(I_ERR_BIND); +00078 log(DEBUG,"BindSocket() error %s",strerror(errno)); +00079 return; +00080 } +00081 else +00082 { +00083 this->state = I_LISTENING; +00084 ServerInstance->SE->AddFd(this->fd,true,X_ESTAB_MODULE); +00085 socket_ref[this->fd] = this; +00086 log(DEBUG,"New socket now in I_LISTENING state"); +00087 return; +00088 } +00089 } +00090 } else { +00091 char* ip; +00092 this->host = host; +00093 hostent* hoste = gethostbyname(host.c_str()); +00094 if (!hoste) { +00095 ip = (char*)host.c_str(); +00096 } else { +00097 struct in_addr* ia = (in_addr*)hoste->h_addr; +00098 ip = inet_ntoa(*ia); +00099 } +00100 +00101 this->IP = ip; +00102 +00103 timeout_end = time(NULL)+maxtime; +00104 timeout = false; +00105 if ((this->fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) +00106 { +00107 this->state = I_ERROR; +00108 this->OnError(I_ERR_SOCKET); +00109 return; +00110 } +00111 this->port = port; +00112 inet_aton(ip,&addy); +00113 addr.sin_family = AF_INET; +00114 addr.sin_addr = addy; +00115 addr.sin_port = htons(this->port); +00116 +00117 int flags; +00118 flags = fcntl(this->fd, F_GETFL, 0); +00119 fcntl(this->fd, F_SETFL, flags | O_NONBLOCK); +00120 +00121 if(connect(this->fd, (sockaddr*)&this->addr,sizeof(this->addr)) == -1) +00122 { +00123 if (errno != EINPROGRESS) +00124 { +00125 this->Close(); +00126 this->OnError(I_ERR_CONNECT); +00127 this->state = I_ERROR; +00128 return; +00129 } +00130 } +00131 this->state = I_CONNECTING; +00132 ServerInstance->SE->AddFd(this->fd,false,X_ESTAB_MODULE); +00133 socket_ref[this->fd] = this; +00134 return; +00135 } +00136 } +00137 +00138 void InspSocket::Close() +00139 { +00140 if (this->fd != -1) +00141 { +00142 this->OnClose(); +00143 shutdown(this->fd,2); +00144 close(this->fd); +00145 socket_ref[this->fd] = NULL; +00146 this->fd = -1; +00147 } +00148 } +00149 +00150 std::string InspSocket::GetIP() +00151 { +00152 return this->IP; +00153 } +00154 +00155 char* InspSocket::Read() +00156 { +00157 int n = recv(this->fd,this->ibuf,sizeof(this->ibuf),0); +00158 if (n > 0) +00159 { +00160 ibuf[n] = 0; +00161 return ibuf; +00162 } +00163 else +00164 { +00165 log(DEBUG,"EOF or error on socket"); +00166 return NULL; +00167 } +00168 } +00169 +00170 // There are two possible outcomes to this function. +00171 // It will either write all of the data, or an undefined amount. +00172 // If an undefined amount is written the connection has failed +00173 // and should be aborted. +00174 int InspSocket::Write(std::string data) +00175 { +00176 this->Buffer = this->Buffer + data; +00177 this->FlushWriteBuffer(); +00178 return data.length(); +00179 } +00180 +00181 void InspSocket::FlushWriteBuffer() +00182 { +00183 int result = 0; +00184 if (this->Buffer.length()) +00185 { +00186 result = send(this->fd,this->Buffer.c_str(),this->Buffer.length(),0); +00187 if (result > 0) +00188 { +00189 /* If we wrote some, advance the buffer forwards */ +00190 char* n = (char*)this->Buffer.c_str(); +00191 n += result; +00192 this->Buffer = n; +00193 } +00194 } +00195 } +00196 +00197 bool InspSocket::Timeout(time_t current) +00198 { +00199 if ((this->state == I_CONNECTING) && (current > timeout_end)) +00200 { +00201 // for non-listening sockets, the timeout can occur +00202 // which causes termination of the connection after +00203 // the given number of seconds without a successful +00204 // connection. +00205 this->OnTimeout(); +00206 this->OnError(I_ERR_TIMEOUT); +00207 timeout = true; +00208 this->state = I_ERROR; +00209 return true; +00210 } +00211 if (this->Buffer.length()) +00212 this->FlushWriteBuffer(); +00213 return false; +00214 } +00215 +00216 bool InspSocket::Poll() +00217 { +00218 int incoming = -1; +00219 +00220 switch (this->state) +00221 { +00222 case I_CONNECTING: +00223 this->SetState(I_CONNECTED); +00224 /* Our socket was in write-state, so delete it and re-add it +00225 * in read-state. +00226 */ +00227 ServerInstance->SE->DelFd(this->fd); +00228 ServerInstance->SE->AddFd(this->fd,true,X_ESTAB_MODULE); +00229 return this->OnConnected(); +00230 break; +00231 case I_LISTENING: +00232 length = sizeof (client); +00233 incoming = accept (this->fd, (sockaddr*)&client,&length); +00234 this->OnIncomingConnection(incoming,inet_ntoa(client.sin_addr)); +00235 return true; +00236 break; +00237 case I_CONNECTED: +00238 return this->OnDataReady(); +00239 break; +00240 default: +00241 break; +00242 } +00243 +00244 return true; +00245 } +00246 +00247 void InspSocket::SetState(InspSocketState s) +00248 { +00249 log(DEBUG,"Socket state change"); +00250 this->state = s; +00251 } +00252 +00253 InspSocketState InspSocket::GetState() +00254 { +00255 return this->state; +00256 } +00257 +00258 int InspSocket::GetFd() +00259 { +00260 return this->fd; +00261 } +00262 +00263 bool InspSocket::OnConnected() { return true; } +00264 void InspSocket::OnError(InspSocketError e) { return; } +00265 int InspSocket::OnDisconnect() { return 0; } +00266 int InspSocket::OnIncomingConnection(int newfd, char* ip) { return 0; } +00267 bool InspSocket::OnDataReady() { return true; } +00268 void InspSocket::OnTimeout() { return; } +00269 void InspSocket::OnClose() { return; } +00270 +00271 InspSocket::~InspSocket() +00272 { +00273 this->Close(); +00274 } +00275 +00276 /* +00277 int BindSocket (int sockfd, struct sockaddr_in client, struct sockaddr_in server, int port, char* addr) +00278 int OpenTCPSocket (void) +00279 */ +
Generated on Mon Dec 19 18:02:13 2005 for InspIRCd by  doxygen 1.4.4-20050815
-- cgit v1.3.1-10-gc9f91