X-Git-Url: https://arthur.barton.de/cgi-bin/gitweb.cgi?p=ngircd-alex.git;a=blobdiff_plain;f=src%2Fngircd%2Fconn.c;h=7d2c4c6adb212f2a58c1c78050997c704b3e9968;hp=e0bd7b457151e5cec6981e5ab003447decd46937;hb=f0831174c3500cefc4f93d1da823b96a961d6c81;hpb=79809118a30e8160773bf0f521100339efff6000 diff --git a/src/ngircd/conn.c b/src/ngircd/conn.c index e0bd7b45..7d2c4c6a 100644 --- a/src/ngircd/conn.c +++ b/src/ngircd/conn.c @@ -9,130 +9,15 @@ * Naehere Informationen entnehmen Sie bitter der Datei COPYING. Eine Liste * der an ngIRCd beteiligten Autoren finden Sie in der Datei AUTHORS. * - * $Id: conn.c,v 1.33 2002/01/06 15:18:14 alex Exp $ + * $Id: conn.c,v 1.62 2002/05/18 21:53:53 alex Exp $ * * connect.h: Verwaltung aller Netz-Verbindungen ("connections") - * - * $Log: conn.c,v $ - * Revision 1.33 2002/01/06 15:18:14 alex - * - Loglevel und Meldungen nochmals geaendert. Level passen nun besser. - * - * Revision 1.32 2002/01/05 23:25:25 alex - * - Vorbereitungen fuer Ident-Abfragen bei neuen Client-Strukturen. - * - * Revision 1.31 2002/01/05 19:15:03 alex - * - Fehlerpruefung bei select() in der "Hauptschleife" korrigiert. - * - * Revision 1.30 2002/01/05 15:56:23 alex - * - "arpa/inet.h" wird nur noch includiert, wenn vorhanden. - * - Ein Fehler bei select() fuerht nun zum Abbruch von ngIRCd. - * - NO_ADDRESS durch NO_DATA ersetzt: ist wohl portabler. - * - * Revision 1.29 2002/01/04 01:36:40 alex - * - Loglevel ein wenig angepasst. - * - * Revision 1.28 2002/01/04 01:20:23 alex - * - Client-Strukruren werden nur noch ueber Funktionen angesprochen. - * - * Revision 1.27 2002/01/03 02:25:36 alex - * - diverse Aenderungen und Umsetellungen fuer Server-Links. - * - * Revision 1.26 2002/01/02 02:50:47 alex - * - Asyncroner Resolver Hostname->IP. - * - Server-Links begonnen zu implementieren. Die Verbindung wird aufgebaut, - * jedoch noch keine SERVER-Befehle verschickt. - * - Diverse Bug-Fixes und kleinere Erweiterungen. - * - * Revision 1.24 2002/01/01 18:25:44 alex - * - #include's fuer stdlib.h ergaenzt. - * - * Revision 1.23 2001/12/31 02:18:51 alex - * - viele neue Befehle (WHOIS, ISON, OPER, DIE, RESTART), - * - neuen Header "defines.h" mit (fast) allen Konstanten. - * - Code Cleanups und viele "kleine" Aenderungen & Bugfixes. - * - * Revision 1.22 2001/12/30 19:26:11 alex - * - Unterstuetzung fuer die Konfigurationsdatei eingebaut. - * - * Revision 1.21 2001/12/29 22:33:36 alex - * - bessere Dokumentation des Modules bzw. der Funktionen. - * - * Revision 1.20 2001/12/29 22:09:43 alex - * - kleinere Aenderungen ("clean-ups") bei Logging (Resolver). - * - * Revision 1.19 2001/12/29 21:53:57 alex - * - Da hatte ich mich wohl ein wenig verrannt; jetzt sollte der Resolver - * aber tatsaechlich funktionieren. - * - * Revision 1.18 2001/12/29 20:17:25 alex - * - asyncronen Resolver (IP->Name) implementiert, dadurch div. Aenderungen. - * - * Revision 1.17 2001/12/29 03:06:16 alex - * - Loglevel (nochmal) angepasst. - * - * Revision 1.16 2001/12/27 19:32:44 alex - * - bei "Null-Requests" wird nichts mehr geloggt. Uberfluessig, da normal. - * - * Revision 1.15 2001/12/27 16:35:04 alex - * - vergessene Variable bei Ping-Timeout-Logmeldung ergaenzt. Opsa. - * - * Revision 1.14 2001/12/26 14:45:37 alex - * - "Code Cleanups". - * - * Revision 1.13 2001/12/26 03:36:57 alex - * - Verbindungen mit Lesefehlern werden nun korrekt terminiert. - * - * Revision 1.12 2001/12/26 03:20:53 alex - * - PING/PONG-Timeout implementiert. - * - * Revision 1.11 2001/12/25 23:15:16 alex - * - buffer werden nun periodisch geprueft, keine haengenden Clients mehr. - * - * Revision 1.10 2001/12/25 22:03:47 alex - * - Conn_Close() eingefuehrt: war die lokale Funktion Close_Connection(). - * - * Revision 1.9 2001/12/24 01:32:33 alex - * - in Conn_WriteStr() wurde das CR+LF nicht angehaengt! - * - Fehler-Ausgaben vereinheitlicht. - * - * Revision 1.8 2001/12/23 22:02:54 alex - * - Conn_WriteStr() nimmt nun variable Parameter, - * - diverse kleinere Aenderungen. - * - * Revision 1.7 2001/12/21 22:24:25 alex - * - kleinere Aenderungen an den Log-Meldungen, - * - Parse_Request() wird aufgerufen. - * - * Revision 1.6 2001/12/15 00:11:55 alex - * - Lese- und Schreib-Puffer implementiert. - * - einige neue (Unter-)Funktionen eingefuehrt. - * - diverse weitere kleinere Aenderungen. - * - * Revision 1.5 2001/12/14 08:16:47 alex - * - Begonnen, Client-spezifische Lesepuffer zu implementieren. - * - Umstellung auf Datentyp "CONN_ID". - * - * Revision 1.4 2001/12/13 02:04:16 alex - * - boesen "Speicherschiesser" in Log() gefixt. - * - * Revision 1.3 2001/12/13 01:33:09 alex - * - Conn_Handler() unterstuetzt nun einen Timeout. - * - fuer Verbindungen werden keine FILE-Handles mehr benutzt. - * - kleinere "Code Cleanups" ;-) - * - * Revision 1.2 2001/12/12 23:32:02 alex - * - diverse Erweiterungen und Verbesserungen (u.a. sind nun mehrere - * Verbindungen und Listen-Sockets moeglich). - * - * Revision 1.1 2001/12/12 17:18:38 alex - * - Modul zur Verwaltung aller Netzwerk-Verbindungen begonnen. */ -#include -#include "global.h" +#include "portab.h" -#include +#include "imp.h" #include #include #include @@ -165,11 +50,11 @@ #include "parse.h" #include "tool.h" -#include +#include "exp.h" #include "conn.h" -#define SERVER_WAIT NONE - 1 +#define SERVER_WAIT (NONE - 1) typedef struct _Connection @@ -199,6 +84,7 @@ LOCAL VOID Handle_Buffer( CONN_ID Idx ); LOCAL VOID Check_Connections( VOID ); LOCAL VOID Check_Servers( VOID ); LOCAL VOID Init_Conn_Struct( INT Idx ); +LOCAL BOOLEAN Init_Socket( INT Sock ); LOCAL VOID New_Server( INT Server, CONN_ID Idx ); LOCAL RES_STAT *ResolveAddr( struct sockaddr_in *Addr ); @@ -206,12 +92,16 @@ LOCAL RES_STAT *ResolveName( CHAR *Host ); LOCAL VOID Do_ResolveAddr( struct sockaddr_in *Addr, INT w_fd ); LOCAL VOID Do_ResolveName( CHAR *Host, INT w_fd ); LOCAL VOID Read_Resolver_Result( INT r_fd ); + +#ifdef h_errno LOCAL CHAR *Resolv_Error( INT H_Error ); +#endif LOCAL fd_set My_Listeners; LOCAL fd_set My_Sockets; LOCAL fd_set My_Resolvers; +LOCAL fd_set My_Connects; LOCAL INT My_Max_Fd; @@ -228,6 +118,7 @@ GLOBAL VOID Conn_Init( VOID ) FD_ZERO( &My_Listeners ); FD_ZERO( &My_Sockets ); FD_ZERO( &My_Resolvers ); + FD_ZERO( &My_Connects ); My_Max_Fd = 0; @@ -254,30 +145,35 @@ GLOBAL VOID Conn_Exit( VOID ) { if( My_Connections[idx].sock == i ) break; } - if( idx < MAX_CONNECTIONS ) Conn_Close( idx, NULL, "Server going down", TRUE ); - else if( FD_ISSET( i, &My_Listeners )) + if( FD_ISSET( i, &My_Listeners )) { close( i ); Log( LOG_DEBUG, "Listening socket %d closed.", i ); } + else if( FD_ISSET( i, &My_Connects )) + { + close( i ); + Log( LOG_DEBUG, "Connection %d closed during creation (socket %d).", idx, i ); + } + else if( idx < MAX_CONNECTIONS ) Conn_Close( idx, NULL, "Server going down", TRUE ); else { + Log( LOG_WARNING, "Closing unknown connection %d ...", i ); close( i ); - Log( LOG_WARNING, "Unknown connection %d closed.", i ); } } } } /* Conn_Exit */ -GLOBAL BOOLEAN Conn_NewListener( CONST INT Port ) +GLOBAL BOOLEAN Conn_NewListener( CONST UINT Port ) { /* Neuen Listen-Socket erzeugen: der Server wartet dann auf * dem angegebenen Port auf Verbindungen. Kann der Listen- * Socket nicht erteugt werden, so wird NULL geliefert.*/ struct sockaddr_in addr; - INT sock, on = 1; + INT sock; /* Server-"Listen"-Socket initialisieren */ memset( &addr, 0, sizeof( addr )); @@ -293,18 +189,7 @@ GLOBAL BOOLEAN Conn_NewListener( CONST INT Port ) return FALSE; } - /* Socket-Optionen setzen */ - if( fcntl( sock, F_SETFL, O_NONBLOCK ) != 0 ) - { - Log( LOG_CRIT, "Can't enable non-blocking mode: %s!", strerror( errno )); - close( sock ); - return FALSE; - } - if( setsockopt( sock, SOL_SOCKET, SO_REUSEADDR, &on, (socklen_t)sizeof( on )) != 0) - { - Log( LOG_ERR, "Can't set socket options: %s!", strerror( errno )); - /* dieser Fehler kann ignoriert werden. */ - } + if( ! Init_Socket( sock )) return FALSE; /* an Port binden */ if( bind( sock, (struct sockaddr *)&addr, (socklen_t)sizeof( addr )) != 0 ) @@ -372,7 +257,7 @@ GLOBAL VOID Conn_Handler( INT Timeout ) Handle_Buffer( i ); } } - + /* noch volle Schreib-Puffer suchen */ FD_ZERO( &write_sockets ); for( i = 0; i < MAX_CONNECTIONS; i++ ) @@ -383,6 +268,11 @@ GLOBAL VOID Conn_Handler( INT Timeout ) FD_SET( My_Connections[i].sock, &write_sockets ); } } + /* Sockets mit im Aufbau befindlichen ausgehenden Verbindungen suchen */ + for( i = 0; i < MAX_CONNECTIONS; i++ ) + { + if(( My_Connections[i].sock > NONE ) && ( FD_ISSET( My_Connections[i].sock, &My_Connects ))) FD_SET( My_Connections[i].sock, &write_sockets ); + } /* von welchen Sockets koennte gelesen werden? */ read_sockets = My_Sockets; @@ -393,6 +283,11 @@ GLOBAL VOID Conn_Handler( INT Timeout ) /* Hier muss noch auf den Resolver Sub-Prozess gewartet werden */ FD_CLR( My_Connections[i].sock, &read_sockets ); } + if(( My_Connections[i].sock > NONE ) && ( FD_ISSET( My_Connections[i].sock, &My_Connects ))) + { + /* Hier laeuft noch ein asyncrones connect() */ + FD_CLR( My_Connections[i].sock, &read_sockets ); + } } for( i = 0; i < My_Max_Fd + 1; i++ ) { @@ -440,6 +335,10 @@ GLOBAL BOOLEAN Conn_WriteStr( CONN_ID Idx, CHAR *Format, ... ) BOOLEAN ok; va_list ap; + assert( Idx >= 0 ); + assert( My_Connections[Idx].sock > NONE ); + assert( Format != NULL ); + va_start( ap, Format ); if( vsnprintf( buffer, COMMAND_LEN - 2, Format, ap ) == COMMAND_LEN - 2 ) { @@ -449,7 +348,7 @@ GLOBAL BOOLEAN Conn_WriteStr( CONN_ID Idx, CHAR *Format, ... ) } #ifdef SNIFFER - Log( LOG_DEBUG, " -> connection %d: '%s'.", Idx, buffer ); + if( NGIRCd_Sniffer ) Log( LOG_DEBUG, " -> connection %d: '%s'.", Idx, buffer ); #endif strcat( buffer, "\r\n" ); @@ -506,7 +405,7 @@ GLOBAL VOID Conn_Close( CONN_ID Idx, CHAR *LogMsg, CHAR *FwdMsg, BOOLEAN InformC * Sub-Prozessen offene Pipes werden geschlossen. */ CLIENT *c; - + assert( Idx >= 0 ); assert( My_Connections[Idx].sock > NONE ); @@ -527,7 +426,7 @@ GLOBAL VOID Conn_Close( CONN_ID Idx, CHAR *LogMsg, CHAR *FwdMsg, BOOLEAN InformC } c = Client_GetFromConn( Idx ); - if( c ) Client_Destroy( c, LogMsg, FwdMsg ); + if( c ) Client_Destroy( c, LogMsg, FwdMsg, TRUE ); if( My_Connections[Idx].res_stat ) { @@ -538,10 +437,17 @@ GLOBAL VOID Conn_Close( CONN_ID Idx, CHAR *LogMsg, CHAR *FwdMsg, BOOLEAN InformC free( My_Connections[Idx].res_stat ); } - /* Bei Server-Verbindungen lasttry-Zeitpunkt auf "jetzt" setzen */ - if( My_Connections[Idx].our_server >= 0 ) Conf_Server[My_Connections[Idx].our_server].lasttry = time( NULL ); + /* Bei Server-Verbindungen lasttry-Zeitpunkt so setzen, dass + * der naechste Verbindungsversuch in RECONNECT_DELAY Sekunden + * gestartet wird. */ + if(( My_Connections[Idx].our_server >= 0 ) && ( Conf_Server[My_Connections[Idx].our_server].lasttry < time( NULL ))) + { + /* Okay, die Verbindung stand schon "genuegend lange" */ + Conf_Server[My_Connections[Idx].our_server].lasttry = time( NULL ) - Conf_ConnectRetry + RECONNECT_DELAY; + } FD_CLR( My_Connections[Idx].sock, &My_Sockets ); + FD_CLR( My_Connections[Idx].sock, &My_Connects ); My_Connections[Idx].sock = NONE; } /* Conn_Close */ @@ -555,7 +461,7 @@ GLOBAL VOID Conn_UpdateIdle( CONN_ID Idx ) } -GLOBAL INT32 Conn_GetIdle( CONN_ID Idx ) +GLOBAL time_t Conn_GetIdle( CONN_ID Idx ) { /* Idle-Time einer Verbindung liefern (in Sekunden) */ @@ -564,6 +470,15 @@ GLOBAL INT32 Conn_GetIdle( CONN_ID Idx ) } /* Conn_GetIdle */ +GLOBAL time_t Conn_LastPing( CONN_ID Idx ) +{ + /* Zeitpunkt des letzten PING liefern */ + + assert( Idx >= 0 ); + return My_Connections[Idx].lastping; +} /* Conn_LastPing */ + + LOCAL BOOLEAN Try_Write( CONN_ID Idx ) { /* Versuchen, Daten aus dem Schreib-Puffer in den @@ -603,7 +518,7 @@ LOCAL VOID Handle_Read( INT Sock ) CONN_ID idx; assert( Sock >= 0 ); - + if( FD_ISSET( Sock, &My_Listeners )) { /* es ist einer unserer Listener-Sockets: es soll @@ -629,12 +544,51 @@ LOCAL VOID Handle_Read( INT Sock ) LOCAL BOOLEAN Handle_Write( CONN_ID Idx ) { - /* Daten aus Schreibpuffer versenden */ + /* Daten aus Schreibpuffer versenden bzw. Connection aufbauen */ - INT len; + INT len, res, err; assert( Idx >= 0 ); assert( My_Connections[Idx].sock > NONE ); + + if( FD_ISSET( My_Connections[Idx].sock, &My_Connects )) + { + /* es soll nichts geschrieben werden, sondern ein + * connect() hat ein Ergebnis geliefert */ + + FD_CLR( My_Connections[Idx].sock, &My_Connects ); + + /* Ergebnis des connect() ermitteln */ + len = sizeof( err ); + res = getsockopt( My_Connections[Idx].sock, SOL_SOCKET, SO_ERROR, &err, &len ); + assert( len == sizeof( err )); + + /* Fehler aufgetreten? */ + if(( res != 0 ) || ( err != 0 )) + { + /* Fehler! */ + if( res != 0 ) Log( LOG_CRIT, "getsockopt (connection %d): %s!", Idx, strerror( errno )); + else Log( LOG_CRIT, "Can't connect socket to \"%s:%d\" (connection %d): %s!", My_Connections[Idx].host, Conf_Server[My_Connections[Idx].our_server].port, Idx, strerror( err )); + + /* Socket etc. pp. aufraeumen */ + FD_CLR( My_Connections[Idx].sock, &My_Sockets ); + close( My_Connections[Idx].sock ); + Init_Conn_Struct( Idx ); + + /* Bei Server-Verbindungen lasttry-Zeitpunkt auf "jetzt" setzen */ + Conf_Server[My_Connections[Idx].our_server].lasttry = time( NULL ); + + return FALSE; + } + Log( LOG_DEBUG, "Connection %d with \"%s:%d\" established, now sendig PASS and SERVER ...", Idx, My_Connections[Idx].host, Conf_Server[My_Connections[Idx].our_server].port ); + + /* PASS und SERVER verschicken */ + Conn_WriteStr( Idx, "PASS %s "PASSSERVERADD, Conf_Server[My_Connections[Idx].our_server].pwd ); + Conn_WriteStr( Idx, "SERVER %s :%s", Conf_ServerName, Conf_ServerInfo ); + + return TRUE; + } + assert( My_Connections[Idx].wdatalen > 0 ); /* Daten schreiben */ @@ -664,7 +618,7 @@ LOCAL VOID New_Connection( INT Sock ) INT new_sock, new_sock_len; RES_STAT *s; CONN_ID idx; - + assert( Sock >= 0 ); new_sock_len = sizeof( new_addr ); @@ -757,7 +711,7 @@ LOCAL VOID Read_Request( CONN_ID Idx ) { /* Socket wurde geschlossen */ Log( LOG_INFO, "%s:%d is closing the connection ...", inet_ntoa( My_Connections[Idx].addr.sin_addr ), ntohs( My_Connections[Idx].addr.sin_port)); - Conn_Close( Idx, "Socket closed.", NULL, FALSE ); + Conn_Close( Idx, "Socket closed!", "Client closed connection", FALSE ); return; } @@ -765,7 +719,7 @@ LOCAL VOID Read_Request( CONN_ID Idx ) { /* Fehler beim Lesen */ Log( LOG_ERR, "Read error on connection %d: %s!", Idx, strerror( errno )); - Conn_Close( Idx, "Read error!", NULL, FALSE ); + Conn_Close( Idx, "Read error!", "Client closed connection", FALSE ); return; } @@ -787,7 +741,7 @@ LOCAL VOID Handle_Buffer( CONN_ID Idx ) CHAR *ptr, *ptr1, *ptr2; INT len, delta; - + /* Eine komplette Anfrage muss mit CR+LF enden, vgl. * RFC 2812. Haben wir eine? */ ptr = strstr( My_Connections[Idx].rbuf, "\r\n" ); @@ -806,7 +760,7 @@ LOCAL VOID Handle_Buffer( CONN_ID Idx ) else if( ptr2 ) ptr = ptr2; } #endif - + if( ptr ) { /* Ende der Anfrage wurde gefunden */ @@ -821,7 +775,7 @@ LOCAL VOID Handle_Buffer( CONN_ID Idx ) Conn_Close( Idx, NULL, "Request too long", TRUE ); return; } - + if( len > delta ) { /* Es wurde ein Request gelesen */ @@ -858,7 +812,7 @@ LOCAL VOID Check_Connections( VOID ) if( My_Connections[i].lastping < time( NULL ) - Conf_PongTimeout ) { /* Timeout */ - Log( LOG_DEBUG, "Connection %d: Ping timeout.", i ); + Log( LOG_DEBUG, "Connection %d: Ping timeout: %d seconds.", i, Conf_PongTimeout ); Conn_Close( i, NULL, "Ping timeout", TRUE ); } } @@ -876,8 +830,8 @@ LOCAL VOID Check_Connections( VOID ) if( My_Connections[i].lastdata < time( NULL ) - Conf_PingTimeout ) { /* Timeout */ - Log( LOG_INFO, "Connection %d: Timeout.", i ); - Conn_Close( i, NULL, "Timeout", TRUE ); + Log( LOG_DEBUG, "Connection %d timed out ...", i ); + Conn_Close( i, NULL, "Timeout", FALSE ); } } } @@ -891,16 +845,22 @@ LOCAL VOID Check_Servers( VOID ) INT idx, i, n; RES_STAT *s; - + + /* Wenn "Passive-Mode" aktiv: nicht verbinden */ + if( NGIRCd_Passive ) return; + for( i = 0; i < Conf_Server_Count; i++ ) { /* Ist ein Hostname und Port definiert? */ if(( ! Conf_Server[i].host[0] ) || ( ! Conf_Server[i].port > 0 )) continue; - + /* Haben wir schon eine Verbindung? */ for( n = 0; n < MAX_CONNECTIONS; n++ ) { - if(( My_Connections[n].sock != NONE ) && ( My_Connections[n].our_server == i )) + if( My_Connections[n].sock == NONE ) continue; + + /* Verbindung zu diesem Server? */ + if( My_Connections[n].our_server == i ) { /* Komplett aufgebaute Verbindung? */ if( My_Connections[n].sock > NONE ) break; @@ -908,9 +868,15 @@ LOCAL VOID Check_Servers( VOID ) /* IP schon aufgeloest? */ if( My_Connections[n].res_stat == NULL ) New_Server( i, n ); } + + /* Verbindung in dieser Server-Gruppe? */ + if(( My_Connections[n].our_server != NONE ) && ( Conf_Server[i].group != NONE )) + { + if( Conf_Server[My_Connections[n].our_server].group == Conf_Server[i].group ) break; + } } if( n < MAX_CONNECTIONS ) continue; - + /* Wann war der letzte Connect-Versuch? */ if( Conf_Server[i].lasttry > time( NULL ) - Conf_ConnectRetry ) continue; @@ -930,7 +896,7 @@ LOCAL VOID Check_Servers( VOID ) Init_Conn_Struct( idx ); My_Connections[idx].sock = SERVER_WAIT; My_Connections[idx].our_server = i; - + /* Hostnamen in IP aufloesen */ s = ResolveName( Conf_Server[i].host ); if( s ) @@ -967,8 +933,8 @@ LOCAL VOID New_Server( INT Server, CONN_ID Idx ) Log( LOG_ERR, "Can't connect to \"%s\" (connection %d): ip address unknown!", Conf_Server[Server].host, Idx ); return; } - - Log( LOG_INFO, "Establishing connection to \"%s\", %s (connection %d) ... ", Conf_Server[Server].host, Conf_Server[Server].ip, Idx ); + + Log( LOG_INFO, "Establishing connection to \"%s\", %s, port %d (connection %d) ... ", Conf_Server[Server].host, Conf_Server[Server].ip, Conf_Server[Server].port, Idx ); if( inet_aton( Conf_Server[Server].ip, &inaddr ) == 0 ) { @@ -990,8 +956,13 @@ LOCAL VOID New_Server( INT Server, CONN_ID Idx ) Log( LOG_CRIT, "Can't create socket: %s!", strerror( errno )); return; } - if( connect( new_sock, (struct sockaddr *)&new_addr, sizeof( new_addr )) < 0) + + if( ! Init_Socket( new_sock )) return; + + connect( new_sock, (struct sockaddr *)&new_addr, sizeof( new_addr )); + if( errno != EINPROGRESS ) { + close( new_sock ); Init_Conn_Struct( Idx ); Log( LOG_CRIT, "Can't connect socket: %s!", strerror( errno )); @@ -1008,7 +979,8 @@ LOCAL VOID New_Server( INT Server, CONN_ID Idx ) return; } Client_SetIntroducer( c, c ); - + Client_SetToken( c, TOKEN_OUTBOUND ); + /* Verbindung registrieren */ My_Connections[Idx].sock = new_sock; My_Connections[Idx].addr = new_addr; @@ -1016,11 +988,8 @@ LOCAL VOID New_Server( INT Server, CONN_ID Idx ) /* Neuen Socket registrieren */ FD_SET( new_sock, &My_Sockets ); + FD_SET( new_sock, &My_Connects ); if( new_sock > My_Max_Fd ) My_Max_Fd = new_sock; - - /* PASS und SERVER verschicken */ - Conn_WriteStr( Idx, "PASS %s "PROTOVER""PROTOSUFFIX" IRC|"PACKAGE"-"VERSION" P", Conf_Server[Server].pwd ); - Conn_WriteStr( Idx, "SERVER %s :%s", Conf_ServerName, Conf_ServerInfo ); } /* New_Server */ @@ -1035,13 +1004,37 @@ LOCAL VOID Init_Conn_Struct( INT Idx ) My_Connections[Idx].rdatalen = 0; My_Connections[Idx].wbuf[0] = '\0'; My_Connections[Idx].wdatalen = 0; - My_Connections[Idx].our_server = -1; + My_Connections[Idx].our_server = NONE; My_Connections[Idx].lastdata = time( NULL ); My_Connections[Idx].lastping = 0; My_Connections[Idx].lastprivmsg = time( NULL ); } /* Init_Conn_Struct */ +LOCAL BOOLEAN Init_Socket( INT Sock ) +{ + /* Socket-Optionen setzen */ + + INT on = 1; + +#ifdef O_NONBLOCK /* A/UX kennt das nicht? */ + if( fcntl( Sock, F_SETFL, O_NONBLOCK ) != 0 ) + { + Log( LOG_CRIT, "Can't enable non-blocking mode: %s!", strerror( errno )); + close( Sock ); + return FALSE; + } +#endif + if( setsockopt( Sock, SOL_SOCKET, SO_REUSEADDR, &on, (socklen_t)sizeof( on )) != 0) + { + Log( LOG_ERR, "Can't set socket options: %s!", strerror( errno )); + /* dieser Fehler kann ignoriert werden. */ + } + + return TRUE; +} /* Init_Socket */ + + LOCAL RES_STAT *ResolveAddr( struct sockaddr_in *Addr ) { /* IP (asyncron!) aufloesen. Bei Fehler, z.B. wenn der @@ -1164,7 +1157,11 @@ LOCAL VOID Do_ResolveAddr( struct sockaddr_in *Addr, INT w_fd ) if( h ) strcpy( hostname, h->h_name ); else { - Log_Resolver( LOG_WARNING, "Can't resolve address %s: code %s!", inet_ntoa( Addr->sin_addr ), Resolv_Error( h_errno )); +#ifdef h_errno + Log_Resolver( LOG_WARNING, "Can't resolve address \"%s\": %s!", inet_ntoa( Addr->sin_addr ), Resolv_Error( h_errno )); +#else + Log_Resolver( LOG_WARNING, "Can't resolve address \"%s\"!", inet_ntoa( Addr->sin_addr )); +#endif strcpy( hostname, inet_ntoa( Addr->sin_addr )); } @@ -1199,7 +1196,11 @@ LOCAL VOID Do_ResolveName( CHAR *Host, INT w_fd ) } else { +#ifdef h_errno Log_Resolver( LOG_WARNING, "Can't resolve \"%s\": %s!", Host, Resolv_Error( h_errno )); +#else + Log_Resolver( LOG_WARNING, "Can't resolve \"%s\"!", Host ); +#endif strcpy( ip, "" ); } @@ -1274,6 +1275,9 @@ LOCAL VOID Read_Resolver_Result( INT r_fd ) } /* Read_Resolver_Result */ + +#ifdef h_errno + LOCAL CHAR *Resolv_Error( INT H_Error ) { /* Fehlerbeschreibung fuer H_Error liefern */ @@ -1293,5 +1297,7 @@ LOCAL CHAR *Resolv_Error( INT H_Error ) } } /* Resolv_Error */ +#endif + /* -eof- */