ZLMediaKit/api/source/mk_tcp_private.h

46 lines
1.4 KiB
C++
Raw Permalink Normal View History

2019-12-27 10:46:40 +08:00
/*
2020-04-04 20:30:09 +08:00
* Copyright (c) 2016 The ZLMediaKit project authors. All Rights Reserved.
2019-12-27 10:46:40 +08:00
*
* This file is part of ZLMediaKit(https://github.com/xia-chu/ZLMediaKit).
2019-12-27 10:46:40 +08:00
*
2020-04-04 20:30:09 +08:00
* Use of this source code is governed by MIT license that can be found in the
* LICENSE file in the root of the source tree. All contributing project authors
* may be found in the AUTHORS file in the root of the source tree.
2019-12-27 10:46:40 +08:00
*/
#ifndef MK_TCP_PRIVATE_H
#define MK_TCP_PRIVATE_H
#include "mk_tcp.h"
#include "Network/TcpClient.h"
#include "Network/Session.h"
2019-12-27 10:46:40 +08:00
class TcpClientForC : public toolkit::TcpClient {
public:
2022-12-02 14:43:06 +08:00
using Ptr = std::shared_ptr<TcpClientForC>;
2019-12-27 10:46:40 +08:00
TcpClientForC(mk_tcp_client_events *events) ;
~TcpClientForC() override ;
void onRecv(const toolkit::Buffer::Ptr &pBuf) override;
Push force replace (#2899) Co-authored-by: Alex <liyu7352@gmail.com> Co-authored-by: xia-chu <771730766@qq.com> Co-authored-by: Johnny <hellojinqiang@gmail.com> Co-authored-by: BackT0TheFuture <10088733+BackT0TheFuture@users.noreply.github.com> Co-authored-by: ljx0305 <ljx0305@gmail.com> Co-authored-by: Per-Arne Andersen <per@sysx.no> Co-authored-by: codeRATny <60806889+codeRATny@users.noreply.github.com> Co-authored-by: 老衲不出家 <tannzh2018@outlook.com> Co-authored-by: Kiki <haijuanchen.sun@gmail.com> Co-authored-by: PioLing <964472638@qq.com> Co-authored-by: dengjfzh <76604422+dengjfzh@users.noreply.github.com> Co-authored-by: a-ucontrol <55526028+a-ucontrol@users.noreply.github.com> Co-authored-by: 百鸣 <94030128+ixingqiao@users.noreply.github.com> Co-authored-by: fruit Juice <2317232721@qq.com> Co-authored-by: Luosh <fjlshyyyy@qq.com> Co-authored-by: tbago <moonzalor@gmail.com> Co-authored-by: Talus <xiaoxiaochenjian@gmail.com> Co-authored-by: 朱如洪 <zhu410289616@163.com> Co-authored-by: pedoc <pedoc@qq.com> Co-authored-by: XiaoYan Lin <linxiaoyan87@foxmail.com> Co-authored-by: xiangshengjye <46069012+xiangshengjye@users.noreply.github.com> Co-authored-by: tjpgt <602950305@qq.com> Co-authored-by: Nick <joyouswind@gmail.com> Co-authored-by: yogo-zhangyingzhe <100331270+yogo-zhangyingzhe@users.noreply.github.com> Co-authored-by: Xiaofeng Wang <wasphin@gmail.com> Co-authored-by: Dw9 <xweimvp@gmail.com> Co-authored-by: waken <33921191+mc373906408@users.noreply.github.com> Co-authored-by: Deepslient <1154547394@qq.com>
2023-10-12 17:09:20 +08:00
void onError(const toolkit::SockException &ex) override;
2019-12-27 10:46:40 +08:00
void onManager() override;
void onConnect(const toolkit::SockException &ex) override;
2019-12-27 10:46:40 +08:00
void setClient(mk_tcp_client client);
std::shared_ptr<void> _user_data;
private:
2019-12-27 10:46:40 +08:00
mk_tcp_client_events _events;
mk_tcp_client _client;
};
class SessionForC : public toolkit::Session {
public:
SessionForC(const toolkit::Socket::Ptr &pSock) ;
~SessionForC() override = default;
void onRecv(const toolkit::Buffer::Ptr &buffer) override ;
void onError(const toolkit::SockException &err) override;
2019-12-27 10:46:40 +08:00
void onManager() override;
std::shared_ptr<void> _user_data;
2019-12-27 10:46:40 +08:00
uint16_t _local_port;
};
#endif //MK_TCP_PRIVATE_H