[C++]: formatting to fix #266

aeron-client/src/main/cpp/Aeron.cpp

@@ -107,4 +107,4 @@ inline MemoryMappedFile::ptr_t Aeron::mapCncFile(Context &context)
     return cncBuffer;
 }
 
-}
+}

aeron-client/src/main/cpp/Aeron.h

@@ -180,4 +180,4 @@ class Aeron
 
 }
 
-#endif
+#endif

aeron-client/src/main/cpp/ClientConductor.cpp

@@ -475,4 +475,4 @@ void ClientConductor::lingerResources(long now, Image* images, int imagesLength)
     }
 }
 
-}
+}

aeron-client/src/main/cpp/ClientConductor.h

@@ -298,4 +298,4 @@ class ClientConductor
 
 }
 
-#endif
+#endif

aeron-client/src/main/cpp/CncFileDescriptor.h

@@ -174,4 +174,4 @@ inline static std::int64_t clientLivenessTimeout(MemoryMappedFile::ptr_t cncFile
 
 };
 
-#endif
+#endif

aeron-client/src/main/cpp/Context.h

@@ -354,4 +354,4 @@ class Context
 
 }
 
-#endif
+#endif

aeron-client/src/main/cpp/DriverListenerAdapter.h

@@ -117,4 +117,4 @@ class DriverListenerAdapter
 
 }
 
-#endif
+#endif

aeron-client/src/main/cpp/DriverProxy.h

@@ -167,4 +167,4 @@ class DriverProxy
 
 }
 
-#endif
+#endif

aeron-client/src/main/cpp/LogBuffers.cpp

@@ -83,4 +83,4 @@ LogBuffers::LogBuffers(std::uint8_t *address, index_t length)
 
 LogBuffers::~LogBuffers() = default;
 
-}
+}

aeron-client/src/main/cpp/Publication.cpp

@@ -65,4 +65,4 @@ bool Publication::isPublicationConnected(std::int64_t timeOfLastStatusMessage) c
     return m_conductor.isPublicationConnected(timeOfLastStatusMessage);
 }
 
-}
+}

aeron-client/src/main/cpp/Publication.h

@@ -427,4 +427,4 @@ class Publication
 
 }
 
-#endif
+#endif

aeron-client/src/main/cpp/Subscription.cpp

@@ -37,4 +37,4 @@ Subscription::~Subscription()
     m_conductor.releaseSubscription(m_registrationId, m_images, m_imagesLength);
 }
 
-}
+}

aeron-client/src/main/cpp/Subscription.h

@@ -343,4 +343,4 @@ class Subscription
 
 }
 
-#endif
+#endif

aeron-client/src/main/cpp/command/ControlProtocolEvents.h

@@ -55,4 +55,4 @@ struct ControlProtocolEvents
 };
 
 }};
-#endif
+#endif

aeron-client/src/main/cpp/command/CorrelatedMessageFlyweight.h

@@ -79,4 +79,4 @@ class CorrelatedMessageFlyweight : public Flyweight<CorrelatedMessageDefn>
 };
 
 }};
-#endif
+#endif

aeron-client/src/main/cpp/command/Flyweight.h

@@ -78,4 +78,4 @@ class Flyweight
 
 }}
 
-#endif
+#endif

aeron-client/src/main/cpp/command/ImageBuffersReadyFlyweight.h

@@ -211,4 +211,4 @@ class ImageBuffersReadyFlyweight : public Flyweight<ImageBuffersReadyDefn>
 
 }};
 
-#endif
+#endif

aeron-client/src/main/cpp/command/ImageMessageFlyweight.h

@@ -106,4 +106,4 @@ class ImageMessageFlyweight : public Flyweight<ImageMessageDefn>
 };
 
 }}
-#endif
+#endif

aeron-client/src/main/cpp/command/PublicationBuffersReadyFlyweight.h

@@ -135,4 +135,4 @@ class PublicationBuffersReadyFlyweight : public Flyweight<PublicationBuffersRead
 
 }};
 
-#endif
+#endif

aeron-client/src/main/cpp/command/PublicationMessageFlyweight.h

@@ -106,4 +106,4 @@ class PublicationMessageFlyweight : public CorrelatedMessageFlyweight
 
 }};
 
-#endif
+#endif

aeron-client/src/main/cpp/command/RemoveMessageFlyweight.h

@@ -79,4 +79,4 @@ class RemoveMessageFlyweight : public CorrelatedMessageFlyweight
 };
 
 }};
-#endif
+#endif

aeron-client/src/main/cpp/command/SubscriptionMessageFlyweight.h

@@ -114,4 +114,4 @@ class SubscriptionMessageFlyweight : public CorrelatedMessageFlyweight
 };
 
 }};
-#endif
+#endif

aeron-client/src/main/cpp/concurrent/AgentRunner.h

