This commit is contained in:
Changho Hwang
2026-04-01 21:20:55 +00:00
parent 94d0508ec2
commit 553fd3b2d8
2 changed files with 4 additions and 5 deletions

View File

@@ -411,11 +411,11 @@ void IBConnection::updateAndSync(RegisteredMemory dst, uint64_t dstOffset, uint6
// detection (tokens are monotonically increasing, so a decrease in the lower 32 bits
// indicates the upper 32 bits incremented by 1).
if (newValue <= oldValue) {
WARN(CONN, "IBConnection signal forwarding: token is not monotonically increasing: ", oldValue, " -> ",
newValue);
WARN(CONN, "IBConnection signal forwarding: token is not monotonically increasing: ", oldValue, " -> ", newValue);
} else if (newValue - oldValue >= (1ULL << 32)) {
WARN(CONN, "IBConnection signal forwarding: token increment too large for 32-bit wrap-around detection: ",
oldValue, " -> ", newValue, " (delta ", newValue - oldValue, " >= 2^32)");
WARN(CONN,
"IBConnection signal forwarding: token increment too large for 32-bit wrap-around detection: ", oldValue,
" -> ", newValue, " (delta ", newValue - oldValue, " >= 2^32)");
}
unsigned int immData = static_cast<unsigned int>(newValue);
qp_.lock()->stageSendWriteWithImm(nullptr, dstMrInfo,

View File

@@ -120,7 +120,6 @@ class IBConnection : public BaseConnection {
// incremented), then writes it to signalAddr_ via atomicStore through GDRCopy BAR1.
uint64_t signalAddr_;
std::unique_ptr<GdrMap> signalGdrMap_;
void recvThreadFunc();