Store : Webshell.Store

Linux lhcp3406.webapps.net 3.10.0-962.3.2.lve1.5.82.el7.x86_64 #1 SMP Tue Oct 31 10:15:24 UTC 2023 x86_64

Apache

81.88.53.156 | Your IP: 216.73.216.101

Cant read [ /etc/named.conf ]

[ drwxr-xr-x ]

/ opt / cloudlinux / alt-php82 / root / usr / include / php / ext / swoole / include /

Home Upload Info Server

Server Info

Operating System	:	Linux lhcp3406.webapps.net 3.10.0-962.3.2.lve1.5.82.el7.x86_64 #1 SMP Tue Oct 31 10:15:24 UTC 2023 x86_64
User / Group	:	1190[c43ut3hs] / 1192[c43ut3hs]
PHP Version	:	5.6.40
IP Server	:	81.88.53.156
Your IP	:	216.73.216.101
Storage	:	Total = 1.05 TB, Free = 301.76 GB [28%]
Domains	:	Cant read [ /etc/named.conf ]
Software	:	Apache
Disable Functions	:	All function is accessible
Useful Functions	:	gcc, lcc, cc, ld, make, php, perl, python, ruby, tar, gzip, bzip, bzialfa2, nc, locate, suidperl, git, docker, ssh
Downloader	:	wget, fetch, lynx, links, curl, get, lwp-mirror
CURL : ON \| SSH2 : OFF \| Magic Quotes : ON \| MySQL : ON \| MSSQL : OFF \| PostgreSQL : OFF \| Oracle : OFF
Safe Mode : OFF \| Open Basedir : NONE \| Safe Mode Exec Dir : NONE \| Safe Mode Include Dir : NONE

swoole_process_pool.h

/*
  +----------------------------------------------------------------------+
  | 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"

#include <signal.h>
#include <unordered_map>

#include "swoole_lock.h"
#include "swoole_pipe.h"
#include "swoole_channel.h"
#include "swoole_msg_queue.h"

enum swWorkerStatus {
    SW_WORKER_BUSY = 1,
    SW_WORKER_IDLE = 2,
    SW_WORKER_EXIT = 3,
};

enum swIPCMode {
    SW_IPC_NONE = 0,
    SW_IPC_UNIXSOCK = 1,
    SW_IPC_MSGQUEUE = 2,
    SW_IPC_SOCKET = 3,
};

namespace swoole {

enum WorkerMessageType {
    SW_WORKER_MESSAGE_STOP = 1,
};

struct WorkerStopMessage {
    pid_t pid;
    uint16_t worker_id;
};

class ExitStatus {
  private:
    pid_t pid_;
    int status_;

public:
    ExitStatus(pid_t _pid, int _status) : pid_(_pid), status_(_status) {}

pid_t get_pid() const {
        return pid_;
    }

int get_status() const {
        return status_;
    }

int get_code() const {
        return WEXITSTATUS(status_);
    }

int get_signal() const {
        return WTERMSIG(status_);
    }

bool is_normal_exit() {
        return WIFEXITED(status_);
    }
};

static inline ExitStatus wait_process() {
    int status = 0;
    pid_t pid = ::wait(&status);
    return ExitStatus(pid, status);
}

static inline ExitStatus wait_process(pid_t _pid, int options) {
    int status = 0;
    pid_t pid = ::waitpid(_pid, &status, options);
    return ExitStatus(pid, status);
}

struct ProcessPool;
struct Worker;

struct WorkerGlobal {
    bool run_always;
    bool shutdown;
    uint32_t max_request;
    Worker *worker;
    time_t exit_time;
};

struct Worker {
    pid_t pid;
    WorkerId id;
    ProcessPool *pool;
    MsgQueue *queue;

bool redirect_stdout;
    bool redirect_stdin;
    bool redirect_stderr;

/**
     * worker status, IDLE or BUSY
     */
    uint8_t status;
    uint8_t type;
    uint8_t ipc_mode;
    uint8_t child_process;

