__ __ __ __ _____ _ _ _____ _ _ _ | \/ | \ \ / / | __ \ (_) | | / ____| | | | | | \ / |_ __\ V / | |__) | __ ___ ____ _| |_ ___ | (___ | |__ ___| | | | |\/| | '__|> < | ___/ '__| \ \ / / _` | __/ _ \ \___ \| '_ \ / _ \ | | | | | | |_ / . \ | | | | | |\ V / (_| | || __/ ____) | | | | __/ | | |_| |_|_(_)_/ \_\ |_| |_| |_| \_/ \__,_|\__\___| |_____/|_| |_|\___V 2.1 if you need WebShell for Seo everyday contact me on Telegram Telegram Address : @jackleetFor_More_Tools:
/*
+----------------------------------------------------------------------+
| Swoole |
+----------------------------------------------------------------------+
| This source file is subject to version 2.0 of the Apache license, |
| that is bundled with this package in the file LICENSE, and is |
| available through the world-wide-web at the following url: |
| http://www.apache.org/licenses/LICENSE-2.0.html |
| If you did not receive a copy of the Apache2.0 license and are unable|
| to obtain it through the world-wide-web, please send a note to |
| license@swoole.com so we can mail you a copy immediately. |
+----------------------------------------------------------------------+
| Author: Tianfeng Han <rango@swoole.com> |
| Twosee <twose@qq.com> |
+----------------------------------------------------------------------+
*/
#pragma once
#include "swoole.h"
#ifdef SW_USE_THREAD_CONTEXT
#include <thread>
#include <mutex>
#elif !defined(SW_USE_ASM_CONTEXT)
#define USE_UCONTEXT 1
#ifndef _XOPEN_SOURCE
#define _XOPEN_SOURCE
#endif
#include <ucontext.h>
#else
#define USE_ASM_CONTEXT 1
#include "swoole_asm_context.h"
#endif
#if defined(HAVE_VALGRIND) && !defined(HAVE_KQUEUE)
#define USE_VALGRIND 1
#include <valgrind/valgrind.h>
#endif
#ifdef USE_UCONTEXT
typedef ucontext_t coroutine_context_t;
#elif defined(USE_ASM_CONTEXT)
typedef fcontext_t coroutine_context_t;
typedef transfer_t coroutine_transfer_t;
#endif
#if defined(USE_UCONTEXT) || defined(SW_USE_THREAD_CONTEXT)
typedef void *coroutine_transfer_t;
#endif
typedef std::function<void(void *)> CoroutineFunc;
namespace swoole {
namespace coroutine {
class Context {
public:
Context(size_t stack_size, CoroutineFunc fn, void *private_data);
~Context();
bool swap_in();
bool swap_out();
#if !defined(SW_USE_THREAD_CONTEXT) && defined(SW_CONTEXT_DETECT_STACK_USAGE)
ssize_t get_stack_usage();
#endif
#ifndef SW_USE_THREAD_CONTEXT
char *get_stack() const {
return stack_;
}
size_t get_stack_size() const {
return stack_size_;
}
#endif
bool is_end() const {
return end_;
}
protected:
CoroutineFunc fn_;
#ifdef SW_USE_THREAD_CONTEXT
std::thread thread_;
std::mutex lock_;
std::mutex *swap_lock_;
#else
coroutine_context_t ctx_;
coroutine_context_t swap_ctx_;
char *stack_;
uint32_t stack_size_;
#endif
#ifdef USE_VALGRIND
uint32_t valgrind_stack_id;
#endif
void *private_data_;
bool end_;
static void context_func(coroutine_transfer_t arg);
};
} // namespace coroutine
} // namespace swoole
| Name | Type | Size | Permission | Actions |
|---|---|---|---|---|
| swoole.h | File | 26.96 KB | 0644 |
|
| swoole_api.h | File | 2.02 KB | 0644 |
|
| swoole_asm_context.h | File | 2.31 KB | 0644 |
|
| swoole_async.h | File | 3.29 KB | 0644 |
|
| swoole_atomic.h | File | 2.3 KB | 0644 |
|
| swoole_base64.h | File | 1.3 KB | 0644 |
|
| swoole_buffer.h | File | 2.24 KB | 0644 |
|
| swoole_channel.h | File | 2.37 KB | 0644 |
|
| swoole_client.h | File | 11.75 KB | 0644 |
|
| swoole_config.h | File | 8.79 KB | 0644 |
|
| swoole_coroutine.h | File | 8.92 KB | 0644 |
|
| swoole_coroutine_api.h | File | 5.12 KB | 0644 |
|
| swoole_coroutine_channel.h | File | 4.17 KB | 0644 |
|
| swoole_coroutine_context.h | File | 2.75 KB | 0644 |
|
| swoole_coroutine_socket.h | File | 17.64 KB | 0644 |
|
| swoole_coroutine_system.h | File | 3.78 KB | 0644 |
|
| swoole_dtls.h | File | 2.42 KB | 0644 |
|
| swoole_error.h | File | 6.46 KB | 0644 |
|
| swoole_file.h | File | 4.88 KB | 0644 |
|
| swoole_file_hook.h | File | 2.76 KB | 0644 |
|
| swoole_hash.h | File | 1.24 KB | 0644 |
|
| swoole_heap.h | File | 1.9 KB | 0644 |
|
| swoole_http.h | File | 7.24 KB | 0644 |
|
| swoole_http2.h | File | 8.55 KB | 0644 |
|
| swoole_iouring.h | File | 5.52 KB | 0644 |
|
| swoole_llhttp.h | File | 2.02 KB | 0644 |
|
| swoole_lock.h | File | 3.25 KB | 0644 |
|
| swoole_log.h | File | 15.71 KB | 0644 |
|
| swoole_lru_cache.h | File | 3.18 KB | 0644 |
|
| swoole_memory.h | File | 2.83 KB | 0644 |
|
| swoole_message_bus.h | File | 5.18 KB | 0644 |
|
| swoole_mime_type.h | File | 1.42 KB | 0644 |
|
| swoole_mqtt.h | File | 2.16 KB | 0644 |
|
| swoole_msg_queue.h | File | 1.96 KB | 0644 |
|
| swoole_pipe.h | File | 2.6 KB | 0644 |
|
| swoole_process_pool.h | File | 13.17 KB | 0644 |
|
| swoole_protocol.h | File | 5.03 KB | 0644 |
|
| swoole_proxy.h | File | 3.3 KB | 0644 |
|
| swoole_reactor.h | File | 12.4 KB | 0644 |
|
| swoole_redis.h | File | 1.83 KB | 0644 |
|
| swoole_server.h | File | 49.72 KB | 0644 |
|
| swoole_signal.h | File | 2.99 KB | 0644 |
|
| swoole_socket.h | File | 18.51 KB | 0644 |
|
| swoole_socket_hook.h | File | 2.31 KB | 0644 |
|
| swoole_socket_impl.h | File | 1.43 KB | 0644 |
|
| swoole_ssl.h | File | 5.22 KB | 0644 |
|
| swoole_static_handler.h | File | 5.21 KB | 0644 |
|
| swoole_string.h | File | 7.32 KB | 0644 |
|
| swoole_table.h | File | 6.5 KB | 0644 |
|
| swoole_thread.h | File | 1.99 KB | 0644 |
|
| swoole_timer.h | File | 4.37 KB | 0644 |
|
| swoole_uring_socket.h | File | 3.84 KB | 0644 |
|
| swoole_util.h | File | 7.49 KB | 0644 |
|
| swoole_version.h | File | 1.74 KB | 0644 |
|
| swoole_websocket.h | File | 5.11 KB | 0644 |
|