mcs/class/RabbitMQ.Client/src/client/impl/ContentHeaderPropertyReader.cs

   1 // This source code is dual-licensed under the Apache License, version
   2 // 2.0, and the Mozilla Public License, version 1.1.
   3 //
   4 // The APL v2.0:
   5 //
   6 //---------------------------------------------------------------------------
   7 //   Copyright (C) 2007, 2008 LShift Ltd., Cohesive Financial
   8 //   Technologies LLC., and Rabbit Technologies Ltd.
   9 //
  10 //   Licensed under the Apache License, Version 2.0 (the "License");
  11 //   you may not use this file except in compliance with the License.
  12 //   You may obtain a copy of the License at
  13 //
  14 //       http://www.apache.org/licenses/LICENSE-2.0
  15 //
  16 //   Unless required by applicable law or agreed to in writing, software
  17 //   distributed under the License is distributed on an "AS IS" BASIS,
  18 //   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  19 //   See the License for the specific language governing permissions and
  20 //   limitations under the License.
  21 //---------------------------------------------------------------------------
  22 //
  23 // The MPL v1.1:
  24 //
  25 //---------------------------------------------------------------------------
  26 //   The contents of this file are subject to the Mozilla Public License
  27 //   Version 1.1 (the "License"); you may not use this file except in
  28 //   compliance with the License. You may obtain a copy of the License at
  29 //   http://www.rabbitmq.com/mpl.html
  30 //
  31 //   Software distributed under the License is distributed on an "AS IS"
  32 //   basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the
  33 //   License for the specific language governing rights and limitations
  34 //   under the License.
  35 //
  36 //   The Original Code is The RabbitMQ .NET Client.
  37 //
  38 //   The Initial Developers of the Original Code are LShift Ltd.,
  39 //   Cohesive Financial Technologies LLC., and Rabbit Technologies Ltd.
  40 //
  41 //   Portions created by LShift Ltd., Cohesive Financial Technologies
  42 //   LLC., and Rabbit Technologies Ltd. are Copyright (C) 2007, 2008
  43 //   LShift Ltd., Cohesive Financial Technologies LLC., and Rabbit
  44 //   Technologies Ltd.;
  45 //
  46 //   All Rights Reserved.
  47 //
  48 //   Contributor(s): ______________________________________.
  49 //
  50 //---------------------------------------------------------------------------
  51 using System;
  52 using System.Collections;
  53 using RabbitMQ.Client;
  54 using RabbitMQ.Client.Exceptions;
  55 using RabbitMQ.Util;
  56
  57 namespace RabbitMQ.Client.Impl
  58 {
  59     public class ContentHeaderPropertyReader
  60     {
  61         private NetworkBinaryReader m_reader;
  62
  63         public NetworkBinaryReader BaseReader { get { return m_reader; } }
  64
  65         protected ushort m_flagWord;
  66         protected ushort m_bitCount;
  67
  68         public ContentHeaderPropertyReader(NetworkBinaryReader reader)
  69         {
  70             m_reader = reader;
  71             m_flagWord = 1; // just the continuation bit
  72             m_bitCount = 15; // the correct position to force a m_flagWord read
  73         }
  74
  75         public bool ContinuationBitSet { get { return ((m_flagWord & 1) != 0); } }
  76
  77         public void ReadFlagWord()
  78         {
  79             if (!ContinuationBitSet)
  80             {
  81                 throw new MalformedFrameException("Attempted to read flag word when none advertised");
  82             }
  83             m_flagWord = m_reader.ReadUInt16();
  84             m_bitCount = 0;
  85         }
  86
  87         public bool ReadPresence()
  88         {
  89             if (m_bitCount == 15)
  90             {
  91                 ReadFlagWord();
  92             }
  93
  94             int bit = 15 - m_bitCount;
  95             bool result = (m_flagWord & (1 << bit)) != 0;
  96             m_bitCount++;
  97             return result;
  98         }
  99
 100         public void FinishPresence()
 101         {
 102             if (ContinuationBitSet)
 103             {
 104                 throw new MalformedFrameException("Unexpected continuation flag word");
 105             }
 106         }
 107
 108         public bool ReadBit()
 109         {
 110             return ReadPresence();
 111         }
 112
 113         public byte ReadOctet()
 114         {
 115             return WireFormatting.ReadOctet(m_reader);
 116         }
 117
 118         public string ReadShortstr()
 119         {
 120             return WireFormatting.ReadShortstr(m_reader);
 121         }
 122
 123         public byte[] ReadLongstr()
 124         {
 125             return WireFormatting.ReadLongstr(m_reader);
 126         }
 127
 128         public ushort ReadShort()
 129         {
 130             return WireFormatting.ReadShort(m_reader);
 131         }
 132
 133         public uint ReadLong()
 134         {
 135             return WireFormatting.ReadLong(m_reader);
 136         }
 137
 138         public ulong ReadLonglong()
 139         {
 140             return WireFormatting.ReadLonglong(m_reader);
 141         }
 142
 143         public IDictionary ReadTable()
 144         {
 145             return WireFormatting.ReadTable(m_reader);
 146         }
 147
 148         public AmqpTimestamp ReadTimestamp()
 149         {
 150             return WireFormatting.ReadTimestamp(m_reader);
 151         }
 152     }
 153 }