summaryrefslogtreecommitdiff
path: root/cppe/src/IceE/Connection.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cppe/src/IceE/Connection.cpp')
-rwxr-xr-xcppe/src/IceE/Connection.cpp48
1 files changed, 2 insertions, 46 deletions
diff --git a/cppe/src/IceE/Connection.cpp b/cppe/src/IceE/Connection.cpp
index 84f87a030cc..6e15315278b 100755
--- a/cppe/src/IceE/Connection.cpp
+++ b/cppe/src/IceE/Connection.cpp
@@ -530,7 +530,7 @@ Ice::Connection::prepareBatchRequest(BasicStream* os)
{
try
{
- _batchStream.writeBlob(&_requestBatchHdr[0], headerSize + sizeof(Int));
+ _batchStream.writeBlob(requestBatchHdr, sizeof(requestBatchHdr));
}
catch(const LocalException& ex)
{
@@ -908,16 +908,13 @@ Ice::Connection::Connection(const InstancePtr& instance,
_logger(_instance->logger()), // Cached for better performance.
_traceLevels(_instance->traceLevels()), // Cached for better performance.
_warn(_instance->properties()->getPropertyAsInt("Ice.Warn.Connections") > 0),
- _requestHdr(headerSize + sizeof(Int), 0),
#ifndef ICEE_PURE_CLIENT
- _replyHdr(headerSize, 0),
_in(_instance.get(), this, _stream, adapter),
#endif
#ifndef ICEE_PURE_BLOCKING_CLIENT
_stream(_instance.get(), _instance->messageSizeMax()),
#endif
#ifdef ICEE_HAS_BATCH
- _requestBatchHdr(headerSize + sizeof(Int), 0),
_batchStream(_instance.get(), _instance->messageSizeMax()),
_batchStreamInUse(false),
_batchRequestNum(0),
@@ -956,47 +953,6 @@ Ice::Connection::Connection(const InstancePtr& instance,
_transceiver->setTimeouts(_endpoint->timeout(), _endpoint->timeout());
#endif
- 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;
-
-#ifdef ICEE_HAS_BATCH
- 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;
-#endif
-
-#ifndef ICEE_PURE_CLIENT
- 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;
-
-#endif
-
#ifdef ICEE_PURE_BLOCKING_CLIENT
validate();
#else
@@ -1795,7 +1751,7 @@ Ice::Connection::run()
// Add the reply header and request id.
//
BasicStream* os = _in.os();
- os->writeBlob(&_replyHdr[0], headerSize);
+ os->writeBlob(replyHdr, sizeof(replyHdr));
os->write(requestId);
}