@@ -87,4 +87,4 @@ class AgentRunner
 
 }}
 
-#endif
+#endif

aeron-client/src/main/cpp/concurrent/AtomicCounter.h

@@ -90,5 +90,3 @@ class AtomicCounter
 }}
 
 #endif
-
-

aeron-client/src/main/cpp/concurrent/BusySpinIdleStrategy.h

@@ -51,4 +51,4 @@ class BusySpinIdleStrategy
 
 }}
 
-#endif
+#endif

aeron-client/src/main/cpp/concurrent/CountersManager.h

@@ -116,4 +116,4 @@ class CountersManager : public CountersReader
 
 }}
 
-#endif
+#endif

aeron-client/src/main/cpp/concurrent/logbuffer/Header.h

@@ -190,4 +190,4 @@ class Header
 
 }}}
 
-#endif
+#endif

aeron-client/src/main/cpp/concurrent/logbuffer/TermReader.h

@@ -114,4 +114,4 @@ inline void read(
 
 }}}
 
-#endif
+#endif

aeron-client/src/main/cpp/util/BitUtil.h

@@ -145,4 +145,4 @@ namespace BitUtil
 }};
 
 
-#endif
+#endif

aeron-client/src/main/cpp/util/CommandOption.cpp

@@ -130,4 +130,4 @@ void CommandOption::validate() const
         throw CommandOptionException(std::string("option -") + m_optionChar + " has too few parameters specified.", SOURCEINFO);
 }
 
-}}
+}}

aeron-client/src/main/cpp/util/CommandOptionParser.cpp

@@ -89,4 +89,4 @@ void CommandOptionParser::displayOptionsHelp (std::ostream& out)
     }
 }
 
-}}
+}}

aeron-client/src/main/cpp/util/Exceptions.h

@@ -102,4 +102,4 @@ class RegistrationException : public SourcedException
 };
 
 }}
-#endif
+#endif

aeron-client/src/main/cpp/util/MacroUtil.h

@@ -34,4 +34,4 @@
     #define AERON_COND_EXPECT(exp,c) (exp)
 #endif
 
-#endif
+#endif

aeron-client/src/main/cpp/util/MemoryMappedFile.cpp

@@ -299,4 +299,4 @@ std::int64_t MemoryMappedFile::getFileSize(const char *filename)
 
 #endif
 
-}}
+}}

aeron-client/src/main/cpp/util/Platform.h

@@ -49,4 +49,4 @@
     #error Unsupported compiler!
 #endif
 
-#endif
+#endif

aeron-client/src/main/cpp/util/ScopeUtils.h

@@ -57,4 +57,4 @@ class OnScopeExit
 }}
 
 
-#endif
+#endif

aeron-client/src/main/cpp/util/StringUtil.h

@@ -124,4 +124,4 @@ static T fromString (const std::string &str)
 
 }}
 
-#endif
+#endif

aeron-client/src/test/cpp/FragmentAssemblerTest.cpp

@@ -234,4 +234,4 @@ TEST_F(FragmentAssemblerTest, shouldNotReassembleIfMissingBegin)
     fillFrame(FrameDescriptor::END_FRAG, MTU_LENGTH * 2, msgLength, (msgLength * 2) % 256);
     adapter.handler()(m_buffer, (MTU_LENGTH * 2) + DataFrameHeader::LENGTH, msgLength, m_header);
     ASSERT_FALSE(called);
-}
+}

aeron-client/src/test/cpp/ImageTest.cpp

@@ -446,4 +446,4 @@ TEST_F(ImageTest, shouldPollFragmentsToControlledFragmentHandlerOnContinue)
     EXPECT_EQ(fragments, 2);
     EXPECT_EQ(m_subscriberPosition.get(), initialPosition + ALIGNED_FRAME_LENGTH * 2);
     EXPECT_EQ(image.position(), initialPosition + ALIGNED_FRAME_LENGTH * 2);
-}
+}

aeron-client/src/test/cpp/PublicationTest.cpp

@@ -204,4 +204,4 @@ TEST_F(PublicationTest, shouldRotateWhenClaimTrips)
 
     EXPECT_GT(m_publication->tryClaim(SRC_BUFFER_LENGTH, bufferClaim), initialPosition + DataFrameHeader::LENGTH + m_srcBuffer.capacity());
     EXPECT_GT(m_publication->position(), initialPosition + DataFrameHeader::LENGTH + m_srcBuffer.capacity());
-}
+}

aeron-client/src/test/cpp/command/CommandTest.cpp

@@ -198,4 +198,4 @@ TEST (commandTests, testImageBuffersReadyFlyweight)
                 sizeof(std::int32_t) + sourceInfoData.length()));
     }
     );
-}
+}

aeron-client/src/test/cpp/concurrent/BroadcastReceiverTest.cpp

