Macros
#define	BB_STORE_DEFAULT_DUMP_FREQ 10

Functions
int	store_init (Cfg cfg, const Octstr type, const Octstr fname, long dump_freq, void pack_func, void *unpack_func)

Octstr *	store_status (int status_type)

int	store_spool_init (const Octstr *fname)

int	store_file_init (const Octstr *fname, long dump_freq)

Variables
long(*	store_messages )(void)

int(*	store_save )(Msg *msg)

int(*	store_save_ack )(Msg *msg, ack_status_t status)

int(*	store_load )(void(receive_msg)(Msg ))

int(*	store_dump )(void)

Octstr (	store_msg_pack )(Msg *msg)

Msg (	store_msg_unpack )(Octstr *os)

void(*	store_shutdown )(void)

void(*	store_for_each_message )(void(callback_fn)(Msg , void ), void data)

Macro Definition Documentation

◆ BB_STORE_DEFAULT_DUMP_FREQ

#define BB_STORE_DEFAULT_DUMP_FREQ 10

Definition at line 66 of file bb_store.h.

Referenced by store_file_init().

Function Documentation

◆ store_file_init()

int store_file_init	(	const Octstr *	fname,
		long	dump_freq
	)

Definition at line 515 of file bb_store_file.c.

References active, bakfile, BB_STORE_DEFAULT_DUMP_FREQ, dict_create(), dump_frequency, file_mutex, filename, gwlist_add_producer(), gwlist_create, loaded, msg_destroy_item(), mutex_create, newfile, octstr_duplicate, octstr_format(), octstr_get_cstr, octstr_len(), panic, sms_dict, store_dump, store_file_dump(), store_file_for_each_message(), store_file_load(), store_file_messages(), store_file_save(), store_file_save_ack(), store_file_shutdown(), store_for_each_message, store_load, store_messages, store_save, store_save_ack, and store_shutdown.

Referenced by store_init().

 {
     /* Initialize function pointers */
     store_messages = store_file_messages;
     store_save = store_file_save;
     store_save_ack = store_file_save_ack;
     store_load = store_file_load;
     store_dump = store_file_dump;
     store_shutdown = store_file_shutdown;
     store_for_each_message = store_file_for_each_message;
 
     if (fname == NULL)
         return 0; /* we are done */
 
     if (octstr_len(fname) > (FILENAME_MAX-5))
         panic(0, "Store file filename too long: `%s', failed to init.",
           octstr_get_cstr(fname));
 
     filename = octstr_duplicate(fname);
     newfile = octstr_format("%s.new", octstr_get_cstr(filename));
     bakfile = octstr_format("%s.bak", octstr_get_cstr(filename));
 
     sms_dict = dict_create(1024, msg_destroy_item);
 
     if (dump_freq > 0)
         dump_frequency = dump_freq;
     else
         dump_frequency = BB_STORE_DEFAULT_DUMP_FREQ;
 
     file_mutex = mutex_create();
     active = 1;
 
     loaded = gwlist_create();
     gwlist_add_producer(loaded);
 
     return 0;
 }

◆ store_init()

int store_init	(	Cfg *	cfg,
		const Octstr *	type,
		const Octstr *	fname,
		long	dump_freq,
		void *	pack_func,
		void *	unpack_func
	)

Definition at line 82 of file bb_store.c.

References cfg, error(), octstr_str_compare(), store_file_init(), store_msg_pack, store_msg_unpack, store_spool_init(), and type.

Referenced by init_bearerbox(), init_smppbox(), and main().

 {
     int ret;
     
     store_msg_pack = pack_func;
     store_msg_unpack = unpack_func;
 
     if (type == NULL || octstr_str_compare(type, "file") == 0) {
         ret = store_file_init(fname, dump_freq);
     } else if (octstr_str_compare(type, "spool") == 0) {
         ret = store_spool_init(fname);
 #ifdef HAVE_REDIS
     } else if (octstr_str_compare(type, "redis") == 0) {
         ret = store_redis_init(cfg);
 #endif
     } else {
         error(0, "Unknown 'store-type' defined.");
         ret = -1;
     }
 
     return ret;
 }