sw_atomic_t tasking_num;
    uint32_t concurrency;
    time_t start_time;

sw_atomic_long_t dispatch_count;
    sw_atomic_long_t request_count;
    sw_atomic_long_t response_count;
    size_t coroutine_num;

Mutex *lock;
    UnixSocket *pipe_object;

network::Socket *pipe_master;
    network::Socket *pipe_worker;
    network::Socket *pipe_current;

void *ptr;
    void *ptr2;

ssize_t send_pipe_message(const void *buf, size_t n, int flags);

void set_status(enum swWorkerStatus _status) {
        status = _status;
    }

bool is_busy() {
        return status == SW_WORKER_BUSY;
    }

bool is_idle() {
        return status == SW_WORKER_IDLE;
    }
};

struct StreamInfo {
    network::Socket *socket;
    network::Socket *last_connection;
    char *socket_file;
    int socket_port;
    String *response_buffer;
};

struct ProcessPool {
    /**
     * reloading
     */
    bool reloading;
    bool running;
    bool reload_init;
    bool read_message;
    bool started;
    bool schedule_by_sysvmsg;
    uint8_t ipc_mode;
    pid_t master_pid;
    uint32_t reload_worker_i;
    uint32_t max_wait_time;
    uint64_t reload_count;
    time_t reload_last_time;
    Worker *reload_workers;

/**
     * process type
     */
    uint8_t type;

/**
     * worker->id = start_id + i
     */
    uint16_t start_id;

/**
     * use message queue IPC
     */
    uint8_t use_msgqueue;

/**
     * use stream socket IPC
     */
    uint8_t use_socket;

char *packet_buffer;
    uint32_t max_packet_size_;

/**
     * message queue key
     */
    key_t msgqueue_key;

uint32_t worker_num;
    uint32_t max_request;
    uint32_t max_request_grace;

/**
     * No idle task work process is available.
     */
    uint8_t scheduler_warning;
    time_t warning_time;

int (*onTask)(ProcessPool *pool, EventData *task);
    void (*onWorkerStart)(ProcessPool *pool, int worker_id);
    void (*onMessage)(ProcessPool *pool, const char *data, uint32_t length);
    void (*onWorkerStop)(ProcessPool *pool, int worker_id);
    void (*onWorkerMessage)(ProcessPool *pool, EventData *msg);
    int (*onWorkerNotFound)(ProcessPool *pool, const ExitStatus &exit_status);
    int (*main_loop)(ProcessPool *pool, Worker *worker);

sw_atomic_t round_id;

Worker *workers;
    std::vector<std::shared_ptr<UnixSocket>> *pipes;
    std::unordered_map<pid_t, Worker *> *map_;
    Reactor *reactor;
    MsgQueue *queue;
    StreamInfo *stream_info_;
    Channel *message_box = nullptr;

void *ptr;

inline void set_type(int _type) {
        uint32_t i;
        type = _type;
        for (i = 0; i < worker_num; i++) {
            workers[i].type = type;
        }
    }

inline void set_start_id(int _start_id) {
        uint32_t i;
        start_id = _start_id;
        for (i = 0; i < worker_num; i++) {
            workers[i].id = start_id + i;
        }
    }

inline Worker *get_worker(int worker_id) {
        return &(workers[worker_id - start_id]);
    }

Worker *get_worker_by_pid(pid_t pid) {
        auto iter = map_->find(pid);
        if (iter == map_->end()) {
            return nullptr;
        }
        return iter->second;
    }

void set_max_request(uint32_t _max_request, uint32_t _max_request_grace);
    int get_max_request();
    void set_protocol(int task_protocol, uint32_t max_packet_size);
    bool detach();
    int wait();
    int start();
    void shutdown();
    bool reload();
    pid_t spawn(Worker *worker);
    int dispatch(EventData *data, int *worker_id);
    int response(const char *data, int length);
    int dispatch_blocking(EventData *data, int *dst_worker_id);
    int dispatch_blocking(const char *data, uint32_t len);
    int add_worker(Worker *worker);
    int del_worker(Worker *worker);
    void destroy();
    int create(uint32_t worker_num, key_t msgqueue_key = 0, swIPCMode ipc_mode = SW_IPC_NONE);
    int create_message_box(size_t memory_size);
    int push_message(uint8_t type, const void *data, size_t length);
    int push_message(EventData *msg);
    int pop_message(void *data, size_t size);
    int listen(const char *socket_file, int blacklog);
    int listen(const char *host, int port, int blacklog);
    int schedule();
    static void kill_timeout_worker(Timer *timer, TimerNode *tnode);
};
};  // namespace swoole

