projects
/
sonitus.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Access source threadsafely.
[sonitus.git]
/
src
/
main
/
java
/
net
/
pterodactylus
/
sonitus
/
data
/
filter
/
MultiSourceFilter.java
diff --git
a/src/main/java/net/pterodactylus/sonitus/data/filter/MultiSourceFilter.java
b/src/main/java/net/pterodactylus/sonitus/data/filter/MultiSourceFilter.java
index
57c313e
..
38e7473
100644
(file)
--- a/
src/main/java/net/pterodactylus/sonitus/data/filter/MultiSourceFilter.java
+++ b/
src/main/java/net/pterodactylus/sonitus/data/filter/MultiSourceFilter.java
@@
-135,9
+135,11
@@
public class MultiSourceFilter implements Filter, ReusableSink {
while (true) {
/* wait for source to be set. */
OutputStream outputStream;
while (true) {
/* wait for source to be set. */
OutputStream outputStream;
+ Source source;
logger.finest("Entering synchronized block...");
synchronized (syncObject) {
logger.finest("Entered synchronized block.");
logger.finest("Entering synchronized block...");
synchronized (syncObject) {
logger.finest("Entered synchronized block.");
+ source = this.source;
while (source == null) {
try {
logger.finest("Waiting for source to connect...");
while (source == null) {
try {
logger.finest("Waiting for source to connect...");
@@
-145,6
+147,7
@@
public class MultiSourceFilter implements Filter, ReusableSink {
} catch (InterruptedException ie1) {
/* ignore, keep waiting. */
}
} catch (InterruptedException ie1) {
/* ignore, keep waiting. */
}
+ source = this.source;
}
outputStream = pipedOutputStream;
}
}
outputStream = pipedOutputStream;
}