From 58c83f507c7d244031f80f98349bb3025606147b Mon Sep 17 00:00:00 2001
From: tzafrir <tzafrir@5390a7c7-147a-4af0-8ec9-7488f05a26cb>
Date: Sat, 24 Feb 2007 01:05:05 +0000
Subject: Add the Zaptel and Zaptel::Xpp perl modules, and some simple
 utilities that use them. disabled by default for now.

git-svn-id: http://svn.digium.com/svn/zaptel/branches/1.2@2223 5390a7c7-147a-4af0-8ec9-7488f05a26cb
---
 xpp/utils/zconf/Zaptel/Xpp.pm | 88 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 88 insertions(+)
 create mode 100644 xpp/utils/zconf/Zaptel/Xpp.pm

(limited to 'xpp/utils/zconf/Zaptel/Xpp.pm')

diff --git a/xpp/utils/zconf/Zaptel/Xpp.pm b/xpp/utils/zconf/Zaptel/Xpp.pm
new file mode 100644
index 0000000..b627438
--- /dev/null
+++ b/xpp/utils/zconf/Zaptel/Xpp.pm
@@ -0,0 +1,88 @@
+package Zaptel::Xpp;
+#
+# Written by Oron Peled <oron@actcom.co.il>
+# Copyright (C) 2007, Xorcom
+# This program is free software; you can redistribute and/or
+# modify it under the same terms as Perl itself.
+#
+#use strict;
+use Zaptel::Xpp::Xbus;
+
+my $proc_base = "/proc/xpp";
+
+# Static Functions
+
+# Nominal sorters for xbuses
+sub by_name {
+	return $a cmp $b;
+}
+
+sub by_connector {
+	return $a->connector cmp $b->connector;
+}
+
+sub xbuses {
+	my $optsort = shift || 'SORT_NAME';
+	my @xbuses;
+
+	open(F, "$proc_base/xbuses") ||
+		die "$0: Failed to open $proc_base/xbuses. xpp module is loaded?\n";
+	while(<F>) {
+		chomp;
+		my ($name, @attr) = split;
+		$name =~ s/://;
+		$name =~ /XBUS-(\d\d)/ or die "Bad XBUS number: $name";
+		my $num = $1;
+		@attr = map { $_ = uc($_); split(/=/); } @attr;
+		my $xbus = Zaptel::Xpp::Xbus->new(NAME => $name, NUM => $num, @attr);
+		push(@xbuses, $xbus);
+	}
+	close F;
+	my $sorter;
+	if($optsort eq "SORT_CONNECTOR") {
+		$sorter = \&by_connector;
+	} elsif($optsort eq "SORT_NAME") {
+		$sorter = \&by_name;
+	} elsif(ref($optsort) eq 'CODE') {
+		$sorter = $optsort;
+	} else {
+		die "Unknown optional sorter '$optsort'";
+	}
+	return sort $sorter @xbuses;
+}
+
+sub sync {
+	my $newsync = shift;
+	my $result;
+	my $newapi = 0;
+
+	my $file = "$proc_base/sync";
+	die "$file is missing" unless -f $file;
+	# First query
+	open(F, "$file") or die "Failed to open $file for reading: $!";
+	while(<F>) {
+		chomp;
+		/SYNC=/ and $newapi = 1;
+		s/#.*//;
+		if(/\S/) {	# First non-comment line
+			s/^SYNC=\D*// if $newapi;
+			$result = $_;
+			last;
+		}
+	}
+	close F;
+	if(defined($newsync)) {		# Now change
+		open(F, ">$file") or die "Failed to open $file for writing: $!";
+		if($newsync eq 'HOST') {
+			print F "HOST";
+		} elsif($newsync =~ /^(\d+)$/) {
+			print F ($newapi)? "SYNC=$1" : "$1 0";
+		} else {
+			die "Bad sync parameter '$newsync'";
+		}
+		close(F) or die "Failed in closing $file: $!";
+	}
+	return $result;
+}
+
+1;
-- 
cgit v1.2.3