summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/UdpTransceiver.cpp
diff options
context:
space:
mode:
authorMarc Laukien <marc@zeroc.com>2004-09-13 18:19:41 +0000
committerMarc Laukien <marc@zeroc.com>2004-09-13 18:19:41 +0000
commite012bfcd0c32c6fd185890aedb5f17e69da8870e (patch)
tree28dd15cd1a91ee0a244078487ed0d7b799364504 /cpp/src/Ice/UdpTransceiver.cpp
parentadding AMI tests (diff)
downloadice-e012bfcd0c32c6fd185890aedb5f17e69da8870e.tar.bz2
ice-e012bfcd0c32c6fd185890aedb5f17e69da8870e.tar.xz
ice-e012bfcd0c32c6fd185890aedb5f17e69da8870e.zip
Connection.ice
Diffstat (limited to 'cpp/src/Ice/UdpTransceiver.cpp')
-rw-r--r--cpp/src/Ice/UdpTransceiver.cpp51
1 files changed, 17 insertions, 34 deletions
diff --git a/cpp/src/Ice/UdpTransceiver.cpp b/cpp/src/Ice/UdpTransceiver.cpp
index 4e7b72453f0..504b96fcb37 100644
--- a/cpp/src/Ice/UdpTransceiver.cpp
+++ b/cpp/src/Ice/UdpTransceiver.cpp
@@ -34,7 +34,7 @@ IceInternal::UdpTransceiver::close()
if(_traceLevels->network >= 1)
{
Trace out(_logger, _traceLevels->networkCat);
- out << "closing udp connection\n" << _info->toString();
+ out << "closing udp connection\n" << toString();
}
assert(_fd != INVALID_SOCKET);
@@ -103,12 +103,12 @@ repeat:
if(_traceLevels->network >= 3)
{
Trace out(_logger, _traceLevels->networkCat);
- out << "sent " << ret << " bytes via udp\n" << _info->toString();
+ out << "sent " << ret << " bytes via udp\n" << toString();
}
if(_stats)
{
- _stats->bytesSent(_info->type(), static_cast<Int>(ret));
+ _stats->bytesSent(type(), static_cast<Int>(ret));
}
assert(ret == static_cast<ssize_t>(buf.b.size()));
@@ -160,7 +160,7 @@ repeat:
if(_traceLevels->network >= 1)
{
Trace out(_logger, _traceLevels->networkCat);
- out << "connected udp socket\n" << _info->toString();
+ out << "connected udp socket\n" << toString();
}
}
}
@@ -220,22 +220,28 @@ repeat:
if(_traceLevels->network >= 3)
{
Trace out(_logger, _traceLevels->networkCat);
- out << "received " << ret << " bytes via udp\n" << _info->toString();
+ out << "received " << ret << " bytes via udp\n" << toString();
}
if(_stats)
{
- _stats->bytesReceived(_info->type(), static_cast<Int>(ret));
+ _stats->bytesReceived(type(), static_cast<Int>(ret));
}
buf.b.resize(ret);
buf.i = buf.b.end();
}
-TransportInfoPtr
-IceInternal::UdpTransceiver::info() const
+string
+IceInternal::UdpTransceiver::type() const
+{
+ return "udp";
+}
+
+string
+IceInternal::UdpTransceiver::toString() const
{
- return _info;
+ return fdToString(_fd);
}
bool
@@ -268,12 +274,10 @@ IceInternal::UdpTransceiver::UdpTransceiver(const InstancePtr& instance, const s
doConnect(_fd, _addr, -1);
_connect = false; // We're connected now
- const_cast<TransportInfoPtr&>(_info) = new UdpTransportInfoI(_fd);
-
if(_traceLevels->network >= 1)
{
Trace out(_logger, _traceLevels->networkCat);
- out << "starting to send udp packets\n" << _info->toString();
+ out << "starting to send udp packets\n" << toString();
}
}
catch(...)
@@ -307,12 +311,10 @@ IceInternal::UdpTransceiver::UdpTransceiver(const InstancePtr& instance, const s
}
doBind(_fd, _addr);
- const_cast<TransportInfoPtr&>(_info) = new UdpTransportInfoI(_fd);
-
if(_traceLevels->network >= 1)
{
Trace out(_logger, _traceLevels->networkCat);
- out << "starting to receive udp packets\n" << _info->toString();
+ out << "starting to receive udp packets\n" << toString();
}
}
catch(...)
@@ -422,22 +424,3 @@ IceInternal::UdpTransceiver::setBufSize(const InstancePtr& instance)
//
const int IceInternal::UdpTransceiver::_udpOverhead = 20 + 8;
const int IceInternal::UdpTransceiver::_maxPacketSize = 65535 - _udpOverhead;
-
-string
-Ice::UdpTransportInfoI::type() const
-{
- return _type;
-}
-
-string
-Ice::UdpTransportInfoI::toString() const
-{
- return _desc;
-}
-
-const string Ice::UdpTransportInfoI::_type = "udp";
-
-Ice::UdpTransportInfoI::UdpTransportInfoI(SOCKET fd) :
- _desc(fdToString(fd))
-{
-}