Added some netsplit handling stuff (untested)

[user/henk/code/inspircd.git] / include / connection.h

diff --git a/include/connection.h b/include/connection.h
index 91eb7f0dc7093802b0d223d1de6cfc79099998f9..3316bd6c0fd09a8f7546f4c3299edbe31aa1214a 100644 (file)
--- a/include/connection.h
+++ b/include/connection.h
@@ -2,17 +2,103 @@
 
 */
 
-#include "inspircd_config.h" 
+#include "inspircd_config.h"
 #include "base.h"
 #include <string>
-#include <map.h>
- 
-#ifndef __CONNECTION_H__ 
-#define __CONNECTION_H__ 
+#include <map>
+#include <sys/socket.h>
+#include <sys/types.h>
+#include <netdb.h>
+#include <netinet/in.h>
+#include <unistd.h>
+#include <errno.h>
+#include <time.h>
+#include <vector>
+#include <deque>
+
+#ifndef __CONNECTION_H__
+#define __CONNECTION_H__
+
+#define STATE_DISCONNECTED     0
+#define STATE_CONNECTED                1
+#define STATE_SYNC             2
+#define STATE_NOAUTH_INBOUND   3
+#define STATE_NOAUTH_OUTBOUND  4
+
+/** Each connection has one or more of these
+ * each represents ONE outbound connection to another ircd
+ * so each inbound has multiple outbounds.
+ */
+class ircd_connector : public classbase
+{
+ private:
+       /** Sockaddr of the outbound ip and port
+        */
+       sockaddr_in addr;
+       
+       /** File descriptor of the connection
+        */
+       int fd;
+       
+       /** Server name
+        */
+       std::string servername;
+       
+       /** Server 'GECOS'
+        */
+       std::string description;
+       
+       /** State. STATE_NOAUTH_INBOUND, STATE_NOAUTH_OUTBOUND
+        * STATE_SYNC, STATE_DISCONNECTED, STATE_CONNECTED
+        */
+       int state;
+       
+       bool SetHostAddress(char* host, int port);
+
+ public:
+       char host[MAXBUF];
+       int port;
+       
+       /** Server names of servers that this server is linked to
+        * So for A->B->C, if this was the record for B it would contain A and C
+        * whilever both servers are connected to B.
+        */
+       std::vector<std::string> routes;
+       
  
+       bool MakeOutboundConnection(char* host, int port);
+       std::string GetServerName();
+       void SetServerName(std::string serv);
+       int GetDescriptor();
+       void SetDescriptor(int fd);
+       int GetState();
+       void SetState(int state);
+       char* GetServerIP();
+       std::string GetDescription();
+       void SetDescription(std::string desc);
+       int GetServerPort();
+       bool SetHostAndPort(char* host, int port);
+       void CloseConnection();
+};
+
+
+class packet : public classbase
+{
+ public:
+       long key;
+       int id;
+       short int type;
+       char data[MAXBUF];
+
+       packet();
+       ~packet();
+};
+
+
 class connection : public classbase
 {
  public:
+       long key;
        int fd;                 // file descriptor
        char host[256];         // hostname
        long ip;                // ipv4 address
@@ -24,10 +110,25 @@ class connection : public classbase
        bool haspassed;
        int port;
        int registered;
+       short int state;
        time_t lastping;
        time_t signon;
        time_t idle_lastmsg;
        time_t nping;
+       char internal_addr[1024];
+       int internal_port;
+       std::vector<ircd_connector> connectors;
+       
+       connection();
+       bool CreateListener(char* host, int p);
+       bool BeginLink(char* targethost, int port, char* password, char* servername);
+       bool MeshCookie(char* targethost, int port, long cookie, char* servername);
+       void TerminateLink(char* targethost);
+       bool SendPacket(char *message, const char* host);
+       bool RecvPacket(std::deque<std::string> &messages, char* host);
+       ircd_connector* FindHost(std::string host);
+       bool AddIncoming(int fd,char* targethost, int sourceport);
+       long GenKey();
 };