projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
added Windows only BPQ interface from John G8BPQ
[spider.git]
/
perl
/
cluster.pl
diff --git
a/perl/cluster.pl
b/perl/cluster.pl
index 620c7e77c90a7500a5a8ee5b6d7904cd6ab090ef..0fe3b575a98588be279dac7e658f24170219a8e3 100755
(executable)
--- a/
perl/cluster.pl
+++ b/
perl/cluster.pl
@@
-102,6
+102,7
@@
use RouteDB;
use DXXml;
use DXSql;
use IsoTime;
use DXXml;
use DXSql;
use IsoTime;
+use BPQMsg;
use Data::Dumper;
use IO::File;
use Data::Dumper;
use IO::File;
@@
-260,6
+261,7
@@
sub cease
# disconnect AGW
AGWMsg::finish();
# disconnect AGW
AGWMsg::finish();
+ BPQMsg::finish();
# disconnect UDP customers
UDPMsg::finish();
# disconnect UDP customers
UDPMsg::finish();
@@
-411,6
+413,9
@@
foreach my $l (@main::listen) {
dbg("AGW Listener") if $AGWMsg::enable;
AGWrestart();
dbg("AGW Listener") if $AGWMsg::enable;
AGWrestart();
+dbg("BPQ Listener") if $BPQMsg::enable;
+BPQMsg::init(\&new_channel);
+
dbg("UDP Listener") if $UDPMsg::enable;
UDPMsg::init(\&new_channel);
dbg("UDP Listener") if $UDPMsg::enable;
UDPMsg::init(\&new_channel);
@@
-538,6
+543,7
@@
for (;;) {
DXUser::process();
DXDupe::process();
AGWMsg::process();
DXUser::process();
DXDupe::process();
AGWMsg::process();
+ BPQMsg::process();
if (defined &Local::process) {
eval {
if (defined &Local::process) {
eval {