00001 /* ==================================================================== 00002 * The Kannel Software License, Version 1.0 00003 * 00004 * Copyright (c) 2001-2008 Kannel Group 00005 * Copyright (c) 1998-2001 WapIT Ltd. 00006 * All rights reserved. 00007 * 00008 * Redistribution and use in source and binary forms, with or without 00009 * modification, are permitted provided that the following conditions 00010 * are met: 00011 * 00012 * 1. Redistributions of source code must retain the above copyright 00013 * notice, this list of conditions and the following disclaimer. 00014 * 00015 * 2. Redistributions in binary form must reproduce the above copyright 00016 * notice, this list of conditions and the following disclaimer in 00017 * the documentation and/or other materials provided with the 00018 * distribution. 00019 * 00020 * 3. The end-user documentation included with the redistribution, 00021 * if any, must include the following acknowledgment: 00022 * "This product includes software developed by the 00023 * Kannel Group (http://www.kannel.org/)." 00024 * Alternately, this acknowledgment may appear in the software itself, 00025 * if and wherever such third-party acknowledgments normally appear. 00026 * 00027 * 4. The names "Kannel" and "Kannel Group" must not be used to 00028 * endorse or promote products derived from this software without 00029 * prior written permission. For written permission, please 00030 * contact org@kannel.org. 00031 * 00032 * 5. Products derived from this software may not be called "Kannel", 00033 * nor may "Kannel" appear in their name, without prior written 00034 * permission of the Kannel Group. 00035 * 00036 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED 00037 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 00038 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 00039 * DISCLAIMED. IN NO EVENT SHALL THE KANNEL GROUP OR ITS CONTRIBUTORS 00040 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, 00041 * OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT 00042 * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR 00043 * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 00044 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE 00045 * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, 00046 * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 00047 * ==================================================================== 00048 * 00049 * This software consists of voluntary contributions made by many 00050 * individuals on behalf of the Kannel Group. For more information on 00051 * the Kannel Group, please see <http://www.kannel.org/>. 00052 * 00053 * Portions of this software are based upon software originally written at 00054 * WapIT Ltd., Helsinki, Finland for the Kannel project. 00055 */ 00056 00057 /* 00058 * bb_store.h : declarations for the bearerbox box SMS storage/retrieval module 00059 * 00060 * Author: Alexander Malysh, 2005 00061 */ 00062 00063 #ifndef BB_STORE_H_ 00064 #define BB_STORE_H_ 00065 00066 #define BB_STORE_DEFAULT_DUMP_FREQ 10 00067 00068 /* return number of SMS messages in current store (file) */ 00069 extern long (*store_messages)(void); 00070 00071 /* assign ID and save given message to store. Return -1 if save failed */ 00072 extern int (*store_save)(Msg *msg); 00073 00074 /* 00075 * Store ack/nack to the store file for a given message with a given status. 00076 * @return: -1 if save failed ; 0 otherwise. 00077 */ 00078 extern int (*store_save_ack)(Msg *msg, ack_status_t status); 00079 00080 /* load store from file; delete any messages that have been relayed, 00081 * and create a new store file from remaining. Calling this function 00082 * might take a while, depending on store size 00083 * Return -1 if something fails (bb can then PANIC normally) 00084 */ 00085 extern int (*store_load)(void(*receive_msg)(Msg*)); 00086 00087 /* dump currently non-acknowledged messages into file. This is done 00088 * automatically now and then, but can be forced. Return -1 if file 00089 * problems 00090 */ 00091 extern int (*store_dump)(void); 00092 00093 /* 00094 * Function pointers used inside the storage subsystem to pack and 00095 * unpack a Msg with variable serialization functions. 00096 */ 00097 extern Octstr* (*store_msg_pack)(Msg *msg); 00098 extern Msg* (*store_msg_unpack)(Octstr *os); 00099 00100 /* initialize system. Return -1 if fname is bad (too long). */ 00101 int store_init(const Octstr *type, const Octstr *fname, long dump_freq, 00102 void *pack_func, void *unpack_func); 00103 00104 /* init shutdown (system dies when all acks have been processed) */ 00105 extern void (*store_shutdown)(void); 00106 00107 /* return all containing messages in the current store */ 00108 extern Octstr* (*store_status)(int status_type); 00109 00113 int store_spool_init(const Octstr *fname); 00114 int store_file_init(const Octstr *fname, long dump_freq); 00115 00116 00117 #endif /*BB_STORE_H_*/ 00118