Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
蚂蚁寻路
zoompipeline
提交
d4cb36c8
zoompipeline
项目概览
蚂蚁寻路
/
zoompipeline
与 Fork 源项目一致
Fork自
colorEagleStdio / zoompipeline
通知
4
Star
1
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
zoompipeline
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
d4cb36c8
编写于
12月 27, 2013
作者:
丁劲犇
😸
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Master branch comments
上级
6b4c368d
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
13 addition
and
18 deletion
+13
-18
ZoomPipeline_FuncSvr/network/zp_net_threadpool.cpp
ZoomPipeline_FuncSvr/network/zp_net_threadpool.cpp
+1
-1
ZoomPipeline_FuncSvr/network/zp_nettransthread.cpp
ZoomPipeline_FuncSvr/network/zp_nettransthread.cpp
+1
-1
ZoomPipeline_FuncSvr/network/zp_nettransthread.h
ZoomPipeline_FuncSvr/network/zp_nettransthread.h
+11
-16
未找到文件。
ZoomPipeline_FuncSvr/network/zp_net_threadpool.cpp
浏览文件 @
d4cb36c8
...
...
@@ -222,7 +222,7 @@ void zp_net_ThreadPool::SendDataToClient(QObject * objClient,const QByteArray &
emit
evt_SendDataToClient
(
objClient
,
dtarray
);
}
//向客户端广播数据,不包括 objFromClient
void
zp_net_ThreadPool
::
BroadcastData
(
QObject
*
objFromClient
,
const
QByteArray
&
dtarray
)
{
emit
evt_BroadcastData
(
objFromClient
,
dtarray
);
...
...
ZoomPipeline_FuncSvr/network/zp_nettransthread.cpp
浏览文件 @
d4cb36c8
...
...
@@ -43,7 +43,6 @@ void zp_netTransThread::SetPayload(int nPayload)
m_nPayLoad
=
nPayload
;
assert
(
m_nPayLoad
>=
256
&&
m_nPayLoad
<=
16
*
1024
*
1024
);
}
//µĿͻӵ
void
zp_netTransThread
::
incomingConnection
(
QObject
*
threadid
,
qintptr
socketDescriptor
)
{
...
...
@@ -56,6 +55,7 @@ void zp_netTransThread::incomingConnection(QObject * threadid,qintptr socketDesc
sock_client
=
new
QTcpSocket
(
this
);
if
(
sock_client
)
{
//Initial content
if
(
true
==
sock_client
->
setSocketDescriptor
(
socketDescriptor
))
{
connect
(
sock_client
,
SIGNAL
(
readyRead
()),
this
,
SLOT
(
new_data_recieved
()));
...
...
ZoomPipeline_FuncSvr/network/zp_nettransthread.h
浏览文件 @
d4cb36c8
...
...
@@ -26,46 +26,41 @@ public:
private:
bool
m_bActivated
;
bool
m_bSSLConnection
;
//sending buffer, hold byteArraies.
QMap
<
QObject
*
,
QList
<
QByteArray
>
>
m_buffer_sending
;
QMap
<
QObject
*
,
QList
<
qint64
>
>
m_buffer_sending_offset
;
QMap
<
QObject
*
,
int
>
m_clientList
;
int
m_nPayLoad
;
QMutex
m_mutex_protect
;
zp_net_ThreadPool
*
m_pThreadPool
;
public
slots
:
//
新的客户连接到来
//
This slot dealing with multi-thread client socket accept.
void
incomingConnection
(
QObject
*
threadid
,
qintptr
socketDescriptor
);
//
向客户端发送数据
//
sending dtarray to objClient. dtarray will be pushed into m_buffer_sending
void
SendDataToClient
(
QObject
*
objClient
,
const
QByteArray
&
dtarray
);
//
向客户端广播数据,不包括 objFromClient
//
Broadcast dtarray to every client except objFromClient itself
void
BroadcastData
(
QObject
*
objFromClient
,
const
QByteArray
&
dtarray
);
//
让本线程不再接受新的连接
//
Set terminate mark, the thread will quit after last client quit.
void
Deactivate
(){
m_bActivated
=
true
;}
//
立刻终止本线程的所有连接
//
terminate this thread immediately
void
DeactivateImmediately
(
zp_netTransThread
*
);
//
踢出所有客户
//
Kick all clients .
void
KickAllClients
(
zp_netTransThread
*
);
protected
slots
:
//
客户连接被关闭
//
when client closed, this slot will be activated.
void
client_closed
();
//新的数据到来
void
new_data_recieved
();
//一批数据发送完毕
void
some_data_sended
(
qint64
);
//客户端错误
void
displayError
(
QAbstractSocket
::
SocketError
socketError
);
//SSL
加密开始
//SSL
Encrypted started
void
on_encrypted
();
signals:
//错误信息
void
evt_SocketError
(
QObject
*
senderSock
,
QAbstractSocket
::
SocketError
socketError
);
//新的客户端连接
void
evt_NewClientConnected
(
QObject
*
client
);
//客户端退出
void
evt_ClientDisconnected
(
QObject
*
client
);
//收到一批数据
void
evt_Data_recieved
(
QObject
*
,
const
QByteArray
&
);
//一批数据被发送
void
evt_Data_transferred
(
QObject
*
client
,
qint64
);
};
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录