1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556 |
- #define LIBCO_C
- #include "libco.h"
- #include "settings.h"
- #define WINVER 0x0400
- #define _WIN32_WINNT 0x0400
- #include <windows.h>
- #ifdef __cplusplus
- extern "C" {
- #endif
- static thread_local cothread_t co_active_ = 0;
- static void __stdcall co_thunk(void* coentry) {
- ((void (*)(void))coentry)();
- }
- cothread_t co_active() {
- if(!co_active_) {
- ConvertThreadToFiber(0);
- co_active_ = GetCurrentFiber();
- }
- return co_active_;
- }
- cothread_t co_derive(void* memory, unsigned int heapsize, void (*coentry)(void)) {
- /* Windows fibers do not allow users to supply their own memory */
- return (cothread_t)0;
- }
- cothread_t co_create(unsigned int heapsize, void (*coentry)(void)) {
- if(!co_active_) {
- ConvertThreadToFiber(0);
- co_active_ = GetCurrentFiber();
- }
- return (cothread_t)CreateFiber(heapsize, co_thunk, (void*)coentry);
- }
- void co_delete(cothread_t cothread) {
- DeleteFiber(cothread);
- }
- void co_switch(cothread_t cothread) {
- co_active_ = cothread;
- SwitchToFiber(cothread);
- }
- int co_serializable() {
- return 0;
- }
- #ifdef __cplusplus
- }
- #endif
|