acceptor.c

Go to the documentation of this file.

#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <assert.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/ioctl.h>
#include <signal.h>
#include <netinet/in.h>
#include <netdb.h>
#include <stdlib.h>

#include "acceptor.h"
#include "utils.h"
#include "globals.h"
#include "tcp_accept.h"
#include "config.h"
#include "worker.h"


/* defined in ../diameter_peer.c */
int dp_add_pid(pid_t pid);
void dp_del_pid(pid_t pid);

void acceptor_process(dp_config *cfg)
{
    int i,k;
    unsigned int sock;
    
    LOG(L_INFO,"INFO:Acceptor process starting up...\n");
    listening_socks = pkg_malloc((cfg->acceptors_cnt+1)*sizeof(int));
    if (!listening_socks){
        LOG_NO_MEM("pkg",(cfg->acceptors_cnt+1)*sizeof(int));
        goto done;
    }
    memset(listening_socks,0,(cfg->acceptors_cnt+1)*sizeof(int));   
    k=0;
    for(i=0;i<cfg->acceptors_cnt;i++)
        if (create_socket(cfg->acceptors[i].port,cfg->acceptors[i].bind,&sock)){
            listening_socks[k++]=sock;          
        }   

    
    LOG(L_INFO,"INFO:... Acceptor opened sockets. Entering accept loop ...\n");     
    accept_loop();

    for(i=0;listening_socks[i];i++)
        close(listening_socks[i]);
    
    if (listening_socks) pkg_free(listening_socks);
#ifdef CDP_FOR_SER
#else
#ifdef PKG_MALLOC
    #ifdef PKG_MALLOC
        LOG(memlog, "Acceptor Memory status (pkg):\n");
        //pkg_status();
        #ifdef pkg_sums
            pkg_sums();
        #endif 
    #endif
#endif
        dp_del_pid(getpid());       
#endif      
done:       
    LOG(L_INFO,"INFO:... Acceptor process finished\n");
    exit(0);
}

---