moonlight-stream/moonlight-common-c
1
0
Fork 0
mirror of https://github.com/moonlight-stream/moonlight-common-c.git synced 2025-07-01 23:35:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

Batch async control stream callbacks

Browse Source
This commit is contained in:
Cameron Gutman 2023-09-18 23:02:44 -05:00
parent a258b7e12b
commit c1744de069
1 changed files with 74 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

82
src/ControlStream.c
View File

@ -819,26 +819,75 @@ static int ignoreDisconnectIntercept(ENetHost* host, ENetEvent* event) {
}
static void asyncCallbackThreadFunc(void* context) {
PQUEUED_ASYNC_CALLBACK queuedCb;
PQUEUED_ASYNC_CALLBACK queuedCb, nextCb;
while (LbqWaitForQueueElement(&asyncCallbackQueue, (void**)&queuedCb) == LBQ_SUCCESS) {
switch (queuedCb->typeIndex) {
case IDX_RUMBLE_DATA:
// Look for another rumble packet to batch with
while (LbqPeekQueueElement(&asyncCallbackQueue, (void**)&nextCb) == LBQ_SUCCESS) {
// Don't batch with the next packet if it is a different type or controller number
if (nextCb->typeIndex != queuedCb->typeIndex ||
nextCb->data.rumble.controllerNumber != queuedCb->data.rumble.controllerNumber) {
break;
}
// This entry is batchable, so pop it off the queue
if (LbqPollQueueElement(&asyncCallbackQueue, (void**)&nextCb) != LBQ_SUCCESS) {
break;
}
// Replace the old entry with the new one
free(queuedCb);
queuedCb = nextCb;
}
ListenerCallbacks.rumble(queuedCb->data.rumble.controllerNumber,
queuedCb->data.rumble.lowFreqRumble,
queuedCb->data.rumble.highFreqRumble);
break;
case IDX_RUMBLE_TRIGGER_DATA:
// Look for another rumble triggers packet to batch with
while (LbqPeekQueueElement(&asyncCallbackQueue, (void**)&nextCb) == LBQ_SUCCESS) {
// Don't batch with the next packet if it is a different type or controller number
if (nextCb->typeIndex != queuedCb->typeIndex ||
nextCb->data.rumbleTriggers.controllerNumber != queuedCb->data.rumbleTriggers.controllerNumber) {
break;
}
// This entry is batchable, so pop it off the queue
if (LbqPollQueueElement(&asyncCallbackQueue, (void**)&nextCb) != LBQ_SUCCESS) {
break;
}
// Replace the old entry with the new one
free(queuedCb);
queuedCb = nextCb;
}
ListenerCallbacks.rumbleTriggers(queuedCb->data.rumbleTriggers.controllerNumber,
queuedCb->data.rumbleTriggers.leftTriggerMotor,
queuedCb->data.rumbleTriggers.rightTriggerMotor);
break;
case IDX_SET_MOTION_EVENT:
ListenerCallbacks.setMotionEventState(queuedCb->data.setMotionEventState.controllerNumber,
queuedCb->data.setMotionEventState.motionType,
queuedCb->data.setMotionEventState.reportRateHz);
break;
case IDX_SET_RGB_LED:
// Look for another controller LED packet to batch with
while (LbqPeekQueueElement(&asyncCallbackQueue, (void**)&nextCb) == LBQ_SUCCESS) {
// Don't batch with the next packet if it is a different type or controller number
if (nextCb->typeIndex != queuedCb->typeIndex ||
nextCb->data.setControllerLed.controllerNumber != queuedCb->data.setControllerLed.controllerNumber) {
break;
}
// This entry is batchable, so pop it off the queue
if (LbqPollQueueElement(&asyncCallbackQueue, (void**)&nextCb) != LBQ_SUCCESS) {
break;
}
// Replace the old entry with the new one
free(queuedCb);
queuedCb = nextCb;
}
ListenerCallbacks.setControllerLED(queuedCb->data.setControllerLed.controllerNumber,
queuedCb->data.setControllerLed.r,
queuedCb->data.setControllerLed.g,
@ -846,10 +895,27 @@ static void asyncCallbackThreadFunc(void* context) {
break;
case IDX_HDR_INFO:
// HDR state is maintained globally, so we just invoke the client callback here.
// If the state has changed multiple times, the client could receive duplicate
// callbacks but that is fine.
// These events are stateless, so we can consume all of them now.
while (LbqPeekQueueElement(&asyncCallbackQueue, (void**)&nextCb) == LBQ_SUCCESS && nextCb->typeIndex == queuedCb->typeIndex) {
// This entry is batchable, so pop it off the queue
if (LbqPollQueueElement(&asyncCallbackQueue, (void**)&nextCb) != LBQ_SUCCESS) {
break;
}
// Replace the old entry with the new one
free(queuedCb);
queuedCb = nextCb;
}
ListenerCallbacks.setHdrMode(hdrEnabled);
break;
case IDX_SET_MOTION_EVENT:
// These events are infrequent and cannot be batched
ListenerCallbacks.setMotionEventState(queuedCb->data.setMotionEventState.controllerNumber,
queuedCb->data.setMotionEventState.motionType,
queuedCb->data.setMotionEventState.reportRateHz);
break;
default:
// Unhandled packet type from queueAsyncCallback()
LC_ASSERT(false);