Subversion Repositories SmartDukaan

Rev

Rev 30 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
30 ashish 1
#
2
# Licensed to the Apache Software Foundation (ASF) under one
3
# or more contributor license agreements. See the NOTICE file
4
# distributed with this work for additional information
5
# regarding copyright ownership. The ASF licenses this file
6
# to you under the Apache License, Version 2.0 (the
7
# "License"); you may not use this file except in compliance
8
# with the License. You may obtain a copy of the License at
9
#
10
#   http://www.apache.org/licenses/LICENSE-2.0
11
#
12
# Unless required by applicable law or agreed to in writing,
13
# software distributed under the License is distributed on an
14
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15
# KIND, either express or implied. See the License for the
16
# specific language governing permissions and limitations
17
# under the License.
18
#
19
 
20
$:.push File.dirname(__FILE__) + '/../gen-rb'
21
$:.push File.join(File.dirname(__FILE__), '../../../lib/rb/lib')
22
$:.push File.join(File.dirname(__FILE__), '../../../lib/rb/ext')
23
 
24
require 'thrift'
25
require 'ThriftTest'
26
 
27
class SimpleHandler
28
  [:testString, :testByte, :testI32, :testI64, :testDouble,
29
   :testStruct, :testMap, :testSet, :testList, :testNest,
30
   :testEnum, :testTypedef].each do |meth|
31
 
32
    define_method(meth) do |thing|
33
      thing
34
    end
35
 
36
  end
37
 
38
  def testInsanity(thing)
39
    num, uid = thing.userMap.find { true }
40
    return {uid => {num => thing}}
41
  end
42
 
43
  def testMapMap(thing)
44
    return {thing => {thing => thing}}
45
  end
46
 
47
  def testEnum(thing)
48
    return thing
49
  end
50
 
51
  def testTypedef(thing)
52
    return thing
53
  end
54
 
55
  def testException(thing)
56
    raise Thrift::Test::Xception, :message => 'error'
57
  end
58
end
59
 
60
@handler   = SimpleHandler.new
61
@processor = Thrift::Test::ThriftTest::Processor.new(@handler)
62
@transport = Thrift::ServerSocket.new(9090)
63
@server    = Thrift::ThreadedServer.new(@processor, @transport, Thrift::BufferedTransportFactory.new, Thrift::BinaryProtocolAcceleratedFactory.new)
64
 
65
@server.serve