cs/test/Ice/background/Transceiver.cs

   1 // **********************************************************************
   2 //
   3 // Copyright (c) 2003-2011 ZeroC, Inc. All rights reserved.
   4 //
   5 // This copy of Ice is licensed to you under the terms described in the
   6 // ICE_LICENSE file included in this distribution.
   7 //
   8 // **********************************************************************
   9
  10 using System;
  11 using System.Net.Sockets;
  12
  13 internal class Transceiver : IceInternal.Transceiver
  14 {
  15     public int initialize()
  16     {
  17         _configuration.checkInitializeException();
  18         if(!_initialized)
  19         {
  20             int s = _transceiver.initialize();
  21             if(s != IceInternal.SocketOperation.None)
  22             {
  23                 return s;
  24             }
  25             _initialized = true;
  26         }
  27         return IceInternal.SocketOperation.None;
  28     }
  29
  30     public void close()
  31     {
  32         _transceiver.close();
  33     }
  34
  35     public bool write(IceInternal.Buffer buf)
  36     {
  37         if(!_initialized)
  38         {
  39             throw new Ice.SocketException();
  40         }
  41
  42         if(!_configuration.writeReady())
  43         {
  44             return false;
  45         }
  46
  47         _configuration.checkWriteException();
  48         return _transceiver.write(buf);
  49     }
  50
  51     public bool read(IceInternal.Buffer buf)
  52     {
  53         if(!_initialized)
  54         {
  55             throw new Ice.SocketException();
  56         }
  57
  58         if(!_configuration.readReady())
  59         {
  60             return false;
  61         }
  62
  63         _configuration.checkReadException();
  64         return _transceiver.read(buf);
  65     }
  66
  67     public bool startRead(IceInternal.Buffer buf, AsyncCallback callback, object state)
  68     {
  69         if(_configuration.readReady())
  70         {
  71             _configuration.checkReadException(); // Only raise if we're configured to read now.
  72         }
  73         return _transceiver.startRead(buf, callback, state);
  74     }
  75
  76     public void finishRead(IceInternal.Buffer buf)
  77     {
  78         _configuration.checkReadException();
  79         _transceiver.finishRead(buf);
  80     }
  81
  82     public bool startWrite(IceInternal.Buffer buf, AsyncCallback callback, object state, out bool completed)
  83     {
  84         _configuration.checkWriteException();
  85         return _transceiver.startWrite(buf, callback, state, out completed);
  86     }
  87
  88     public void finishWrite(IceInternal.Buffer buf)
  89     {
  90         _configuration.checkWriteException();
  91         _transceiver.finishWrite(buf);
  92     }
  93
  94     public string type()
  95     {
  96         return "test-" + _transceiver.type();
  97     }
  98
  99     public Ice.ConnectionInfo getInfo()
 100     {
 101         return _transceiver.getInfo();
 102     }
 103
 104     public override string ToString()
 105     {
 106         return _transceiver.ToString();
 107     }
 108
 109     public void checkSendSize(IceInternal.Buffer buf, int messageSizeMax)
 110     {
 111         _transceiver.checkSendSize(buf, messageSizeMax);
 112     }
 113
 114     //
 115     // Only for use by Connector, Acceptor
 116     //
 117     internal Transceiver(IceInternal.Transceiver transceiver)
 118     {
 119         _transceiver = transceiver;
 120         _configuration = Configuration.getInstance();
 121     }
 122
 123     private IceInternal.Transceiver _transceiver;
 124     private Configuration _configuration;
 125     private bool _initialized = false;
 126 }