ceph/src/jaegertracing/thrift/lib/go/thrift/deserializer.go

   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 package thrift
  21
  22 type TDeserializer struct {
  23         Transport TTransport
  24         Protocol  TProtocol
  25 }
  26
  27 func NewTDeserializer() *TDeserializer {
  28         var transport TTransport
  29         transport = NewTMemoryBufferLen(1024)
  30
  31         protocol := NewTBinaryProtocolFactoryDefault().GetProtocol(transport)
  32
  33         return &TDeserializer{
  34                 transport,
  35                 protocol}
  36 }
  37
  38 func (t *TDeserializer) ReadString(msg TStruct, s string) (err error) {
  39         err = nil
  40         if _, err = t.Transport.Write([]byte(s)); err != nil {
  41                 return
  42         }
  43         if err = msg.Read(t.Protocol); err != nil {
  44                 return
  45         }
  46         return
  47 }
  48
  49 func (t *TDeserializer) Read(msg TStruct, b []byte) (err error) {
  50         err = nil
  51         if _, err = t.Transport.Write(b); err != nil {
  52                 return
  53         }
  54         if err = msg.Read(t.Protocol); err != nil {
  55                 return
  56         }
  57         return
  58 }