mirrors/ngircd
1
0
Fork 0
mirror of https://github.com/osmarks/ngircd.git synced 2025-10-31 14:02:59 +00:00
Code Issues Releases Wiki Activity

- angenommene Socketes werden nun korrekt auf "non-blocking" gestellt;

Browse Source 
- beim Senden und Empfangen wird EAGAIN ("Blockierung") nun abgefangen.
This commit is contained in:
Alexander Barton
2002-11-20 15:52:40 +00:00
parent 92a9e0d34f
commit b0eb4b0019
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/ngircd/conn.c
View File

@@ -9,7 +9,7 @@
* 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.72.2.4 2002/11/04 19:18:39 alex Exp $ * $Id: conn.c,v 1.72.2.5 2002/11/20 15:52:40 alex Exp $
* *
* connect.h: Verwaltung aller Netz-Verbindungen ("connections") * connect.h: Verwaltung aller Netz-Verbindungen ("connections")
*/ */
@@ -671,6 +671,9 @@ Handle_Write( CONN_ID Idx )
len = send( My_Connections[Idx].sock, My_Connections[Idx].wbuf, My_Connections[Idx].wdatalen, 0 ); len = send( My_Connections[Idx].sock, My_Connections[Idx].wbuf, My_Connections[Idx].wdatalen, 0 );
if( len < 0 ) if( len < 0 )
{ {
/* Operation haette Socket "nur" blockiert ... */
if( errno == EAGAIN ) return TRUE;
/* Oops, ein Fehler! */ /* Oops, ein Fehler! */
Log( LOG_ERR, "Write error on connection %d (socket %d): %s!", Idx, My_Connections[Idx].sock, strerror( errno )); Log( LOG_ERR, "Write error on connection %d (socket %d): %s!", Idx, My_Connections[Idx].sock, strerror( errno ));
Conn_Close( Idx, "Write error!", NULL, FALSE ); Conn_Close( Idx, "Write error!", NULL, FALSE );
@@ -699,6 +702,7 @@ New_Connection( INT Sock )
assert( Sock >= 0 ); assert( Sock >= 0 );
/* Connection auf Listen-Socket annehmen */
new_sock_len = sizeof( new_addr ); new_sock_len = sizeof( new_addr );
new_sock = accept( Sock, (struct sockaddr *)&new_addr, (socklen_t *)&new_sock_len ); new_sock = accept( Sock, (struct sockaddr *)&new_addr, (socklen_t *)&new_sock_len );
if( new_sock < 0 ) if( new_sock < 0 )
@@ -707,6 +711,9 @@ New_Connection( INT Sock )
return; return;
} }
/* Socket initialisieren */
Init_Socket( new_sock );
/* Freie Connection-Struktur suchen */ /* Freie Connection-Struktur suchen */
for( idx = 0; idx < MAX_CONNECTIONS; idx++ ) if( My_Connections[idx].sock == NONE ) break; for( idx = 0; idx < MAX_CONNECTIONS; idx++ ) if( My_Connections[idx].sock == NONE ) break;
if( idx >= MAX_CONNECTIONS ) if( idx >= MAX_CONNECTIONS )
@@ -808,6 +815,9 @@ Read_Request( CONN_ID Idx )
if( len < 0 ) if( len < 0 )
{ {
/* Operation haette Socket "nur" blockiert ... */
if( errno == EAGAIN ) return;
/* Fehler beim Lesen */ /* Fehler beim Lesen */
Log( LOG_ERR, "Read error on connection %d (socket %d): %s!", Idx, My_Connections[Idx].sock, strerror( errno )); Log( LOG_ERR, "Read error on connection %d (socket %d): %s!", Idx, My_Connections[Idx].sock, strerror( errno ));
Conn_Close( Idx, "Read error!", "Client closed connection", FALSE ); Conn_Close( Idx, "Read error!", "Client closed connection", FALSE );