static sw_inline int swoole_waitpid(pid_t __pid, int *__stat_loc, int __options) {
    int ret;
    do {
        ret = waitpid(__pid, __stat_loc, __options);
    } while (ret < 0 && errno == EINTR);
    return ret;
}

static sw_inline int swoole_kill(pid_t __pid, int __sig) {
    return kill(__pid, __sig);
}

extern swoole::WorkerGlobal SwooleWG;  // Worker Global Variable

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	drwxr-xr-x	2023-11-27 11:07:38
..	dir	-	root/root	drwxr-xr-x	2023-11-27 11:07:38
swoole.h	file	21.94 KB	root/root	-rw-r--r--	2023-10-05 02:51:21
swoole_api.h	file	3.39 KB	root/root	-rw-r--r--	2023-10-05 02:51:21
swoole_asm_context.h	file	1.76 KB	root/root	-rw-r--r--	2023-10-05 02:51:21
swoole_async.h	file	2.66 KB	root/root	-rw-r--r--	2023-10-05 02:51:21
swoole_atomic.h	file	2.39 KB	root/root	-rw-r--r--	2023-10-05 02:51:21
swoole_base64.h	file	1.29 KB	root/root	-rw-r--r--	2023-10-05 02:51:21
swoole_buffer.h	file	2.28 KB	root/root	-rw-r--r--	2023-10-05 02:51:21
swoole_c_api.h	file	2.16 KB	root/root	-rw-r--r--	2023-10-05 02:51:21
swoole_channel.h	file	2.36 KB	root/root	-rw-r--r--	2023-10-05 02:51:21
swoole_client.h	file	8.41 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_config.h	file	9.72 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_coroutine.h	file	8.58 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_coroutine_c_api.h	file	4.48 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_coroutine_channel.h	file	4.25 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_coroutine_context.h	file	2.43 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_coroutine_socket.h	file	18.65 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_coroutine_system.h	file	3.16 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_dtls.h	file	2.42 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_error.h	file	5.46 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_file.h	file	4.09 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_file_hook.h	file	2.58 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_hash.h	file	9.69 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_heap.h	file	1.79 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_http.h	file	6.9 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_http2.h	file	7.43 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_lock.h	file	2.64 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_log.h	file	15.56 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_lru_cache.h	file	3.2 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_memory.h	file	2.75 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_mime_type.h	file	1.44 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_mqtt.h	file	2.18 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_msg_queue.h	file	1.84 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_pipe.h	file	2.64 KB	root/root	-rw-r--r--	2023-10-05 02:51:22
swoole_process_pool.h	file	7.44 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_protocol.h	file	5.32 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_proxy.h	file	2.12 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_reactor.h	file	11.35 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_redis.h	file	2.09 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_server.h	file	43.39 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_signal.h	file	1.68 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_socket.h	file	17.06 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_socket_hook.h	file	2.12 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_ssl.h	file	4.94 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_static_handler.h	file	3.08 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_string.h	file	8.18 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_table.h	file	7.41 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_timer.h	file	4.1 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_util.h	file	5.39 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_version.h	file	2.21 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_websocket.h	file	4.33 KB	root/root	-rw-r--r--	2023-10-05 02:51:23
swoole_wheel_timer.h	file	2.48 KB	root/root	-rw-r--r--	2023-10-05 02:51:23