summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/Collector.cpp
diff options
context:
space:
mode:
authorMarc Laukien <marc@zeroc.com>2001-10-09 18:27:58 +0000
committerMarc Laukien <marc@zeroc.com>2001-10-09 18:27:58 +0000
commitca9e4073d50175daa12dba5f197f3324eb2722cc (patch)
treeee1813a45b738c456b4bc3eb72e19e78d1b35b36 /cpp/src/Ice/Collector.cpp
parentremoved pickler, native (diff)
downloadice-ca9e4073d50175daa12dba5f197f3324eb2722cc.tar.bz2
ice-ca9e4073d50175daa12dba5f197f3324eb2722cc.tar.xz
ice-ca9e4073d50175daa12dba5f197f3324eb2722cc.zip
IntStream
Diffstat (limited to 'cpp/src/Ice/Collector.cpp')
-rw-r--r--cpp/src/Ice/Collector.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/Ice/Collector.cpp b/cpp/src/Ice/Collector.cpp
index 747ba9df0ec..a7e75c70c90 100644
--- a/cpp/src/Ice/Collector.cpp
+++ b/cpp/src/Ice/Collector.cpp
@@ -73,16 +73,16 @@ IceInternal::Collector::readable() const
}
void
-IceInternal::Collector::read(Stream& stream)
+IceInternal::Collector::read(IntStream& stream)
{
_transceiver->read(stream, 0);
}
void
-IceInternal::Collector::message(Stream& stream)
+IceInternal::Collector::message(IntStream& stream)
{
Incoming in(_instance, _adapter);
- Stream* os = in.os();
+ IntStream* os = in.os();
bool invoke = false;
bool batch = false;
bool response = false;
@@ -442,7 +442,7 @@ IceInternal::Collector::setState(State state)
void
IceInternal::Collector::closeConnection()
{
- Stream os(_instance);
+ IntStream os(_instance);
os.write(protocolVersion);
os.write(encodingVersion);
os.write(closeConnectionMsg);
@@ -518,13 +518,13 @@ IceInternal::CollectorFactory::readable() const
}
void
-IceInternal::CollectorFactory::read(Stream&)
+IceInternal::CollectorFactory::read(IntStream&)
{
assert(false); // Must not be called
}
void
-IceInternal::CollectorFactory::message(Stream&)
+IceInternal::CollectorFactory::message(IntStream&)
{
JTCSyncT<JTCMutex> sync(*this);