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=36a33dacac80606aa852072ff5f7806dd16e0cb4;hb=f0831174c3500cefc4f93d1da823b96a961d6c81;hpb=590f2a3f0c2131b70109a1aca513581620f30557 diff --git a/src/ngircd/conn.c b/src/ngircd/conn.c index 36a33dac..7d2c4c6a 100644 --- a/src/ngircd/conn.c +++ b/src/ngircd/conn.c @@ -9,187 +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.50 2002/03/11 00:04:48 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.50 2002/03/11 00:04:48 alex - * - ein sofortiger Re-Connect wird nur dann versucht, wenn die Vernindung - * "lange genug" bereits bestanden hatte. - * - * Revision 1.49 2002/03/10 18:47:02 alex - * *** empty log message *** - * - * Revision 1.48 2002/03/10 17:50:48 alex - * - Server-Gruppen implementiert. - * - * Revision 1.47 2002/03/04 23:16:23 alex - * - Logging geaendert: detaillierter im Syslog, "allgemeiner" fuer Clients. - * - * Revision 1.46 2002/03/02 03:32:08 alex - * - Aenderung des Idle-Verhalten revidiert: das war ein Schnellschuss :-/ - * - * Revision 1.45 2002/03/02 02:44:01 alex - * - Timeouts ausgehender Verbindungen werden besser erkannt (z.B. unter Cygwin). - * - Idle-Time der Hauptschleife [Conn_Handle()] erhoeht: weniger Last. - * - * Revision 1.44 2002/03/02 00:43:31 alex - * - bei abgebrochene ausgehende Server-Verbindungen wird der naechste Ver- - * bindungsversuch in RECONNECT_DELAY Sekunden (3) unternommen und nicht - * mehr "ConnectRetry" Sekunden gewartet. - * - * Revision 1.43 2002/03/02 00:29:11 alex - * - der Wert der Konfigurations-Variable "ConnectRetry" wird besser beachtet. - * - * Revision 1.42 2002/03/02 00:23:32 alex - * - ausgehende Verbindungen werden nun asyncron connectiert und blockieren - * nicht mehr den Server. Dadurch waren einige Aenderungen noetig. - * - diverse Log-Meldungen ueberarbeitet. - * - * Revision 1.41 2002/02/27 14:47:04 alex - * - Logging bei Timeout von Verbindungen geaendert. - * - * Revision 1.40 2002/02/27 02:26:23 alex - * - an Conn_Close() werden zwei weitere Fehlermeldungen zum Forwarden uebergeben. - * - * Revision 1.39 2002/02/23 00:03:54 alex - * - Ergebnistyp von Conn_GetIdle() und Conn_LastPing() auf "time_t" geaendert. - * - * Revision 1.38 2002/02/19 20:34:31 alex - * - Bei ausgehenden Verbindungen wird der Ziel-Port ins Log geschrieben. - * - * Revision 1.37 2002/02/19 20:05:37 alex - * - "Passive-Mode" implementiert: kein Auto-Conect zu anderen Servern. - * - * Revision 1.36 2002/02/11 01:00:50 alex - * - neue Funktion Conn_LastPing(). - * - * Revision 1.35 2002/01/18 11:12:11 alex - * - der Sniffer wird nun nur noch aktiviert, wenn auf Kommandozeile angegeben. - * - * Revision 1.34 2002/01/07 15:29:52 alex - * - PASSSERVERADD definiert, wird beim PASS-Befehl an Server verwendet. - * - * 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 @@ -222,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 @@ -264,7 +92,10 @@ 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; @@ -335,7 +166,7 @@ GLOBAL VOID Conn_Exit( VOID ) } /* 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- @@ -504,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 ) { @@ -591,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 ) { @@ -977,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 ); } } @@ -1022,8 +857,10 @@ LOCAL VOID Check_Servers( VOID ) /* Haben wir schon eine Verbindung? */ for( n = 0; n < MAX_CONNECTIONS; n++ ) { + if( My_Connections[n].sock == NONE ) continue; + /* Verbindung zu diesem Server? */ - if(( My_Connections[n].sock != NONE ) && ( My_Connections[n].our_server == i )) + if( My_Connections[n].our_server == i ) { /* Komplett aufgebaute Verbindung? */ if( My_Connections[n].sock > NONE ) break; @@ -1033,9 +870,9 @@ LOCAL VOID Check_Servers( VOID ) } /* Verbindung in dieser Server-Gruppe? */ - if(( My_Connections[n].sock != NONE ) && ( My_Connections[n].our_server != NONE )) + if(( My_Connections[n].our_server != NONE ) && ( Conf_Server[i].group != NONE )) { - if( Conf_Server[n].group == Conf_Server[i].group != NONE ) break; + if( Conf_Server[My_Connections[n].our_server].group == Conf_Server[i].group ) break; } } if( n < MAX_CONNECTIONS ) continue; @@ -1142,6 +979,7 @@ 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; @@ -1179,12 +1017,14 @@ LOCAL BOOLEAN Init_Socket( INT Sock ) 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 )); @@ -1317,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 )); } @@ -1352,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, "" ); } @@ -1427,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 */ @@ -1446,5 +1297,7 @@ LOCAL CHAR *Resolv_Error( INT H_Error ) } } /* Resolv_Error */ +#endif + /* -eof- */