diff options
Diffstat (limited to 'firmware/target/hosted/sdl/filesystem-sdl.c')
-rw-r--r-- | firmware/target/hosted/sdl/filesystem-sdl.c | 55 |
1 files changed, 55 insertions, 0 deletions
diff --git a/firmware/target/hosted/sdl/filesystem-sdl.c b/firmware/target/hosted/sdl/filesystem-sdl.c new file mode 100644 index 0000000000..5a8e2c417a --- /dev/null +++ b/firmware/target/hosted/sdl/filesystem-sdl.c | |||
@@ -0,0 +1,55 @@ | |||
1 | /*************************************************************************** | ||
2 | * __________ __ ___. | ||
3 | * Open \______ \ ____ ____ | | _\_ |__ _______ ___ | ||
4 | * Source | _// _ \_/ ___\| |/ /| __ \ / _ \ \/ / | ||
5 | * Jukebox | | ( <_> ) \___| < | \_\ ( <_> > < < | ||
6 | * Firmware |____|_ /\____/ \___ >__|_ \|___ /\____/__/\_ \ | ||
7 | * \/ \/ \/ \/ \/ | ||
8 | * $Id$ | ||
9 | * | ||
10 | * Copyright (C) 2014 by Michael Sevakis | ||
11 | * | ||
12 | * This program is free software; you can redistribute it and/or | ||
13 | * modify it under the terms of the GNU General Public License | ||
14 | * as published by the Free Software Foundation; either version 2 | ||
15 | * of the License, or (at your option) any later version. | ||
16 | * | ||
17 | * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY | ||
18 | * KIND, either express or implied. | ||
19 | * | ||
20 | ****************************************************************************/ | ||
21 | #define RB_FILESYSTEM_OS | ||
22 | #include "config.h" | ||
23 | #include "system.h" | ||
24 | #include "thread-sdl.h" | ||
25 | #include "mutex.h" | ||
26 | #include "file.h" | ||
27 | |||
28 | #ifdef HAVE_SDL_THREADS | ||
29 | #define YIELD_THRESHOLD 512 | ||
30 | static bool initialized = false; | ||
31 | static struct mutex readwrite_mtx; | ||
32 | |||
33 | /* Allow other threads to run while performing I/O */ | ||
34 | ssize_t os_sdl_readwrite(int osfd, void *buf, size_t nbyte, bool dowrite) | ||
35 | { | ||
36 | if (!initialized) | ||
37 | { | ||
38 | mutex_init(&readwrite_mtx); | ||
39 | initialized = true; | ||
40 | } | ||
41 | |||
42 | mutex_lock(&readwrite_mtx); | ||
43 | |||
44 | void *mythread = nbyte > YIELD_THRESHOLD ? sim_thread_unlock() : NULL; | ||
45 | |||
46 | ssize_t rc = dowrite ? write(osfd, buf, nbyte) : read(osfd, buf, nbyte); | ||
47 | |||
48 | if (mythread) | ||
49 | sim_thread_lock(mythread); | ||
50 | |||
51 | mutex_unlock(&readwrite_mtx); | ||
52 | return rc; | ||
53 | } | ||
54 | |||
55 | #endif /* HAVE_SDL_THREADS */ | ||