mirrors/ngircd
1
0
Fork 0
mirror of https://github.com/osmarks/ngircd.git synced 2025-08-05 21:33:44 +00:00
Code Issues Releases Wiki Activity

- diverse Aenderungen und Umsetellungen fuer Server-Links.

Browse Source
This commit is contained in:
Alexander Barton 2002-01-03 02:25:36 +00:00
parent 93aa0dbfb8
commit 54e487d424
1 changed files with 38 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
src/ngircd/conn.c
View File

@ -9,11 +9,14 @@
* Naehere Informationen entnehmen Sie bitter der Datei COPYING. Eine Liste * Naehere Informationen entnehmen Sie bitter der Datei COPYING. Eine Liste
* der an ngIRCd beteiligten Autoren finden Sie in der Datei AUTHORS. * der an ngIRCd beteiligten Autoren finden Sie in der Datei AUTHORS.
* *
* $Id: conn.c,v 1.26 2002/01/02 02:50:47 alex Exp $ * $Id: conn.c,v 1.27 2002/01/03 02:25:36 alex Exp $
* *
* connect.h: Verwaltung aller Netz-Verbindungen ("connections") * connect.h: Verwaltung aller Netz-Verbindungen ("connections")
* *
* $Log: conn.c,v $ * $Log: conn.c,v $
* 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 * Revision 1.26 2002/01/02 02:50:47 alex
* - Asyncroner Resolver Hostname->IP. * - Asyncroner Resolver Hostname->IP.
* - Server-Links begonnen zu implementieren. Die Verbindung wird aufgebaut, * - Server-Links begonnen zu implementieren. Die Verbindung wird aufgebaut,
@ -708,8 +711,15 @@ LOCAL VOID Read_Request( CONN_ID Idx )
assert( Idx >= 0 ); assert( Idx >= 0 );
assert( My_Connections[Idx].sock > NONE ); assert( My_Connections[Idx].sock > NONE );
len = recv( My_Connections[Idx].sock, My_Connections[Idx].rbuf + My_Connections[Idx].rdatalen, READBUFFER_LEN - My_Connections[Idx].rdatalen - 1, 0 ); if( READBUFFER_LEN - My_Connections[Idx].rdatalen - 2 < 0 )
My_Connections[Idx].rbuf[READBUFFER_LEN - 1] = '\0'; {
/* Der Lesepuffer ist voll */
Log( LOG_ALERT, "Read buffer overflow (connection %d): %d bytes!", Idx, My_Connections[Idx].rdatalen );
Conn_Close( Idx, "Read buffer overflow!" );
return;
}
len = recv( My_Connections[Idx].sock, My_Connections[Idx].rbuf + My_Connections[Idx].rdatalen, READBUFFER_LEN - My_Connections[Idx].rdatalen - 2, 0 );
if( len == 0 ) if( len == 0 )
{ {
@ -729,19 +739,9 @@ LOCAL VOID Read_Request( CONN_ID Idx )
/* Lesebuffer updaten */ /* Lesebuffer updaten */
My_Connections[Idx].rdatalen += len; My_Connections[Idx].rdatalen += len;
assert( My_Connections[Idx].rdatalen <= READBUFFER_LEN ); assert( My_Connections[Idx].rdatalen < READBUFFER_LEN );
My_Connections[Idx].rbuf[My_Connections[Idx].rdatalen] = '\0'; My_Connections[Idx].rbuf[My_Connections[Idx].rdatalen] = '\0';
if( My_Connections[Idx].rdatalen > COMMAND_LEN )
{
/* Eine Anfrage darf(!) nicht laenger als 512 Zeichen
* (incl. CR+LF!) werden; vgl. RFC 2812. Wenn soetwas
* empfangen wird, wird der Client disconnectiert. */
Log( LOG_ALERT, "Request too long (connection %d)!", Idx );
Conn_Close( Idx, "Request too long!" );
return;
}
/* Timestamp aktualisieren */ /* Timestamp aktualisieren */
My_Connections[Idx].lastdata = time( NULL ); My_Connections[Idx].lastdata = time( NULL );
@ -761,6 +761,7 @@ LOCAL VOID Handle_Buffer( CONN_ID Idx )
ptr = strstr( My_Connections[Idx].rbuf, "\r\n" ); ptr = strstr( My_Connections[Idx].rbuf, "\r\n" );
if( ptr ) delta = 2; if( ptr ) delta = 2;
#ifndef STRICT_RFC
else else
{ {
/* Nicht RFC-konforme Anfrage mit nur CR oder LF? Leider /* Nicht RFC-konforme Anfrage mit nur CR oder LF? Leider
@ -772,12 +773,23 @@ LOCAL VOID Handle_Buffer( CONN_ID Idx )
else if( ptr1 ) ptr = ptr1; else if( ptr1 ) ptr = ptr1;
else if( ptr2 ) ptr = ptr2; else if( ptr2 ) ptr = ptr2;
} }
#endif
if( ptr ) if( ptr )
{ {
/* Ende der Anfrage wurde gefunden */ /* Ende der Anfrage wurde gefunden */
*ptr = '\0'; *ptr = '\0';
len = ( ptr - My_Connections[Idx].rbuf ) + delta; len = ( ptr - My_Connections[Idx].rbuf ) + delta;
if( len > COMMAND_LEN )
{
/* Eine Anfrage darf(!) nicht laenger als 512 Zeichen
* (incl. CR+LF!) werden; vgl. RFC 2812. Wenn soetwas
* empfangen wird, wird der Client disconnectiert. */
Log( LOG_ALERT, "Request too long (connection %d): %d bytes!", Idx, My_Connections[Idx].rdatalen );
Conn_Close( Idx, "Request too long!" );
return;
}
if( len > delta ) if( len > delta )
{ {
/* Es wurde ein Request gelesen */ /* Es wurde ein Request gelesen */
@ -910,6 +922,7 @@ LOCAL VOID New_Server( INT Server, CONN_ID Idx )
struct sockaddr_in new_addr; struct sockaddr_in new_addr;
struct in_addr inaddr; struct in_addr inaddr;
INT new_sock; INT new_sock;
CLIENT *c;
assert( Server >= 0 ); assert( Server >= 0 );
assert( Idx >= 0 ); assert( Idx >= 0 );
@ -954,13 +967,15 @@ LOCAL VOID New_Server( INT Server, CONN_ID Idx )
} }
/* Client-Struktur initialisieren */ /* Client-Struktur initialisieren */
if( ! Client_NewLocal( Idx, inet_ntoa( new_addr.sin_addr ))) c = Client_NewLocal( Idx, inet_ntoa( new_addr.sin_addr ));
if( ! c )
{ {
close( new_sock ); close( new_sock );
Init_Conn_Struct( Idx ); Init_Conn_Struct( Idx );
Log( LOG_ALERT, "Can't establish connection: can't create client structure!" ); Log( LOG_ALERT, "Can't establish connection: can't create client structure!" );
return; return;
} }
c->type = CLIENT_UNKNOWNSERVER;
/* Verbindung registrieren */ /* Verbindung registrieren */
My_Connections[Idx].sock = new_sock; My_Connections[Idx].sock = new_sock;
@ -970,6 +985,10 @@ LOCAL VOID New_Server( INT Server, CONN_ID Idx )
/* Neuen Socket registrieren */ /* Neuen Socket registrieren */
FD_SET( new_sock, &My_Sockets ); FD_SET( new_sock, &My_Sockets );
if( new_sock > My_Max_Fd ) My_Max_Fd = new_sock; 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 */ } /* New_Server */
@ -1209,9 +1228,10 @@ LOCAL VOID Read_Resolver_Result( INT r_fd )
if( My_Connections[i].sock > NONE ) if( My_Connections[i].sock > NONE )
{ {
/* Eingehende Verbindung: Hostnamen setzen */ /* Eingehende Verbindung: Hostnamen setzen */
strcpy( My_Connections[i].host, result );
c = Client_GetFromConn( i ); c = Client_GetFromConn( i );
if( c ) Client_SetHostname( c, result ); assert( c != NULL );
strcpy( My_Connections[i].host, result );
Client_SetHostname( c, result );
} }
else else
{ {