package android.media.midi;
import android.os.IBinder;
import android.os.ParcelFileDescriptor;
import android.os.RemoteException;
import android.util.Log;
import com.android.internal.midi.MidiDispatcher;
import dalvik.system.CloseGuard;
import libcore.io.IoUtils;
import java.io.Closeable;
import java.io.FileDescriptor;
import java.io.FileInputStream;
import java.io.IOException;
public final class MidiOutputPort extends MidiSender implements Closeable {
private static final String TAG = "MidiOutputPort";
private IMidiDeviceServer mDeviceServer;
private final IBinder mToken;
private final int mPortNumber;
private final FileInputStream mInputStream;
private final MidiDispatcher mDispatcher = new MidiDispatcher();
private final CloseGuard mGuard = CloseGuard.get();
private boolean mIsClosed;
private final Thread mThread = new Thread() {
@Override
public void run() {
byte[] buffer = new byte[MidiPortImpl.MAX_PACKET_SIZE];
try {
while (true) {
int count = mInputStream.read(buffer);
if (count < 0) {
break;
}
int packetType = MidiPortImpl.getPacketType(buffer, count);
switch (packetType) {
case MidiPortImpl.PACKET_TYPE_DATA: {
int offset = MidiPortImpl.getDataOffset(buffer, count);
int size = MidiPortImpl.getDataSize(buffer, count);
long timestamp = MidiPortImpl.getPacketTimestamp(buffer, count);
mDispatcher.send(buffer, offset, size, timestamp);
break;
}
case MidiPortImpl.PACKET_TYPE_FLUSH:
mDispatcher.flush();
break;
default:
Log.e(TAG, "Unknown packet type " + packetType);
break;
}
}
} catch (IOException e) {
Log.e(TAG, "read failed", e);
} finally {
IoUtils.closeQuietly(mInputStream);
}
}
};
MidiOutputPort(IMidiDeviceServer server, IBinder token,
FileDescriptor fd, int portNumber) {
mDeviceServer = server;
mToken = token;
mPortNumber = portNumber;
mInputStream = new ParcelFileDescriptor.AutoCloseInputStream(new ParcelFileDescriptor(fd));
mThread.start();
mGuard.open("close");
}
MidiOutputPort(FileDescriptor fd, int portNumber) {
this(null, null, fd, portNumber);
}
public final int getPortNumber() {
return mPortNumber;
}
@Override
public void onConnect(MidiReceiver receiver) {
mDispatcher.getSender().connect(receiver);
}
@Override
public void onDisconnect(MidiReceiver receiver) {
mDispatcher.getSender().disconnect(receiver);
}
@Override
public void close() throws IOException {
synchronized (mGuard) {
if (mIsClosed) return;
mGuard.close();
mInputStream.close();
if (mDeviceServer != null) {
try {
mDeviceServer.closePort(mToken);
} catch (RemoteException e) {
Log.e(TAG, "RemoteException in MidiOutputPort.close()");
}
}
mIsClosed = true;
}
}
@Override
protected void finalize() throws Throwable {
try {
if (mGuard != null) {
mGuard.warnIfOpen();
}
mDeviceServer = null;
close();
} finally {
super.finalize();
}
}
}