Cameron Gutman
306 lines
12 KiB
Java
306 lines
12 KiB
Java
package com.limelight.nvstream.jni;
|
|
|
|
import com.limelight.nvstream.NvConnectionListener;
|
|
import com.limelight.nvstream.av.audio.AudioRenderer;
|
|
import com.limelight.nvstream.av.video.VideoDecoderRenderer;
|
|
|
|
public class MoonBridge {
|
|
/* See documentation in Limelight.h for information about these functions and constants */
|
|
|
|
public static final AudioConfiguration AUDIO_CONFIGURATION_STEREO = new AudioConfiguration(2, 0x3);
|
|
public static final AudioConfiguration AUDIO_CONFIGURATION_51_SURROUND = new AudioConfiguration(6, 0x3F);
|
|
public static final AudioConfiguration AUDIO_CONFIGURATION_71_SURROUND = new AudioConfiguration(8, 0x63F);
|
|
|
|
public static final int VIDEO_FORMAT_H264 = 0x0001;
|
|
public static final int VIDEO_FORMAT_H265 = 0x0100;
|
|
public static final int VIDEO_FORMAT_H265_MAIN10 = 0x0200;
|
|
|
|
public static final int VIDEO_FORMAT_MASK_H264 = 0x00FF;
|
|
public static final int VIDEO_FORMAT_MASK_H265 = 0xFF00;
|
|
|
|
public static final int BUFFER_TYPE_PICDATA = 0;
|
|
public static final int BUFFER_TYPE_SPS = 1;
|
|
public static final int BUFFER_TYPE_PPS = 2;
|
|
public static final int BUFFER_TYPE_VPS = 3;
|
|
|
|
public static final int CAPABILITY_DIRECT_SUBMIT = 1;
|
|
public static final int CAPABILITY_REFERENCE_FRAME_INVALIDATION_AVC = 2;
|
|
public static final int CAPABILITY_REFERENCE_FRAME_INVALIDATION_HEVC = 4;
|
|
|
|
public static final int DR_OK = 0;
|
|
public static final int DR_NEED_IDR = -1;
|
|
|
|
public static final int CONN_STATUS_OKAY = 0;
|
|
public static final int CONN_STATUS_POOR = 1;
|
|
|
|
public static final int ML_ERROR_GRACEFUL_TERMINATION = 0;
|
|
public static final int ML_ERROR_NO_VIDEO_TRAFFIC = -100;
|
|
public static final int ML_ERROR_NO_VIDEO_FRAME = -101;
|
|
public static final int ML_ERROR_UNEXPECTED_EARLY_TERMINATION = -102;
|
|
public static final int ML_ERROR_PROTECTED_CONTENT = -103;
|
|
|
|
public static final int ML_PORT_INDEX_TCP_47984 = 0;
|
|
public static final int ML_PORT_INDEX_TCP_47989 = 1;
|
|
public static final int ML_PORT_INDEX_TCP_48010 = 2;
|
|
public static final int ML_PORT_INDEX_UDP_47998 = 8;
|
|
public static final int ML_PORT_INDEX_UDP_47999 = 9;
|
|
public static final int ML_PORT_INDEX_UDP_48000 = 10;
|
|
public static final int ML_PORT_INDEX_UDP_48010 = 11;
|
|
|
|
public static final int ML_PORT_FLAG_ALL = 0xFFFFFFFF;
|
|
public static final int ML_PORT_FLAG_TCP_47984 = 0x0001;
|
|
public static final int ML_PORT_FLAG_TCP_47989 = 0x0002;
|
|
public static final int ML_PORT_FLAG_TCP_48010 = 0x0004;
|
|
public static final int ML_PORT_FLAG_UDP_47998 = 0x0100;
|
|
public static final int ML_PORT_FLAG_UDP_47999 = 0x0200;
|
|
public static final int ML_PORT_FLAG_UDP_48000 = 0x0400;
|
|
public static final int ML_PORT_FLAG_UDP_48010 = 0x0800;
|
|
|
|
public static final int ML_TEST_RESULT_INCONCLUSIVE = 0xFFFFFFFF;
|
|
|
|
private static AudioRenderer audioRenderer;
|
|
private static VideoDecoderRenderer videoRenderer;
|
|
private static NvConnectionListener connectionListener;
|
|
|
|
static {
|
|
System.loadLibrary("moonlight-core");
|
|
init();
|
|
}
|
|
|
|
public static int CAPABILITY_SLICES_PER_FRAME(byte slices) {
|
|
return slices << 24;
|
|
}
|
|
|
|
public static class AudioConfiguration {
|
|
public final int channelCount;
|
|
public final int channelMask;
|
|
|
|
public AudioConfiguration(int channelCount, int channelMask) {
|
|
this.channelCount = channelCount;
|
|
this.channelMask = channelMask;
|
|
}
|
|
|
|
// Creates an AudioConfiguration from the integer value returned by moonlight-common-c
|
|
// See CHANNEL_COUNT_FROM_AUDIO_CONFIGURATION() and CHANNEL_MASK_FROM_AUDIO_CONFIGURATION()
|
|
// in Limelight.h
|
|
private AudioConfiguration(int audioConfiguration) {
|
|
// Check the magic byte before decoding to make sure we got something that's actually
|
|
// a MAKE_AUDIO_CONFIGURATION()-based value and not something else like an older version
|
|
// hardcoded AUDIO_CONFIGURATION value from an earlier version of moonlight-common-c.
|
|
if ((audioConfiguration & 0xFF) != 0xCA) {
|
|
throw new IllegalArgumentException("Audio configuration has invalid magic byte!");
|
|
}
|
|
|
|
this.channelCount = (audioConfiguration >> 8) & 0xFF;
|
|
this.channelMask = (audioConfiguration >> 16) & 0xFFFF;
|
|
}
|
|
|
|
// See SURROUNDAUDIOINFO_FROM_AUDIO_CONFIGURATION() in Limelight.h
|
|
public int getSurroundAudioInfo() {
|
|
return channelMask << 16 | channelCount;
|
|
}
|
|
|
|
@Override
|
|
public boolean equals(Object obj) {
|
|
if (obj instanceof AudioConfiguration) {
|
|
AudioConfiguration that = (AudioConfiguration)obj;
|
|
return this.toInt() == that.toInt();
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
@Override
|
|
public int hashCode() {
|
|
return toInt();
|
|
}
|
|
|
|
// Returns the integer value expected by moonlight-common-c
|
|
// See MAKE_AUDIO_CONFIGURATION() in Limelight.h
|
|
public int toInt() {
|
|
return ((channelMask) << 16) | (channelCount << 8) | 0xCA;
|
|
}
|
|
}
|
|
|
|
public static int bridgeDrSetup(int videoFormat, int width, int height, int redrawRate) {
|
|
if (videoRenderer != null) {
|
|
return videoRenderer.setup(videoFormat, width, height, redrawRate);
|
|
}
|
|
else {
|
|
return -1;
|
|
}
|
|
}
|
|
|
|
public static void bridgeDrStart() {
|
|
if (videoRenderer != null) {
|
|
videoRenderer.start();
|
|
}
|
|
}
|
|
|
|
public static void bridgeDrStop() {
|
|
if (videoRenderer != null) {
|
|
videoRenderer.stop();
|
|
}
|
|
}
|
|
|
|
public static void bridgeDrCleanup() {
|
|
if (videoRenderer != null) {
|
|
videoRenderer.cleanup();
|
|
}
|
|
}
|
|
|
|
public static int bridgeDrSubmitDecodeUnit(byte[] decodeUnitData, int decodeUnitLength,
|
|
int decodeUnitType, int frameNumber,
|
|
long receiveTimeMs, long enqueueTimeMs) {
|
|
if (videoRenderer != null) {
|
|
return videoRenderer.submitDecodeUnit(decodeUnitData, decodeUnitLength,
|
|
decodeUnitType, frameNumber, receiveTimeMs, enqueueTimeMs);
|
|
}
|
|
else {
|
|
return DR_OK;
|
|
}
|
|
}
|
|
|
|
public static int bridgeArInit(int audioConfiguration, int sampleRate, int samplesPerFrame) {
|
|
if (audioRenderer != null) {
|
|
return audioRenderer.setup(new AudioConfiguration(audioConfiguration), sampleRate, samplesPerFrame);
|
|
}
|
|
else {
|
|
return -1;
|
|
}
|
|
}
|
|
|
|
public static void bridgeArStart() {
|
|
if (audioRenderer != null) {
|
|
audioRenderer.start();
|
|
}
|
|
}
|
|
|
|
public static void bridgeArStop() {
|
|
if (audioRenderer != null) {
|
|
audioRenderer.stop();
|
|
}
|
|
}
|
|
|
|
public static void bridgeArCleanup() {
|
|
if (audioRenderer != null) {
|
|
audioRenderer.cleanup();
|
|
}
|
|
}
|
|
|
|
public static void bridgeArPlaySample(short[] pcmData) {
|
|
if (audioRenderer != null) {
|
|
audioRenderer.playDecodedAudio(pcmData);
|
|
}
|
|
}
|
|
|
|
public static void bridgeClStageStarting(int stage) {
|
|
if (connectionListener != null) {
|
|
connectionListener.stageStarting(getStageName(stage));
|
|
}
|
|
}
|
|
|
|
public static void bridgeClStageComplete(int stage) {
|
|
if (connectionListener != null) {
|
|
connectionListener.stageComplete(getStageName(stage));
|
|
}
|
|
}
|
|
|
|
public static void bridgeClStageFailed(int stage, int errorCode) {
|
|
if (connectionListener != null) {
|
|
connectionListener.stageFailed(getStageName(stage), getPortFlagsFromStage(stage), errorCode);
|
|
}
|
|
}
|
|
|
|
public static void bridgeClConnectionStarted() {
|
|
if (connectionListener != null) {
|
|
connectionListener.connectionStarted();
|
|
}
|
|
}
|
|
|
|
public static void bridgeClConnectionTerminated(int errorCode) {
|
|
if (connectionListener != null) {
|
|
connectionListener.connectionTerminated(errorCode);
|
|
}
|
|
}
|
|
|
|
public static void bridgeClRumble(short controllerNumber, short lowFreqMotor, short highFreqMotor) {
|
|
if (connectionListener != null) {
|
|
connectionListener.rumble(controllerNumber, lowFreqMotor, highFreqMotor);
|
|
}
|
|
}
|
|
|
|
public static void bridgeClConnectionStatusUpdate(int connectionStatus) {
|
|
if (connectionListener != null) {
|
|
connectionListener.connectionStatusUpdate(connectionStatus);
|
|
}
|
|
}
|
|
|
|
public static void setupBridge(VideoDecoderRenderer videoRenderer, AudioRenderer audioRenderer, NvConnectionListener connectionListener) {
|
|
MoonBridge.videoRenderer = videoRenderer;
|
|
MoonBridge.audioRenderer = audioRenderer;
|
|
MoonBridge.connectionListener = connectionListener;
|
|
}
|
|
|
|
public static void cleanupBridge() {
|
|
MoonBridge.videoRenderer = null;
|
|
MoonBridge.audioRenderer = null;
|
|
MoonBridge.connectionListener = null;
|
|
}
|
|
|
|
public static native int startConnection(String address, String appVersion, String gfeVersion,
|
|
int width, int height, int fps,
|
|
int bitrate, int packetSize, int streamingRemotely,
|
|
int audioConfiguration, boolean supportsHevc,
|
|
boolean enableHdr,
|
|
int hevcBitratePercentageMultiplier,
|
|
int clientRefreshRateX100,
|
|
byte[] riAesKey, byte[] riAesIv,
|
|
int videoCapabilities);
|
|
|
|
public static native void stopConnection();
|
|
|
|
public static native void interruptConnection();
|
|
|
|
public static native void sendMouseMove(short deltaX, short deltaY);
|
|
|
|
public static native void sendMousePosition(short x, short y, short referenceWidth, short referenceHeight);
|
|
|
|
public static native void sendMouseButton(byte buttonEvent, byte mouseButton);
|
|
|
|
public static native void sendMultiControllerInput(short controllerNumber,
|
|
short activeGamepadMask, short buttonFlags,
|
|
byte leftTrigger, byte rightTrigger,
|
|
short leftStickX, short leftStickY,
|
|
short rightStickX, short rightStickY);
|
|
|
|
public static native void sendControllerInput(short buttonFlags,
|
|
byte leftTrigger, byte rightTrigger,
|
|
short leftStickX, short leftStickY,
|
|
short rightStickX, short rightStickY);
|
|
|
|
public static native void sendKeyboardInput(short keyMap, byte keyDirection, byte modifier);
|
|
|
|
public static native void sendMouseScroll(byte scrollClicks);
|
|
|
|
public static native void sendMouseHighResScroll(short scrollAmount);
|
|
|
|
public static native String getStageName(int stage);
|
|
|
|
public static native String findExternalAddressIP4(String stunHostName, int stunPort);
|
|
|
|
public static native int getPendingAudioDuration();
|
|
|
|
public static native int getPendingVideoFrames();
|
|
|
|
public static native int testClientConnectivity(String testServerHostName, int referencePort, int testFlags);
|
|
|
|
public static native int getPortFlagsFromStage(int stage);
|
|
|
|
public static native int getPortFlagsFromTerminationErrorCode(int errorCode);
|
|
|
|
public static native String stringifyPortFlags(int portFlags, String separator);
|
|
|
|
public static native void init();
|
|
}
|