juv rtmp android

package com.weedong.net.rtmp; import java.lang.reflect.Method; import java.util.Map; import com.smaxe.uv.client.ICamera; import com.smaxe.uv.client.IMicrophone; import com.smaxe.uv.client.INetConnection; import com.smaxe.uv.client.INetStream; import com.smaxe.uv.client.IVideo; import com.smaxe.uv.client.a.c; import com.smaxe.uv.client.video.EmptyVideo; import com.smaxe.uv.stream.MediaData; public final class UltraNetStream extends c implements INetStream { private com.smaxe.uv.client.a.d a = null; private IVideo b = new EmptyVideo(); private volatile boolean c = false; private IMicrophone d = null; private ICamera e = null; private e f = null; private c g = null; private a h = null; private a i = null; public UltraNetStream(INetConnection paramINetConnection) { this.a = ((UltraNetConnection)paramINetConnection).a(); this.a.a(paramINetConnection, this, new d()); this.h = new a(); this.i = new a(); } public INetStream.Info getInfo() { return new INetStream.Info(this.h.a, this.h.b, this.h.c, this.i.a, this.i.b, this.i.c); } public ICamera getCamera() { return this.e; } public IMicrophone getMicrophone() { return this.d; } public IVideo getVideo() { if ((this.b instanceof b)) return ((b)this.b).a(); return this.b; } public double bufferLength() { return this.c ? this.a.b(this) : this.b.bufferLength(); } public int bufferSize() { return this.c ? this.a.c(this) : 0; } public long bytesLoaded() { return this.b.bytesLoaded(); } public long bytesTotal() { return this.b.bytesTotal(); } public int clearBuffer() { return this.a.a(this); } public void attachAudio(IMicrophone paramIMicrophone) { if (this.d == paramIMicrophone) return; if (this.d != null) { this.d.removeListener(this.g); this.g = null; } this.d = paramIMicrophone; if (this.d != null) this.d.addListener(this.g = new c()); } public void attachCamera(ICamera paramICamera, int paramInt) { if (this.e == paramICamera) return; if (this.e != null) { this.e.removeListener(this.f); this.f = null; } this.e = paramICamera; if (this.e != null) this.e.addListener(this.f = new e(paramInt)); } public void publish(String paramString1, String paramString2) { paramString2 = paramString2 == null ? "live" : paramString2; if ((!"append".equalsIgnoreCase(paramString2)) && (!"live".equalsIgnoreCase(paramString2)) && (!"record".equalsIgnoreCase(paramString2))) throw new IllegalArgumentException("Wrong publish type '" + paramString2 + "'. Use 'live','record' or 'append' type"); this.a.a(this, paramString1, paramString2); this.c = true; } public void send(String paramString, Object... paramArrayOfObject) { this.a.a(this, paramString, paramArrayOfObject); } public double currentFPS() { return this.b.fps(); } public double liveDelay() { return this.b.liveDelay(); } public double time() { return this.b.time(); } public void play(IVideo paramIVideo, Object... paramArrayOfObject) { if (paramIVideo == null) throw new IllegalArgumentException("Parameter 'video' is null"); this.b = new b(paramIVideo); this.a.a(this, this.b, paramArrayOfObject); } public void pause() { this.a.d(this); } public void receiveAudio(boolean paramBoolean) { this.a.a(this, paramBoolean); } public void receiveVideo(boolean paramBoolean) { this.a.b(this, paramBoolean); } public void resume() { this.a.e(this); } public void seek(double paramDouble) { this.a.a(this, paramDouble); } public void togglePause() { if (this.c) pause(); else resume(); } public void close() { attachAudio(null); attachCamera(null, 0); this.a.f(this); super.close(); } public void _RtmpSampleAccess(boolean paramBoolean1, boolean paramBoolean2) { } static void a(UltraNetStream netstream, String s, Exception exception) { netstream.a(s, exception); } static void a(UltraNetStream netstream, String s) { netstream.a(s); } static void a(UltraNetStream netstream, Map map) { netstream.c(map); } static void b(UltraNetStream netstream, Map map) { netstream.a(map); } static IVideo a(UltraNetStream netstream) { return netstream.b; } static void c(UltraNetStream netstream, Map map) { netstream.b(map); } static void d(UltraNetStream netstream, Map map) { netstream.d(map); } static boolean b(UltraNetStream netstream) { return netstream.c; } static a c(UltraNetStream netstream) { return netstream.i; } static com.smaxe.uv.client.a.d d(UltraNetStream netstream) { return netstream.a; } static a e(UltraNetStream netstream) { return netstream.h; } private final class a { public int a = 0; public int b = 0; public int c = 0; public a() { } public MediaData a(MediaData paramMediaData) { this.a = (this.b == 0 ? 0 : this.a + paramMediaData.rtime); this.b += 1; this.c += paramMediaData.size(); return paramMediaData; } } private final class b implements IVideo { private final IVideo b; public b(IVideo arg2) { this.b = arg2; } public IVideo a() { return this.b; } public double bufferLength() { return this.b.bufferLength(); } public long bytesLoaded() { return this.b.bytesLoaded(); } public long bytesTotal() { return this.b.bytesTotal(); } public void clear() { this.b.clear(); } public void clearPlayBuffer() { this.b.clearPlayBuffer(); } public double fps() { return this.b.fps(); } public double liveDelay() { return this.b.liveDelay(); } public void reset() { this.b.reset(); } public double time() { return this.b.time(); } public void onAudioData(MediaData paramMediaData) { this.b.onAudioData(UltraNetStream.e(UltraNetStream.this).a(paramMediaData)); } public void onVideoData(MediaData paramMediaData) { this.b.onVideoData(UltraNetStream.c(UltraNetStream.this).a(paramMediaData)); } public void onFlvData(MediaData paramMediaData) { this.b.onFlvData(paramMediaData); } public void onCuePoint(Object paramObject) { this.b.onCuePoint(paramObject); } public void onMetaData(Object paramObject) { this.b.onMetaData(paramObject); } public void onSetDataFrame(String paramString, Object paramObject) { this.b.onSetDataFrame(paramString, paramObject); } } private final class c extends IMicrophone.ListenerAdapter { public c() { } public void onAudioData(MediaData paramMediaData) { if (!UltraNetStream.b(UltraNetStream.this)) return; UltraNetStream.d(UltraNetStream.this).a(UltraNetStream.this, UltraNetStream.e(UltraNetStream.this).a(paramMediaData)); } } private final class e extends ICamera.ListenerAdapter { private final int b; private long c = 0L; public e(int arg2) { this.b = arg2; } public void onVideoData(MediaData paramMediaData) { if (!UltraNetStream.b(UltraNetStream.this)) return; if (this.b > 0) { try { Cl