Push
2020-08-17 10:22:03 0 举报
FATE联邦学习框架 push方法
作者其他创作
大纲/内容
将Packet写入队列
发布事件publishEvent()
从队列取出Packet
packet为空,且重试次数大于30
push()| ▼ getStub()
ServerPushRequestStreamObserver.java
调用方法
Java服务端
放入模型
CascadedCaller.java
OnNext()
DataTransferPipedClient.java
非空
重试次数+1
DataTransferServiceImpl.java
Push()
stub.push()
client.push()
Java客户端
判断Packet非空和尝试次数
onApplicationEvent|▼cascadedCaller.push
OnComplete()
PipHandleNotificationEventListener.java
返回响应
Python调用方
0 条评论
回复 删除
下一页