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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
#
# 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 Test::More tests => 2;
use strict;
use warnings;
use Thrift::BinaryProtocol;
use Thrift::MemoryBuffer;
use Thrift::MessageType;
use ThriftTest::ThriftTest;
use ThriftTest::Types;
use Data::Dumper;
my $buffer = Thrift::MemoryBuffer->new(1024);
my $protocol = Thrift::BinaryProtocol->new($buffer);
my $client = ThriftTest::ThriftTestClient->new($protocol);
$buffer->open();
$client->send_testString("foo");
$client->{seqid}++;
$client->send_testString("bar");
my $client_command_binary = $buffer->getBuffer;
$buffer->resetBuffer;
# Process by server
my $server_output_binary;
{
my $protocol_factory = Thrift::BinaryProtocolFactory->new();
my $input_buffer = Thrift::MemoryBuffer->new();
$input_buffer->write($client_command_binary);
my $input_protocol = $protocol_factory->getProtocol($input_buffer);
my $output_buffer = Thrift::MemoryBuffer->new();
my $output_protocol = $protocol_factory->getProtocol($output_buffer);
my $processor = ThriftTest::ThriftTestProcessor->new( My::ThriftTest->new() );
my $result = $processor->process($input_protocol, $output_protocol);
print "process resulted in $result\n";
$result = $processor->process($input_protocol, $output_protocol);
print "process resulted in $result\n";
$server_output_binary = $output_buffer->getBuffer();
}
$buffer->write($server_output_binary);
foreach my $val (("got foo","got bar")){
my ($function_name, $message_type, $sequence_id);
$protocol->readMessageBegin(\$function_name, \$message_type, \$sequence_id);
print " $function_name, $message_type, $sequence_id\n";
if ($message_type == Thrift::TMessageType::EXCEPTION) {
die;
}
my $result = ThriftTest::ThriftTest_testString_result->new();
$result->read($protocol);
$protocol->readMessageEnd();
is($result->success(),$val);
}
package My::ThriftTest;
use strict;
use warnings;
use Data::Dumper;
sub new {
my $class = shift;
return bless {}, $class;
}
sub testString {
my ($self, $string) = @_;
print __PACKAGE__ . "->testString()\n";
return "got ".$string;
}
|
