Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
BaiXuePrincess
Paddle
提交
b7d44eb9
P
Paddle
项目概览
BaiXuePrincess
/
Paddle
与 Fork 源项目一致
Fork自
PaddlePaddle / Paddle
通知
1
Star
1
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
P
Paddle
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
未验证
提交
b7d44eb9
编写于
1月 16, 2023
作者:
W
wangxiaoning
提交者:
GitHub
1月 16, 2023
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[fix code style]fix cpplint code style (#49811)
上级
0355bb90
变更
7
隐藏空白更改
内联
并排
Showing
7 changed file
with
17 addition
and
14 deletion
+17
-14
paddle/fluid/distributed/ps/service/ps_client.h
paddle/fluid/distributed/ps/service/ps_client.h
+1
-1
paddle/fluid/distributed/ps/service/ps_local_server.h
paddle/fluid/distributed/ps/service/ps_local_server.h
+1
-1
paddle/fluid/distributed/ps/service/ps_service/service.h
paddle/fluid/distributed/ps/service/ps_service/service.h
+1
-1
paddle/fluid/distributed/ps/table/depends/sparse_utils.h
paddle/fluid/distributed/ps/table/depends/sparse_utils.h
+1
-1
paddle/fluid/distributed/ps/table/graph/graph_weighted_sampler.h
...fluid/distributed/ps/table/graph/graph_weighted_sampler.h
+6
-4
paddle/fluid/distributed/test/graph_node_split_test.cc
paddle/fluid/distributed/test/graph_node_split_test.cc
+6
-5
paddle/fluid/distributed/test/table_test.cc
paddle/fluid/distributed/test/table_test.cc
+1
-1
未找到文件。
paddle/fluid/distributed/ps/service/ps_client.h
浏览文件 @
b7d44eb9
...
@@ -67,7 +67,7 @@ class PSClient {
...
@@ -67,7 +67,7 @@ class PSClient {
PSClient
(
PSClient
&&
)
=
delete
;
PSClient
(
PSClient
&&
)
=
delete
;
PSClient
(
const
PSClient
&
)
=
delete
;
PSClient
(
const
PSClient
&
)
=
delete
;
virtual
int32_t
Configure
(
virtual
int32_t
Configure
(
// NOLINT
const
PSParameter
&
config
,
const
PSParameter
&
config
,
const
std
::
map
<
uint64_t
,
std
::
vector
<
paddle
::
distributed
::
Region
>>
const
std
::
map
<
uint64_t
,
std
::
vector
<
paddle
::
distributed
::
Region
>>
&
regions
,
&
regions
,
...
...
paddle/fluid/distributed/ps/service/ps_local_server.h
浏览文件 @
b7d44eb9
...
@@ -31,7 +31,7 @@ class PsLocalServer : public PSServer {
...
@@ -31,7 +31,7 @@ class PsLocalServer : public PSServer {
virtual
int32_t
Stop
()
{
return
0
;
}
virtual
int32_t
Stop
()
{
return
0
;
}
virtual
int32_t
Configure
(
virtual
int32_t
Configure
(
const
PSParameter
&
config
,
const
PSParameter
&
config
,
PSEnvironment
&
env
,
PSEnvironment
&
env
,
// NOLINT
size_t
server_rank
,
size_t
server_rank
,
const
std
::
vector
<
framework
::
ProgramDesc
>
&
server_sub_program
=
{})
{
const
std
::
vector
<
framework
::
ProgramDesc
>
&
server_sub_program
=
{})
{
return
0
;
return
0
;
...
...
paddle/fluid/distributed/ps/service/ps_service/service.h
浏览文件 @
b7d44eb9
...
@@ -39,7 +39,7 @@ using paddle::distributed::PsService;
...
@@ -39,7 +39,7 @@ using paddle::distributed::PsService;
class
PSCore
{
class
PSCore
{
public:
public:
explicit
PSCore
()
{}
PSCore
()
{}
virtual
~
PSCore
()
{}
virtual
~
PSCore
()
{}
virtual
int
InitServer
(
virtual
int
InitServer
(
...
...
paddle/fluid/distributed/ps/table/depends/sparse_utils.h
浏览文件 @
b7d44eb9
...
@@ -60,7 +60,7 @@ struct PullSparseValue {
...
@@ -60,7 +60,7 @@ struct PullSparseValue {
std
::
vector
<
int
>*
offset_shard
)
const
{
std
::
vector
<
int
>*
offset_shard
)
const
{
offset_shard
->
reserve
(
numel_
/
shard_num
+
1
);
offset_shard
->
reserve
(
numel_
/
shard_num
+
1
);
for
(
int
x
=
0
;
x
<
numel_
;
++
x
)
{
for
(
int
x
=
0
;
x
<
numel_
;
++
x
)
{
if
(
int
(
feasigns_
[
x
]
%
shard_num
)
==
shard_id
)
{
if
(
static_cast
<
int
>
(
feasigns_
[
x
]
%
shard_num
)
==
shard_id
)
{
offset_shard
->
push_back
(
x
);
offset_shard
->
push_back
(
x
);
}
}
}
}
...
...
paddle/fluid/distributed/ps/table/graph/graph_weighted_sampler.h
浏览文件 @
b7d44eb9
...
@@ -55,10 +55,12 @@ class WeightedSampler : public Sampler {
...
@@ -55,10 +55,12 @@ class WeightedSampler : public Sampler {
const
std
::
shared_ptr
<
std
::
mt19937_64
>
rng
);
const
std
::
shared_ptr
<
std
::
mt19937_64
>
rng
);
private:
private:
int
sample
(
float
query_weight
,
int
sample
(
std
::
unordered_map
<
WeightedSampler
*
,
float
>
&
subtract_weight_map
,
float
query_weight
,
std
::
unordered_map
<
WeightedSampler
*
,
int
>
&
subtract_count_map
,
std
::
unordered_map
<
WeightedSampler
*
,
float
>
float
&
subtract
);
&
subtract_weight_map
,
// NOLINT
std
::
unordered_map
<
WeightedSampler
*
,
int
>
&
subtract_count_map
,
// NOLINT
float
&
subtract
);
// NOLINT
};
};
}
// namespace distributed
}
// namespace distributed
}
// namespace paddle
}
// namespace paddle
paddle/fluid/distributed/test/graph_node_split_test.cc
浏览文件 @
b7d44eb9
...
@@ -157,7 +157,8 @@ void GetDownpourSparseTableProto(
...
@@ -157,7 +157,8 @@ void GetDownpourSparseTableProto(
/*-------------------------------------------------------------------------*/
/*-------------------------------------------------------------------------*/
std
::
string
ip_
=
"127.0.0.1"
,
ip2
=
"127.0.0.1"
;
const
char
*
ip_
=
"127.0.0.1"
;
const
char
*
ip2
=
"127.0.0.1"
;
uint32_t
port_
=
5209
,
port2
=
5210
;
uint32_t
port_
=
5209
,
port2
=
5210
;
std
::
vector
<
std
::
string
>
host_sign_list_
;
std
::
vector
<
std
::
string
>
host_sign_list_
;
...
@@ -203,10 +204,10 @@ void RunServer2() {
...
@@ -203,10 +204,10 @@ void RunServer2() {
pserver_ptr2
->
build_peer2peer_connection
(
1
);
pserver_ptr2
->
build_peer2peer_connection
(
1
);
}
}
void
RunClient
(
void
RunClient
(
std
::
map
<
uint64_t
,
std
::
vector
<
paddle
::
distributed
::
Region
>>&
std
::
map
<
uint64_t
,
std
::
vector
<
paddle
::
distributed
::
Region
>>&
dense_regions
,
dense_regions
,
// NOLINT
int
index
,
int
index
,
paddle
::
distributed
::
PsBaseService
*
service
)
{
paddle
::
distributed
::
PsBaseService
*
service
)
{
::
paddle
::
distributed
::
PSParameter
worker_proto
=
GetWorkerProto
();
::
paddle
::
distributed
::
PSParameter
worker_proto
=
GetWorkerProto
();
paddle
::
distributed
::
PaddlePSEnvironment
_ps_env
;
paddle
::
distributed
::
PaddlePSEnvironment
_ps_env
;
auto
servers_
=
host_sign_list_
.
size
();
auto
servers_
=
host_sign_list_
.
size
();
...
...
paddle/fluid/distributed/test/table_test.cc
浏览文件 @
b7d44eb9
...
@@ -15,7 +15,7 @@ limitations under the License. */
...
@@ -15,7 +15,7 @@ limitations under the License. */
#include "gtest/gtest.h"
#include "gtest/gtest.h"
#include "paddle/fluid/distributed/ps/table/memory_dense_table.h"
#include "paddle/fluid/distributed/ps/table/memory_dense_table.h"
#include "paddle/fluid/distributed/the_one_ps.pb.h"
#include "paddle/fluid/distributed/the_one_ps.pb.h"
//#include "paddle/fluid/distributed/ps/table/sparse_geo_table.h"
//
#include "paddle/fluid/distributed/ps/table/sparse_geo_table.h"
namespace
paddle
{
namespace
paddle
{
namespace
distributed
{
namespace
distributed
{
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录