projects
/
sonitus.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Include source/sink details in exceptions.
[sonitus.git]
/
src
/
main
/
java
/
net
/
pterodactylus
/
sonitus
/
data
/
Pipeline.java
diff --git
a/src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
b/src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
index
93648bc
..
b45d346
100644
(file)
--- a/
src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
+++ b/
src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
@@
-261,7
+261,12
@@
public class Pipeline {
try {
final Metadata lastMetadata = firstMetadata;
final Metadata metadata = firstMetadata = source.metadata();
try {
final Metadata lastMetadata = firstMetadata;
final Metadata metadata = firstMetadata = source.metadata();
- final byte[] buffer = source.get(4096);
+ final byte[] buffer;
+ try {
+ buffer = source.get(4096);
+ } catch (IOException ioe1) {
+ throw new IOException(String.format("I/O error while reading from %s.", source), ioe1);
+ }
List<Future<Void>> futures = executorService.invokeAll(FluentIterable.from(sinks).transform(new Function<Sink, Callable<Void>>() {
@Override
List<Future<Void>> futures = executorService.invokeAll(FluentIterable.from(sinks).transform(new Function<Sink, Callable<Void>>() {
@Override
@@
-273,7
+278,11
@@
public class Pipeline {
if (!metadata.equals(lastMetadata)) {
sink.metadataUpdated(metadata);
}
if (!metadata.equals(lastMetadata)) {
sink.metadataUpdated(metadata);
}
- sink.process(buffer);
+ try {
+ sink.process(buffer);
+ } catch (IOException ioe1) {
+ throw new IOException(String.format("I/O error while writing to %s", sink), ioe1);
+ }
return null;
}
};
return null;
}
};