Skip to content

Commit

Permalink
[Java] Rename dataHeader to heartbeatDataHeader
Browse files Browse the repository at this point in the history
  • Loading branch information
nitsanw committed Jan 10, 2017
1 parent e0f7659 commit a3358b4
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,7 @@ public class NetworkPublication
private final Position senderLimit;
private final SendChannelEndpoint channelEndpoint;
private final ByteBuffer heartbeatBuffer;
private final DataHeaderFlyweight dataHeader;
private final DataHeaderFlyweight heartbeatDataHeader;
private final ByteBuffer setupBuffer;
private final SetupFlyweight setupHeader;
private final ByteBuffer rttMeasurementBuffer;
Expand Down Expand Up @@ -149,7 +149,7 @@ public NetworkPublication(
setupBuffer = threadLocals.setupBuffer();
setupHeader = threadLocals.setupHeader();
heartbeatBuffer = threadLocals.heartbeatBuffer();
dataHeader = threadLocals.heartbeatDataHeader();
heartbeatDataHeader = threadLocals.heartbeatDataHeader();
rttMeasurementBuffer = threadLocals.rttMeasurementBuffer();
rttMeasurementHeader = threadLocals.rttMeasurementHeader();

Expand Down Expand Up @@ -472,7 +472,7 @@ private int heartbeatMessageCheck(final long now, final int activeTermId, final
if (now > (timeOfLastSendOrHeartbeat + PUBLICATION_HEARTBEAT_TIMEOUT_NS))
{
heartbeatBuffer.clear();
dataHeader
heartbeatDataHeader
.sessionId(sessionId)
.streamId(streamId)
.termId(activeTermId)
Expand Down

0 comments on commit a3358b4

Please sign in to comment.