@@ -298,4 +298,4 @@ TEST_F(BroadcastReceiverTest, shouldDealWithRecordBecomingInvalidDueToOverwrite)
     EXPECT_EQ(m_broadcastReceiver.offset(), RecordDescriptor::msgOffset(recordOffset));
     EXPECT_EQ(m_broadcastReceiver.length(), length);
     EXPECT_FALSE(m_broadcastReceiver.validate());
-}
+}

aeron-client/src/test/cpp/concurrent/BroadcastTransmitterTest.cpp

@@ -266,4 +266,4 @@ TEST_F(BroadcastTransmitterTest, shouldApplyPaddingWhenInsufficientSpaceAtEndOfB
         .InSequence(sequence);
 
     m_broadcastTransmitter.transmit(MSG_TYPE_ID, srcBuffer, srcIndex, length);
-}
+}

aeron-client/src/test/cpp/concurrent/CountersManagerTest.cpp

@@ -180,5 +180,3 @@ TEST_F(CountersManagerTest, shouldStoreAndLoadValue)
     m_countersManager.setCounterValue(counterId, value);
     EXPECT_EQ(m_countersManager.getCounterValue(counterId), value);
 }
-
-

aeron-client/src/test/cpp/concurrent/DistinctErrorLogTest.cpp

@@ -197,4 +197,3 @@ TEST_F(DistinctErrorLogTest, shouldRecordTwoDistinctObservations)
 
     EXPECT_TRUE(m_errorLog.record(2, "description 2", "message"));
 }
-

aeron-client/src/test/cpp/concurrent/ErrorLogReaderTest.cpp

@@ -157,4 +157,4 @@ TEST_F(ErrorLogReaderTest, shouldReadOneObservationSinceTimestamp)
     EXPECT_TRUE(log.record(2, "description 2", "message"));
 
     EXPECT_EQ(ErrorLogReader::read(m_mockBuffer, m_consumer, 10), 1);
-}
+}

aeron-client/src/test/cpp/concurrent/MockAtomicBuffer.cpp

@@ -26,4 +26,4 @@ MockAtomicBuffer::MockAtomicBuffer(std::uint8_t *buffer, util::index_t length) :
 
 MockAtomicBuffer::~MockAtomicBuffer() = default;
 
-}}};
+}}};

aeron-client/src/test/cpp/concurrent/MockAtomicBuffer.h

@@ -70,4 +70,4 @@ class MockAtomicBuffer : public AtomicBuffer
 
 }}}
 
-#endif
+#endif

aeron-client/src/test/cpp/concurrent/OneToOneRingBufferTest.cpp

@@ -494,4 +494,3 @@ TEST(OneToOneRingBufferConcurrentTest, shouldExchangeMessages)
         printf("EXCEPTION unknown\n");
     }
 }
-

aeron-client/src/test/cpp/concurrent/TermAppenderTest.cpp

@@ -282,4 +282,4 @@ TEST_F(TermAppenderTest, shouldClaimRegionForZeroCopyEncoding)
     EXPECT_EQ(bufferClaim.length(), msgLength);
 
     bufferClaim.commit();
-}
+}

aeron-client/src/test/cpp/concurrent/TermReaderTest.cpp

@@ -253,4 +253,4 @@ TEST_F(TermReaderTest, shouldNotReadLastMessageWhenPadding)
 
     EXPECT_EQ(readOutcome.offset, TERM_BUFFER_CAPACITY);
     EXPECT_EQ(readOutcome.fragmentsRead, 0);
-}
+}

aeron-client/src/test/cpp/util/MemoryMappedFileTest.cpp

@@ -83,4 +83,4 @@ TEST(mmfileTest, writeReadCheck)
     }
 
     ::unlink(name.c_str());
-}
+}

aeron-driver/src/main/cpp/DataPacketDispatcher.cpp

@@ -40,14 +40,3 @@ void DataPacketDispatcher::removeCoolDown(std::int32_t sessionId, std::int32_t s
         m_ignoredSessions.erase({sessionId, streamId});
     }
 }
-
-
-
-
-
-
-
-
-
-
-

aeron-driver/src/main/cpp/buffer/MappedRawLog.cpp

@@ -103,4 +103,4 @@ void MappedRawLog::allocatePages(std::uint8_t *mapping, size_t length)
     }
 }
 
-}}}
+}}}

aeron-driver/src/main/cpp/media/NetworkInterface.cpp

@@ -23,4 +23,4 @@ void NetworkInterface::setAsMulticastInterface(int socketFd) const
         default:
             throw IllegalStateException("Invalid address type", SOURCEINFO);
     }
-}
+}

aeron-samples/src/main/cpp/AeronStat.cpp

@@ -146,4 +146,4 @@ int main (int argc, char** argv)
     }
 
     return 0;
-}
+}