◆ store_spool_init()

int store_spool_init ( const Octstr * fname )

Init functions for different store types.

Definition at line 338 of file bb_store_spool.c.

References counter, counter_create(), error(), gwlist_add_producer(), gwlist_create, loaded, octstr_duplicate, octstr_get_cstr, spool, store_dump, store_for_each_message, store_load, store_messages, store_save, store_save_ack, store_shutdown, store_spool_dump(), store_spool_for_each_message(), store_spool_load(), store_spool_messages(), store_spool_save(), store_spool_save_ack(), and store_spool_shutdown().

Referenced by store_init().

 {
     DIR *dir;
 
     store_messages = store_spool_messages;
     store_save = store_spool_save;
     store_save_ack = store_spool_save_ack;
     store_load = store_spool_load;
     store_dump = store_spool_dump;
     store_shutdown = store_spool_shutdown;
     store_for_each_message = store_spool_for_each_message;
 
     if (store_dir == NULL)
         return 0;
 
     /* check if we can open directory */
     if ((dir = opendir(octstr_get_cstr(store_dir))) == NULL) {
         error(errno, "Could not open directory `%s'", octstr_get_cstr(store_dir));
         return -1;
     }
     closedir(dir);
 
     loaded = gwlist_create();
     gwlist_add_producer(loaded);
     spool = octstr_duplicate(store_dir);
     counter = counter_create();
 
     return 0;
 }

◆ store_status()

Octstr* store_status ( int status_type )

Definition at line 148 of file bb_store.c.

References BBSTATUS_HTML, BBSTATUS_XML, status::data, format(), octstr_append_cstr(), octstr_create, status_cb(), and store_for_each_message.

Referenced by httpd_store_status().

 {
     Octstr *ret = octstr_create("");
     const char *format;
     struct status data;
 
     /* check if we are active */
     if (store_for_each_message == NULL)
         return ret;
 
     /* set the type based header */
     if (status_type == BBSTATUS_HTML) {
         octstr_append_cstr(ret, "<table border=1>\n"
             "<tr><td>SMS ID</td><td>Type</td><td>Time</td><td>Sender</td><td>Receiver</td>"
             "<td>SMSC ID</td><td>BOX ID</td><td>Flags</td>"
             "<td>UDH</td><td>Message</td>"
             "</tr>\n");
 
         format = "<tr><td>%s</td><td>%s</td>"
                 "<td>%04d-%02d-%02d %02d:%02d:%02d</td>"
                 "<td>%s</td><td>%s</td><td>%s</td>"
                 "<td>%s</td><td>%ld:%ld:%ld:%ld:%ld</td><td>%E</td><td>%E</td></tr>\n";
     } else if (status_type == BBSTATUS_XML) {
         format = "\t<message>\n\t<id>%s</id>\n\t<type>%s</type>\n\t"
                 "<time>%04d-%02d-%02d %02d:%02d:%02d</time>\n\t"
                 "<sender>%s</sender>\n\t"
                 "<receiver>%s</receiver>\n\t<smsc-id>%s</smsc-id>\n\t"
                 "<box-id>%s</box-id>\n\t"
                 "<flags>%ld:%ld:%ld:%ld:%ld</flags>\n\t"
                 "<udh-data>%E</udh-data>\n\t<msg-data>%E</msg-data>\n\t"
                 "</message>\n";
     } else {
         octstr_append_cstr(ret, "[SMS ID] [Type] [Time] [Sender] [Receiver] [SMSC ID] [BOX ID] [Flags] [UDH] [Message]\n");
         format = "[%s] [%s] [%04d-%02d-%02d %02d:%02d:%02d] [%s] [%s] [%s] [%s] [%ld:%ld:%ld:%ld:%ld] [%E] [%E]\n";
     }
 
     data.format = format;
     data.status = ret;
 
     store_for_each_message(status_cb, &data);
 
     /* set the type based footer */
     if (status_type == BBSTATUS_HTML) {
         octstr_append_cstr(ret,"</table>");
     }
 
     return ret;
 }