mirrors/looking-glass
2
0
Fork 0
mirror of https://github.com/gnif/LookingGlass.git synced 2025-01-11 06:43:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

[c-host] added cursor and frame thread stubs

Browse source
This commit is contained in:
Geoffrey McRae 2019-03-01 12:42:12 +11:00
parent c9d9205bb8
commit 3674b4ed96
1 changed files with 41 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
c-host/app.c
View file

@ -21,6 +21,7 @@ Place, Suite 330, Boston, MA 02111-1307 USA
#include <stdio.h> #include <stdio.h>
#include <inttypes.h> #include <inttypes.h>
#include <unistd.h>
#include "debug.h" #include "debug.h"
#include "capture/interfaces.h" #include "capture/interfaces.h"
#include "KVMFR.h" #include "KVMFR.h"
@ -40,10 +41,28 @@ struct app
unsigned int frameSize; unsigned int frameSize;
uint8_t * frame[MAX_FRAMES]; uint8_t * frame[MAX_FRAMES];
unsigned int frameOffset[MAX_FRAMES]; unsigned int frameOffset[MAX_FRAMES];
bool running;
osThreadHandle * cursorThread;
osThreadHandle * frameThread;
}; };
static struct app app; static struct app app;
static int cursorThread(void * opaque)
{
while(app.running)
usleep(10000);
return 0;
}
static int frameThread(void * opaque)
{
while(app.running)
usleep(10000);
return 0;
}
int app_main() int app_main()
{ {
unsigned int shmemSize = os_shmemSize(); unsigned int shmemSize = os_shmemSize();
@ -109,10 +128,32 @@ int app_main()
} }
DEBUG_INFO("Capture Size : %u MiB (%u)", maxFrameSize / 1048576, maxFrameSize); DEBUG_INFO("Capture Size : %u MiB (%u)", maxFrameSize / 1048576, maxFrameSize);
if (!os_createThread("CursorThread", cursorThread, NULL, &app.cursorThread))
{
DEBUG_ERROR("Failed to create the cursor thread");
exitcode = -1;
goto exit;
}
if (!os_createThread("FrameThread", frameThread, NULL, &app.frameThread))
{
DEBUG_ERROR("Failed to create the frame thread");
exitcode = -1;
goto exit_cursor_thread;
}
iface->capture(); iface->capture();
iface->capture(); iface->capture();
iface->capture(); iface->capture();
//finish:
app.running = false;
if (!os_joinThread(app.frameThread, NULL))
DEBUG_WARN("Failed to join the cursor thread");
exit_cursor_thread:
app.running = false;
if (!os_joinThread(app.cursorThread, NULL))
DEBUG_WARN("Failed to join the cursor thread");
exit: exit:
iface->deinit(); iface->deinit();
iface->free(); iface->free();