This commit is contained in:
pigeatgarlic 2025-02-13 17:12:09 +00:00
parent daf569a6d0
commit e95124fe1d
2 changed files with 8 additions and 8 deletions

View File

@ -12,7 +12,6 @@
#include <sstream>
#include <windows.h>
#pragma comment(lib, "user32.lib")
#define BUF_SIZE 256
@ -35,7 +34,7 @@ map_file(char* name)
FILE_MAP_ALL_ACCESS, // read/write permission
0,
0,
BUF_SIZE);
sizeof(Queue));
if (pBuf == NULL) {
BOOST_LOG(error) << "Could not map view of file (%d) " << GetLastError();

View File

@ -164,6 +164,7 @@ main(int argc, char *argv[]) {
auto platf_deinit_guard = platf::init();
auto queue = init_shared_memory(argv[2]);
memset(queue,0,sizeof(Queue));
if (!platf_deinit_guard) {
BOOST_LOG(error) << "Platform failed to initialize"sv;
return StatusCode::NO_ENCODER_AVAILABLE;
@ -257,9 +258,9 @@ main(int argc, char *argv[]) {
if (queue->inindex >= QUEUE_SIZE)
queue->inindex = 0;
memcpy(&queue->incoming[queue->inindex],&queue->inindex,sizeof(uint32_t));
memcpy(&queue->incoming[queue->inindex] + sizeof(uint32_t),&duration,sizeof(uint32_t));
memcpy(&queue->incoming[queue->inindex] + sizeof(uint32_t) + sizeof(uint32_t),ptr,size);
memcpy(queue->incoming[queue->inindex].data,&queue->inindex,sizeof(uint32_t));
memcpy(queue->incoming[queue->inindex].data + sizeof(uint32_t),&duration,sizeof(uint32_t));
memcpy(queue->incoming[queue->inindex].data + sizeof(uint32_t) + sizeof(uint32_t),ptr,size);
queue->incoming[queue->inindex].size = size + sizeof(uint32_t) + sizeof(uint32_t);
queue->inindex++;
last_timestamp = timestamp;
@ -274,9 +275,9 @@ main(int argc, char *argv[]) {
if (queue->inindex >= QUEUE_SIZE)
queue->inindex = 0;
memcpy(&queue->incoming[queue->inindex],&queue->inindex,sizeof(uint32_t));
memcpy(&queue->incoming[queue->inindex] + sizeof(uint32_t),&duration,sizeof(uint32_t));
memcpy(&queue->incoming[queue->inindex] + sizeof(uint32_t) + sizeof(uint32_t),ptr,size);
memcpy(queue->incoming[queue->inindex].data,&queue->inindex,sizeof(uint32_t));
memcpy(queue->incoming[queue->inindex].data + sizeof(uint32_t),&duration,sizeof(uint32_t));
memcpy(queue->incoming[queue->inindex].data + sizeof(uint32_t) + sizeof(uint32_t),ptr,size);
queue->incoming[queue->inindex].size = size + sizeof(uint32_t) + sizeof(uint32_t);
queue->inindex++;
last_timestamp = timestamp;