bb_boxc.c File Reference

#include <errno.h>
#include <stdlib.h>
#include <stdio.h>
#include <time.h>
#include <string.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <signal.h>
#include "gwlib/gwlib.h"
#include "msg.h"
#include "bearerbox.h"
#include "bb_smscconn_cb.h"

Include dependency graph for bb_boxc.c:

Go to the source code of this file.

Data Structures

struct _boxc

struct _addrpar

Defines

#define SMSBOX_MAX_PENDING 100

Typedefs

typedef _boxc Boxc

typedef _addrpar AddrPar

Functions

void sms_to_smsboxes (void *arg)

int send_msg (Boxc *boxconn, Msg *pmsg)

void boxc_sent_push (Boxc *, Msg *)

void boxc_sent_pop (Boxc *, Msg *, Msg **)

Msg * read_from_box (Boxc *boxconn)

void deliver_sms_to_queue (Msg *msg, Boxc *conn)

void boxc_receiver (void *arg)

void boxc_sender (void *arg)

Boxc * boxc_create (int fd, Octstr *ip, int ssl)

void boxc_destroy (Boxc *boxc)

Boxc * accept_boxc (int fd, int ssl)

void run_smsbox (void *arg)

void run_wapbox (void *arg)

void ap_destroy (AddrPar *addr)

int cmp_route (void *ap, void *ms)

int cmp_boxc (void *bc, void *ap)

Boxc * route_msg (List *route_info, Msg *msg)

void wdp_to_wapboxes (void *arg)

void wait_for_connections (int fd, void(*function)(void *arg), List *waited, int ssl)

void smsboxc_run (void *arg)

void wapboxc_run (void *arg)

void init_smsbox_routes (Cfg *cfg)

int smsbox_start (Cfg *cfg)

int smsbox_restart (Cfg *cfg)

int wapbox_start (Cfg *cfg)

Octstr * boxc_status (int status_type)

int boxc_incoming_wdp_queue (void)

void boxc_cleanup (void)

int route_incoming_to_boxc (Msg *msg)

Variables

volatile sig_atomic_t bb_status

volatile sig_atomic_t restart

List * incoming_sms

List * outgoing_sms

List * incoming_wdp

List * outgoing_wdp

List * flow_threads

List * suspended

long max_incoming_sms_qlength

volatile sig_atomic_t smsbox_running

volatile sig_atomic_t wapbox_running

List * wapbox_list

List * smsbox_list

RWLock * smsbox_list_rwlock

Dict * smsbox_by_id

Dict * smsbox_by_smsc

Dict * smsbox_by_receiver

Dict * smsbox_by_smsc_receiver

long smsbox_port

int smsbox_port_ssl

long wapbox_port

int wapbox_port_ssl

long smsbox_max_pending

Octstr * box_allow_ip

Octstr * box_deny_ip

Counter * boxid

long sms_dequeue_thread

Define Documentation

#define SMSBOX_MAX_PENDING 100

Definition at line 83 of file bb_boxc.c.

Typedef Documentation

typedef struct _addrpar AddrPar

Referenced by ap_destroy(), cmp_boxc(), cmp_route(), route_msg(), and wdp_to_wapboxes().

typedef struct _boxc Boxc

Referenced by accept_boxc(), boxc_create(), boxc_destroy(), boxc_incoming_wdp_queue(), boxc_receiver(), boxc_sender(), boxc_sent_pop(), boxc_sent_push(), boxc_status(), cmp_boxc(), deliver_sms_to_queue(), read_from_box(), route_incoming_to_boxc(), route_msg(), run_smsbox(), run_wapbox(), send_msg(), sms_to_smsboxes(), wait_for_connections(), and wdp_to_wapboxes().

Function Documentation

Boxc* accept_boxc ( int fd,

int ssl

) [static]

Definition at line 542 of file bb_boxc.c.
References box_allow_ip, box_deny_ip, Boxc, boxc_create(), _boxc::conn, conn_get_ssl(), host_ip(), info(), is_allowed_ip(), octstr_destroy(), octstr_get_cstr, and ssl.
Referenced by wait_for_connections().
00543 { 00544 Boxc *newconn; 00545 Octstr *ip; 00546 00547 int newfd; 00548 struct sockaddr_in client_addr; 00549 socklen_t client_addr_len; 00550 00551 client_addr_len = sizeof(client_addr); 00552 00553 newfd = accept(fd, (struct sockaddr *)&client_addr, &client_addr_len); 00554 if (newfd < 0) 00555 return NULL; 00556 00557 ip = host_ip(client_addr); 00558 00559 if (is_allowed_ip(box_allow_ip, box_deny_ip, ip) == 0) { 00560 info(0, "Box connection tried from denied host <%s>, disconnected", 00561 octstr_get_cstr(ip)); 00562 octstr_destroy(ip); 00563 close(newfd); 00564 return NULL; 00565 } 00566 newconn = boxc_create(newfd, ip, ssl); 00567 00568 /* 00569 * check if the SSL handshake was successfull, otherwise 00570 * this is no valid box connection any more 00571 */ 00572 #ifdef HAVE_LIBSSL 00573 if (ssl && !conn_get_ssl(newconn->conn)) 00574 return NULL; 00575 #endif 00576 00577 info(0, "Client connected from <%s> %s", octstr_get_cstr(ip), ssl?"using SSL":""); 00578 00579 /* XXX TODO: do the hand-shake, baby, yeah-yeah! */ 00580 00581 return newconn; 00582 }