]> scm.dxcluster.org Git - spider.git/blob - perl/IntMsg.pm
95c6ac74347793ce9f38f27d8af303bbe1265930
[spider.git] / perl / IntMsg.pm
1 #
2 # This class is the internal subclass that deals with the internal port 27754
3 # communications for Msg.pm
4 #
5 # $Id$
6 #
7 # Copyright (c) 2001 - Dirk Koopman G1TLH
8 #
9
10 package IntMsg;
11
12 use strict;
13
14 use vars qw($VERSION $BRANCH);
15 $VERSION = sprintf( "%d.%03d", q$Revision$ =~ /(\d+)\.(\d+)/ );
16 $BRANCH = sprintf( "%d.%03d", q$Revision$ =~ /\d+\.\d+\.(\d+)\.(\d+)/ ) || 0;
17 $main::build += $VERSION;
18 $main::branch += $BRANCH;
19
20 use Msg;
21
22 use vars qw(@ISA);
23
24 @ISA = qw(Msg);
25
26 sub enqueue
27 {
28         my ($conn, $msg) = @_;
29         $msg =~ s/([\%\x00-\x1f\x7f-\xff])/sprintf("%%%02X", ord($1))/eg; 
30     push (@{$conn->{outqueue}}, $msg . "\n");
31 }
32
33 sub dequeue
34 {
35         my $conn = shift;
36
37         if ($conn && $conn->{msg} =~ /\cJ/) {
38                 my @lines =  $conn->{msg} =~ /([^\cM\cJ]*)\cM?\cJ/g;
39                 if ($conn->{msg} =~ /\cJ$/) {
40                         delete $conn->{msg};
41                 } else {
42                         $conn->{msg} =~ s/([^\cM\cJ]*)\cM?\cJ//g;
43                 }
44                 for (@lines) {
45                         if (defined $_) {
46                                 s/\%([0-9A-F][0-9A-F])/chr(hex($1))/eg;
47                         } else {
48                                 $_ = '';
49                         }
50                         &{$conn->{rproc}}($conn, $_) if exists $conn->{rproc};
51                 }
52         }
53 }
54