Skip to content

Commit 0737efc

Browse files
committed
Run pre-commit
1 parent 584417a commit 0737efc

File tree

10 files changed

+30
-12
lines changed

10 files changed

+30
-12
lines changed

src/app/Stopper.hpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,7 @@ class Stopper {
8383
* @param subscriptions The subscription manager to stop.
8484
* @param backend The backend to stop.
8585
* @param cacheSaver The ledger cache saver
86+
* @param clusterCommunicationService The cluster communication service to stop.
8687
* @param ioc The io_context to stop.
8788
* @return The callback to be called on application stop.
8889
*/

src/cluster/Backend.hpp

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -128,6 +128,11 @@ class Backend {
128128
return onNewState_.connect(s);
129129
}
130130

131+
/**
132+
* @brief Get the UUID of this node in the cluster.
133+
*
134+
* @return The UUID of this node.
135+
*/
131136
ClioNode::cUUID
132137
selfId() const;
133138

@@ -140,3 +145,4 @@ class Backend {
140145
};
141146

142147
} // namespace cluster
148+

src/cluster/Concepts.hpp

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,12 @@
2323

2424
namespace cluster {
2525

26+
/**
27+
* @brief Tag type for cluster communication service implementations.
28+
*
29+
* This tag is used to identify types that implement cluster communication functionality.
30+
* Types should inherit from this tag to be recognized as cluster communication services.
31+
*/
2632
struct ClusterCommunicationServiceTag {
2733
virtual ~ClusterCommunicationServiceTag() = default;
2834
};

src/etl/ETLService.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -437,4 +437,3 @@ ETLService::giveUpWriter()
437437
}
438438

439439
} // namespace etl
440-

src/etl/SystemState.hpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -133,4 +133,3 @@ struct SystemState {
133133
};
134134

135135
} // namespace etl
136-

src/etl/WriterState.hpp

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,15 @@ class WriterStateInterface {
8787
virtual void
8888
setWriterDecidingFallback() = 0;
8989

90+
/**
91+
* @brief Create a clone of this writer state.
92+
*
93+
* Creates a new instance of the writer state with the same underlying system state.
94+
* This is used when spawning operations that need their own writer state instance
95+
* while sharing the same system state.
96+
*
97+
* @return A unique pointer to the cloned writer state.
98+
*/
9099
[[nodiscard]] virtual std::unique_ptr<WriterStateInterface>
91100
clone() const = 0;
92101
};
@@ -154,6 +163,13 @@ class WriterState : public WriterStateInterface {
154163
bool
155164
isFallback() const override;
156165

166+
/**
167+
* @brief Create a clone of this writer state.
168+
*
169+
* Creates a new WriterState instance sharing the same system state.
170+
*
171+
* @return A unique pointer to the cloned writer state.
172+
*/
157173
std::unique_ptr<WriterStateInterface>
158174
clone() const override;
159175
};

src/etl/impl/Loading.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -157,4 +157,3 @@ Loader::loadInitialLedger(model::LedgerData const& data)
157157
}
158158

159159
} // namespace etl::impl
160-

tests/unit/cluster/ClioNodeTests.cpp

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -222,7 +222,3 @@ TEST_P(ClioNodeFromTest, FromWriterState)
222222
EXPECT_GE(node.updateTime, beforeTime);
223223
EXPECT_LE(node.updateTime, afterTime);
224224
}
225-
226-
227-
228-

tests/unit/etl/ETLServiceTests.cpp

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -461,7 +461,7 @@ TEST_F(ETLServiceTests, AttemptTakeoverWriter)
461461
EXPECT_FALSE(systemState_->isWriting); // will attempt to become writer after new sequence appears but not yet
462462
EXPECT_FALSE(systemState_->isWriterDecidingFallback);
463463
capturedDbStalledCallback();
464-
EXPECT_TRUE(systemState_->isWriting); // should attempt to become writer
464+
EXPECT_TRUE(systemState_->isWriting); // should attempt to become writer
465465
EXPECT_TRUE(systemState_->isWriterDecidingFallback); // fallback mode activated
466466
}
467467

@@ -857,6 +857,3 @@ TEST_F(ETLServiceTests, WriteCommandsAreSerializedOnStrand)
857857
// Final state should be writing (last signal was StartWriting)
858858
EXPECT_TRUE(systemState_->isWriting);
859859
}
860-
861-
862-

tests/unit/etl/WriterStateTests.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,4 +107,3 @@ TEST_F(WriterStateTest, IsFallbackReturnsSystemStateValue)
107107
systemState->isWriterDecidingFallback = true;
108108
EXPECT_TRUE(writerState.isFallback());
109109
}
110-

0 commit comments

Comments
 (0)