Skip to content

Commit 230cf22

Browse files
committed
all: Replaced <some_unit>(<some_expression>).get() with <some_expression>.get<some_unit>().
The latter is much more intentional and easier to read.
1 parent ece9e56 commit 230cf22

File tree

169 files changed

+510
-510
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

169 files changed

+510
-510
lines changed

src/inet/applications/base/ApplicationPacketSerializer.cc

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,11 @@ void ApplicationPacketSerializer::serialize(MemoryOutputStream& stream, const Pt
1818
{
1919
auto startPosition = stream.getLength();
2020
const auto& applicationPacket = staticPtrCast<const ApplicationPacket>(chunk);
21-
stream.writeUint32Be(B(applicationPacket->getChunkLength()).get());
21+
stream.writeUint32Be(applicationPacket->getChunkLength().get<B>());
2222
stream.writeUint32Be(applicationPacket->getSequenceNumber());
23-
int64_t remainders = B(applicationPacket->getChunkLength() - (stream.getLength() - startPosition)).get();
23+
int64_t remainders = (applicationPacket->getChunkLength() - (stream.getLength() - startPosition)).get<B>();
2424
if (remainders < 0)
25-
throw cRuntimeError("ApplicationPacket length = %d smaller than required %d bytes", (int)B(applicationPacket->getChunkLength()).get(), (int)B(stream.getLength() - startPosition).get());
25+
throw cRuntimeError("ApplicationPacket length = %d smaller than required %d bytes", (int)applicationPacket->getChunkLength().get<B>(), (int)(stream.getLength() - startPosition).get<B>());
2626
stream.writeByteRepeatedly('?', remainders);
2727
}
2828

@@ -34,7 +34,7 @@ const Ptr<Chunk> ApplicationPacketSerializer::deserialize(MemoryInputStream& str
3434
applicationPacket->setSequenceNumber(stream.readUint32Be());
3535
B remainders = dataLength - (stream.getPosition() - startPosition);
3636
ASSERT(remainders >= B(0));
37-
stream.readByteRepeatedly('?', B(remainders).get());
37+
stream.readByteRepeatedly('?', remainders.get<B>());
3838
return applicationPacket;
3939
}
4040

src/inet/applications/clock/SimpleClockSynchronizer.cc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,8 +55,8 @@ void SimpleClockSynchronizer::synchronizeSlaveClock()
5555
auto masterOscillatorBasedClock = check_and_cast<OscillatorBasedClock*>(masterClock.get());
5656
auto clockTime = masterClock->getClockTime() + synchronizationClockTimeErrorParameter->doubleValue();
5757
ppm oscillatorCompensation = unit(getCurrentRelativeTickLength(slaveClock.get()) / getCurrentRelativeTickLength(masterClock.get())
58-
* (1 + unit(masterOscillatorBasedClock->getOscillatorCompensation()).get())
59-
* (1 + unit(ppm(synchronizationOscillatorCompensationErrorParameter->doubleValue())).get()) - 1);
58+
* (1 + masterOscillatorBasedClock->getOscillatorCompensation().get<unit>())
59+
* (1 + ppm(synchronizationOscillatorCompensationErrorParameter->doubleValue()).get<unit>()) - 1);
6060
slaveClock->setClockTime(clockTime, oscillatorCompensation, true);
6161
}
6262

