1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
#!/usr/bin/env perl
# 1. Start sdedit and enable 'RT diagram server' in 'Global preferences'.
#
# 2. Start this tool (see defaults below):
# gnunet-logread-ipc-sdedit -n buffer-name -i /path/to/ipc.sock -h <sdedit-host> -p <sdedit-port>
#
# 3. Start a gnunet-logread instance for each component with the -n <component_name> option
use strict;
use warnings;
use Getopt::Std;
use IO::Socket::INET;
use POSIX qw(mkfifo);
my %opts;
getopts ('i:n:h:p:', \%opts);
my $ipc = $opts{i} || '/tmp/gnunet-logread-ipc.sock';
my $name = $opts{n} || 'gnunet';
my $host = $opts{h} || 'localhost';
my $port = $opts{p} || 16001;
my %svcs = map { $_ => 1 } @ARGV;
my $sdedit = IO::Socket::INET->new(PeerAddr => $host,
PeerPort => $port,
Proto => 'tcp')
or die "Cannot connect to $host:$port: $!\n";
print $sdedit "$name\n";
print $sdedit "_t:time[e]\n";
print $sdedit "$_:$_\[ap\] \"$_\"\n" for @ARGV;
print $sdedit "_e:ext[e]\n";
print $sdedit "\n";
mkfifo $ipc, 0600 or die "$ipc: $!\n" unless -e $ipc;
open IPC, '<', $ipc or die "$ipc: $!\n";
$| = 1;
while (<IPC>)
{
print;
my ($time, $from, $to, $msg, $svc);
if (my ($time, $from, $to, $msg) =
/^([A-Z][a-z]{2}\ .[0-9]\ [0-9:]{8}(?:-[0-9]{6})?)\s+
(\S+)\s+ -> \s+(\S+)\s+ (\S+\s+ \(\d+\))/x)
{
$from = '_e' unless exists $svcs{$from};
$to = '_e' unless exists $svcs{$to};
print $sdedit "*0 _t\n$time\n*0\n", "$from:$to.$msg\n"
}
elsif (($time, $svc, $msg) =
/^([A-Z][a-z]{2}\ .[0-9]\ [0-9:]{8}(?:-[0-9]{6})?)\s+
(\S+)\s+(.+)/x)
{
print $sdedit "*0 _t\n$time\n*0\n", "*0 $svc\n$msg\n*0\n"
}
}
close IPC;
|
