X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXCommandmode.pm;h=aef8d84c9bc048cc526bbfb9ffd4a2e05e98fc80;hb=4b49fe47b37249d748f0a52fe2a778d4bc27232f;hp=1e3efc47fd97bc6ecae12f506bcca9b3ede6f857;hpb=a76624e4742348ed0f39c7c3f732cdec8462da9e;p=spider.git diff --git a/perl/DXCommandmode.pm b/perl/DXCommandmode.pm index 1e3efc47..aef8d84c 100644 --- a/perl/DXCommandmode.pm +++ b/perl/DXCommandmode.pm @@ -37,6 +37,7 @@ use DB_File; use VE7CC; use DXXml; use AsyncMsg; +use JSON; use Mojo::IOLoop; use Mojo::IOLoop::ForkCall; @@ -122,6 +123,7 @@ sub start $self->{ann_talk} = $user->wantann_talk; $self->{here} = 1; $self->{prompt} = $user->prompt if $user->prompt; + $self->{lastmsgpoll} = 0; # sort out new dx spot stuff $user->wantdxcq(0) unless defined $user->{wantdxcq}; @@ -564,7 +566,7 @@ sub process my $dxchan; foreach $dxchan (@dxchan) { - next if $dxchan->sort ne 'U'; + next unless $dxchan->{sort} eq 'U'; # send a outstanding message prompt if required if ($t >= $dxchan->lastmsgpoll + $msgpolltime) { @@ -1090,7 +1092,7 @@ sub broadcast_debug { my $s = shift; # the line to be rebroadcast - foreach my $dxchan (DXChannel::get_all) { + foreach my $dxchan (DXChannel::get_all_users) { next unless $dxchan->{enhanced} && $dxchan->{senddbg}; if ($dxchan->{gtk}) { $dxchan->send_later('L', dd(['db', $s])); @@ -1166,6 +1168,9 @@ sub import_cmd my @names = readdir(DIR); closedir(DIR); my $name; + + return unless @names; + foreach $name (@names) { next if $name =~ /^\./; @@ -1248,9 +1253,13 @@ sub send_motd # Punt off a long running command into a separate process # -# Hhis is called from commands to run some potentially long running +# This is called from commands to run some potentially long running # function. The process forks and then runs the function and returns # the result back to the cmd. +# +# NOTE: this merely forks the current process and then runs the cmd in that (current) context. +# IT DOES NOT START UP SOME NEW PROGRAM AND RELIES ON THE FACT THAT IT IS RUNNING DXSPIDER +# THE CURRENT CONTEXT!! # # call: $self->spawn_cmd(\, [cb => sub{...}], [prefix => "cmd> "], [progress => 0|1], [args => [...]]); sub spawn_cmd @@ -1269,6 +1278,8 @@ sub spawn_cmd no strict 'refs'; my $fc = Mojo::IOLoop::ForkCall->new; + $fc->serializer(\&encode_json); + $fc->deserializer(\&decode_json); $fc->run( sub {my @args = @_; my @res = $cmdref->(@args); return @res}, $args,