Class: Thrift::MultiplexedProtocol

Inherits:
BaseProtocol show all
Defined in:
lib/thrift/protocol/multiplexed_protocol.rb

Instance Method Summary collapse

Methods inherited from BaseProtocol

#native?, #read_type, #skip, #write_field, #write_type

Constructor Details

#initialize(protocol, service_name) ⇒ MultiplexedProtocol

Returns a new instance of MultiplexedProtocol.



28
29
30
31
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 28

def initialize(protocol,service_name)
  @protocol = protocol
  @service_name = service_name
end

Instance Method Details

#read_binary ⇒ Object 



202
203
204
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 202

def read_binary
  @protocol.read_binary
end

#read_bool ⇒ Object 



174
175
176
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 174

def read_bool
  @protocol.read_bool
end

#read_byte ⇒ Object 



178
179
180
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 178

def read_byte
  @protocol.read_byte
end

#read_double ⇒ Object 



194
195
196
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 194

def read_double
  @protocol.read_double
end

#read_field_begin ⇒ Object 



142
143
144
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 142

def read_field_begin
  @protocol.read_field_begin
end

#read_field_end ⇒ Object 



146
147
148
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 146

def read_field_end
  @protocol.read_field_end
end

#read_i16 ⇒ Object 



182
183
184
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 182

def read_i16
  @protocol.read_i16
end

#read_i32 ⇒ Object 



186
187
188
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 186

def read_i32
  @protocol.read_i32
end

#read_i64 ⇒ Object 



190
191
192
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 190

def read_i64
  @protocol.read_i64
end

#read_list_begin ⇒ Object 



158
159
160
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 158

def read_list_begin
  @protocol.read_list_begin
end

#read_list_end ⇒ Object 



162
163
164
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 162

def read_list_end
  @protocol.read_list_end
end

#read_map_begin ⇒ Object 



150
151
152
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 150

def read_map_begin
  @protocol.read_map_begin
end

#read_map_end ⇒ Object 



154
155
156
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 154

def read_map_end
  @protocol.read_map_end
end

#read_message_begin ⇒ Object 



126
127
128
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 126

def read_message_begin
  @protocol.read_message_begin
end

#read_message_end ⇒ Object 



130
131
132
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 130

def read_message_end
  @protocol.read_message_end
end

#read_set_begin ⇒ Object 



166
167
168
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 166

def read_set_begin
  @protocol.read_set_begin
end

#read_set_end ⇒ Object 



170
171
172
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 170

def read_set_end
  @protocol.read_set_end
end

#read_string ⇒ Object 



198
199
200
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 198

def read_string
  @protocol.read_string
end

#read_struct_begin ⇒ Object 



134
135
136
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 134

def read_struct_begin
  @protocol.read_struct_begin
end

#read_struct_end ⇒ Object 



138
139
140
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 138

def read_struct_end
  @protocol.read_struct_end
end

#trans ⇒ Object 



33
34
35
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 33

def trans
  @protocol.trans
end

#write_binary(buf) ⇒ Object 



122
123
124
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 122

def write_binary(buf)
  @protocol.write_binary(buf)
end

#write_bool(bool) ⇒ Object 



94
95
96
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 94

def write_bool(bool)
  @protocol.write_bool(bool)
end

#write_byte(byte) ⇒ Object 



98
99
100
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 98

def write_byte(byte)
  @protocol.write_byte(byte)
end

#write_double(dub) ⇒ Object 



114
115
116
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 114

def write_double(dub)
  @protocol.write_double(dub)
end

#write_field_begin(name, type, id) ⇒ Object 



58
59
60
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 58

def write_field_begin(name, type, id)
  @protocol.write_field_begin(name, type, id)
end

#write_field_end ⇒ Object 



62
63
64
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 62

def write_field_end
  @protocol.write_field_end
end

#write_field_stop ⇒ Object 



66
67
68
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 66

def write_field_stop
  @protocol.write_field_stop
end

#write_i16(i16) ⇒ Object 



102
103
104
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 102

def write_i16(i16)
  @protocol.write_i16(i16)
end

#write_i32(i32) ⇒ Object 



106
107
108
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 106

def write_i32(i32)
  @protocol.write_i32(i32)
end

#write_i64(i64) ⇒ Object 



110
111
112
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 110

def write_i64(i64)
  @protocol.write_i64(i64)
end

#write_list_begin(etype, size) ⇒ Object 



78
79
80
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 78

def write_list_begin(etype, size)
  @protocol.write_list_begin(etype, size)
end

#write_list_end ⇒ Object 



82
83
84
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 82

def write_list_end
  @protocol.write_list_end
end

#write_map_begin(ktype, vtype, size) ⇒ Object 



70
71
72
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 70

def write_map_begin(ktype, vtype, size)
  @protocol.write_map_begin(ktype, vtype, size)
end

#write_map_end ⇒ Object 



74
75
76
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 74

def write_map_end
  @protocol.write_map_end
end

#write_message_begin(name, type, seqid) ⇒ Object 



37
38
39
40
41
42
43
44
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 37

def write_message_begin(name, type, seqid)
  case type
  when MessageTypes::CALL, MessageTypes::ONEWAY
    @protocol.write_message_begin(@service_name + ":" + name, type, seqid)
  else
    @protocol.write_message_begin(name, type, seqid)
  end 
end

#write_message_end ⇒ Object 



46
47
48
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 46

def write_message_end
  @protocol.write_message_end
end

#write_set_begin(etype, size) ⇒ Object 



86
87
88
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 86

def write_set_begin(etype, size)
  @protocol.write_set_begin(etype, size)
end

#write_set_end ⇒ Object 



90
91
92
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 90

def write_set_end
  @protocol.write_set_end
end

#write_string(str) ⇒ Object 



118
119
120
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 118

def write_string(str)
  @protocol.write_string(str)
end

#write_struct_begin(name) ⇒ Object 



50
51
52
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 50

def write_struct_begin(name)
  @protocol.write_struct_begin(name)
end

#write_struct_end ⇒ Object 



54
55
56
 
# File 'lib/thrift/protocol/multiplexed_protocol.rb', line 54

def write_struct_end
  @protocol.write_struct_end
end