summaryrefslogtreecommitdiff
path: root/cpp/include/Ice/Outgoing.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/include/Ice/Outgoing.h')
-rw-r--r--cpp/include/Ice/Outgoing.h39
1 files changed, 20 insertions, 19 deletions
diff --git a/cpp/include/Ice/Outgoing.h b/cpp/include/Ice/Outgoing.h
index e44c1660a4e..b86819cd8d7 100644
--- a/cpp/include/Ice/Outgoing.h
+++ b/cpp/include/Ice/Outgoing.h
@@ -18,7 +18,8 @@
#include <Ice/InstanceF.h>
#include <Ice/ConnectionIF.h>
#include <Ice/ReferenceF.h>
-#include <Ice/BasicStream.h>
+#include <Ice/OutputStream.h>
+#include <Ice/InputStream.h>
#include <Ice/Current.h>
#include <Ice/ObserverHelper.h>
#include <Ice/ObjectAdapterF.h>
@@ -43,10 +44,10 @@ public:
virtual void sent() = 0;
virtual void completed(const Ice::Exception&) = 0;
- virtual void completed(BasicStream&) = 0;
+ virtual void completed(Ice::InputStream&) = 0;
virtual void retryException(const Ice::Exception&) = 0;
- BasicStream* os() { return &_os; }
+ Ice::OutputStream* os() { return &_os; }
void attachRemoteObserver(const Ice::ConnectionInfoPtr& c, const Ice::EndpointPtr& endpt, Ice::Int requestId)
{
@@ -64,7 +65,7 @@ protected:
OutgoingBase(Instance*);
- BasicStream _os;
+ Ice::OutputStream _os;
#ifdef ICE_CPP11_MAPPING
std::exception_ptr _exception;
#else
@@ -89,7 +90,7 @@ public:
virtual void sent();
virtual void completed(const Ice::Exception&);
- virtual void completed(BasicStream&);
+ virtual void completed(Ice::InputStream&);
virtual void retryException(const Ice::Exception&);
protected:
@@ -130,49 +131,49 @@ public:
bool invoke(); // Returns true if ok, false if user exception.
void abort(const Ice::LocalException&);
- virtual void completed(BasicStream&);
+ virtual void completed(Ice::InputStream&);
// Inlined for speed optimization.
- BasicStream* startReadParams()
+ Ice::InputStream* startReadParams()
{
- _is.startReadEncaps();
+ _is.startEncapsulation();
return &_is;
}
void endReadParams()
{
- _is.endReadEncaps();
+ _is.endEncapsulation();
}
void readEmptyParams()
{
- _is.skipEmptyEncaps();
+ _is.skipEmptyEncapsulation();
}
void readParamEncaps(const Ice::Byte*& encaps, Ice::Int& sz)
{
- _is.readEncaps(encaps, sz);
+ _is.readEncapsulation(encaps, sz);
}
- BasicStream* startWriteParams(Ice::FormatType format)
+ Ice::OutputStream* startWriteParams(Ice::FormatType format)
{
- _os.startWriteEncaps(_encoding, format);
+ _os.startEncapsulation(_encoding, format);
return &_os;
}
void endWriteParams()
{
- _os.endWriteEncaps();
+ _os.endEncapsulation();
}
void writeEmptyParams()
{
- _os.writeEmptyEncaps(_encoding);
+ _os.writeEmptyEncapsulation(_encoding);
}
void writeParamEncaps(const Ice::Byte* encaps, Ice::Int size)
{
if(size == 0)
{
- _os.writeEmptyEncaps(_encoding);
+ _os.writeEmptyEncapsulation(_encoding);
}
else
{
- _os.writeEncaps(encaps, size);
+ _os.writeEncapsulation(encaps, size);
}
}
@@ -186,7 +187,7 @@ public:
private:
Ice::EncodingVersion _encoding;
- BasicStream _is;
+ Ice::InputStream _is;
const std::string& _operation;
};
@@ -216,7 +217,7 @@ public:
virtual void sent();
virtual void completed(const Ice::Exception&);
- virtual void completed(BasicStream&);
+ virtual void completed(Ice::InputStream&);
virtual void retryException(const Ice::Exception&);
private: