Added initial support for forwarding calls inside a cluster.

git-svn-id: http://voip.null.ro/svn/yate@1660 acf43c95-373e-0410-b603-e72c3f656dc1

conf.d/clustering.conf.sample

@@ -0,0 +1,24 @@
+[general]
+; Global settings of the clustering module
+
+; enabled: boolean: Enable clustering module operation
+;enabled=true if regexp and callto are set, false if any of them is empty
+
+; prefix: string: Prefix used for cluster resources
+;prefix=cluster
+
+; regexp: string: Regular expression describing node name match rules
+;regexp=
+
+; callto: string: Template for forwarding the call to target node
+;callto=
+
+
+[priorities]
+; Handler priorities for each message
+
+; call.route: int: Priority of route message handler (on target node)
+;call.route=50
+
+; call.execute: int: Priority of execute message handler (on source node)
+;call.execute=50

modules/Makefile.in

@@ -35,7 +35,7 @@ PROGS := cdrbuild.yate cdrfile.yate regexroute.yate \
 	server/regfile.yate server/accfile.yate server/register.yate \
 	server/yradius.yate \
 	server/sipfeatures.yate \
-	server/heartbeat.yate \
+	server/heartbeat.yate server/clustering.yate \
 	server/mgcpgw.yate server/mgcpca.yate \
 	server/mrcpspeech.yate \
 	server/ysigchan.yate \

modules/server/clustering.cpp

@@ -0,0 +1,145 @@
+/**
+ * clustering.cpp
+ * This file is part of the YATE Project http://YATE.null.ro
+ *
+ * Clustering server support.
+ *
+ * Yet Another Telephony Engine - a fully featured software PBX and IVR
+ * Copyright (C) 2004-2006 Null Team
+ *
+ * This program 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.
+ *
+ * This program 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA.
+ */
+
+#include <yatephone.h>
+
+using namespace TelEngine;
+namespace { // anonymous
+
+class ClusterModule : public Module
+{
+public:
+    ClusterModule();
+    ~ClusterModule();
+    virtual void initialize();
+    virtual bool received(Message& msg, int id);
+    virtual bool msgRoute(Message& msg);
+    virtual bool msgExecute(Message& msg);
+private:
+    String m_prefix;
+    String m_callto;
+    Regexp m_regexp;
+    bool m_init;
+};
+
+INIT_PLUGIN(ClusterModule);
+
+
+bool ClusterModule::msgRoute(Message& msg)
+{
+    String called = msg.getValue("called");
+    if (called.null())
+	return false;
+    Lock lock(this);
+    if (!called.startSkip(m_prefix,false))
+	return false;
+    lock.drop();
+    if (called.trimBlanks().null())
+	return false;
+    Debug(&__plugin,DebugInfo,"Got call to '%s' on this node",called.c_str());
+    msg.setParam("called",called);
+    return false;
+}
+
+bool ClusterModule::msgExecute(Message& msg)
+{
+    String callto = msg.getValue("callto");
+    if (callto.null())
+	return false;
+    String tmp = callto;
+    Lock lock(this);
+    if (!callto.startSkip(m_prefix,false))
+	return false;
+    int sep = callto.find("/");
+    if (sep < 0)
+	return false;
+    String node = callto.substr(0,sep).trimBlanks();
+    callto = callto.substr(sep+1);
+    if (callto.trimBlanks().null())
+	return false;
+    DDebug(&__plugin,DebugAll,"Call to '%s' on node '%s'",callto.c_str(),node.c_str());
+    msg.setParam("callto",callto);
+    // if the call is for the local node just let it through
+    if (node.null() || (Engine::nodeName() == node))
+	return false;
+    if (!node.matches(m_regexp)) {
+	msg.setParam("callto",tmp);
+	return false;
+    }
+    String dest = node.replaceMatches(m_callto);
+    lock.drop();
+    msg.replaceParams(dest);
+    if (dest.trimBlanks().null()) {
+	msg.setParam("callto",tmp);
+	return false;
+    }
+    Debug(&__plugin,DebugInfo,"Call to '%s' on node '%s' goes to '%s'",
+	callto.c_str(),node.c_str(),dest.c_str());
+    msg.setParam("callto",dest);
+    msg.setParam("osip_x-callto",callto);
+    msg.setParam("osip_x-billid",msg.getValue("billid"));
+    msg.setParam("osip_x-nodename",Engine::nodeName());
+    msg.setParam("osip_x-username",msg.getValue("username"));
+    return false;
+}
+
+bool ClusterModule::received(Message& msg, int id)
+{
+    return (Execute == id) ? msgExecute(msg) : Module::received(msg,id);
+}
+
+ClusterModule::ClusterModule()
+    : Module("clustering","misc",true),
+      m_init(false)
+{
+    Output("Loaded module Clustering");
+}
+
+ClusterModule::~ClusterModule()
+{
+    Output("Unloading module Clustering");
+}
+
+void ClusterModule::initialize()
+{
+    Output("Initializing module Clustering");
+    Configuration cfg(Engine::configFile("clustering"));
+    lock();
+    m_prefix = cfg.getValue("general","prefix","cluster");
+    if (!m_prefix.endsWith("/"))
+	m_prefix += "/";
+    m_regexp = cfg.getValue("general","regexp");
+    m_callto = cfg.getValue("general","callto");
+    unlock();
+    if (!m_init && cfg.getBoolValue("general","enabled",(m_callto && m_regexp))) {
+	setup();
+	installRelay(Route,cfg.getIntValue("priorities","call.route",50));
+	installRelay(Execute,cfg.getIntValue("priorities","call.execute",50));
+	m_init = true;
+    }
+}
+
+}; // anonymous namespace
+
+/* vi: set ts=8 sw=4 sts=4 noet: */

packing/rpm/yate.spec.in

@@ -92,6 +92,7 @@ for small to large scale projects.
 %{_libdir}/yate/client/osschan.yate
 %{_libdir}/yate/ilbccodec.yate
 %{_libdir}/yate/server/heartbeat.yate
+%{_libdir}/yate/server/clustering.yate
 %{_libdir}/yate/server/mgcpca.yate
 %{_libdir}/yate/server/mgcpgw.yate
 %{_libdir}/yate/server/mrcpspeech.yate
@@ -122,6 +123,7 @@ for small to large scale projects.
 %config(noreplace) %{_sysconfdir}/yate/ysipchan.conf
 %config(noreplace) %{_sysconfdir}/yate/yjinglechan.conf
 %config(noreplace) %{_sysconfdir}/yate/heartbeat.conf
+%config(noreplace) %{_sysconfdir}/yate/clustering.conf
 %config(noreplace) %{_sysconfdir}/yate/mgcpca.conf
 %config(noreplace) %{_sysconfdir}/yate/mgcpgw.conf
 %config(noreplace) %{_sysconfdir}/yate/analog.conf