acceptor.c File Reference

---

Detailed Description

CDiameterPeer Acceptor initialization.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file acceptor.c.

#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"

Go to the source code of this file.

Functions
int	dp_add_pid (pid_t pid)
	Add a pid to the local process list.
void	dp_del_pid (pid_t pid)
	Delete a pid from the process list.
void	acceptor_process (dp_config *cfg)
	Called from diameter_peer_start, after a process was forked for this.

---

Function Documentation

int dp_add_pid

(

pid_t

pid

)

[inline]

Add a pid to the local process list.

Parameters:

pid

newly forked pid

Returns:

1 on success or 0 on error

Definition at line 95 of file diameter_peer.c.

Referenced by accept_connection(), and diameter_peer_start().

{
    pid_list_t *n;
    lock_get(pid_list_lock);
    n = shm_malloc(sizeof(pid_list_t));
    if (!n){
        LOG_NO_MEM("shm",sizeof(pid_list_t));
        lock_release(pid_list_lock);
        return 0;
    }
    n->pid = pid;
    n->next = 0;
    n->prev = pid_list->tail;
    if (!pid_list->head) pid_list->head = n;
    if (pid_list->tail) pid_list->tail->next = n;
    pid_list->tail = n;
    lock_release(pid_list_lock);
    return 1;
}

void dp_del_pid

(

pid_t

pid

)

[inline]

Delete a pid from the process list.

Parameters:

pid

- the pid to remove

Definition at line 132 of file diameter_peer.c.

Referenced by diameter_peer_destroy(), receiver_process(), timer_process(), and worker_process().

{   
    pid_list_t *i;
    lock_get(pid_list_lock);
    i = pid_list->head;
    if (!i) {
        lock_release(pid_list_lock);
        return;
    }
    while(i && i->pid!=pid) i = i->next;
    if (i){
        if (i->prev) i->prev->next = i->next;
        else pid_list->head = i->next;
        if (i->next) i->next->prev = i->prev;
        else pid_list->tail = i->prev;
        shm_free(i);
    }
    lock_release(pid_list_lock);
}

void acceptor_process

(

dp_config *

cfg

)

Called from diameter_peer_start, after a process was forked for this.

• opens the listening sockets and binds them to the addresses.

  Parameters:

  cfg

  - the dp_config file, which contains the list of acceptors

  Returns:

  - never. As this is forked, when finished it is expected to exit on itself.

Definition at line 86 of file acceptor.c.

References dp_config::acceptors, dp_config::acceptors_cnt, acceptor_config::bind, create_socket(), listening_socks, LOG_NO_MEM, and acceptor_config::port.

Referenced by diameter_peer_start().

{
    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);
}

---