NSAmelchev commented on code in PR #11361:
URL: https://github.com/apache/ignite/pull/11361#discussion_r1696667041
##########
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteSnapshotManager.java:
##########
@@ -3775,57 +3774,34 @@ private synchronized void scheduleNext() {
}
/** Stopping handler. */
- public synchronized void stop() {
- stopping = true;
-
- if (active != null)
- active.acceptException(new
IgniteException(SNP_NODE_STOPPING_ERR_MSG));
+ public void stop() {
+ synchronized (this) {
+ stopping = true;
+ }
RemoteSnapshotFilesRecevier r;
while ((r = queue.poll()) != null)
r.acceptException(new
IgniteException(SNP_NODE_STOPPING_ERR_MSG));
- Set<RemoteSnapshotFilesRecevier> futs = activeTasks();
- GridCompoundFuture<Void, Void> stopFut = new
GridCompoundFuture<>();
-
- try {
- for (IgniteInternalFuture<Void> fut : futs)
- stopFut.add(fut);
-
- stopFut.markInitialized().get();
- }
- catch (IgniteCheckedException e) {
- throw new IgniteException(e);
- }
+ if (active != null)
+ active.acceptException(new
IgniteException(SNP_NODE_STOPPING_ERR_MSG));
Review Comment:
Done
--
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.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
