diff options
author | Bernard Normier <bernard@zeroc.com> | 2007-02-01 17:09:49 +0000 |
---|---|---|
committer | Bernard Normier <bernard@zeroc.com> | 2007-02-01 17:09:49 +0000 |
commit | abada90e3f84dc703b8ddc9efcbed8a946fadead (patch) | |
tree | 2c6f9dccd510ea97cb927a7bd635422efaae547a /cs/src/Ice/InputStreamI.cs | |
parent | removing trace message (diff) | |
download | ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.tar.bz2 ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.tar.xz ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.zip |
Expanded tabs into spaces
Diffstat (limited to 'cs/src/Ice/InputStreamI.cs')
-rw-r--r-- | cs/src/Ice/InputStreamI.cs | 374 |
1 files changed, 187 insertions, 187 deletions
diff --git a/cs/src/Ice/InputStreamI.cs b/cs/src/Ice/InputStreamI.cs index ea1e19142a6..21ff63d94fa 100644 --- a/cs/src/Ice/InputStreamI.cs +++ b/cs/src/Ice/InputStreamI.cs @@ -11,192 +11,192 @@ namespace Ice { public class InputStreamI : InputStream { - public InputStreamI(Communicator communicator, byte[] data) - { - _communicator = communicator; - - _is = new IceInternal.BasicInputStream(Util.getInstance(communicator), this); - _is.resize(data.Length, true); - IceInternal.ByteBuffer buf = _is.prepareRead(); - buf.position(0); - buf.put(data); - buf.position(0); - } - - public Communicator communicator() - { - return _communicator; - } - - public void sliceObjects(bool slice) - { - _is.sliceObjects(slice); - } - - public bool readBool() - { - return _is.readBool(); - } - - public bool[] readBoolSeq() - { - return _is.readBoolSeq(); - } - - public byte readByte() - { - return _is.readByte(); - } - - public byte[] readByteSeq() - { - return _is.readByteSeq(); - } - - public short readShort() - { - return _is.readShort(); - } - - public short[] readShortSeq() - { - return _is.readShortSeq(); - } - - public int readInt() - { - return _is.readInt(); - } - - public int[] readIntSeq() - { - return _is.readIntSeq(); - } - - public long readLong() - { - return _is.readLong(); - } - - public long[] readLongSeq() - { - return _is.readLongSeq(); - } - - public float readFloat() - { - return _is.readFloat(); - } - - public float[] readFloatSeq() - { - return _is.readFloatSeq(); - } - - public double readDouble() - { - return _is.readDouble(); - } - - public double[] readDoubleSeq() - { - return _is.readDoubleSeq(); - } - - public string readString() - { - return _is.readString(); - } - - public string[] readStringSeq() - { - return _is.readStringSeq(); - } - - public int readSize() - { - return _is.readSize(); - } - - public ObjectPrx readProxy() - { - return _is.readProxy(); - } - - private class Patcher : IceInternal.Patcher - { - public Patcher(ReadObjectCallback cb) - { - _cb = cb; - } - - public override void patch(Ice.Object v) - { - _cb.invoke(v); - } - - public override string type() - { - return "unknown"; - } - - ReadObjectCallback _cb; - } - - public void readObject(ReadObjectCallback cb) - { - _is.readObject(new Patcher(cb)); - } - - public string readTypeId() - { - return _is.readTypeId(); - } - - public void throwException() - { - _is.throwException(); - } - - public void startSlice() - { - _is.startReadSlice(); - } - - public void endSlice() - { - _is.endReadSlice(); - } - - public void skipSlice() - { - _is.skipSlice(); - } - - public void startEncapsulation() - { - _is.startReadEncaps(); - } - - public void endEncapsulation() - { - _is.endReadEncaps(); - } - - public void readPendingObjects() - { - _is.readPendingObjects(); - } - - public void destroy() - { - if(_is != null) - { - _is = null; - } - } - - private Communicator _communicator; - private IceInternal.BasicInputStream _is; + public InputStreamI(Communicator communicator, byte[] data) + { + _communicator = communicator; + + _is = new IceInternal.BasicInputStream(Util.getInstance(communicator), this); + _is.resize(data.Length, true); + IceInternal.ByteBuffer buf = _is.prepareRead(); + buf.position(0); + buf.put(data); + buf.position(0); + } + + public Communicator communicator() + { + return _communicator; + } + + public void sliceObjects(bool slice) + { + _is.sliceObjects(slice); + } + + public bool readBool() + { + return _is.readBool(); + } + + public bool[] readBoolSeq() + { + return _is.readBoolSeq(); + } + + public byte readByte() + { + return _is.readByte(); + } + + public byte[] readByteSeq() + { + return _is.readByteSeq(); + } + + public short readShort() + { + return _is.readShort(); + } + + public short[] readShortSeq() + { + return _is.readShortSeq(); + } + + public int readInt() + { + return _is.readInt(); + } + + public int[] readIntSeq() + { + return _is.readIntSeq(); + } + + public long readLong() + { + return _is.readLong(); + } + + public long[] readLongSeq() + { + return _is.readLongSeq(); + } + + public float readFloat() + { + return _is.readFloat(); + } + + public float[] readFloatSeq() + { + return _is.readFloatSeq(); + } + + public double readDouble() + { + return _is.readDouble(); + } + + public double[] readDoubleSeq() + { + return _is.readDoubleSeq(); + } + + public string readString() + { + return _is.readString(); + } + + public string[] readStringSeq() + { + return _is.readStringSeq(); + } + + public int readSize() + { + return _is.readSize(); + } + + public ObjectPrx readProxy() + { + return _is.readProxy(); + } + + private class Patcher : IceInternal.Patcher + { + public Patcher(ReadObjectCallback cb) + { + _cb = cb; + } + + public override void patch(Ice.Object v) + { + _cb.invoke(v); + } + + public override string type() + { + return "unknown"; + } + + ReadObjectCallback _cb; + } + + public void readObject(ReadObjectCallback cb) + { + _is.readObject(new Patcher(cb)); + } + + public string readTypeId() + { + return _is.readTypeId(); + } + + public void throwException() + { + _is.throwException(); + } + + public void startSlice() + { + _is.startReadSlice(); + } + + public void endSlice() + { + _is.endReadSlice(); + } + + public void skipSlice() + { + _is.skipSlice(); + } + + public void startEncapsulation() + { + _is.startReadEncaps(); + } + + public void endEncapsulation() + { + _is.endReadEncaps(); + } + + public void readPendingObjects() + { + _is.readPendingObjects(); + } + + public void destroy() + { + if(_is != null) + { + _is = null; + } + } + + private Communicator _communicator; + private IceInternal.BasicInputStream _is; } } |