]>
git.proxmox.com Git - ceph.git/blob - ceph/src/jaegertracing/thrift/lib/rb/lib/thrift/protocol/multiplexed_protocol.rb
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
10 # http://www.apache.org/licenses/LICENSE-2.0
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
19 require 'thrift/protocol/protocol_decorator'
22 class MultiplexedProtocol
< BaseProtocol
24 include ProtocolDecorator
26 def initialize(protocol
, service_name
)
28 @service_name = service_name
31 def write_message_begin(name
, type
, seqid
)
33 when MessageTypes
::CALL, MessageTypes
::ONEWAY
34 @protocol.write_message_begin("#{@service_name}:#{name}", type
, seqid
)
36 @protocol.write_message_begin(name
, type
, seqid
)
41 "multiplexed(#{@service_name=@protocol.to_s})"