Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
机器未来
Paddle
提交
4db7c546
P
Paddle
项目概览
机器未来
/
Paddle
与 Fork 源项目一致
Fork自
PaddlePaddle / Paddle
通知
1
Star
1
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
P
Paddle
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
4db7c546
编写于
5月 16, 2017
作者:
H
Helin Wang
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
add documentation for client
上级
61a49e49
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
24 addition
and
2 deletion
+24
-2
paddle/go/pserver/client.go
paddle/go/pserver/client.go
+24
-2
未找到文件。
paddle/go/pserver/client.go
浏览文件 @
4db7c546
...
...
@@ -13,49 +13,71 @@ const (
Float64
)
// Parameter is a piece of data to sync with the parameter server.
type
Parameter
struct
{
Name
string
ElementType
ElementType
Content
[]
byte
}
// ParameterWithConfig contains the parameter and the configuration.
type
ParameterWithConfig
struct
{
Param
Parameter
Config
[]
byte
Config
[]
byte
// parameter configuration in Proto Buffer format
}
// Gradient is the gradient of the parameter.
type
Gradient
Parameter
// Client is the client to parameter servers.
type
Client
struct
{
}
// NewClient creates a new client.
func
NewClient
(
addr
string
)
*
Client
{
return
&
Client
{}
}
func
(
c
*
Client
)
BeginInitParams
(
pserverConfigProto
[]
byte
)
(
bool
,
error
)
{
// BeginInitParams begins to initialize parameters on parameter
// servers.
//
// BeginInitParams will be called from multiple trainers, only one
// trainer will be selected to initialize the parameters on parameter
// servers. Other trainers will be blocked until the initialization is
// done, and they need to get the initialized parameters from
// parameter servers using GetParams.
func
(
c
*
Client
)
BeginInitParams
(
pserverConfigProto
[]
byte
)
(
selected
bool
,
err
error
)
{
return
true
,
nil
}
// InitParam initializes the parameter on parameter servers.
func
(
c
*
Client
)
InitParam
(
paramWithConfigs
ParameterWithConfig
)
error
{
return
nil
}
// FinishInitParams tells parameter servers client has sent all
// parameters to parameter servers as initialization.
func
(
c
*
Client
)
FinishInitParams
()
error
{
return
nil
}
// SendGrads sends gradients to parameter servers for updating
// parameters.
func
(
c
*
Client
)
SendGrads
(
grads
[]
Gradient
)
error
{
return
nil
}
// GetParams gets parameters from parameter servers.
func
(
c
*
Client
)
GetParams
(
names
[]
string
)
([]
Parameter
,
error
)
{
return
nil
,
nil
}
// SaveModel indicates parameters to save the parameter to the given
// path.
func
(
c
*
Client
)
SaveModel
(
path
string
)
error
{
return
nil
}
// Cleanup cleans up the client states.
func
(
c
*
Client
)
Cleanup
()
{
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录