ipc_service

Documentation

Index

• Variables
• func IPC_chat(sess *Session, obj *IPCObject) []byte
• func IPC_kick(sess *Session, obj *IPCObject) []byte
• func IPC_ping(sess *Session, obj *IPCObject) []byte
• func PKT_command_result_pack(reader *packet.Packet) (tbl command_result_pack, err error)
• func PKT_talk(reader *packet.Packet) (tbl talk, err error)
• func PKT_user_login_info(reader *packet.Packet) (tbl user_login_info, err error)
• func PKT_user_snapshot(reader *packet.Packet) (tbl user_snapshot, err error)
• func SYS_broadcast(sess *Session, obj *IPCObject) []byte
• func SYS_multicast(sess *Session, obj *IPCObject) []byte

Variables

var IPCHandler map[int16]func(*Session, *IPCObject) []byte = map[int16]func(*Session, *IPCObject) []byte{
	SVC_PING: IPC_ping,
	SVC_CHAT: IPC_chat,
	SVC_KICK: IPC_kick,

	SYS_BROADCAST: SYS_broadcast,
	SYS_MULTICAST: SYS_multicast,
}

Functions

func IPC_chat

func IPC_chat(sess *Session, obj *IPCObject) []byte

---------------------------------------------------------- 聊天通知

func IPC_kick

func IPC_kick(sess *Session, obj *IPCObject) []byte

---------------------------------------------------------- 用于强制挤下线

func IPC_ping

func IPC_ping(sess *Session, obj *IPCObject) []byte

---------------------------------------------------------- 连通性测试

func PKT_command_result_pack

func PKT_command_result_pack(reader *packet.Packet) (tbl command_result_pack, err error)

func PKT_talk

func PKT_talk(reader *packet.Packet) (tbl talk, err error)

func PKT_user_login_info

func PKT_user_login_info(reader *packet.Packet) (tbl user_login_info, err error)

func PKT_user_snapshot

func PKT_user_snapshot(reader *packet.Packet) (tbl user_snapshot, err error)

func SYS_broadcast

func SYS_broadcast(sess *Session, obj *IPCObject) []byte

---------------------------------------------------------- 广播包 只由 SYS_USR 接收 外部只需要调用Broadcast函数即可

func SYS_multicast

func SYS_multicast(sess *Session, obj *IPCObject) []byte

---------------------------------------------------------- 组播包