summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ConnectionI.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/Ice/ConnectionI.cpp')
-rw-r--r--cpp/src/Ice/ConnectionI.cpp52
1 files changed, 2 insertions, 50 deletions
diff --git a/cpp/src/Ice/ConnectionI.cpp b/cpp/src/Ice/ConnectionI.cpp
index 30f1c9a8140..4d8171c6783 100644
--- a/cpp/src/Ice/ConnectionI.cpp
+++ b/cpp/src/Ice/ConnectionI.cpp
@@ -476,15 +476,6 @@ Ice::ConnectionI::monitor()
}
}
-//
-// TODO: Should not be a member function of Connection.
-//
-void
-Ice::ConnectionI::prepareRequest(BasicStream* os)
-{
- os->writeBlob(_requestHdr);
-}
-
void
Ice::ConnectionI::sendRequest(BasicStream* os, Outgoing* out, bool compress)
{
@@ -834,7 +825,7 @@ Ice::ConnectionI::prepareBatchRequest(BasicStream* os)
{
try
{
- _batchStream.writeBlob(_requestBatchHdr);
+ _batchStream.writeBlob(requestBatchHdr, sizeof(requestBatchHdr));
}
catch(const LocalException& ex)
{
@@ -1411,9 +1402,6 @@ Ice::ConnectionI::ConnectionI(const InstancePtr& instance,
_finishedCount(0),
_warn(_instance->properties()->getPropertyAsInt("Ice.Warn.Connections") > 0),
_acmTimeout(0),
- _requestHdr(headerSize + sizeof(Int), 0),
- _requestBatchHdr(headerSize + sizeof(Int), 0),
- _replyHdr(headerSize, 0),
_compressionLevel(1),
_nextRequestId(1),
_requestsHint(_requests.end()),
@@ -1443,42 +1431,6 @@ Ice::ConnectionI::ConnectionI(const InstancePtr& instance,
}
}
- vector<Byte>& requestHdr = const_cast<vector<Byte>&>(_requestHdr);
- requestHdr[0] = magic[0];
- requestHdr[1] = magic[1];
- requestHdr[2] = magic[2];
- requestHdr[3] = magic[3];
- requestHdr[4] = protocolMajor;
- requestHdr[5] = protocolMinor;
- requestHdr[6] = encodingMajor;
- requestHdr[7] = encodingMinor;
- requestHdr[8] = requestMsg;
- requestHdr[9] = 0;
-
- vector<Byte>& requestBatchHdr = const_cast<vector<Byte>&>(_requestBatchHdr);
- requestBatchHdr[0] = magic[0];
- requestBatchHdr[1] = magic[1];
- requestBatchHdr[2] = magic[2];
- requestBatchHdr[3] = magic[3];
- requestBatchHdr[4] = protocolMajor;
- requestBatchHdr[5] = protocolMinor;
- requestBatchHdr[6] = encodingMajor;
- requestBatchHdr[7] = encodingMinor;
- requestBatchHdr[8] = requestBatchMsg;
- requestBatchHdr[9] = 0;
-
- vector<Byte>& replyHdr = const_cast<vector<Byte>&>(_replyHdr);
- replyHdr[0] = magic[0];
- replyHdr[1] = magic[1];
- replyHdr[2] = magic[2];
- replyHdr[3] = magic[3];
- replyHdr[4] = protocolMajor;
- replyHdr[5] = protocolMinor;
- replyHdr[6] = encodingMajor;
- replyHdr[7] = encodingMinor;
- replyHdr[8] = replyMsg;
- replyHdr[9] = 0;
-
int& compressionLevel = const_cast<int&>(_compressionLevel);
compressionLevel = _instance->properties()->getPropertyAsIntWithDefault("Ice.Compression.Level", 1);
if(compressionLevel < 1)
@@ -2255,7 +2207,7 @@ Ice::ConnectionI::invokeAll(BasicStream& stream, Int invokeNum, Int requestId, B
if(response)
{
assert(invokeNum == 1); // No further invocations if a response is expected.
- os->writeBlob(_replyHdr);
+ os->writeBlob(replyHdr, sizeof(replyHdr));
//
// Add the request ID.