/
opt
/
alt
/
php82
/
usr
/
include
/
php
/
ext
/
swoole
/
include
/
/opt/alt/php82/usr/include/php/ext/swoole/include
mkdir
upload
Name
Size
Mode
Actions
swoole.h
23401
0644
edit
dl
rm
swoole_api.h
3472
0644
edit
dl
rm
swoole_asm_context.h
1805
0644
edit
dl
rm
swoole_async.h
3789
0644
edit
dl
rm
swoole_atomic.h
2198
0644
edit
dl
rm
swoole_base64.h
1325
0644
edit
dl
rm
swoole_buffer.h
2333
0644
edit
dl
rm
swoole_channel.h
2393
0644
edit
dl
rm
swoole_client.h
8610
0644
edit
dl
rm
swoole_config.h
9052
0644
edit
dl
rm
swoole_coroutine.h
9179
0644
edit
dl
rm
swoole_coroutine_channel.h
4284
0644
edit
dl
rm
swoole_coroutine_context.h
2652
0644
edit
dl
rm
swoole_coroutine_c_api.h
5018
0644
edit
dl
rm
swoole_coroutine_socket.h
19303
0644
edit
dl
rm
swoole_coroutine_system.h
3559
0644
edit
dl
rm
swoole_c_api.h
2244
0644
edit
dl
rm
swoole_dtls.h
2463
0644
edit
dl
rm
swoole_error.h
5989
0644
edit
dl
rm
swoole_file.h
4192
0644
edit
dl
rm
swoole_file_hook.h
2924
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_lock.h
2699
0644
edit
dl
rm
swoole_log.h
16100
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
5658
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
9095
0644
edit
dl
rm
swoole_protocol.h
5443
0644
edit
dl
rm
swoole_proxy.h
2192
0644
edit
dl
rm
swoole_reactor.h
11519
0644
edit
dl
rm
swoole_redis.h
2142
0644
edit
dl
rm
swoole_server.h
40573
0644
edit
dl
rm
swoole_signal.h
1718
0644
edit
dl
rm
swoole_socket.h
18032
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
8252
0644
edit
dl
rm
swoole_table.h
7522
0644
edit
dl
rm
swoole_timer.h
4144
0644
edit
dl
rm
swoole_util.h
5716
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/php82/usr/include/php/ext/swoole/include/swoole_mqtt.h
(2228B)
/* +----------------------------------------------------------------------+ | Swoole | +----------------------------------------------------------------------+ | Copyright (c) 2012-2015 The Swoole Group | +----------------------------------------------------------------------+ | 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> | +----------------------------------------------------------------------+ */ #pragma once #include "swoole.h" #include "swoole_protocol.h" #define SW_MQTT_MIN_LENGTH_SIZE 1 #define SW_MQTT_MAX_LENGTH_SIZE 4 #define SW_MQTT_MAX_PAYLOAD_SIZE 268435455 #define SW_MQTT_SETRETAIN(HDR, R) (HDR | (R)) #define SW_MQTT_SETQOS(HDR, Q) (HDR | ((Q) << 1)) #define SW_MQTT_SETDUP(HDR, D) (HDR | ((D) << 3)) namespace swoole { namespace mqtt { enum Opcode { SW_MQTT_CONNECT = 0x10, SW_MQTT_CONNACK = 0x20, SW_MQTT_PUBLISH = 0x30, SW_MQTT_PUBACK = 0x40, SW_MQTT_PUBREC = 0x50, SW_MQTT_PUBREL = 0x60, SW_MQTT_PUBCOMP = 0x70, SW_MQTT_SUBSCRIBE = 0x80, SW_MQTT_SUBACK = 0x90, SW_MQTT_UNSUBSCRIBE = 0xA0, SW_MQTT_UNSUBACK = 0xB0, SW_MQTT_PINGREQ = 0xC0, SW_MQTT_PINGRESP = 0xD0, SW_MQTT_DISCONNECT = 0xE0, }; struct Packet { uint8_t type : 4; uint8_t dup : 1; uint8_t qos : 2; uint8_t retain : 1; uint32_t length; char protocol_name[8]; }; ssize_t get_package_length(const Protocol *protocol, network::Socket *conn, PacketLength *pl); void set_protocol(Protocol *protocol); } // namespace mqtt } // namespace swoole
Save
cmd:
run