src/inet/applications/ethernet/EtherAppPacketSerializer.cc

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -19,12 +19,12 @@ void EtherAppReqSerializer::serialize(MemoryOutputStream& stream, const Ptr<cons
1919
{
2020
auto startPosition = stream.getLength();
2121
const auto& etherAppReq = staticPtrCast<const EtherAppReq>(chunk);
22-
stream.writeUint32Be(B(etherAppReq->getChunkLength()).get());
22+
stream.writeUint32Be(etherAppReq->getChunkLength().get<B>());
2323
stream.writeUint32Be(etherAppReq->getRequestId());
2424
stream.writeUint32Be(etherAppReq->getResponseBytes());
25-
int64_t remainders = B(etherAppReq->getChunkLength() - (stream.getLength() - startPosition)).get();
25+
int64_t remainders = (etherAppReq->getChunkLength() - (stream.getLength() - startPosition)).get<B>();
2626
if (remainders < 0)
27-
throw cRuntimeError("EtherAppReq length = %d smaller than required %d bytes", (int)B(etherAppReq->getChunkLength()).get(), (int)B(stream.getLength() - startPosition).get());
27+
throw cRuntimeError("EtherAppReq length = %d smaller than required %d bytes", (int)etherAppReq->getChunkLength().get<B>(), (int)(stream.getLength() - startPosition).get<B>());
2828
stream.writeByteRepeatedly('?', remainders);
2929
}
3030

@@ -38,20 +38,20 @@ const Ptr<Chunk> EtherAppReqSerializer::deserialize(MemoryInputStream& stream) c
3838
etherAppReq->setResponseBytes(stream.readUint32Be());
3939
B remainders = dataLength - (stream.getPosition() - startPosition);
4040
ASSERT(remainders >= B(0));
41-
stream.readByteRepeatedly('?', B(remainders).get());
41+
stream.readByteRepeatedly('?', remainders.get<B>());
4242
return etherAppReq;
4343
}
4444

4545
void EtherAppRespSerializer::serialize(MemoryOutputStream& stream, const Ptr<const Chunk>& chunk) const
4646
{
4747
auto startPosition = stream.getLength();
4848
const auto& etherAppResp = staticPtrCast<const EtherAppResp>(chunk);
49-
stream.writeUint32Be(B(etherAppResp->getChunkLength()).get());
49+
stream.writeUint32Be(etherAppResp->getChunkLength().get<B>());
5050
stream.writeUint32Be(etherAppResp->getRequestId());
5151
stream.writeUint32Be(etherAppResp->getNumFrames());
52-
int64_t remainders = B(etherAppResp->getChunkLength() - (stream.getLength() - startPosition)).get();
52+
int64_t remainders = (etherAppResp->getChunkLength() - (stream.getLength() - startPosition)).get<B>();
5353
if (remainders < 0)
54-
throw cRuntimeError("EtherAppResp length = %d smaller than required %d bytes", (int)B(etherAppResp->getChunkLength()).get(), (int)B(stream.getLength() - startPosition).get());
54+
throw cRuntimeError("EtherAppResp length = %d smaller than required %d bytes", (int)etherAppResp->getChunkLength().get<B>(), (int)(stream.getLength() - startPosition).get<B>());
5555
stream.writeByteRepeatedly('?', remainders);
5656
}
5757

@@ -65,7 +65,7 @@ const Ptr<Chunk> EtherAppRespSerializer::deserialize(MemoryInputStream& stream)
6565
etherAppResp->setNumFrames(stream.readUint32Be());
6666
B remainders = dataLength - (stream.getPosition() - startPosition);
6767
ASSERT(remainders >= B(0));
68-
stream.readByteRepeatedly('?', B(remainders).get());
68+
stream.readByteRepeatedly('?', remainders.get<B>());
6969
return etherAppResp;
7070
}
7171

src/inet/applications/netperfmeter/NetPerfMeter.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1176,7 +1176,7 @@ void NetPerfMeter::receiveMessage(cMessage *msg)
11761176

11771177
ReceiverStatistics *receiverStatistics = getReceiverStatistics(streamID);
11781178
receiverStatistics->ReceivedMessages++;
1179-
receiverStatistics->ReceivedBytes += B(smsg->getChunkLength()).get();
1179+
receiverStatistics->ReceivedBytes += smsg->getChunkLength().get<B>();
11801180
for (auto& region : smsg->getAllTags<CreationTimeTag>())
11811181
receiverStatistics->ReceivedDelayHistogram.collect(simTime() - region.getTag()->getCreationTime());
11821182
}

src/inet/applications/pingapp/PingApp.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -478,7 +478,7 @@ void PingApp::processPingResponse(int originatorId, int seqNo, Packet *packet)
478478
}
479479

480480
// update statistics
481-
countPingResponse(B(pingPayload->getChunkLength()).get(), seqNo, rtt, isDup);
481+
countPingResponse(pingPayload->getChunkLength().get<B>(), seqNo, rtt, isDup);
482482
}
483483

