This is an automated email from the ASF dual-hosted git repository.
shishkovilja pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 913d6381537 IGNITE-28538 Remove the rejected field in
MetadataRemoveProposedMessage (#13021)
913d6381537 is described below
commit 913d6381537ae7ce2c11d4db5b3d8e171dbccb16
Author: Dmitry Werner <[email protected]>
AuthorDate: Tue Apr 14 20:14:44 2026 +0500
IGNITE-28538 Remove the rejected field in MetadataRemoveProposedMessage
(#13021)
---
.../cache/binary/MetadataRemoveProposedMessage.java | 14 ++++----------
1 file changed, 4 insertions(+), 10 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
index 656570ac57f..9aa2064ad54 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataRemoveProposedMessage.java
@@ -47,16 +47,12 @@ public final class MetadataRemoveProposedMessage implements
DiscoveryCustomMessa
@Order(2)
int typeId;
- /** Message acceptance status. */
- @Order(3)
- boolean rejected;
-
/** Message received on coordinator. */
- @Order(4)
+ @Order(3)
boolean onCoordinator = true;
/** */
- @Order(5)
+ @Order(4)
String errMsg;
/** Constructor. */
@@ -83,7 +79,7 @@ public final class MetadataRemoveProposedMessage implements
DiscoveryCustomMessa
/** {@inheritDoc} */
@Nullable @Override public DiscoveryCustomMessage ackMessage() {
- return !rejected ? new MetadataRemoveAcceptedMessage(typeId) : null;
+ return !rejected() ? new MetadataRemoveAcceptedMessage(typeId) : null;
}
/** {@inheritDoc} */
@@ -95,13 +91,12 @@ public final class MetadataRemoveProposedMessage implements
DiscoveryCustomMessa
* @param errMsg Error message caused this update to be rejected.
*/
void markRejected(String errMsg) {
- rejected = true;
this.errMsg = errMsg;
}
/** */
boolean rejected() {
- return rejected;
+ return errMsg != null;
}
/** */
@@ -133,5 +128,4 @@ public final class MetadataRemoveProposedMessage implements
DiscoveryCustomMessa
@Override public String toString() {
return S.toString(MetadataRemoveProposedMessage.class, this);
}
-
}