blob: 151298731011df2acc9f483b425b7f553ba15184 [file] [log] [blame]
#!/usr/bin/env perl
#
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
use strict;
use lib '../../lib/perl/lib';
use lib 'gen-perl';
use Thrift::Socket;
use Thrift::Server;
use Thrift::ServerSocket;
use tutorial::Calculator;
package CalculatorHandler;
use base qw(tutorial::CalculatorIf);
sub new {
my $classname = shift;
my $self = {};
return bless($self,$classname);
}
sub ping
{
print "ping()\n";
}
sub add
{
my($self, $n1, $n2) = @_;
printf("add(%d,%d)\n", $n1, $n2);
return $n1 + $n2;
}
sub calculate
{
my($self, $logid, $work) = @_;
my $op = $work->{op};
my $num1 = $work->{num1};
my $num2 = $work->{num2};
printf("calculate(%d, %d %d %d)\n", $logid, $num1, $num2, $op);
my $val;
if ($op == tutorial::Operation::ADD) {
$val = $num1 + $num2;
} elsif ($op == tutorial::Operation::SUBTRACT) {
$val = $num1 - $num2;
} elsif ($op == tutorial::Operation::MULTIPLY) {
$val = $num1 * $num2;
} elsif ($op == tutorial::Operation::DIVIDE) {
if ($num2 == 0)
{
my $x = tutorial::InvalidOperation->new();
$x->whatOp($op);
$x->why('Cannot divide by 0');
die $x;
}
$val = $num1 / $num2;
} else {
my $x = tutorial::InvalidOperation->new();
$x->whatOp($op);
$x->why('Invalid operation');
die $x;
}
my $log = shared::SharedStruct->new();
$log->key($logid);
$log->value(int($val));
$self->{log}->{$logid} = $log;
return $val;
}
sub getStruct
{
my($self, $key) = @_;
printf("getStruct(%d)\n", $key);
return $self->{log}->{$key};
}
sub zip
{
my($self) = @_;
print "zip()\n";
}
eval {
my $handler = CalculatorHandler->new();
my $processor = tutorial::CalculatorProcessor->new($handler);
my $serversocket = Thrift::ServerSocket->new(9090);
my $forkingserver = Thrift::ForkingServer->new($processor, $serversocket);
print "Starting the server...\n";
$forkingserver->serve();
print "done.\n";
}; if ($@) {
if ($@ =~ m/TException/ and exists $@->{message}) {
my $message = $@->{message};
my $code = $@->{code};
my $out = $code . ':' . $message;
die $out;
} else {
die $@;
}
}