java/test/Ice/background/Transceiver.java

   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 package test.Ice.background;
  11
  12 final class Transceiver implements IceInternal.Transceiver
  13 {
  14     public java.nio.channels.SelectableChannel
  15     fd()
  16     {
  17         return _transceiver.fd();
  18     }
  19
  20     public int
  21     initialize()
  22     {
  23         int status = _configuration.initializeSocketStatus();
  24         if(status == IceInternal.SocketOperation.Connect || status == IceInternal.SocketOperation.Write)
  25         {
  26             if(!_initialized)
  27             {
  28                 status = _transceiver.initialize();
  29                 if(status != IceInternal.SocketOperation.None)
  30                 {
  31                     return status;
  32                 }
  33                 _initialized = true;
  34             }
  35             return IceInternal.SocketOperation.Write;
  36         }
  37         else if(status == IceInternal.SocketOperation.Read)
  38         {
  39             return status;
  40         }
  41
  42         _configuration.checkInitializeException();
  43         if(!_initialized)
  44         {
  45             status = _transceiver.initialize();
  46             if(status != IceInternal.SocketOperation.None)
  47             {
  48                 return status;
  49             }
  50             _initialized = true;
  51         }
  52         return IceInternal.SocketOperation.None;
  53     }
  54
  55     public void
  56     close()
  57     {
  58         _transceiver.close();
  59     }
  60
  61     public boolean
  62     write(IceInternal.Buffer buf)
  63     {
  64         if(!_initialized)
  65         {
  66             throw new Ice.SocketException();
  67         }
  68
  69         if(!_configuration.writeReady())
  70         {
  71             return false;
  72         }
  73         _configuration.checkWriteException();
  74         return _transceiver.write(buf);
  75     }
  76
  77     public boolean
  78     read(IceInternal.Buffer buf, Ice.BooleanHolder moreData)
  79     {
  80         if(!_initialized)
  81         {
  82             throw new Ice.SocketException();
  83         }
  84
  85         if(!moreData.value)
  86         {
  87             if(!_configuration.readReady())
  88             {
  89                 return false;
  90             }
  91         }
  92         _configuration.checkReadException();
  93         return _transceiver.read(buf, moreData);
  94     }
  95
  96     public String
  97     type()
  98     {
  99         return "test-" + _transceiver.type();
 100     }
 101
 102     public String
 103     toString()
 104     {
 105         return _transceiver.toString();
 106     }
 107
 108     public Ice.ConnectionInfo
 109     getInfo()
 110     {
 111         return _transceiver.getInfo();
 112     }
 113
 114     public void
 115     checkSendSize(IceInternal.Buffer buf, int messageSizeMax)
 116     {
 117         _transceiver.checkSendSize(buf, messageSizeMax);
 118     }
 119
 120     //
 121     // Only for use by Connector, Acceptor
 122     //
 123     Transceiver(Configuration configuration, IceInternal.Transceiver transceiver)
 124     {
 125         _transceiver = transceiver;
 126         _configuration = configuration;
 127     }
 128
 129     protected synchronized void
 130     finalize()
 131         throws Throwable
 132     {
 133         super.finalize();
 134     }
 135
 136     final private IceInternal.Transceiver _transceiver;
 137     final private Configuration _configuration;
 138     private boolean _initialized = false;
 139 }