tcp_accept.h File Reference

---

Detailed Description

CDiameterPeer TCP Acceptor Process.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file tcp_accept.h.

Go to the source code of this file.

Functions
int	create_socket (int listen_port, str bind_to, unsigned int *sock)
	Creates a socket and binds it.
void	accept_loop ()
	Accept loop that listens for incoming connections on all listening sockets.

---

Function Documentation

int create_socket	(	int	listen_port,
		str	bind_to,
		unsigned int *	sock
	)

Creates a socket and binds it.

Parameters:

	listen_port	- port to listen to
	bind_to	- IP address to bind to - if empty, will bind to :: (0.0.0.0) (all)
	sock	- socket to be update with the identifier of the opened one

Returns:

1 on success, 0 on error

Definition at line 91 of file tcp_accept.c.

References errno, and NULL.

Referenced by acceptor_process().

{
    unsigned int server_sock=-1;
    struct addrinfo *ainfo=0,*res=0,hints;
    char buf[256],host[256],serv[256];
    int error=0;
    unsigned int option;
    
    memset (&hints, 0, sizeof(hints));
    //hints.ai_protocol = IPPROTO_SCTP;
    //hints.ai_protocol = IPPROTO_TCP;
    hints.ai_flags = AI_PASSIVE|AI_ADDRCONFIG;
    hints.ai_socktype = SOCK_STREAM;

    sprintf(buf,"%d",listen_port);
    
    if (bind_to.len){
        error = getaddrinfo(bind_to.s, buf, &hints, &res);
        if (error!=0){
            LOG(L_WARN,"WARNING:create_socket(): Error opening %.*s port %d while doing gethostbyname >%s\n",
                bind_to.len,bind_to.s,listen_port,gai_strerror(error));
            goto error;
        }
    }else{
        error = getaddrinfo(NULL, buf, &hints, &res);
        if (error!=0){
            LOG(L_WARN,"WARNING:create_socket(): Error opening ANY port %d while doing gethostbyname >%s\n",
                listen_port,gai_strerror(error));
            goto error;
        }
    }
        
    LOG(L_DBG,"DBG:create_sockets: create socket and bind for IPv4...\n");

    for(ainfo = res;ainfo;ainfo = ainfo->ai_next)
    {
        if (getnameinfo(ainfo->ai_addr,ainfo->ai_addrlen,
            host,256,serv,256,NI_NUMERICHOST|NI_NUMERICSERV)==0){
                LOG(L_WARN,"INFO:create_socket(): Trying to open/bind/listen on %s port %s\n",
                    host,serv);
        }               

        if ((server_sock = socket(ainfo->ai_family, ainfo->ai_socktype, ainfo->ai_protocol)) == -1) {
            LOG(L_ERR,"ERROR:create_socket(): error creating server socket on %s port %s >"
                " %s\n",host,serv,strerror(errno));
            goto error;
        }
        option = 1;
        setsockopt(server_sock,SOL_SOCKET,SO_REUSEADDR,&option,sizeof(option));
        
        if (bind(   server_sock,ainfo->ai_addr,ainfo->ai_addrlen)==-1 ) {
            LOG(L_ERR,"ERROR:create_socket(): error binding on %s port %s >"
                " %s\n",host,serv,strerror(errno));
            goto error;
        }
    
        if (listen( server_sock, 5) == -1) {
            LOG(L_ERR,"ERROR:create_socket(): error listening on %s port %s > %s\n",host,serv,strerror(errno) );
            goto error;
        }
    
        *sock = server_sock;    
        
        LOG(L_WARN,"INFO:create_socket(): Successful socket open/bind/listen on %s port %s\n",
                    host,serv);
    }
    if (res) freeaddrinfo(res); 
    return 1;
error:
    if (res) freeaddrinfo(res);
    if (server_sock!=-1) close(server_sock);
    return 0;
    
}

void accept_loop

(

)

Accept loop that listens for incoming connections on all listening sockets.

When a connection is received, accept_connection() is called.

Returns:

only on shutdown

Definition at line 226 of file tcp_accept.c.

References accept_connection(), errno, listening_socks, select, and shutdownx.

{
    fd_set listen_set;
    struct timeval timeout;
    int i=0,max_sock=0,nready;
    int new_sock;
    

    while(listening_socks[i]){
        if (listening_socks[i]>max_sock) max_sock=listening_socks[i];
        i++;
    }

    while(1){
        if (shutdownx && *shutdownx) break;
        
        timeout.tv_sec=2;
        timeout.tv_usec=0;  
        FD_ZERO(&listen_set);
        i=0;
        while(listening_socks[i]){
            FD_SET(listening_socks[i],&listen_set);                 
            i++;
        }

        nready = select( max_sock+1, &listen_set, 0, 0, &timeout);
        if (nready == 0){
            LOG(L_DBG,"DBG:accept_loop(): No connection attempts\n");
            continue;
        }
        if (nready == -1) {
            if (errno == EINTR) {
                continue;
            } else {
                LOG(L_ERR,"ERROR:accept_loop(): select fails: %s\n",
                    strerror(errno));
                sleep(2);
                continue;
            }
        }

        i=0;
        while(listening_socks[i]){
            if (FD_ISSET(listening_socks[i],&listen_set)){
                accept_connection(listening_socks[i],&new_sock);
            }
            i++;
        }
    }
}

---