import net.pterodactylus.sonitus.data.AbstractFilter;
import net.pterodactylus.sonitus.data.Controller;
+import net.pterodactylus.sonitus.data.DataPacket;
import net.pterodactylus.sonitus.data.Filter;
import net.pterodactylus.sonitus.data.Metadata;
this.source.notifyAll();
}
metadataUpdated(source.metadata());
- logger.info(String.format("Next Source set: %s", source));
+ logger.info(String.format("Next Source set: %s", source.name()));
}
}
@Override
public Metadata metadata() {
- if (super.metadata() == null) {
+ if (super.metadata() == Metadata.UNKNOWN) {
/* no metadata yet, wait for it. */
waitForNewSource();
sourceChanged = false;
}
@Override
- public byte[] get(int bufferSize) throws EOFException, IOException {
+ public DataPacket get(int bufferSize) throws EOFException, IOException {
while (true) {
try {
return source.get().get(bufferSize);
} catch (EOFException eofe1) {
+ logger.info(String.format("Got EOF from %s.", source.get().name()));
waitForNewSource();
} finally {
synchronized (source) {