Skip to content
GitLab
Menu
Projects
Groups
Snippets
Help
Projects
Groups
Snippets
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in
Toggle navigation
Menu
Open sidebar
小 白蛋
Neo4jsource
Commits
a1d2cbdd
Commit
a1d2cbdd
authored
7 years ago
by
MishaDemianenko
Browse files
Options
Download
Email Patches
Plain Diff
Synchronize start and stop of services that restarted on master/slave
switch.
parent
34ba760d
No related merge requests found
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
community/kernel/src/main/java/org/neo4j/kernel/impl/util/watcher/DefaultFileSystemWatcherService.java
+2
-2
...el/impl/util/watcher/DefaultFileSystemWatcherService.java
community/kernel/src/main/java/org/neo4j/kernel/internal/locker/StoreLockerLifecycleAdapter.java
+2
-2
...j/kernel/internal/locker/StoreLockerLifecycleAdapter.java
enterprise/backup/src/main/java/org/neo4j/backup/OnlineBackupKernelExtension.java
+2
-2
...in/java/org/neo4j/backup/OnlineBackupKernelExtension.java
with
6 additions
and
6 deletions
+6
-6
community/kernel/src/main/java/org/neo4j/kernel/impl/util/watcher/DefaultFileSystemWatcherService.java
+
2
-
2
View file @
a1d2cbdd
...
...
@@ -51,7 +51,7 @@ public class DefaultFileSystemWatcherService implements FileSystemWatcherService
}
@Override
public
void
start
()
public
synchronized
void
start
()
{
assert
watcher
==
null
;
watcher
=
fileWatchers
.
newThread
(
eventWatcher
);
...
...
@@ -59,7 +59,7 @@ public class DefaultFileSystemWatcherService implements FileSystemWatcherService
}
@Override
public
void
stop
()
throws
Throwable
public
synchronized
void
stop
()
throws
Throwable
{
eventWatcher
.
stopWatching
();
if
(
watcher
!=
null
)
...
...
This diff is collapsed.
Click to expand it.
community/kernel/src/main/java/org/neo4j/kernel/internal/locker/StoreLockerLifecycleAdapter.java
+
2
-
2
View file @
a1d2cbdd
...
...
@@ -31,13 +31,13 @@ public class StoreLockerLifecycleAdapter extends LifecycleAdapter
}
@Override
public
void
start
()
public
synchronized
void
start
()
{
storeLocker
.
checkLock
();
}
@Override
public
void
stop
()
throws
Throwable
public
synchronized
void
stop
()
throws
Throwable
{
storeLocker
.
close
();
}
...
...
This diff is collapsed.
Click to expand it.
enterprise/backup/src/main/java/org/neo4j/backup/OnlineBackupKernelExtension.java
+
2
-
2
View file @
a1d2cbdd
...
...
@@ -112,7 +112,7 @@ public class OnlineBackupKernelExtension extends LifecycleAdapter
}
@Override
public
void
start
()
public
synchronized
void
start
()
{
if
(
config
.
get
(
OnlineBackupSettings
.
online_backup_enabled
)
)
{
...
...
@@ -148,7 +148,7 @@ public class OnlineBackupKernelExtension extends LifecycleAdapter
}
@Override
public
void
stop
()
throws
Throwable
public
synchronized
void
stop
()
throws
Throwable
{
if
(
server
!=
null
)
{
...
...
This diff is collapsed.
Click to expand it.
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment
Menu
Projects
Groups
Snippets
Help