dialog: add missing header file

modules/dialog/dlg_repl_profile.h

@@ -0,0 +1,159 @@
+/*
+ * dialog module - basic support for dialog tracking
+ *
+ * Copyright (C) 2013 OpenSIPS Solutions
+ *
+ * This file is part of opensips, a free SIP server.
+ *
+ * opensips is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version
+ *
+ * opensips is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ *
+ * History:
+ * --------
+ *  2015-06-10 initial version (razvanc)
+ */
+
+#include "../../ut.h"
+#include "../../bin_interface.h"
+#include "../../socket_info.h"
+#include "../../timer.h"
+
+#ifndef _DIALOG_DLG_PROFILE_REPLICATION_H_
+#define _DIALOG_DLG_PROFILE_REPLICATION_H_
+
+typedef struct repl_prof_count {
+	int counter;
+	time_t update;
+} repl_prof_count_t;
+
+typedef struct repl_prof_novalue {
+	gen_lock_t lock;
+	struct repl_prof_count dsts[0];
+} repl_prof_novalue_t;
+
+typedef struct repl_prof_value {
+	int counter;
+	repl_prof_novalue_t *noval;
+} repl_prof_value_t;
+
+/* profiles functions */
+extern int accept_repl_profiles;
+extern int repl_prof_buffer_th;
+extern int repl_prof_utimer;
+extern int repl_prof_timer_check;
+extern int repl_prof_timer_expire;
+int repl_prof_init(void);
+int repl_prof_remove(str *name, str *value);
+int repl_prof_dest(modparam_t type, void *val);
+int replicate_profiles_nr(void);
+int replicate_profiles_count(repl_prof_novalue_t *rp);
+struct mi_root * mi_profiles_bin_status(struct mi_root *, void *);
+
+#define REPLICATION_DLG_PROFILE		4
+#define DLG_REPL_PROF_TIMER			10
+#define DLG_REPL_PROF_EXPIRE_TIMER	10
+#define DLG_REPL_PROF_BUF_THRESHOLD	1400
+
+static inline repl_prof_novalue_t *repl_prof_allocate(void)
+{
+	repl_prof_novalue_t *rp;
+	int repl_len = replicate_profiles_nr();
+
+	if (!repl_len)
+		return NULL;
+	rp = shm_malloc(sizeof(repl_prof_novalue_t) +
+			repl_len * sizeof(repl_prof_count_t));
+	if (!rp) {
+		/* if there is no more shm memory, there's not much that you can do
+		 * anyway */
+		LM_WARN("no more shm mem\n");
+		return NULL;
+	}
+	memset(rp, 0, sizeof(repl_prof_novalue_t) + repl_len * sizeof(repl_prof_count_t));
+	lock_init(&rp->lock);
+
+	return rp;
+}
+
+static inline void repl_prof_inc(void **dst)
+{
+	repl_prof_value_t *rp;
+
+	if (accept_repl_profiles) {
+		/* if the destination does not exist, create it */
+		if (!*dst) {
+			rp = shm_malloc(sizeof(repl_prof_value_t));
+			if (!rp) {
+				LM_ERR("no more shm memory to allocate repl_prof_value\n");
+				return;
+			}
+			memset(rp, 0, sizeof(repl_prof_value_t));
+			*dst = rp;
+		} else {
+			rp = (repl_prof_value_t *)(*dst);
+		}
+		rp->counter++;
+	} else {
+		(*dst) = (void*)((long)(*dst) + 1);
+	}
+}
+
+static inline int repl_prof_get_all(void **dst)
+{
+	repl_prof_value_t *rp;
+	if (accept_repl_profiles) {
+		rp = (repl_prof_value_t *)(*dst);
+		if (!rp->noval)
+			return rp->counter;
+		return rp->counter + replicate_profiles_count(rp->noval);
+	} else {
+		return (int)(long)(*dst);
+	}
+}
+
+static inline void repl_prof_dec(void **dst)
+{
+	repl_prof_value_t *rp;
+	int counter;
+
+	if (accept_repl_profiles) {
+		rp = (repl_prof_value_t *)(*dst);
+		rp->counter--;
+		/* check all the others to see if we should delete the profile */
+		counter = repl_prof_get_all(dst);
+		if (counter == 0) {
+			if (rp->noval)
+				shm_free(rp->noval);
+			shm_free(rp);
+			*dst = 0;
+		}
+	} else {
+		(*dst) = (void*)((long)(*dst) - 1);
+	}
+}
+
+static inline int repl_prof_get(void **dst)
+{
+	repl_prof_value_t *rp;
+
+	if (accept_repl_profiles) {
+		rp = (repl_prof_value_t *)(*dst);
+		return rp->counter;
+	} else {
+		return (int)(long)(*dst);
+	}
+}
+
+
+#endif /* _DIALOG_DLG_PROFILE_REPLICATION_H_ */