lib/csharp/src/Transport/TTransport.cs

   1 //
   2 //  TTransport.cs
   3 //
   4 //  Begin:  Aug 19, 2007
   5 //  Authors:
   6 //              Todd Berman <tberman@imeem.com>
   7 //
   8 //  Copyright (C) 2007 imeem, inc. <http://www.imeem.com>
   9 //  All rights reserved.
  10 //
  11
  12 using System;
  13 using System.Collections.Generic;
  14 using System.Text;
  15
  16 namespace Thrift.Transport
  17 {
  18         public abstract class TTransport
  19         {
  20                 public abstract bool IsOpen
  21                 {
  22                         get;
  23                 }
  24
  25                 public bool Peek()
  26                 {
  27                         return IsOpen;
  28                 }
  29
  30                 public abstract void Open();
  31
  32                 public abstract void Close();
  33
  34                 public abstract int Read(byte[] buf, int off, int len);
  35
  36                 public int ReadAll(byte[] buf, int off, int len)
  37                 {
  38                         int got = 0;
  39                         int ret = 0;
  40
  41                         while (got < len)
  42                         {
  43                                 ret = Read(buf, off + got, len - got);
  44                                 if (ret <= 0)
  45                                 {
  46                                         throw new TTransportException("Cannot read, Remote side has closed");
  47                                 }
  48                                 got += ret;
  49                         }
  50
  51                         return got;
  52                 }
  53
  54                 public abstract void Write(byte[] buf, int off, int len);
  55
  56                 public virtual void Flush()
  57                 {
  58                 }
  59         }
  60 }