pxcloud/sunshine-sdk
6
0
Fork 0
mirror of https://github.com/thinkonmay/sunshine-sdk.git synced 2026-08-11 12:40:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

verify through index

Browse Source
This commit is contained in:
pigeatgarlic 2025-01-29 16:03:28 +00:00
parent 58faf6d213
commit 0e39e3e1b4
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/main.cpp
View File

@ -335,6 +335,7 @@ main(int argc, char *argv[]) {
auto lPort = local_endpoint.port();
auto buffer = (char*)malloc(1024 * 1024);
uint16_t index = 0;
while (!process_shutdown_event->peek() && !local_shutdown->peek()) {
if (queue_type == QueueType::Video) {
do {
@ -349,17 +350,19 @@ main(int argc, char *argv[]) {
size_t size = packet->data_size();
auto duration = uint32_t(timestamp - last_timestamp);;
memcpy(buffer,&duration,sizeof(uint32_t));
memcpy(buffer+sizeof(uint32_t),ptr,size);
memcpy(buffer,&index,sizeof(uint16_t));
memcpy(buffer + sizeof(uint16_t),&duration,sizeof(uint32_t));
memcpy(buffer + sizeof(uint32_t) + sizeof(uint16_t),ptr,size);
platf::batched_send_info_t send_info {
buffer, size + sizeof(uint32_t), 1,
buffer, size + sizeof(uint32_t) + sizeof(uint16_t), 1,
client->GetHandle(),
rAddr, rPort, lAddr
};
platf::send_batch(send_info);
last_timestamp = timestamp;
index++;
} while (video_packets->peek());
} else if (queue_type == QueueType::Audio) {
do {
@ -369,17 +372,19 @@ main(int argc, char *argv[]) {
size_t size = packet->second.size();
auto duration = uint32_t(timestamp - last_timestamp);;
memcpy(buffer,&duration,sizeof(uint32_t));
memcpy(buffer+sizeof(uint32_t),ptr,size);
memcpy(buffer,&index,sizeof(uint16_t));
memcpy(buffer + sizeof(uint16_t),&duration,sizeof(uint32_t));
memcpy(buffer + sizeof(uint32_t) + sizeof(uint16_t),ptr,size);
platf::batched_send_info_t send_info {
buffer, size + sizeof(uint32_t), 1,
buffer, size + sizeof(uint32_t) + sizeof(uint16_t), 1,
client->GetHandle(),
rAddr, rPort, lAddr
};
platf::send_batch(send_info);
last_timestamp = timestamp;
index++;
} while (audio_packets->peek());
}
}