484484
void PingApp::countPingResponse(int bytes, long seqNo, simtime_t rtt, bool isDup)

src/inet/applications/sctpapp/SctpNatPeer.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -353,7 +353,7 @@ void SctpNatPeer::handleMessage(cMessage *msg)
353353
id = ind->getSocketId();
354354
if (rendezvous) {
355355
const auto& smsg = message->peekDataAsBytes();
356-
int bufferlen = B(smsg->getChunkLength()).get();
356+
int bufferlen = smsg->getChunkLength().get<B>();
357357
uint8_t *buffer = new uint8_t[bufferlen];
358358
std::vector<uint8_t> vec = smsg->getBytes();
359359
for (int i = 0; i < bufferlen; i++) {

src/inet/applications/sctpapp/SctpNatServer.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,7 @@ void SctpNatServer::handleMessage(cMessage *msg)
265265
const auto& ind = tags.findTag<SctpRcvReq>();
266266
id = ind->getSocketId();
267267
const auto& smsg = message->peekDataAsBytes();
268-
int bufferlen = B(smsg->getChunkLength()).get();
268+
int bufferlen = smsg->getChunkLength().get<B>();
269269
uint8_t *buffer = new uint8_t[bufferlen];
270270
std::vector<uint8_t> vec = smsg->getBytes();
271271
for (int i = 0; i < bufferlen; i++) {

src/inet/applications/sctpapp/SctpPeer.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -383,7 +383,7 @@ void SctpPeer::handleMessage(cMessage *msg)
383383
cmd->setPrValue(0);
384384
cmd->setSid(lastStream);
385385
cmsg->setKind(cmd->getSendUnordered() ? SCTP_C_SEND_UNORDERED : SCTP_C_SEND_ORDERED);
386-
bytesSent += B(smsg->getChunkLength()).get();
386+
bytesSent += smsg->getChunkLength().get<B>();
387387
packetsSent++;
388388
sendOrSchedule(cmsg);
389389
}

src/inet/applications/sctpapp/SctpServer.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -398,7 +398,7 @@ void SctpServer::handleMessage(cMessage *msg)
398398
cmd->setPrValue(0);
399399
cmd->setSid(lastStream);
400400
cmsg->setKind(cmd->getSendUnordered() ? SCTP_C_SEND_UNORDERED : SCTP_C_SEND_ORDERED);
401-
bytesSent += B(smsg->getChunkLength()).get();
401+
bytesSent += smsg->getChunkLength().get<B>();
402402
packetsSent++;
403403
sendOrSchedule(cmsg);
404404
}

src/inet/applications/tcpapp/GenericAppMsgSerializer.cc

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,13 +18,13 @@ void GenericAppMsgSerializer::serialize(MemoryOutputStream& stream, const Ptr<co
1818
{
1919
auto startPosition = stream.getLength();
2020
const auto& msg = staticPtrCast<const GenericAppMsg>(chunk);
21-
stream.writeUint32Be(B(msg->getChunkLength()).get());
22-
stream.writeUint32Be(B(msg->getExpectedReplyLength()).get());
21+
stream.writeUint32Be(msg->getChunkLength().get<B>());
22+
stream.writeUint32Be(msg->getExpectedReplyLength().get<B>());
2323
stream.writeUint64Be(SimTime(msg->getReplyDelay()).raw());
2424
stream.writeByte(msg->getServerClose());
25-
int64_t remainders = B(msg->getChunkLength() - (stream.getLength() - startPosition)).get();
25+
int64_t remainders = (msg->getChunkLength() - (stream.getLength() - startPosition)).get<B>();
2626
if (remainders < 0)
27-
throw cRuntimeError("GenericAppMsg length = %d smaller than required %d bytes", (int)B(msg->getChunkLength()).get(), (int)B(stream.getLength() - startPosition).get());
27+
throw cRuntimeError("GenericAppMsg length = %d smaller than required %d bytes", (int)msg->getChunkLength().get<B>(), (int)(stream.getLength() - startPosition).get<B>());
2828
stream.writeByteRepeatedly('?', remainders);
2929
}
3030

0 commit comments

Comments
 (0)