X-Git-Url: https://arthur.barton.de/cgi-bin/gitweb.cgi?p=ngircd-alex.git;a=blobdiff_plain;f=src%2Fngircd%2Fconn.c;h=1819e36f62eb70105ed76a002471dd492769f5db;hp=80da71d748c115cc4b2a4f917e5d740983bd3325;hb=9eee0c883b22fef4c21dda6ffdabd41b58634527;hpb=e68cdf304f1242bbeb3f0b59323f3059d0d543c4 diff --git a/src/ngircd/conn.c b/src/ngircd/conn.c index 80da71d7..1819e36f 100644 --- a/src/ngircd/conn.c +++ b/src/ngircd/conn.c @@ -12,11 +12,11 @@ */ -#define __conn_c__ +#define CONN_MODULE #include "portab.h" -static char UNUSED id[] = "$Id: conn.c,v 1.112 2002/12/30 16:07:23 alex Exp $"; +static char UNUSED id[] = "$Id: conn.c,v 1.115 2003/01/15 14:28:59 alex Exp $"; #include "imp.h" #include @@ -54,6 +54,7 @@ static char UNUSED id[] = "$Id: conn.c,v 1.112 2002/12/30 16:07:23 alex Exp $"; #include "client.h" #include "conf.h" #include "conn-zip.h" +#include "conn-func.h" #include "log.h" #include "parse.h" #include "tool.h" @@ -82,8 +83,6 @@ LOCAL fd_set My_Listeners; LOCAL fd_set My_Sockets; LOCAL fd_set My_Connects; -LOCAL LONG WCounter; - GLOBAL VOID Conn_Init( VOID ) @@ -615,252 +614,6 @@ Conn_Close( CONN_ID Idx, CHAR *LogMsg, CHAR *FwdMsg, BOOLEAN InformClient ) } /* Conn_Close */ -GLOBAL VOID -Conn_UpdateIdle( CONN_ID Idx ) -{ - /* Idle-Timer zuruecksetzen */ - - assert( Idx > NONE ); - My_Connections[Idx].lastprivmsg = time( NULL ); -} - - -GLOBAL time_t -Conn_GetIdle( CONN_ID Idx ) -{ - /* Idle-Time einer Verbindung liefern (in Sekunden) */ - - assert( Idx > NONE ); - return time( NULL ) - My_Connections[Idx].lastprivmsg; -} /* Conn_GetIdle */ - - -GLOBAL time_t -Conn_LastPing( CONN_ID Idx ) -{ - /* Zeitpunkt des letzten PING liefern */ - - assert( Idx > NONE ); - return My_Connections[Idx].lastping; -} /* Conn_LastPing */ - - -GLOBAL VOID -Conn_SetPenalty( CONN_ID Idx, time_t Seconds ) -{ - /* Penalty-Delay fuer eine Verbindung (in Sekunden) setzen; - * waehrend dieser Zeit wird der entsprechende Socket vom Server - * bei Lese-Operationen komplett ignoriert. Der Delay kann mit - * dieser Funktion nur erhoeht, nicht aber verringert werden. */ - - time_t t; - - assert( Idx > NONE ); - assert( Seconds >= 0 ); - - t = time( NULL ) + Seconds; - if( t > My_Connections[Idx].delaytime ) My_Connections[Idx].delaytime = t; -} /* Conn_SetPenalty */ - - -GLOBAL VOID -Conn_ResetPenalty( CONN_ID Idx ) -{ - assert( Idx > NONE ); - My_Connections[Idx].delaytime = 0; -} /* Conn_ResetPenalty */ - - -GLOBAL VOID -Conn_ClearFlags( VOID ) -{ - /* Alle Connection auf "nicht-markiert" setzen */ - - CONN_ID i; - - for( i = 0; i < Pool_Size; i++ ) My_Connections[i].flag = 0; -} /* Conn_ClearFlags */ - - -GLOBAL INT -Conn_Flag( CONN_ID Idx ) -{ - /* Ist eine Connection markiert (TRUE) oder nicht? */ - - assert( Idx > NONE ); - return My_Connections[Idx].flag; -} /* Conn_Flag */ - - -GLOBAL VOID -Conn_SetFlag( CONN_ID Idx, INT Flag ) -{ - /* Connection markieren */ - - assert( Idx > NONE ); - My_Connections[Idx].flag = Flag; -} /* Conn_SetFlag */ - - -GLOBAL CONN_ID -Conn_First( VOID ) -{ - /* Connection-Struktur der ersten Verbindung liefern; - * Ist keine Verbindung vorhanden, wird NONE geliefert. */ - - CONN_ID i; - - for( i = 0; i < Pool_Size; i++ ) - { - if( My_Connections[i].sock != NONE ) return i; - } - return NONE; -} /* Conn_First */ - - -GLOBAL CONN_ID -Conn_Next( CONN_ID Idx ) -{ - /* Naechste Verbindungs-Struktur liefern; existiert keine - * weitere, so wird NONE geliefert. */ - - CONN_ID i = NONE; - - assert( Idx > NONE ); - - for( i = Idx + 1; i < Pool_Size; i++ ) - { - if( My_Connections[i].sock != NONE ) return i; - } - return NONE; -} /* Conn_Next */ - - -GLOBAL VOID -Conn_SetOption( CONN_ID Idx, INT Option ) -{ - /* Option fuer Verbindung setzen. - * Initial sind alle Optionen _nicht_ gesetzt. */ - - assert( Idx > NONE ); - assert( Option != 0 ); - - My_Connections[Idx].options |= Option; -} /* Conn_SetOption */ - - -GLOBAL VOID -Conn_UnsetOption( CONN_ID Idx, INT Option ) -{ - /* Option fuer Verbindung loeschen */ - - assert( Idx > NONE ); - assert( Option != 0 ); - - My_Connections[Idx].options &= ~Option; -} /* Conn_UnsetOption */ - - -GLOBAL INT -Conn_Options( CONN_ID Idx ) -{ - assert( Idx > NONE ); - return My_Connections[Idx].options; -} /* Conn_Options */ - - -GLOBAL time_t -Conn_StartTime( CONN_ID Idx ) -{ - /* Zeitpunkt des Link-Starts liefern (in Sekunden) */ - - assert( Idx > NONE ); - return My_Connections[Idx].starttime; -} /* Conn_Uptime */ - - -GLOBAL INT -Conn_SendQ( CONN_ID Idx ) -{ - /* Laenge der Daten im Schreibbuffer liefern */ - - assert( Idx > NONE ); -#ifdef USE_ZLIB - if( My_Connections[Idx].options & CONN_ZIP ) return My_Connections[Idx].zip.wdatalen; - else -#endif - return My_Connections[Idx].wdatalen; -} /* Conn_SendQ */ - - -GLOBAL LONG -Conn_SendMsg( CONN_ID Idx ) -{ - /* Anzahl gesendeter Nachrichten liefern */ - - assert( Idx > NONE ); - return My_Connections[Idx].msg_out; -} /* Conn_SendMsg */ - - -GLOBAL LONG -Conn_SendBytes( CONN_ID Idx ) -{ - /* Anzahl gesendeter Bytes (unkomprimiert) liefern */ - - assert( Idx > NONE ); - return My_Connections[Idx].bytes_out; -} /* Conn_SendBytes */ - - -GLOBAL INT -Conn_RecvQ( CONN_ID Idx ) -{ - /* Laenge der Daten im Lesebuffer liefern */ - - assert( Idx > NONE ); -#ifdef USE_ZLIB - if( My_Connections[Idx].options & CONN_ZIP ) return My_Connections[Idx].zip.rdatalen; - else -#endif - return My_Connections[Idx].rdatalen; -} /* Conn_RecvQ */ - - -GLOBAL LONG -Conn_RecvMsg( CONN_ID Idx ) -{ - /* Anzahl empfangener Nachrichten liefern */ - - assert( Idx > NONE ); - return My_Connections[Idx].msg_in; -} /* Conn_RecvMsg */ - - -GLOBAL LONG -Conn_RecvBytes( CONN_ID Idx ) -{ - /* Anzahl empfangener Bytes (unkomprimiert) liefern */ - - assert( Idx > NONE ); - return My_Connections[Idx].bytes_in; -} /* Conn_RecvBytes */ - - -GLOBAL VOID -Conn_ResetWCounter( VOID ) -{ - WCounter = 0; -} /* Conn_ResetWCounter */ - - -GLOBAL LONG -Conn_WCounter( VOID ) -{ - return WCounter; -} /* Conn_WCounter */ - - LOCAL BOOLEAN Try_Write( CONN_ID Idx ) { @@ -945,6 +698,7 @@ Handle_Write( CONN_ID Idx ) /* Daten aus Schreibpuffer versenden bzw. Connection aufbauen */ INT len, res, err; + CLIENT *c; assert( Idx > NONE ); assert( My_Connections[Idx].sock > NONE ); @@ -968,8 +722,10 @@ Handle_Write( CONN_ID Idx ) 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[Conf_GetServer( Idx )].port, Idx, strerror( err )); - /* Socket etc. pp. aufraeumen */ + /* Clean up socket, connection and client structures */ FD_CLR( My_Connections[Idx].sock, &My_Sockets ); + c = Client_GetFromConn( Idx ); + if( c ) Client_DestroyNow( c ); close( My_Connections[Idx].sock ); Init_Conn_Struct( Idx ); @@ -1409,9 +1165,6 @@ Check_Servers( VOID ) CONN_ID idx; INT i, n; - /* Don't connect in "passive mode" */ - if( NGIRCd_Passive ) return; - /* Serach all connections, are there results from the resolver? */ for( idx = 0; idx < Pool_Size; idx++ ) { @@ -1424,8 +1177,8 @@ Check_Servers( VOID ) /* Check all configured servers */ for( i = 0; i < MAX_SERVERS; i++ ) { - /* Valid outgoing server which isn't already connected? */ - if(( ! Conf_Server[i].host[0] ) || ( ! Conf_Server[i].port > 0 ) || ( Conf_Server[i].conn_id > NONE )) continue; + /* Valid outgoing server which isn't already connected or disabled? */ + if(( ! Conf_Server[i].host[0] ) || ( ! Conf_Server[i].port > 0 ) || ( Conf_Server[i].conn_id > NONE ) || ( Conf_Server[i].flags & CONF_SFLAG_DISABLED )) continue; /* Is there already a connection in this group? */ if( Conf_Server[i].group > NONE )