/
opt
/
alt
/
php83
/
usr
/
include
/
php
/
ext
/
swoole
/
include
/
/opt/alt/php83/usr/include/php/ext/swoole/include
mkdir
upload
Name
Size
Mode
Actions
swoole.h
25430
0644
edit
dl
rm
swoole_api.h
3511
0644
edit
dl
rm
swoole_asm_context.h
2336
0644
edit
dl
rm
swoole_async.h
3698
0644
edit
dl
rm
swoole_atomic.h
3806
0644
edit
dl
rm
swoole_base64.h
1325
0644
edit
dl
rm
swoole_buffer.h
2287
0644
edit
dl
rm
swoole_channel.h
2393
0644
edit
dl
rm
swoole_client.h
8854
0644
edit
dl
rm
swoole_config.h
9090
0644
edit
dl
rm
swoole_coroutine.h
10214
0644
edit
dl
rm
swoole_coroutine_channel.h
4284
0644
edit
dl
rm
swoole_coroutine_context.h
2813
0644
edit
dl
rm
swoole_coroutine_c_api.h
5965
0644
edit
dl
rm
swoole_coroutine_socket.h
19232
0644
edit
dl
rm
swoole_coroutine_system.h
3960
0644
edit
dl
rm
swoole_c_api.h
2126
0644
edit
dl
rm
swoole_dtls.h
2463
0644
edit
dl
rm
swoole_error.h
6255
0644
edit
dl
rm
swoole_file.h
4536
0644
edit
dl
rm
swoole_file_hook.h
3929
0644
edit
dl
rm
swoole_hash.h
9923
0644
edit
dl
rm
swoole_heap.h
1828
0644
edit
dl
rm
swoole_http.h
7157
0644
edit
dl
rm
swoole_http2.h
8584
0644
edit
dl
rm
swoole_iouring.h
3172
0644
edit
dl
rm
swoole_lock.h
3471
0644
edit
dl
rm
swoole_log.h
15705
0644
edit
dl
rm
swoole_lru_cache.h
3245
0644
edit
dl
rm
swoole_memory.h
2813
0644
edit
dl
rm
swoole_message_bus.h
6169
0644
edit
dl
rm
swoole_mime_type.h
1476
0644
edit
dl
rm
swoole_mqtt.h
2228
0644
edit
dl
rm
swoole_msg_queue.h
1970
0644
edit
dl
rm
swoole_pipe.h
2700
0644
edit
dl
rm
swoole_process_pool.h
10176
0644
edit
dl
rm
swoole_protocol.h
5291
0644
edit
dl
rm
swoole_proxy.h
2942
0644
edit
dl
rm
swoole_reactor.h
11519
0644
edit
dl
rm
swoole_redis.h
2142
0644
edit
dl
rm
swoole_server.h
44999
0644
edit
dl
rm
swoole_signal.h
1762
0644
edit
dl
rm
swoole_socket.h
19496
0644
edit
dl
rm
swoole_socket_hook.h
2284
0644
edit
dl
rm
swoole_ssl.h
5062
0644
edit
dl
rm
swoole_static_handler.h
4815
0644
edit
dl
rm
swoole_string.h
9082
0644
edit
dl
rm
swoole_table.h
7522
0644
edit
dl
rm
swoole_thread.h
2280
0644
edit
dl
rm
swoole_timer.h
4226
0644
edit
dl
rm
swoole_util.h
6765
0644
edit
dl
rm
swoole_version.h
2264
0644
edit
dl
rm
swoole_websocket.h
4638
0644
edit
dl
rm
swoole_wheel_timer.h
2538
0644
edit
dl
rm
Edit:
/opt/alt/php83/usr/include/php/ext/swoole/include/swoole_lock.h
(3471B)
/* +----------------------------------------------------------------------+ | 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 "swoole_memory.h" #include <system_error> namespace swoole { class Lock { public: enum Type { NONE, RW_LOCK = 1, MUTEX = 3, SPIN_LOCK = 5, COROUTINE_LOCK = 6, }; Type get_type() { return type_; } virtual ~Lock(){}; virtual int lock_rd() = 0; virtual int lock() = 0; virtual int unlock() = 0; virtual int trylock_rd() = 0; virtual int trylock() = 0; protected: Lock() { type_ = NONE; shared_ = false; } enum Type type_; bool shared_; }; struct MutexImpl; class Mutex : public Lock { MutexImpl *impl; int flags_; public: enum Flag { PROCESS_SHARED = 1, ROBUST = 2, }; Mutex(int flags); ~Mutex(); int lock_rd() override; int lock() override; int unlock() override; int trylock_rd() override; int trylock() override; int lock_wait(int timeout_msec); }; #ifdef HAVE_RWLOCK struct RWLockImpl; class RWLock : public Lock { RWLockImpl *impl; public: RWLock(int use_in_process); ~RWLock(); int lock_rd() override; int lock() override; int unlock() override; int trylock_rd() override; int trylock() override; }; #endif #ifdef HAVE_SPINLOCK class SpinLock : public Lock { pthread_spinlock_t *impl; public: SpinLock(int use_in_process); ~SpinLock(); int lock_rd() override; int lock() override; int unlock() override; int trylock_rd() override; int trylock() override; }; #endif class CoroutineLock : public Lock { private: long cid = 0; sw_atomic_t *value = nullptr; void *coroutine = nullptr; int lock_impl(bool blocking = true); public: CoroutineLock(bool shared); ~CoroutineLock(); int lock_rd() override; int lock() override; int unlock() override; int trylock_rd() override; int trylock() override; }; #if defined(HAVE_PTHREAD_BARRIER) && !(defined(__FreeBSD__) || defined(__OpenBSD__) || defined(__NetBSD__)) #define SW_USE_PTHREAD_BARRIER #endif struct Barrier { #ifdef SW_USE_PTHREAD_BARRIER pthread_barrier_t barrier_; pthread_barrierattr_t barrier_attr_; bool shared_; #else sw_atomic_t count_; sw_atomic_t barrier_; #endif void init(bool shared, int count); void wait(); void destroy(); }; } // namespace swoole
Save
cmd:
run