package ILMT::KAN::HIN::Tokenizer; use strict; use warnings; use Dir::Self; use Data::Dumper; use IPC::Run qw(run); use List::UtilsBy qw(max_by); use File::Temp qw/ tempfile /; use File::Slurp qw( slurp ); my $cwd = __DIR__; my %daemons = ( "tokenizer" => { "path" => "ind-tokz", "args" => "--l kan --s --daemonize --port", "port" => "8111" } ); sub process { my %args = @_; utf8::encode($args{data}); my ($fh2, $filename2) = tempfile("tokenizer_inputXXXX", DIR => "/tmp", SUFFIX => ".tmp"); print $fh2 $args{"data"}; close($fh2); my $token_out; run ["python", "$cwd/tokenize.py", $filename2], ">", \$token_out; unlink $filename2 or die "Couldn't delete temp file! $filename2"; utf8::decode($token_out); return $token_out; } sub run_daemons { my @daemon_names = @_; foreach my $daemon_name (@daemon_names) { my %daemon = %{$daemons{$daemon_name}}; my $cmd = "$daemon{path} $daemon{args} $daemon{port} &"; my $runfile = __DIR__ . "/run/${daemon_name}_$daemon{port}"; system("flock -e -w 0.01 $runfile -c '$cmd'") == 0 or warn "[" . __PACKAGE__ . "]: Port $daemon{port} maybe unavailable! $?\n"; } } sub call_daemon { my ($daemon_name, $input) = @_; my $port = $daemons{$daemon_name}{port}; my ($socket, $client_socket); $socket = new IO::Socket::INET ( PeerHost => '127.0.0.1', PeerPort => $port, Proto => 'tcp', ) or die "ERROR in Socket Creation : $!\n"; $socket->send("$input\n"); my $result = ""; while (my $line = $socket->getline) { $result .= $line; } $socket->close(); return $result; } #run_daemons(("tokenizer")); 1;