projects
/
sonitus.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add comment to content metadata.
[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
ae4158d
..
66ee2e5
100644
(file)
--- a/
src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
+++ b/
src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
@@
-330,6
+330,9
@@
public class Pipeline implements Iterable<ControlledComponent> {
/** The executor service. */
private final ExecutorService executorService;
/** The executor service. */
private final ExecutorService executorService;
+ /** The time the connection was started. */
+ private long startTime;
+
/** The number of copied bytes. */
private long counter;
/** The number of copied bytes. */
private long counter;
@@
-344,7
+347,7
@@
public class Pipeline implements Iterable<ControlledComponent> {
public Connection(Source source, Collection<Sink> sinks) {
this.source = source;
this.sinks = sinks;
public Connection(Source source, Collection<Sink> sinks) {
this.source = source;
this.sinks = sinks;
- if (sinks.size()
== 1
) {
+ if (sinks.size()
< 2
) {
executorService = MoreExecutors.sameThreadExecutor();
} else {
executorService = Executors.newCachedThreadPool();
executorService = MoreExecutors.sameThreadExecutor();
} else {
executorService = Executors.newCachedThreadPool();
@@
-356,6
+359,16
@@
public class Pipeline implements Iterable<ControlledComponent> {
//
/**
//
/**
+ * Returns the time this connection was started.
+ *
+ * @return The time this connection was started (in milliseconds since Jan 1,
+ * 1970 UTC)
+ */
+ public long startTime() {
+ return startTime;
+ }
+
+ /**
* Returns the number of bytes that this connection has received from its
* source during its lifetime.
*
* Returns the number of bytes that this connection has received from its
* source during its lifetime.
*
@@
-380,7
+393,7
@@
public class Pipeline implements Iterable<ControlledComponent> {
@Override
public void run() {
@Override
public void run() {
-
Metadata firstMetadata = null
;
+
startTime = System.currentTimeMillis()
;
while (!stopped.get()) {
try {
final byte[] buffer;
while (!stopped.get()) {
try {
final byte[] buffer;