aDriv4 website!

Linux bois.o2switch.net 4.18.0-553.33.1.lve.el8.x86_64 #1 SMP Tue Dec 24 22:25:00 UTC 2024 x86_64
Apache
109.234.165.180

File Name : swoole_coroutine.h

#pragma once

#include "coroutine.h"
#include "socket.h"
#include "zend_vm.h"
#include "zend_closures.h"

#include <stack>

#define SW_DEFAULT_MAX_CORO_NUM              3000
#define SW_DEFAULT_PHP_STACK_PAGE_SIZE       8192

#define SWOG ((zend_output_globals *) &OG(handlers))

typedef enum
{
    SW_CORO_CONTEXT_RUNNING,
    SW_CORO_CONTEXT_IN_DELAYED_TIMEOUT_LIST,
    SW_CORO_CONTEXT_TERM
} php_context_state;

enum sw_coro_hook_type
{
    SW_HOOK_TCP               = 1u << 1,
    SW_HOOK_UDP               = 1u << 2,
    SW_HOOK_UNIX              = 1u << 3,
    SW_HOOK_UDG               = 1u << 4,
    SW_HOOK_SSL               = 1u << 5,
    SW_HOOK_TLS               = 1u << 6,
    SW_HOOK_STREAM_SELECT     = 1u << 7,

SW_HOOK_FILE              = 1u << 8,
    SW_HOOK_SLEEP             = 1u << 9,
    SW_HOOK_BLOCKING_FUNCTION = 1u << 30,

SW_HOOK_ALL               = 0x7fffffff,
};

struct php_coro_task
{
    JMP_BUF *bailout;
    zval *vm_stack_top;
    zval *vm_stack_end;
    zend_vm_stack vm_stack;
    size_t vm_stack_page_size;
    zend_execute_data *execute_data;
    zend_error_handling_t error_handling;
    zend_class_entry *exception_class;
    zend_object *exception;
    zend_output_globals *output_ptr;
    SW_DECLARE_EG_SCOPE(scope);
    swoole::Coroutine *co;
    std::stack<php_swoole_fci *> *defer_tasks;
    long pcid;
    zend_object *context;
#ifdef SW_CORO_SCHEDULER_TICK
    int ticks_count;
    int64_t last_msec;
#endif
};

struct php_coro_args
{
    zend_fcall_info_cache *fci_cache;
    zval *argv;
    uint32_t argc;
};

// TODO: remove php coro context
struct php_coro_context
{
    php_context_state state;
    zval coro_params;
    zval *current_coro_return_value_ptr;
    void *private_data;
    swTimer_node *timer;
    php_coro_task *current_task;
};

namespace swoole
{
class PHPCoroutine
{
public:
    static void init();
    static long create(zend_fcall_info_cache *fci_cache, uint32_t argc, zval *argv);
    static void defer(php_swoole_fci *fci);

static void check_bind(const char *name, long bind_cid);

static bool enable_hook(int flags);
    static bool disable_hook();

static void on_yield(void *arg);

// TODO: remove old coro APIs (Manual)
    static void yield_m(zval *return_value, php_coro_context *sw_php_context);
    static int resume_m(php_coro_context *sw_current_context, zval *retval, zval *coro_retval);

static inline long get_cid()
    {
        return likely(active) ? Coroutine::get_current_cid() : -1;
    }

static inline long get_pcid()
    {
        php_coro_task *task = (php_coro_task *) Coroutine::get_current_task();
        return likely(task) ? task->pcid : -1;
    }

static inline php_coro_task* get_task()
    {
        php_coro_task *task = (php_coro_task *) Coroutine::get_current_task();
        return task ? task : &main_task;
    }

static inline php_coro_task* get_origin_task(php_coro_task *task)
    {
        Coroutine *co = task->co->get_origin();
        return co ? (php_coro_task *) co->get_task() : &main_task;
    }

static inline php_coro_task* get_task_by_cid(long cid)
    {
        return cid == -1 ? &main_task : (php_coro_task *) Coroutine::get_task_by_cid(cid);
    }

static inline uint64_t get_max_num()
    {
        return max_num;
    }

static inline void set_max_num(uint64_t n)
    {
        max_num = n;
    }

#ifdef SW_CORO_SCHEDULER_TICK
#define SW_CORO_SCHEDULER_TICK_EXPECT(s)      likely(s)
#define SW_CORO_SCHEDULER_TICK_UNEXPECT(s)    unlikely(s)

static void enable_scheduler_tick();
    static void disable_scheduler_tick();

static inline void set_max_exec_msec(long msec)
    {
        max_exec_msec = MAX(0, msec);
        record_last_msec(get_task());
    }

static inline bool is_schedulable(php_coro_task *task)
    {
        return (swTimer_get_absolute_msec() - task->last_msec > max_exec_msec);
    }
#endif

protected:
    static bool active;
    static uint64_t max_num;
    static php_coro_task main_task;

static inline void vm_stack_init(void);
    static inline void vm_stack_destroy(void);
    static inline void save_vm_stack(php_coro_task *task);
    static inline void restore_vm_stack(php_coro_task *task);
    static inline void save_og(php_coro_task *task);
    static inline void restore_og(php_coro_task *task);
    static inline void save_task(php_coro_task *task);
    static inline void restore_task(php_coro_task *task);
    static void on_resume(void *arg);
    static void on_close(void *arg);
    static void create_func(void *arg);

#ifdef SW_CORO_SCHEDULER_TICK
    static int64_t max_exec_msec;
    static user_opcode_handler_t ori_tick_handler;

static inline void interrupt_callback(void *data);
    static inline void tick(uint32_t tick_count);
    static inline int tick_handler(zend_execute_data *execute_data);

static inline void record_last_msec(php_coro_task *task)
    {
        if (SW_CORO_SCHEDULER_TICK_EXPECT(max_exec_msec > 0))
        {
            task->last_msec = swTimer_get_absolute_msec();
        }
    }
#endif
};
}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	0/976	0755	2025-02-27 01:26:36
..	dir	-	0/976	0755	2026-03-27 02:22:19
include	dir	-	0/976	0755	2025-02-27 01:26:36
thirdparty	dir	-	0/976	0755	2025-02-27 01:26:36
config.h	text/plain	5.02 KB	0/976	0644	2024-03-21 12:23:58
php_swoole.h	text/x-c	36.72 KB	0/976	0644	2024-03-21 12:23:58
php_swoole_cxx.h	text/x-c++	2.36 KB	0/976	0644	2024-03-21 12:23:58
swoole_config.h	text/x-c	9.56 KB	0/976	0644	2024-03-21 12:23:58
swoole_coroutine.h	text/x-c++	4.96 KB	0/976	0644	2024-03-21 12:23:58
swoole_http.h	text/x-c++	8.76 KB	0/976	0644	2024-03-21 12:23:58
swoole_http_client.h	text/x-c	3.62 KB	0/976	0644	2024-03-21 12:23:58
swoole_http_v2_client.h	text/x-c	4.18 KB	0/976	0644	2024-03-21 12:23:58
swoole_mysql_coro.h	text/x-c	20.67 KB	0/976	0644	2024-03-21 12:23:58
swoole_postgresql_coro.h	text/x-c	1.47 KB	0/976	0644	2024-03-21 12:23:58
swoole_serialize.h	text/x-c	4.24 KB	0/976	0644	2024-03-21 12:23:58

For more Private tool come to me!

https://t.me/aDriv4vz