ceph/src/jaegertracing/thrift/lib/php/lib/StoredMessageProtocol.php

   1 <?php
   2 /*
   3  * Licensed to the Apache Software Foundation (ASF) under one
   4  * or more contributor license agreements. See the NOTICE file
   5  * distributed with this work for additional information
   6  * regarding copyright ownership. The ASF licenses this file
   7  * to you under the Apache License, Version 2.0 (the
   8  * "License"); you may not use this file except in compliance
   9  * with the License. You may obtain a copy of the License at
  10  *
  11  *   http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing,
  14  * software distributed under the License is distributed on an
  15  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  16  * KIND, either express or implied. See the License for the
  17  * specific language governing permissions and limitations
  18  * under the License.
  19  *
  20  * @package thrift.processor
  21  */
  22
  23 namespace Thrift;
  24
  25 use Thrift\Protocol\TProtocol;
  26 use Thrift\Protocol\TProtocolDecorator;
  27
  28 /**
  29  *  Our goal was to work with any protocol. In order to do that, we needed
  30  *  to allow them to call readMessageBegin() and get the Message in exactly
  31  *  the standard format, without the service name prepended to the Message name.
  32  */
  33 class StoredMessageProtocol extends TProtocolDecorator
  34 {
  35     private $fname_;
  36     private $mtype_;
  37     private $rseqid_;
  38
  39     public function __construct(TProtocol $protocol, $fname, $mtype, $rseqid)
  40     {
  41         parent::__construct($protocol);
  42         $this->fname_  = $fname;
  43         $this->mtype_  = $mtype;
  44         $this->rseqid_ = $rseqid;
  45     }
  46
  47     public function readMessageBegin(&$name, &$type, &$seqid)
  48     {
  49         $name  = $this->fname_;
  50         $type  = $this->mtype_;
  51         $seqid = $this->rseqid_;
  52     }
  53 }