Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
openeuler
A-Tune
提交
45ded9d3
A
A-Tune
项目概览
openeuler
/
A-Tune
通知
5
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
A
A-Tune
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
45ded9d3
编写于
8月 24, 2020
作者:
X
Xiaoguang Li
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
atune: using the same baseline when the restart flag is enabled.
上级
9d6cacf8
变更
7
隐藏空白更改
内联
并排
Showing
7 changed file
with
156 addition
and
119 deletion
+156
-119
analysis/optimizer/optimizer.py
analysis/optimizer/optimizer.py
+1
-1
api/profile/profile.pb.go
api/profile/profile.pb.go
+68
-65
api/profile/profile.proto
api/profile/profile.proto
+1
-0
common/project/projet.go
common/project/projet.go
+18
-16
common/tuning/optimizer.go
common/tuning/optimizer.go
+28
-18
modules/client/profile/profile_tuning.go
modules/client/profile/profile_tuning.go
+36
-18
modules/server/profile/profile.go
modules/server/profile/profile.go
+4
-1
未找到文件。
analysis/optimizer/optimizer.py
浏览文件 @
45ded9d3
...
...
@@ -282,7 +282,6 @@ class Optimizer(multiprocessing.Process):
if
ref_x
and
ref_y
is
None
:
ref_y
=
list
(
map
(
objective
,
ref_x
))
LOGGER
.
info
(
"ref_y is: %s"
,
ref_y
)
n_calls
-=
len
(
ref_y
)
# Pass user suggested initialisation points to the optimizer
if
ref_x
:
...
...
@@ -294,6 +293,7 @@ class Optimizer(multiprocessing.Process):
"have the same length"
)
LOGGER
.
info
(
"ref_x: %s"
,
ref_x
)
LOGGER
.
info
(
"ref_y: %s"
,
ref_y
)
n_calls
-=
len
(
ref_y
)
ret
=
optimizer
.
tell
(
ref_x
,
ref_y
)
for
i
in
range
(
n_calls
):
...
...
api/profile/profile.pb.go
浏览文件 @
45ded9d3
...
...
@@ -34,6 +34,7 @@ const (
TuningMessage_SyncConfig
TuningMessageStatus
=
6
TuningMessage_Detail
TuningMessageStatus
=
7
TuningMessage_Threshold
TuningMessageStatus
=
8
TuningMessage_JobCreate
TuningMessageStatus
=
9
)
var
TuningMessageStatus_name
=
map
[
int32
]
string
{
...
...
@@ -46,6 +47,7 @@ var TuningMessageStatus_name = map[int32]string{
6
:
"SyncConfig"
,
7
:
"Detail"
,
8
:
"Threshold"
,
9
:
"JobCreate"
,
}
var
TuningMessageStatus_value
=
map
[
string
]
int32
{
...
...
@@ -58,6 +60,7 @@ var TuningMessageStatus_value = map[string]int32{
"SyncConfig"
:
6
,
"Detail"
:
7
,
"Threshold"
:
8
,
"JobCreate"
:
9
,
}
func
(
x
TuningMessageStatus
)
String
()
string
{
...
...
@@ -843,74 +846,74 @@ func init() {
func
init
()
{
proto
.
RegisterFile
(
"profile.proto"
,
fileDescriptor_744bf7a47b381504
)
}
var
fileDescriptor_744bf7a47b381504
=
[]
byte
{
// 10
61
bytes of a gzipped FileDescriptorProto
// 10
70
bytes of a gzipped FileDescriptorProto
0x1f
,
0x8b
,
0x08
,
0x00
,
0x00
,
0x00
,
0x00
,
0x00
,
0x02
,
0xff
,
0x9c
,
0x56
,
0xcb
,
0x6e
,
0xe3
,
0x36
,
0x17
,
0x8e
,
0xed
,
0xf8
,
0x76
,
0xec
,
0x24
,
0xfa
,
0xf9
,
0x4f
,
0x03
,
0x21
,
0xe8
,
0x14
,
0x81
,
0xd0
,
0x45
,
0xd0
,
0x45
,
0x10
,
0x64
,
0x8a
,
0x5e
,
0x10
,
0xcc
,
0x14
,
0x8e
,
0x93
,
0xb4
,
0x0e
,
0x92
,
0xe9
,
0x40
,
0xce
,
0xa0
,
0xb3
,
0x65
,
0x24
,
0x46
,
0x26
,
0x4c
,
0x93
,
0x02
,
0x45
,
0xa7
,
0x70
,
0x
f7
,
0x7d
,
0x
84
,
0x2e
,
0xfa
,
0x36
,
0xdd
,
0xf4
,
0x35
,
0xfa
,
0x2c
,
0x05
,
0x2f
,
0xba
,
0x38
,
0x23
,
0x17
,
0x6d
,
0x
76
,
0xfa
,
0xbe
,
0x73
,
0xe1
,
0xe1
,
0xc7
,
0x43
,
0x1e
,
0xc1
,
0x4e
,
0x2a
,
0xc5
,
0x03
,
0x65
,
0xe4
,
0x
38
,
0x95
,
0x42
,
0x09
,
0xd4
,
0x75
,
0x30
,
0x58
,
0xc0
,
0xe0
,
0x86
,
0x66
,
0xea
,
0x96
,
0x64
,
0x19
,
0x
4e
,
0x08
,
0x0a
,
0x60
,
0xf8
,
0x93
,
0x90
,
0x73
,
0x26
,
0x70
,
0x7c
,
0xb7
,
0x4a
,
0x89
,
0xdf
,
0x3
8
,
0x
6c
,
0x1c
,
0xf5
,
0xc3
,
0x35
,
0x4e
,
0xfb
,
0xbc
,
0xb3
,
0xd1
,
0x6f
,
0xf1
,
0x82
,
0x64
,
0x7e
,
0xd3
,
0x
fa
,
0x54
,
0x39
,
0xb4
,
0x0f
,
0x9d
,
0x51
,
0xa4
,
0xe8
,
0x23
,
0xf1
,
0x5b
,
0xc6
,
0xea
,
0x50
,
0x70
,
0x06
,
0x
03
,
0xe7
,
0x37
,
0xe1
,
0x0f
,
0x02
,
0x21
,
0xd8
,
0xd6
,
0xfe
,
0x6e
,
0x19
,
0xf3
,
0x8d
,
0x7c
,
0x
e8
,
0x8e
,
0x05
,
0x57
,
0x84
,
0x2b
,
0x93
,
0x79
,
0x18
,
0xe6
,
0x30
,
0x48
,
0x60
,
0x6f
,
0xc4
,
0x31
,
0x
5b
,
0x65
,
0x34
,
0xcb
,
0xeb
,
0xad
,
0x4b
,
0xf0
,
0x02
,
0xda
,
0xb7
,
0x22
,
0x26
,
0xcc
,
0x15
,
0x66
,
0x
01
,
0xfa
,
0x02
,
0xbc
,
0xf1
,
0x0c
,
0x4b
,
0x1c
,
0x29
,
0x22
,
0xe9
,
0x2f
,
0x58
,
0x51
,
0xc1
,
0x4d
,
0x
6d
,
0xbd
,
0xf0
,
0x23
,
0x3e
,
0x78
,
0x09
,
0xad
,
0x51
,
0x34
,
0xd7
,
0x9b
,
0x98
,
0x2a
,
0xac
,
0x96
,
0x9
9
,
0x4b
,
0xef
,
0x50
,
0xf0
,
0x01
,
0x7a
,
0xa3
,
0x68
,
0x3e
,
0x9e
,
0x91
,
0x68
,
0x5e
,
0x5b
,
0x40
,
0x
19
,
0xd7
,
0xac
,
0xc6
,
0xa1
,
0x43
,
0x18
,
0x5c
,
0x90
,
0x2c
,
0x92
,
0x34
,
0x2d
,
0x56
,
0xef
,
0x87
,
0x5
5
,
0x2a
,
0xf8
,
0x00
,
0xe0
,
0xe4
,
0xb9
,
0x11
,
0x09
,
0xda
,
0x85
,
0xe6
,
0x24
,
0x36
,
0x99
,
0x5b
,
0x
61
,
0x73
,
0x12
,
0xa3
,
0x4f
,
0xa1
,
0x9f
,
0x8b
,
0x17
,
0xbb
,
0xd4
,
0x25
,
0xa1
,
0xad
,
0x77
,
0x74
,
0x
41
,
0x32
,
0x85
,
0x17
,
0xa9
,
0xcb
,
0x5d
,
0x12
,
0xc1
,
0x9f
,
0x0d
,
0x18
,
0x8c
,
0x05
,
0x63
,
0x24
,
0x
52
,
0x57
,
0x0c
,
0x27
,
0xe8
,
0x00
,
0x7a
,
0x13
,
0xae
,
0x88
,
0x7c
,
0xc4
,
0xcc
,
0xad
,
0x50
,
0x60
,
0x
6d
,
0xbb
,
0x58
,
0x4a
,
0x2b
,
0x51
,
0xd3
,
0xda
,
0x72
,
0xac
,
0x6d
,
0x79
,
0x33
,
0xb8
,
0x45
,
0x0a
,
0x
8c
,
0x3e
,
0x03
,
0xf8
,
0x71
,
0xa9
,
0xd2
,
0xa5
,
0x7a
,
0x87
,
0xd5
,
0xcc
,
0xdf
,
0x36
,
0xd6
,
0x0a
,
0x
a3
,
0x0f
,
0xe6
,
0x9c
,
0x89
,
0x68
,
0xee
,
0xb7
,
0xed
,
0xc1
,
0x18
,
0xa0
,
0xcf
,
0xfb
,
0x2d
,
0x51
,
0x
3f
,
0x0b
,
0x39
,
0xf7
,
0x3b
,
0x86
,
0xcf
,
0xa1
,
0xd6
,
0xd6
,
0x34
,
0x61
,
0xd7
,
0x6a
,
0xab
,
0xbf
,
0x
83
,
0x6b
,
0x18
,
0xde
,
0x49
,
0x4c
,
0x79
,
0xde
,
0x00
,
0xba
,
0x56
,
0xac
,
0xb0
,
0x59
,
0xd1
,
0x9e
,
0x
41
,
0x81
,
0x9f
,
0xd4
,
0xd3
,
0x7c
,
0x5a
,
0x4f
,
0xf0
,
0x7b
,
0x03
,
0x76
,
0x2e
,
0xc8
,
0x03
,
0xe5
,
0x
24
,
0xcf
,
0x76
,
0x08
,
0x83
,
0x29
,
0x91
,
0x8f
,
0x34
,
0x22
,
0x95
,
0xee
,
0xaf
,
0x52
,
0xe8
,
0x0
8
,
0x
f6
,
0x46
,
0x69
,
0xca
,
0x68
,
0x64
,
0xe4
,
0x30
,
0x47
,
0x6f
,
0x13
,
0x3f
,
0xa5
,
0xf5
,
0x35
,
0x99
,
0x
46
,
0x84
,
0x63
,
0x49
,
0x85
,
0x71
,
0xb3
,
0x6a
,
0xad
,
0x71
,
0xd5
,
0x5e
,
0xdf
,
0x5e
,
0xef
,
0xf5
,
0x
29
,
0xec
,
0x4d
,
0xa3
,
0x19
,
0x89
,
0x97
,
0xac
,
0x28
,
0xce
,
0x83
,
0xd6
,
0x28
,
0x4d
,
0x5d
,
0x51
,
0x
fa
,
0xb3
,
0x10
,
0xa8
,
0x59
,
0x0a
,
0xa4
,
0x05
,
0x99
,
0x2a
,
0x89
,
0x15
,
0x49
,
0x56
,
0xf9
,
0x01
,
0x
e5
,
0x38
,
0xf8
,
0x6b
,
0x1b
,
0x76
,
0xee
,
0x96
,
0x9c
,
0xf2
,
0xa4
,
0x72
,
0x7f
,
0x78
,
0xa5
,
0x7d
,
0x
b9
,
0x6b
,
0x5f
,
0xc2
,
0x13
,
0xca
,
0xf3
,
0xbc
,
0x0e
,
0xe9
,
0x62
,
0x23
,
0x57
,
0x6c
,
0xcb
,
0x16
,
0x
eb
,
0x20
,
0x7a
,
0x05
,
0xed
,
0x4c
,
0x61
,
0x45
,
0xcc
,
0x26
,
0x76
,
0x4f
,
0x5f
,
0x1e
,
0xe7
,
0x8f
,
0x
cd
,
0xda
,
0x62
,
0xc7
,
0x99
,
0xb9
,
0x06
,
0xa1
,
0xf5
,
0xd5
,
0xfa
,
0x84
,
0x98
,
0xc7
,
0x62
,
0x31
,
0x
55
,
0x58
,
0xaa
,
0xcc
,
0x34
,
0x45
,
0x3b
,
0x5c
,
0xe3
,
0xd0
,
0x09
,
0xfc
,
0xff
,
0x8a
,
0x60
,
0xb
5
,
0x
94
,
0xe4
,
0x8a
,
0x32
,
0x45
,
0xe4
,
0xa5
,
0xad
,
0xcb
,
0xf6
,
0x49
,
0x9d
,
0x09
,
0x1d
,
0x03
,
0x5a
,
0x
a3
,
0xc7
,
0xab
,
0x88
,
0xd9
,
0x0e
,
0x6a
,
0x87
,
0x35
,
0x96
,
0x8f
,
0xfc
,
0x27
,
0x8a
,
0xc8
,
0xcc
,
0x
ef
,
0xd5
,
0xf8
,
0x1b
,
0x8b
,
0x16
,
0x21
,
0xd4
,
0x57
,
0x4a
,
0x2a
,
0xbf
,
0x6f
,
0x5e
,
0x8f
,
0x1c
,
0x
a2
,
0xcf
,
0x61
,
0x67
,
0xcd
,
0xdf
,
0x07
,
0x63
,
0x5f
,
0x27
,
0xd1
,
0x97
,
0xd0
,
0xb7
,
0xa2
,
0xdc
,
0x
88
,
0xc4
,
0x1f
,
0x1c
,
0x36
,
0x8e
,
0x06
,
0xa7
,
0xfb
,
0x4f
,
0xe4
,
0xfa
,
0x81
,
0x66
,
0x4a
,
0xc8
,
0x
55
,
0x58
,
0x3a
,
0xea
,
0x4e
,
0x9e
,
0xa6
,
0x8c
,
0xaa
,
0xb1
,
0x58
,
0x72
,
0xe5
,
0x0f
,
0x4d
,
0x75
,
0x
15
,
0x26
,
0xf8
,
0xb5
,
0x01
,
0x1d
,
0xab
,
0x2e
,
0x1a
,
0x40
,
0xf7
,
0x5a
,
0xdc
,
0x4f
,
0x38
,
0x5
5
,
0x
de
,
0x16
,
0xda
,
0x05
,
0xb8
,
0x16
,
0xf7
,
0xae
,
0x42
,
0xaf
,
0x81
,
0x76
,
0xa0
,
0x7f
,
0x4e
,
0x78
,
0x
34
,
0xbb
,
0xc5
,
0x72
,
0xee
,
0x35
,
0xb5
,
0xaf
,
0xb6
,
0x09
,
0x49
,
0xbc
,
0x16
,
0x02
,
0xe8
,
0x5c
,
0x
f2
,
0x98
,
0xf2
,
0xc4
,
0xdb
,
0xd6
,
0x86
,
0x0b
,
0x9a
,
0xa5
,
0x0c
,
0xaf
,
0xbc
,
0xb6
,
0x4e
,
0x32
,
0x
5d
,
0xf1
,
0x68
,
0x2c
,
0xf8
,
0x03
,
0x4d
,
0xbc
,
0x8e
,
0x76
,
0xbc
,
0x20
,
0x0a
,
0x53
,
0xe6
,
0x75
,
0x
75
,
0xc2
,
0xbb
,
0x99
,
0x24
,
0xd9
,
0x4c
,
0xb0
,
0xd8
,
0xeb
,
0x05
,
0xbf
,
0x35
,
0xf2
,
0x06
,
0x73
,
0x
9b
,
0xd0
,
0xed
,
0x78
,
0x8e
,
0x33
,
0x72
,
0x99
,
0xbf
,
0x33
,
0xfd
,
0xb0
,
0xc0
,
0x5a
,
0xcb
,
0x5b
,
0x
ca
,
0x8d
,
0xc9
,
0x76
,
0x5a
,
0x0e
,
0xb5
,
0x65
,
0xba
,
0x5c
,
0x18
,
0x8b
,
0xed
,
0xe1
,
0x1c
,
0x9a
,
0x
57
,
0x4e
,
0x28
,
0xcc
,
0xf4
,
0xcb
,
0x66
,
0xda
,
0xad
,
0x15
,
0x96
,
0x84
,
0x7b
,
0x79
,
0xcb
,
0x6e
,
0x
72
,
0xe8
,
0xf4
,
0x8f
,
0x6e
,
0xf1
,
0xb0
,
0xde
,
0x26
,
0x12
,
0x7d
,
0x05
,
0x5d
,
0x87
,
0xd0
,
0x8b
,
0x
42
,
0xfc
,
0xca
,
0x5c
,
0x3a
,
0xf8
,
0x5f
,
0xc1
,
0xe6
,
0x0f
,
0x7d
,
0xb0
,
0x75
,
0xd2
,
0x40
,
0xdf
,
0x
e9
,
0x19
,
0x42
,
0xa2
,
0xb9
,
0x56
,
0xf7
,
0x59
,
0x09
,
0xce
,
0xa0
,
0x97
,
0x4f
,
0x30
,
0xe4
,
0x97
,
0x
2e
,
0xeb
,
0x43
,
0x6d
,
0x53
,
0xf0
,
0x1b
,
0xe8
,
0x58
,
0x6d
,
0xd1
,
0x7e
,
0xfd
,
0x05
,
0x3b
,
0xd8
,
0x
c0
,
0x07
,
0x5b
,
0x47
,
0x0d
,
0x13
,
0x3f
,
0xd4
,
0xa3
,
0xbe
,
0x78
,
0xae
,
0xeb
,
0x2b
,
0x2f
,
0xd9
,
0x
ca
,
0x7f
,
0x81
,
0x59
,
0xff
,
0x35
,
0xec
,
0xbe
,
0x4f
,
0x13
,
0x89
,
0x63
,
0xf2
,
0xac
,
0xbd
,
0xbf
,
0x
86
,
0x81
,
0x36
,
0xff
,
0x73
,
0x6c
,
0x2d
,
0x6b
,
0xc2
,
0x47
,
0x80
,
0x4c
,
0x2e
,
0xfb
,
0x23
,
0xf1
,
0x
ac
,
0x0a
,
0xde
,
0xc0
,
0x9e
,
0xf3
,
0x0a
,
0x05
,
0x63
,
0xf7
,
0x38
,
0x9a
,
0xff
,
0xb7
,
0xf8
,
0x6f
,
0x
01
,
0xdc
,
0x08
,
0xd5
,
0x93
,
0xb0
,
0x0c
,
0xad
,
0xcc
,
0xd5
,
0x4d
,
0xa1
,
0xdf
,
0x40
,
0xcf
,
0x8c
,
0x
2d
,
0x7d
,
0x7a
,
0x9f
,
0x94
,
0xa7
,
0x54
,
0x99
,
0x64
,
0x9b
,
0x22
,
0x4f
,
0xf4
,
0x6d
,
0xd3
,
0x33
,
0x
aa
,
0x72
,
0xea
,
0x6b
,
0x43
,
0xeb
,
0x60
,
0x58
,
0x0d
,
0x0c
,
0xb6
,
0xd0
,
0xb1
,
0x8e
,
0x60
,
0x44
,
0x
6d
,
0x52
,
0xa7
,
0xc6
,
0xff
,
0x7d
,
0x1a
,
0xe3
,
0x7f
,
0xed
,
0x7f
,
0x06
,
0xbd
,
0x7c
,
0x34
,
0x55
,
0x
9a
,
0xf8
,
0xc9
,
0xb4
,
0xda
,
0xb4
,
0x9d
,
0xaf
,
0xa1
,
0xf7
,
0x3d
,
0xe1
,
0x44
,
0x6e
,
0x5e
,
0xa
e
,
0x
3e
,
0xf0
,
0xbe
,
0x63
,
0x7e
,
0x5c
,
0x5f
,
0xfd
,
0x1d
,
0x00
,
0x00
,
0xff
,
0xff
,
0xa9
,
0xb3
,
0x58
,
0x
a0
,
0xc9
,
0x0a
,
0x00
,
0x00
,
0x40
,
0xce
,
0xa0
,
0xb3
,
0x65
,
0x24
,
0x46
,
0x26
,
0x4c
,
0x93
,
0x02
,
0x45
,
0xa7
,
0x70
,
0x
9f
,
0xa3
,
0x
5d
,
0xf4
,
0x6d
,
0xba
,
0xe9
,
0xe3
,
0xf4
,
0x1d
,
0x0a
,
0x5e
,
0x74
,
0x71
,
0x46
,
0x2e
,
0xda
,
0xec
,
0x
f4
,
0x7d
,
0xe7
,
0xc2
,
0xc3
,
0xc3
,
0x8f
,
0x3c
,
0x82
,
0x9d
,
0x54
,
0x8a
,
0x07
,
0xca
,
0xc8
,
0x71
,
0x
2a
,
0x85
,
0x12
,
0xa8
,
0xeb
,
0x60
,
0xb0
,
0x80
,
0xc1
,
0x0d
,
0xcd
,
0xd4
,
0x2d
,
0xc9
,
0x32
,
0x9c
,
0x
10
,
0x14
,
0xc0
,
0xf0
,
0x27
,
0x21
,
0xe7
,
0x4c
,
0xe0
,
0xf8
,
0x6e
,
0x95
,
0x12
,
0xbf
,
0x71
,
0xd
8
,
0x
38
,
0xea
,
0x87
,
0x6b
,
0x9c
,
0xf6
,
0x79
,
0x67
,
0xa3
,
0xdf
,
0xe2
,
0x05
,
0xc9
,
0xfc
,
0xa6
,
0xf5
,
0x
a9
,
0x72
,
0x68
,
0x1f
,
0x3a
,
0xa3
,
0x48
,
0xd1
,
0x47
,
0xe2
,
0xb7
,
0x8c
,
0xd5
,
0xa1
,
0xe0
,
0x0c
,
0x06
,
0x
ce
,
0x6f
,
0xc2
,
0x1f
,
0x04
,
0x42
,
0xb0
,
0xad
,
0xfd
,
0xdd
,
0x32
,
0xe6
,
0x1b
,
0xf9
,
0xd0
,
0x
1d
,
0x0b
,
0xae
,
0x08
,
0x57
,
0x26
,
0xf3
,
0x30
,
0xcc
,
0x61
,
0x90
,
0xc0
,
0xde
,
0x88
,
0x63
,
0xb6
,
0x
ca
,
0x68
,
0x96
,
0xd7
,
0x5b
,
0x97
,
0xe0
,
0x05
,
0xb4
,
0x6f
,
0x45
,
0x4c
,
0x98
,
0x2b
,
0xcc
,
0x02
,
0x
f4
,
0x05
,
0x78
,
0xe3
,
0x19
,
0x96
,
0x38
,
0x52
,
0x44
,
0xd2
,
0x5f
,
0xb0
,
0xa2
,
0x82
,
0x9b
,
0xda
,
0x
7a
,
0xe1
,
0x47
,
0x7c
,
0xf0
,
0x12
,
0x5a
,
0xa3
,
0x68
,
0xae
,
0x37
,
0x31
,
0x55
,
0x58
,
0x2d
,
0x33
,
0x9
7
,
0xde
,
0xa1
,
0xe0
,
0x03
,
0xf4
,
0x46
,
0xd1
,
0x7c
,
0x3c
,
0x23
,
0xd1
,
0xbc
,
0xb6
,
0x80
,
0x32
,
0x
ae
,
0x59
,
0x8d
,
0x43
,
0x87
,
0x30
,
0xb8
,
0x20
,
0x59
,
0x24
,
0x69
,
0x5a
,
0xac
,
0xde
,
0x0f
,
0xab
,
0x5
4
,
0xf0
,
0x01
,
0xc0
,
0xb5
,
0xe7
,
0x46
,
0x24
,
0x68
,
0x17
,
0x9a
,
0x93
,
0xd8
,
0x64
,
0x6e
,
0x85
,
0x
cd
,
0x49
,
0x8c
,
0x3e
,
0x85
,
0x7e
,
0xde
,
0xbc
,
0xd8
,
0xa5
,
0x2e
,
0x09
,
0x6d
,
0xbd
,
0xa3
,
0x0b
,
0x
92
,
0x29
,
0xbc
,
0x48
,
0x5d
,
0xee
,
0x92
,
0x08
,
0xfe
,
0x6c
,
0xc0
,
0x60
,
0x2c
,
0x18
,
0x23
,
0x91
,
0x
ba
,
0x62
,
0x38
,
0x41
,
0x07
,
0xd0
,
0x9b
,
0x70
,
0x45
,
0xe4
,
0x23
,
0x66
,
0x6e
,
0x85
,
0x02
,
0x6b
,
0x
db
,
0xc5
,
0x52
,
0xda
,
0x16
,
0x35
,
0xad
,
0x2d
,
0xc7
,
0xda
,
0x96
,
0x8b
,
0xc1
,
0x2d
,
0x52
,
0x60
,
0x
f4
,
0x19
,
0xc0
,
0x8f
,
0x4b
,
0x95
,
0x2e
,
0xd5
,
0x3b
,
0xac
,
0x66
,
0xfe
,
0xb6
,
0xb1
,
0x56
,
0x18
,
0x
7d
,
0x30
,
0xe7
,
0x4c
,
0x44
,
0x73
,
0xbf
,
0x6d
,
0x0f
,
0xc6
,
0x00
,
0x7d
,
0xde
,
0x6f
,
0x89
,
0xfa
,
0x
59
,
0xc8
,
0xb9
,
0xdf
,
0x31
,
0x7c
,
0x0e
,
0x75
,
0x6f
,
0x8d
,
0x08
,
0xbb
,
0xb6
,
0xb7
,
0xfa
,
0x3b
,
0x
b8
,
0x86
,
0xe1
,
0x9d
,
0xc4
,
0x94
,
0xe7
,
0x02
,
0xd0
,
0xb5
,
0x62
,
0x85
,
0xcd
,
0x8a
,
0xf6
,
0x0c
,
0x
0a
,
0xfc
,
0xa4
,
0x9e
,
0xe6
,
0xd3
,
0x7a
,
0x82
,
0xdf
,
0x1b
,
0xb0
,
0x73
,
0x41
,
0x1e
,
0x28
,
0x27
,
0x
79
,
0xb6
,
0x43
,
0x18
,
0x4c
,
0x89
,
0x7c
,
0xa4
,
0x11
,
0xa9
,
0xa8
,
0xbf
,
0x4a
,
0xa1
,
0x23
,
0xd
8
,
0x
1b
,
0xa5
,
0x29
,
0xa3
,
0x91
,
0x69
,
0x87
,
0x39
,
0x7a
,
0x9b
,
0xf8
,
0x29
,
0xad
,
0xaf
,
0xc9
,
0x34
,
0x
22
,
0x1c
,
0x4b
,
0x2a
,
0x8c
,
0x9b
,
0xed
,
0xd6
,
0x1a
,
0x57
,
0xd5
,
0xfa
,
0xf6
,
0xba
,
0xd6
,
0xa7
,
0x
b0
,
0x37
,
0x8d
,
0x66
,
0x24
,
0x5e
,
0xb2
,
0xa2
,
0x38
,
0x0f
,
0x5a
,
0xa3
,
0x34
,
0x75
,
0x45
,
0xe9
,
0x
cf
,
0xa2
,
0x41
,
0xcd
,
0xb2
,
0x41
,
0xba
,
0x21
,
0x53
,
0x25
,
0xb1
,
0x22
,
0xc9
,
0x2a
,
0x3f
,
0xa0
,
0x
1c
,
0x07
,
0x7f
,
0x6d
,
0xc3
,
0xce
,
0xdd
,
0x92
,
0x53
,
0x9e
,
0x54
,
0xee
,
0x0f
,
0xaf
,
0xc8
,
0x97
,
0x
3b
,
0xf9
,
0x12
,
0x9e
,
0x50
,
0x9e
,
0xe7
,
0x75
,
0x48
,
0x17
,
0x1b
,
0xb9
,
0x62
,
0x5b
,
0xb6
,
0x58
,
0x
07
,
0xd1
,
0x2b
,
0x68
,
0x67
,
0x0a
,
0x2b
,
0x62
,
0x36
,
0xb1
,
0x7b
,
0xfa
,
0xf2
,
0x38
,
0x7f
,
0x6c
,
0x
d6
,
0x16
,
0x3b
,
0xce
,
0xcc
,
0x35
,
0x08
,
0xad
,
0xaf
,
0xee
,
0x4f
,
0x88
,
0x79
,
0x2c
,
0x16
,
0x53
,
0x
85
,
0xa5
,
0xca
,
0x8c
,
0x28
,
0xda
,
0xe1
,
0x1a
,
0x87
,
0x4e
,
0xe0
,
0xff
,
0x57
,
0x04
,
0xab
,
0xa
5
,
0x
24
,
0x57
,
0x94
,
0x29
,
0x22
,
0x2f
,
0x6d
,
0x5d
,
0x56
,
0x27
,
0x75
,
0x26
,
0x74
,
0x0c
,
0x68
,
0x8d
,
0x
1e
,
0xaf
,
0x22
,
0x66
,
0x15
,
0xd4
,
0x0e
,
0x6b
,
0x2c
,
0x1f
,
0xf9
,
0x4f
,
0x14
,
0x91
,
0x99
,
0xdf
,
0x
ab
,
0xf1
,
0x37
,
0x16
,
0xdd
,
0x84
,
0x50
,
0x5f
,
0x29
,
0xa9
,
0xfc
,
0xbe
,
0x79
,
0x3d
,
0x72
,
0x88
,
0x
3e
,
0x87
,
0x9d
,
0x35
,
0x7f
,
0x1f
,
0x8c
,
0x7d
,
0x9d
,
0x44
,
0x5f
,
0x42
,
0xdf
,
0x36
,
0xe5
,
0x46
,
0x
24
,
0xfe
,
0xe0
,
0xb0
,
0x71
,
0x34
,
0x38
,
0xdd
,
0x7f
,
0xd2
,
0xae
,
0x1f
,
0x68
,
0xa6
,
0x84
,
0x5c
,
0x
85
,
0xa5
,
0xa3
,
0x56
,
0xf2
,
0x34
,
0x65
,
0x54
,
0x8d
,
0xc5
,
0x92
,
0x2b
,
0x7f
,
0x68
,
0xaa
,
0xab
,
0x
30
,
0xc1
,
0xaf
,
0x0d
,
0xe8
,
0xd8
,
0xee
,
0xa2
,
0x01
,
0x74
,
0xaf
,
0xc5
,
0xfd
,
0x84
,
0x53
,
0xe
5
,
0x
6d
,
0xa1
,
0x5d
,
0x80
,
0x6b
,
0x71
,
0xef
,
0x2a
,
0xf4
,
0x1a
,
0x68
,
0x07
,
0xfa
,
0xe7
,
0x84
,
0x47
,
0x
b3
,
0x5b
,
0x2c
,
0xe7
,
0x5e
,
0x53
,
0xfb
,
0x6a
,
0x9b
,
0x90
,
0xc4
,
0x6b
,
0x21
,
0x80
,
0xce
,
0x25
,
0x
8f
,
0x29
,
0x4f
,
0xbc
,
0x6d
,
0x6d
,
0xb8
,
0xa0
,
0x59
,
0xca
,
0xf0
,
0xca
,
0x6b
,
0xeb
,
0x24
,
0xd3
,
0x
15
,
0x8f
,
0xc6
,
0x82
,
0x3f
,
0xd0
,
0xc4
,
0xeb
,
0x68
,
0xc7
,
0x0b
,
0xa2
,
0x30
,
0x65
,
0x5e
,
0x57
,
0x
27
,
0xbc
,
0x9b
,
0x49
,
0x92
,
0xcd
,
0x04
,
0x8b
,
0xbd
,
0x9e
,
0x86
,
0xd7
,
0xe2
,
0x7e
,
0x2c
,
0x09
,
0x
56
,
0xc4
,
0xeb
,
0x07
,
0xbf
,
0x35
,
0x72
,
0xbd
,
0xb9
,
0x3d
,
0x69
,
0x75
,
0x9e
,
0xe3
,
0x8c
,
0x5c
,
0x
e6
,
0xcf
,
0x4e
,
0x3f
,
0x2c
,
0xb0
,
0x6e
,
0xed
,
0x2d
,
0xe5
,
0xc6
,
0x64
,
0x85
,
0x97
,
0x43
,
0x6d
,
0x
99
,
0x2e
,
0x17
,
0xc6
,
0x62
,
0x25
,
0x9d
,
0x43
,
0xf3
,
0xe8
,
0x09
,
0x85
,
0x99
,
0x7e
,
0xe8
,
0x8c
,
0x
fa
,
0x5a
,
0x61
,
0x49
,
0xb8
,
0x87
,
0xb8
,
0x14
,
0x97
,
0x43
,
0xa7
,
0x7f
,
0x74
,
0x8b
,
0x77
,
0xf6
,
0x
36
,
0x91
,
0xe8
,
0x2b
,
0xe8
,
0x3a
,
0x84
,
0x5e
,
0x14
,
0x67
,
0x51
,
0x19
,
0x53
,
0x07
,
0xff
,
0x2b
,
0x
d8
,
0xfc
,
0xdd
,
0x0f
,
0xb6
,
0x4e
,
0x1a
,
0xe8
,
0x3b
,
0x3d
,
0x52
,
0x48
,
0x34
,
0xd7
,
0xcd
,
0x7e
,
0x
56
,
0x82
,
0x33
,
0xe8
,
0xe5
,
0x03
,
0x0d
,
0xf9
,
0xa5
,
0xcb
,
0xfa
,
0x8c
,
0xdb
,
0x14
,
0xfc
,
0x06
,
0x
3a
,
0xb6
,
0xb7
,
0x68
,
0xbf
,
0xfe
,
0xbe
,
0x1d
,
0x6c
,
0xe0
,
0x83
,
0xad
,
0xa3
,
0x86
,
0x89
,
0x1f
,
0x
ea
,
0xc9
,
0x5f
,
0xbc
,
0xde
,
0xf5
,
0x95
,
0x97
,
0x6c
,
0xe5
,
0x37
,
0xc1
,
0xac
,
0xff
,
0x1a
,
0x76
,
0x
df
,
0xa7
,
0x89
,
0xc4
,
0x31
,
0x79
,
0xd6
,
0xde
,
0x5f
,
0xc3
,
0x40
,
0x9b
,
0xff
,
0x39
,
0xb6
,
0x96
,
0x
35
,
0xe1
,
0x23
,
0x40
,
0x26
,
0x97
,
0xfd
,
0xaf
,
0x78
,
0x56
,
0x05
,
0x6f
,
0x60
,
0xcf
,
0x79
,
0x85
,
0x
82
,
0xb1
,
0x7b
,
0x1c
,
0xcd
,
0xff
,
0x5b
,
0xfc
,
0xb7
,
0x00
,
0x6e
,
0xa2
,
0xea
,
0xc1
,
0x58
,
0x86
,
0x
56
,
0xc6
,
0xec
,
0xa6
,
0xd0
,
0x6f
,
0xa0
,
0x67
,
0xa6
,
0x98
,
0x3e
,
0xbd
,
0x4f
,
0xca
,
0x53
,
0xaa
,
0x
0c
,
0xb6
,
0x4d
,
0x91
,
0x27
,
0xfa
,
0xf2
,
0xe9
,
0x91
,
0x55
,
0x39
,
0xf5
,
0xb5
,
0x19
,
0x76
,
0x30
,
0x
ac
,
0x06
,
0x06
,
0x5b
,
0xe8
,
0x58
,
0x47
,
0x30
,
0xa2
,
0x36
,
0x75
,
0xa7
,
0xc6
,
0xff
,
0x7d
,
0x1a
,
0x
e3
,
0x7f
,
0xed
,
0x7f
,
0x06
,
0xbd
,
0x7c
,
0x52
,
0x55
,
0x44
,
0xfc
,
0x64
,
0x78
,
0x6d
,
0xda
,
0xc
e
,
0x
d7
,
0xd0
,
0xfb
,
0x9e
,
0x70
,
0x22
,
0x37
,
0x2f
,
0x57
,
0x1f
,
0x78
,
0xdf
,
0x31
,
0xff
,
0xb1
,
0xaf
,
0x
fe
,
0x0e
,
0x00
,
0x00
,
0xff
,
0xff
,
0x7f
,
0xa9
,
0x73
,
0x55
,
0xd8
,
0x0a
,
0x00
,
0x00
,
}
// Reference imports to suppress errors if they are not otherwise used.
...
...
api/profile/profile.proto
浏览文件 @
45ded9d3
...
...
@@ -110,6 +110,7 @@ message TuningMessage {
SyncConfig
=
6
;
Detail
=
7
;
Threshold
=
8
;
JobCreate
=
9
;
}
status
state
=
4
;
int32
RandomStarts
=
5
;
...
...
common/project/projet.go
浏览文件 @
45ded9d3
...
...
@@ -41,10 +41,10 @@ type Evaluate struct {
// EvalInfo :store the evaluation object
type
EvalInfo
struct
{
Get
string
`yaml:"get"`
Type
string
`yaml:"type"`
Weight
int64
`yaml:"weight"`
Threshold
int64
`yaml:"threshold"`
Get
string
`yaml:"get"`
Type
string
`yaml:"type"`
Weight
int64
`yaml:"weight"`
Threshold
float64
`yaml:"threshold"`
}
// YamlPrjCli :store the client yaml project
...
...
@@ -168,25 +168,25 @@ func (y *YamlPrjCli) BenchMark() (string, string, error) {
func
(
y
*
YamlPrjCli
)
BestPerformance
()
string
{
bestPerformance
:=
make
([]
string
,
0
)
for
index
,
evaluation
:=
range
y
.
Evaluations
{
bestPerformance
=
append
(
bestPerformance
,
fmt
.
Sprintf
(
"%s
:
%.2f"
,
evaluation
.
Name
,
math
.
Abs
(
y
.
EvalMinArray
[
index
])))
bestPerformance
=
append
(
bestPerformance
,
fmt
.
Sprintf
(
"%s
=
%.2f"
,
evaluation
.
Name
,
math
.
Abs
(
y
.
EvalMinArray
[
index
])))
}
return
fmt
.
Sprintf
(
"
(%s)
"
,
strings
.
Join
(
bestPerformance
,
","
))
return
fmt
.
Sprintf
(
"
%s
"
,
strings
.
Join
(
bestPerformance
,
","
))
}
func
(
y
*
YamlPrjCli
)
CurrPerformance
()
string
{
currPerformance
:=
make
([]
string
,
0
)
for
index
,
evaluation
:=
range
y
.
Evaluations
{
currPerformance
=
append
(
currPerformance
,
fmt
.
Sprintf
(
"%s
:
%.2f"
,
evaluation
.
Name
,
math
.
Abs
(
y
.
EvalCurrentArray
[
index
])))
currPerformance
=
append
(
currPerformance
,
fmt
.
Sprintf
(
"%s
=
%.2f"
,
evaluation
.
Name
,
math
.
Abs
(
y
.
EvalCurrentArray
[
index
])))
}
return
fmt
.
Sprintf
(
"
(%s)
"
,
strings
.
Join
(
currPerformance
,
","
))
return
fmt
.
Sprintf
(
"
%s
"
,
strings
.
Join
(
currPerformance
,
","
))
}
func
(
y
*
YamlPrjCli
)
BasePerformance
()
string
{
basePerformance
:=
make
([]
string
,
0
)
for
index
,
evaluation
:=
range
y
.
Evaluations
{
basePerformance
=
append
(
basePerformance
,
fmt
.
Sprintf
(
"%s
:
%.2f"
,
evaluation
.
Name
,
math
.
Abs
(
y
.
EvalBaseArray
[
index
])))
basePerformance
=
append
(
basePerformance
,
fmt
.
Sprintf
(
"%s
=
%.2f"
,
evaluation
.
Name
,
math
.
Abs
(
y
.
EvalBaseArray
[
index
])))
}
return
fmt
.
Sprintf
(
"
(%s)
"
,
strings
.
Join
(
basePerformance
,
","
))
return
fmt
.
Sprintf
(
"
%s
"
,
strings
.
Join
(
basePerformance
,
","
))
}
func
(
y
*
YamlPrjCli
)
calculateBenchMark
()
float64
{
...
...
@@ -217,16 +217,18 @@ func (y *YamlPrjCli) improveRate(index int) float64 {
// Threshold return the threshold, which replace with the benchmark result.
// it is used when the parameters is not match with the relations
func
(
y
*
YamlPrjCli
)
Threshold
()
(
string
,
error
)
{
func
(
y
*
YamlPrjCli
)
Threshold
()
(
string
,
string
,
error
)
{
benchStr
:=
make
([]
string
,
0
)
for
_
,
evaluation
:=
range
y
.
Evaluations
{
out
:=
strconv
.
FormatFloat
(
float64
(
evaluation
.
Info
.
Threshold
)
*
float64
(
evaluation
.
Info
.
Weight
)
/
100
,
'f'
,
-
1
,
64
)
for
index
,
evaluation
:=
range
y
.
Evaluations
{
floatOut
:=
evaluation
.
Info
.
Threshold
if
evaluation
.
Info
.
Type
==
"negative"
{
out
=
"-"
+
o
ut
floatOut
=
-
floatO
ut
}
benchStr
=
append
(
benchStr
,
evaluation
.
Name
+
"="
+
out
)
y
.
EvalCurrentArray
[
index
]
=
floatOut
benchStr
=
append
(
benchStr
,
fmt
.
Sprintf
(
"%s=%.2f"
,
evaluation
.
Name
,
floatOut
))
}
return
strings
.
Join
(
benchStr
,
","
),
nil
sum
:=
y
.
calculateBenchMark
()
return
fmt
.
Sprintf
(
"evaluations=%.2f"
,
sum
),
strings
.
Join
(
benchStr
,
","
),
nil
}
// SetHistoryEvalBase method call the set the current EvalBase to history baseline
...
...
common/tuning/optimizer.go
浏览文件 @
45ded9d3
...
...
@@ -56,6 +56,7 @@ type Optimizer struct {
EvalBase
string
RespPutIns
*
models
.
RespPutBody
StartIterTime
string
InitConfig
string
TotalTime
float64
Percentage
float64
BackupFlag
bool
...
...
@@ -124,9 +125,6 @@ func (o *Optimizer) createOptimizerTask(ch chan *PB.TuningMessage, iters int32,
if
o
.
Restart
&&
iters
<=
int32
(
len
(
optimizerBody
.
Xref
))
{
return
fmt
.
Errorf
(
"create task failed for client ask iters less than tuning history"
)
}
if
o
.
Restart
{
iters
=
iters
-
int32
(
len
(
optimizerBody
.
Xref
))
}
optimizerBody
.
MaxEval
=
iters
optimizerBody
.
Engine
=
engine
optimizerBody
.
RandomStarts
=
o
.
RandomStarts
...
...
@@ -167,6 +165,13 @@ func (o *Optimizer) createOptimizerTask(ch chan *PB.TuningMessage, iters int32,
State
:
PB
.
TuningMessage_JobInit
,
FeatureFilter
:
o
.
FeatureFilter
,
Content
:
[]
byte
(
strconv
.
Itoa
(
respPostIns
.
Iters
)),
TuningLog
:
&
PB
.
TuningHistory
{
BaseEval
:
o
.
EvalBase
,
MinEval
:
o
.
EvalMinArray
,
SumEval
:
fmt
.
Sprintf
(
"%.2f"
,
o
.
MinEvalSum
),
TotalTime
:
int64
(
o
.
TotalTime
),
Starts
:
int32
(
o
.
Iter
)
+
1
,
},
}
url
:=
config
.
GetURL
(
config
.
OptimizerURI
)
o
.
OptimizerPutURL
=
fmt
.
Sprintf
(
"%s/%s"
,
url
,
respPostIns
.
TaskID
)
...
...
@@ -202,9 +207,11 @@ func (o *Optimizer) readTuningLog(body *models.OptimizerPostBody) error {
return
err
}
if
o
.
Iter
==
1
{
if
o
.
Iter
==
0
{
o
.
EvalBase
=
items
[
4
]
o
.
MinEvalSum
=
yFloat
o
.
EvalMinArray
=
items
[
4
]
continue
}
if
startTime
,
err
=
time
.
Parse
(
config
.
DefaultTimeFormat
,
items
[
1
]);
err
!=
nil
{
...
...
@@ -258,11 +265,9 @@ func (o *Optimizer) DynamicTuned(ch chan *PB.TuningMessage, stopCh chan int) err
var
evalValue
string
var
err
error
var
message
string
if
o
.
Content
!=
nil
{
evalValue
,
err
=
o
.
evalParsing
(
ch
)
if
err
!=
nil
{
return
err
}
evalValue
,
err
=
o
.
evalParsing
(
ch
)
if
err
!=
nil
{
return
err
}
err
=
os
.
Setenv
(
"ITERATION"
,
strconv
.
Itoa
(
o
.
Iter
))
...
...
@@ -346,13 +351,6 @@ func (o *Optimizer) DynamicTuned(ch chan *PB.TuningMessage, stopCh chan int) err
ch
<-
&
PB
.
TuningMessage
{
State
:
PB
.
TuningMessage_BenchMark
,
Content
:
[]
byte
(
o
.
RespPutIns
.
Param
),
FeatureFilter
:
o
.
FeatureFilter
,
TuningLog
:
&
PB
.
TuningHistory
{
BaseEval
:
o
.
EvalBase
,
MinEval
:
o
.
EvalMinArray
,
SumEval
:
fmt
.
Sprintf
(
"%.2f"
,
o
.
MinEvalSum
),
TotalTime
:
int64
(
o
.
TotalTime
),
Starts
:
int32
(
o
.
Iter
),
},
}
return
nil
}
...
...
@@ -450,12 +448,23 @@ func (o *Optimizer) RestoreConfigTuned(ch chan *PB.TuningMessage) error {
}
func
(
o
*
Optimizer
)
evalParsing
(
ch
chan
*
PB
.
TuningMessage
)
(
string
,
error
)
{
eval
:=
string
(
o
.
Content
)
if
o
.
Restart
&&
o
.
Content
==
nil
{
return
""
,
nil
}
eval
:=
o
.
EvalBase
if
o
.
Content
!=
nil
{
eval
=
string
(
o
.
Content
)
}
configs
:=
o
.
InitConfig
if
o
.
RespPutIns
!=
nil
{
configs
=
o
.
RespPutIns
.
Param
}
endIterTime
:=
time
.
Now
()
.
Format
(
config
.
DefaultTimeFormat
)
iterInfo
:=
make
([]
string
,
0
)
iterInfo
=
append
(
iterInfo
,
strconv
.
Itoa
(
o
.
Iter
),
o
.
StartIterTime
,
endIterTime
,
o
.
Evaluations
,
eval
,
o
.
RespPutIns
.
Param
)
o
.
Evaluations
,
eval
,
configs
)
output
:=
strings
.
Join
(
iterInfo
,
"|"
)
err
:=
utils
.
WriteFile
(
o
.
TuningFile
,
output
+
"
\n
"
,
utils
.
FilePerm
,
os
.
O_APPEND
|
os
.
O_WRONLY
)
...
...
@@ -673,6 +682,7 @@ func (o *Optimizer) Backup(ch chan *PB.TuningMessage) error {
log
.
Error
(
err
)
return
err
}
o
.
InitConfig
=
strings
.
Join
(
initConfigure
,
","
)
return
nil
}
...
...
modules/client/profile/profile_tuning.go
浏览文件 @
45ded9d3
...
...
@@ -148,6 +148,26 @@ func profileTunning(ctx *cli.Context) error {
}
state
:=
reply
.
GetState
()
switch
state
{
case
PB
.
TuningMessage_JobCreate
:
if
!
init
{
select
{
case
err
:=
<-
errors
:
return
err
case
<-
finished
:
break
}
init
=
true
}
content
:=
&
PB
.
TuningMessage
{
State
:
PB
.
TuningMessage_JobCreate
,
TuningLog
:
&
PB
.
TuningHistory
{
BaseEval
:
prj
.
BasePerformance
(),
SumEval
:
fmt
.
Sprintf
(
"evaluations=%.2f"
,
prj
.
EvalCurrent
),
},
}
if
err
:=
stream
.
Send
(
content
);
err
!=
nil
{
return
fmt
.
Errorf
(
"client sends failure, error: %v"
,
err
)
}
case
PB
.
TuningMessage_JobInit
:
prj
.
FeatureFilter
=
reply
.
GetFeatureFilter
()
iterations
,
err
:=
strconv
.
Atoi
(
string
(
reply
.
GetContent
()))
...
...
@@ -155,24 +175,15 @@ func profileTunning(ctx *cli.Context) error {
return
err
}
prj
.
TotalIters
=
int32
(
iterations
)
if
ctx
.
Bool
(
"restart"
)
{
prj
.
SetHistoryEvalBase
(
reply
.
GetTuningLog
())
}
case
PB
.
TuningMessage_JobRestart
:
prj
.
StartIters
=
1
if
err
:=
stream
.
Send
(
&
PB
.
TuningMessage
{
State
:
PB
.
TuningMessage_JobRestart
,
Content
:
[]
byte
(
strconv
.
Itoa
(
int
(
prj
.
Iterations
)))});
err
!=
nil
{
return
fmt
.
Errorf
(
"client sends failure, error: %v"
,
err
)
}
case
PB
.
TuningMessage_BenchMark
:
if
!
init
{
select
{
case
err
:=
<-
errors
:
return
err
case
<-
finished
:
break
}
init
=
true
}
if
ctx
.
Bool
(
"restart"
)
{
prj
.
SetHistoryEvalBase
(
reply
.
GetTuningLog
())
}
prj
.
Params
=
string
(
reply
.
GetContent
())
evaluationSum
,
evaluationDetail
,
err
:=
prj
.
BenchMark
()
if
err
!=
nil
{
...
...
@@ -187,14 +198,14 @@ func profileTunning(ctx *cli.Context) error {
prj
.
StartIters
,
prj
.
TotalIters
)
}
else
{
fmt
.
Printf
(
" Current Tuning Progress......(%d/%d)
\n
"
,
prj
.
StartIters
,
prj
.
TotalIters
)
fmt
.
Printf
(
" Used time: %s, Total Time: %s, Best Performance:
%s
, Performance Improvement Rate: %s%%
\n
"
,
fmt
.
Printf
(
" Used time: %s, Total Time: %s, Best Performance:
(%s)
, Performance Improvement Rate: %s%%
\n
"
,
currentTime
.
Sub
(
prj
.
StartsTime
)
.
Round
(
time
.
Second
)
.
String
(),
time
.
Duration
(
int64
(
currentTime
.
Sub
(
prj
.
StartsTime
)
.
Round
(
time
.
Second
)
.
Seconds
())
+
prj
.
TotalTime
)
*
time
.
Second
,
prj
.
BestPerformance
(),
prj
.
ImproveRateString
(
prj
.
EvalMin
))
}
if
ctx
.
Bool
(
"detail"
)
&&
!
prj
.
FeatureFilter
{
fmt
.
Printf
(
" The %dth recommand parameters is: %s
\n
"
+
" The %dth evaluation value:
%s
(%s%%)
\n
"
,
prj
.
StartIters
,
prj
.
Params
,
prj
.
StartIters
,
prj
.
CurrPerformance
(),
prj
.
ImproveRateString
(
prj
.
EvalCurrent
))
" The %dth evaluation value:
(%s)
(%s%%)
\n
"
,
prj
.
StartIters
,
prj
.
Params
,
prj
.
StartIters
,
prj
.
CurrPerformance
(),
prj
.
ImproveRateString
(
prj
.
EvalCurrent
))
}
prj
.
StartIters
++
err
=
stream
.
Send
(
&
PB
.
TuningMessage
{
...
...
@@ -206,12 +217,18 @@ func profileTunning(ctx *cli.Context) error {
return
fmt
.
Errorf
(
"client sends failure, error: %v"
,
err
)
}
case
PB
.
TuningMessage_Threshold
:
benchmarkByte
,
err
:=
prj
.
Threshold
()
evaluationSum
,
evaluationDetail
,
err
:=
prj
.
Threshold
()
if
err
!=
nil
{
fmt
.
Println
(
"
benchmark result:"
,
benchmarkByte
)
fmt
.
Println
(
"
get threshold failed"
)
return
err
}
if
err
:=
stream
.
Send
(
&
PB
.
TuningMessage
{
State
:
PB
.
TuningMessage_BenchMark
,
Content
:
[]
byte
(
benchmarkByte
)});
err
!=
nil
{
prj
.
StartIters
++
err
=
stream
.
Send
(
&
PB
.
TuningMessage
{
State
:
PB
.
TuningMessage_BenchMark
,
Content
:
[]
byte
(
evaluationDetail
),
TuningLog
:
&
PB
.
TuningHistory
{
SumEval
:
evaluationSum
},
})
if
err
!=
nil
{
return
fmt
.
Errorf
(
"client sends failure, error: %v"
,
err
)
}
case
PB
.
TuningMessage_Display
:
...
...
@@ -221,7 +238,7 @@ func profileTunning(ctx *cli.Context) error {
fmt
.
Printf
(
" %s
\n
"
,
string
(
reply
.
GetContent
()))
}
case
PB
.
TuningMessage_Ending
:
fmt
.
Printf
(
" Baseline Performance is:
%s
\n
"
,
prj
.
BasePerformance
())
fmt
.
Printf
(
" Baseline Performance is:
(%s)
\n
"
,
prj
.
BasePerformance
())
fmt
.
Printf
(
" %s
\n
"
,
string
(
reply
.
GetContent
()))
fmt
.
Printf
(
" Tuning Finished
\n
"
)
goto
End
...
...
@@ -329,6 +346,7 @@ func checkTuningPrjYaml(prj project.YamlPrjCli) error {
return
fmt
.
Errorf
(
"error: split_count must be > 0 "
+
"in project %s"
,
prj
.
Project
)
}
return
nil
}
...
...
modules/server/profile/profile.go
浏览文件 @
45ded9d3
...
...
@@ -620,7 +620,10 @@ func (s *ProfileServer) Tuning(stream PB.ProfileMgr_TuningServer) error {
optimizer
.
FeatureFilterIters
=
reply
.
GetFeatureFilterIters
()
optimizer
.
SplitCount
=
reply
.
GetSplitCount
()
cycles
=
reply
.
GetFeatureFilterCycle
()
ch
<-
&
PB
.
TuningMessage
{
State
:
PB
.
TuningMessage_JobCreate
}
case
PB
.
TuningMessage_JobCreate
:
optimizer
.
EvalBase
=
reply
.
GetTuningLog
()
.
GetBaseEval
()
optimizer
.
Evaluations
=
reply
.
GetTuningLog
()
.
GetSumEval
()
if
cycles
==
0
{
if
optimizer
.
Restart
{
message
=
fmt
.
Sprintf
(
"%d.Continue to tuning the system......"
,
step
)
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录