albino
/
ngircd-tor
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

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

- beim Senden und Empfangen wird EAGAIN ("Blockierung") nun abgefangen.
This commit is contained in:
Alexander Barton 2002-11-20 15:48:41 +00:00
parent 6d5b606c46
commit c6b9f3a13d
1 changed files with 11 additions and 1 deletions
Show Stats 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.90 2002/11/19 12:50:20 alex Exp $ * $Id: conn.c,v 1.91 2002/11/20 15:48:41 alex Exp $
* *
* connect.h: Verwaltung aller Netz-Verbindungen ("connections") * connect.h: Verwaltung aller Netz-Verbindungen ("connections")
*/ */
@ -789,6 +789,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 );
@ -822,6 +825,7 @@ New_Connection( INT Sock )
assert( Sock > NONE ); assert( Sock > NONE );
/* 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 )
@ -830,6 +834,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 < Pool_Size; idx++ ) if( My_Connections[idx].sock == NONE ) break; for( idx = 0; idx < Pool_Size; idx++ ) if( My_Connections[idx].sock == NONE ) break;
if( idx >= Pool_Size ) if( idx >= Pool_Size )
@ -972,6 +979,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 );