You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@ignite.apache.org by GitBox <gi...@apache.org> on 2021/05/19 08:55:21 UTC

[GitHub] [ignite-3] agura commented on a change in pull request #129: IGNITE-14389 In-memory meta storage implementation

agura commented on a change in pull request #129:
URL: https://github.com/apache/ignite-3/pull/129#discussion_r635044173



##########
File path: modules/affinity/src/main/java/org/apache/ignite/internal/affinity/AffinityManager.java
##########
@@ -85,9 +85,9 @@ public AffinityManager(
         this.baselineMgr = baselineMgr;
         this.vaultMgr = vaultMgr;
 
-        metaStorageMgr.registerWatchByPrefix(new Key(INTERNAL_PREFIX), new WatchListener() {
-            @Override public boolean onUpdate(@NotNull Iterable<WatchEvent> events) {
-                for (WatchEvent evt : events) {
+        metaStorageMgr.registerWatchByPrefix(new ByteArray(INTERNAL_PREFIX), new WatchListener() {
+            @Override public boolean onUpdate(@NotNull WatchEvent watchEvt) {

Review comment:
       @sanpwc It seems that `entryEvent()` is still useful in case when your watch updates for only one key. So, if we have two different cases, it is possible to have mixed case.




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org