Skip to content

A
A-Tune

openeuler / A-Tune

通知 5
Star 0
Fork 0
A
A-Tune

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 ddd43d02 编写于 作者: O openeuler-ci-bot 提交者： Gitee
浏览文件
操作

!160 atune: using the same baseline when the restart flag is enabled. 

Merge pull request !160 from lixiaoguang/dev_baseline
上级 97f8a043 45ded9d3
隐藏空白更改
内联 并排
Showing with 156 addition and 119 deletion
analysis/optimizer/optimizer.py
浏览文件 @ ddd43d02
......@@ -290,7 +290,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:
......@@ -302,6 +301,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
浏览文件 @ ddd43d02
......@@ -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{
// 1061 bytes of a gzipped FileDescriptorProto
// 1070 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, 0xf7, 0x7d,
0x84, 0x2e, 0xfa, 0x36, 0xdd, 0xf4, 0x35, 0xfa, 0x2c, 0x05, 0x2f, 0xba, 0x38, 0x23, 0x17, 0x6d,
0x76, 0xfa, 0xbe, 0x73, 0xe1, 0xe1, 0xc7, 0x43, 0x1e, 0xc1, 0x4e, 0x2a, 0xc5, 0x03, 0x65, 0xe4,
0x38, 0x95, 0x42, 0x09, 0xd4, 0x75, 0x30, 0x58, 0xc0, 0xe0, 0x86, 0x66, 0xea, 0x96, 0x64, 0x19,
0x4e, 0x08, 0x0a, 0x60, 0xf8, 0x93, 0x90, 0x73, 0x26, 0x70, 0x7c, 0xb7, 0x4a, 0x89, 0xdf, 0x38,
0x6c, 0x1c, 0xf5, 0xc3, 0x35, 0x4e, 0xfb, 0xbc, 0xb3, 0xd1, 0x6f, 0xf1, 0x82, 0x64, 0x7e, 0xd3,
0xfa, 0x54, 0x39, 0xb4, 0x0f, 0x9d, 0x51, 0xa4, 0xe8, 0x23, 0xf1, 0x5b, 0xc6, 0xea, 0x50, 0x70,
0x06, 0x03, 0xe7, 0x37, 0xe1, 0x0f, 0x02, 0x21, 0xd8, 0xd6, 0xfe, 0x6e, 0x19, 0xf3, 0x8d, 0x7c,
0xe8, 0x8e, 0x05, 0x57, 0x84, 0x2b, 0x93, 0x79, 0x18, 0xe6, 0x30, 0x48, 0x60, 0x6f, 0xc4, 0x31,
0x5b, 0x65, 0x34, 0xcb, 0xeb, 0xad, 0x4b, 0xf0, 0x02, 0xda, 0xb7, 0x22, 0x26, 0xcc, 0x15, 0x66,
0x01, 0xfa, 0x02, 0xbc, 0xf1, 0x0c, 0x4b, 0x1c, 0x29, 0x22, 0xe9, 0x2f, 0x58, 0x51, 0xc1, 0x4d,
0x6d, 0xbd, 0xf0, 0x23, 0x3e, 0x78, 0x09, 0xad, 0x51, 0x34, 0xd7, 0x9b, 0x98, 0x2a, 0xac, 0x96,
0x99, 0x4b, 0xef, 0x50, 0xf0, 0x01, 0x7a, 0xa3, 0x68, 0x3e, 0x9e, 0x91, 0x68, 0x5e, 0x5b, 0x40,
0x19, 0xd7, 0xac, 0xc6, 0xa1, 0x43, 0x18, 0x5c, 0x90, 0x2c, 0x92, 0x34, 0x2d, 0x56, 0xef, 0x87,
0x55, 0x2a, 0xf8, 0x00, 0xe0, 0xe4, 0xb9, 0x11, 0x09, 0xda, 0x85, 0xe6, 0x24, 0x36, 0x99, 0x5b,
0x61, 0x73, 0x12, 0xa3, 0x4f, 0xa1, 0x9f, 0x8b, 0x17, 0xbb, 0xd4, 0x25, 0xa1, 0xad, 0x77, 0x74,
0x41, 0x32, 0x85, 0x17, 0xa9, 0xcb, 0x5d, 0x12, 0xc1, 0x9f, 0x0d, 0x18, 0x8c, 0x05, 0x63, 0x24,
0x52, 0x57, 0x0c, 0x27, 0xe8, 0x00, 0x7a, 0x13, 0xae, 0x88, 0x7c, 0xc4, 0xcc, 0xad, 0x50, 0x60,
0x6d, 0xbb, 0x58, 0x4a, 0x2b, 0x51, 0xd3, 0xda, 0x72, 0xac, 0x6d, 0x79, 0x33, 0xb8, 0x45, 0x0a,
0x8c, 0x3e, 0x03, 0xf8, 0x71, 0xa9, 0xd2, 0xa5, 0x7a, 0x87, 0xd5, 0xcc, 0xdf, 0x36, 0xd6, 0x0a,
0xa3, 0x0f, 0xe6, 0x9c, 0x89, 0x68, 0xee, 0xb7, 0xed, 0xc1, 0x18, 0xa0, 0xcf, 0xfb, 0x2d, 0x51,
0x3f, 0x0b, 0x39, 0xf7, 0x3b, 0x86, 0xcf, 0xa1, 0xd6, 0xd6, 0x34, 0x61, 0xd7, 0x6a, 0xab, 0xbf,
0x83, 0x6b, 0x18, 0xde, 0x49, 0x4c, 0x79, 0xde, 0x00, 0xba, 0x56, 0xac, 0xb0, 0x59, 0xd1, 0x9e,
0x41, 0x81, 0x9f, 0xd4, 0xd3, 0x7c, 0x5a, 0x4f, 0xf0, 0x7b, 0x03, 0x76, 0x2e, 0xc8, 0x03, 0xe5,
0x24, 0xcf, 0x76, 0x08, 0x83, 0x29, 0x91, 0x8f, 0x34, 0x22, 0x95, 0xee, 0xaf, 0x52, 0xe8, 0x08,
0xf6, 0x46, 0x69, 0xca, 0x68, 0x64, 0xe4, 0x30, 0x47, 0x6f, 0x13, 0x3f, 0xa5, 0xf5, 0x35, 0x99,
0x46, 0x84, 0x63, 0x49, 0x85, 0x71, 0xb3, 0x6a, 0xad, 0x71, 0xd5, 0x5e, 0xdf, 0x5e, 0xef, 0xf5,
0x29, 0xec, 0x4d, 0xa3, 0x19, 0x89, 0x97, 0xac, 0x28, 0xce, 0x83, 0xd6, 0x28, 0x4d, 0x5d, 0x51,
0xfa, 0xb3, 0x10, 0xa8, 0x59, 0x0a, 0xa4, 0x05, 0x99, 0x2a, 0x89, 0x15, 0x49, 0x56, 0xf9, 0x01,
0xe5, 0x38, 0xf8, 0x6b, 0x1b, 0x76, 0xee, 0x96, 0x9c, 0xf2, 0xa4, 0x72, 0x7f, 0x78, 0xa5, 0x7d,
0xb9, 0x6b, 0x5f, 0xc2, 0x13, 0xca, 0xf3, 0xbc, 0x0e, 0xe9, 0x62, 0x23, 0x57, 0x6c, 0xcb, 0x16,
0xeb, 0x20, 0x7a, 0x05, 0xed, 0x4c, 0x61, 0x45, 0xcc, 0x26, 0x76, 0x4f, 0x5f, 0x1e, 0xe7, 0x8f,
0xcd, 0xda, 0x62, 0xc7, 0x99, 0xb9, 0x06, 0xa1, 0xf5, 0xd5, 0xfa, 0x84, 0x98, 0xc7, 0x62, 0x31,
0x55, 0x58, 0xaa, 0xcc, 0x34, 0x45, 0x3b, 0x5c, 0xe3, 0xd0, 0x09, 0xfc, 0xff, 0x8a, 0x60, 0xb5,
0x94, 0xe4, 0x8a, 0x32, 0x45, 0xe4, 0xa5, 0xad, 0xcb, 0xf6, 0x49, 0x9d, 0x09, 0x1d, 0x03, 0x5a,
0xa3, 0xc7, 0xab, 0x88, 0xd9, 0x0e, 0x6a, 0x87, 0x35, 0x96, 0x8f, 0xfc, 0x27, 0x8a, 0xc8, 0xcc,
0xef, 0xd5, 0xf8, 0x1b, 0x8b, 0x16, 0x21, 0xd4, 0x57, 0x4a, 0x2a, 0xbf, 0x6f, 0x5e, 0x8f, 0x1c,
0xa2, 0xcf, 0x61, 0x67, 0xcd, 0xdf, 0x07, 0x63, 0x5f, 0x27, 0xd1, 0x97, 0xd0, 0xb7, 0xa2, 0xdc,
0x88, 0xc4, 0x1f, 0x1c, 0x36, 0x8e, 0x06, 0xa7, 0xfb, 0x4f, 0xe4, 0xfa, 0x81, 0x66, 0x4a, 0xc8,
0x55, 0x58, 0x3a, 0xea, 0x4e, 0x9e, 0xa6, 0x8c, 0xaa, 0xb1, 0x58, 0x72, 0xe5, 0x0f, 0x4d, 0x75,
0x15, 0x26, 0xf8, 0xb5, 0x01, 0x1d, 0xab, 0x2e, 0x1a, 0x40, 0xf7, 0x5a, 0xdc, 0x4f, 0x38, 0x55,
0xde, 0x16, 0xda, 0x05, 0xb8, 0x16, 0xf7, 0xae, 0x42, 0xaf, 0x81, 0x76, 0xa0, 0x7f, 0x4e, 0x78,
0x34, 0xbb, 0xc5, 0x72, 0xee, 0x35, 0xb5, 0xaf, 0xb6, 0x09, 0x49, 0xbc, 0x16, 0x02, 0xe8, 0x5c,
0xf2, 0x98, 0xf2, 0xc4, 0xdb, 0xd6, 0x86, 0x0b, 0x9a, 0xa5, 0x0c, 0xaf, 0xbc, 0xb6, 0x4e, 0x32,
0x5d, 0xf1, 0x68, 0x2c, 0xf8, 0x03, 0x4d, 0xbc, 0x8e, 0x76, 0xbc, 0x20, 0x0a, 0x53, 0xe6, 0x75,
0x75, 0xc2, 0xbb, 0x99, 0x24, 0xd9, 0x4c, 0xb0, 0xd8, 0xeb, 0x05, 0xbf, 0x35, 0xf2, 0x06, 0x73,
0x9b, 0xd0, 0xed, 0x78, 0x8e, 0x33, 0x72, 0x99, 0xbf, 0x33, 0xfd, 0xb0, 0xc0, 0x5a, 0xcb, 0x5b,
0xca, 0x8d, 0xc9, 0x76, 0x5a, 0x0e, 0xb5, 0x65, 0xba, 0x5c, 0x18, 0x8b, 0xed, 0xe1, 0x1c, 0x9a,
0x57, 0x4e, 0x28, 0xcc, 0xf4, 0xcb, 0x66, 0xda, 0xad, 0x15, 0x96, 0x84, 0x7b, 0x79, 0xcb, 0x6e,
0x72, 0xe8, 0xf4, 0x8f, 0x6e, 0xf1, 0xb0, 0xde, 0x26, 0x12, 0x7d, 0x05, 0x5d, 0x87, 0xd0, 0x8b,
0x42, 0xfc, 0xca, 0x5c, 0x3a, 0xf8, 0x5f, 0xc1, 0xe6, 0x0f, 0x7d, 0xb0, 0x75, 0xd2, 0x40, 0xdf,
0xe9, 0x19, 0x42, 0xa2, 0xb9, 0x56, 0xf7, 0x59, 0x09, 0xce, 0xa0, 0x97, 0x4f, 0x30, 0xe4, 0x97,
0x2e, 0xeb, 0x43, 0x6d, 0x53, 0xf0, 0x1b, 0xe8, 0x58, 0x6d, 0xd1, 0x7e, 0xfd, 0x05, 0x3b, 0xd8,
0xc0, 0x07, 0x5b, 0x47, 0x0d, 0x13, 0x3f, 0xd4, 0xa3, 0xbe, 0x78, 0xae, 0xeb, 0x2b, 0x2f, 0xd9,
0xca, 0x7f, 0x81, 0x59, 0xff, 0x35, 0xec, 0xbe, 0x4f, 0x13, 0x89, 0x63, 0xf2, 0xac, 0xbd, 0xbf,
0x86, 0x81, 0x36, 0xff, 0x73, 0x6c, 0x2d, 0x6b, 0xc2, 0x47, 0x80, 0x4c, 0x2e, 0xfb, 0x23, 0xf1,
0xac, 0x0a, 0xde, 0xc0, 0x9e, 0xf3, 0x0a, 0x05, 0x63, 0xf7, 0x38, 0x9a, 0xff, 0xb7, 0xf8, 0x6f,
0x01, 0xdc, 0x08, 0xd5, 0x93, 0xb0, 0x0c, 0xad, 0xcc, 0xd5, 0x4d, 0xa1, 0xdf, 0x40, 0xcf, 0x8c,
0x2d, 0x7d, 0x7a, 0x9f, 0x94, 0xa7, 0x54, 0x99, 0x64, 0x9b, 0x22, 0x4f, 0xf4, 0x6d, 0xd3, 0x33,
0xaa, 0x72, 0xea, 0x6b, 0x43, 0xeb, 0x60, 0x58, 0x0d, 0x0c, 0xb6, 0xd0, 0xb1, 0x8e, 0x60, 0x44,
0x6d, 0x52, 0xa7, 0xc6, 0xff, 0x7d, 0x1a, 0xe3, 0x7f, 0xed, 0x7f, 0x06, 0xbd, 0x7c, 0x34, 0x55,
0x9a, 0xf8, 0xc9, 0xb4, 0xda, 0xb4, 0x9d, 0xaf, 0xa1, 0xf7, 0x3d, 0xe1, 0x44, 0x6e, 0x5e, 0xae,
0x3e, 0xf0, 0xbe, 0x63, 0x7e, 0x5c, 0x5f, 0xfd, 0x1d, 0x00, 0x00, 0xff, 0xff, 0xa9, 0xb3, 0x58,
0xa0, 0xc9, 0x0a, 0x00, 0x00,
0x40, 0xce, 0xa0, 0xb3, 0x65, 0x24, 0x46, 0x26, 0x4c, 0x93, 0x02, 0x45, 0xa7, 0x70, 0x9f, 0xa3,
0x5d, 0xf4, 0x6d, 0xba, 0xe9, 0xe3, 0xf4, 0x1d, 0x0a, 0x5e, 0x74, 0x71, 0x46, 0x2e, 0xda, 0xec,
0xf4, 0x7d, 0xe7, 0xc2, 0xc3, 0xc3, 0x8f, 0x3c, 0x82, 0x9d, 0x54, 0x8a, 0x07, 0xca, 0xc8, 0x71,
0x2a, 0x85, 0x12, 0xa8, 0xeb, 0x60, 0xb0, 0x80, 0xc1, 0x0d, 0xcd, 0xd4, 0x2d, 0xc9, 0x32, 0x9c,
0x10, 0x14, 0xc0, 0xf0, 0x27, 0x21, 0xe7, 0x4c, 0xe0, 0xf8, 0x6e, 0x95, 0x12, 0xbf, 0x71, 0xd8,
0x38, 0xea, 0x87, 0x6b, 0x9c, 0xf6, 0x79, 0x67, 0xa3, 0xdf, 0xe2, 0x05, 0xc9, 0xfc, 0xa6, 0xf5,
0xa9, 0x72, 0x68, 0x1f, 0x3a, 0xa3, 0x48, 0xd1, 0x47, 0xe2, 0xb7, 0x8c, 0xd5, 0xa1, 0xe0, 0x0c,
0x06, 0xce, 0x6f, 0xc2, 0x1f, 0x04, 0x42, 0xb0, 0xad, 0xfd, 0xdd, 0x32, 0xe6, 0x1b, 0xf9, 0xd0,
0x1d, 0x0b, 0xae, 0x08, 0x57, 0x26, 0xf3, 0x30, 0xcc, 0x61, 0x90, 0xc0, 0xde, 0x88, 0x63, 0xb6,
0xca, 0x68, 0x96, 0xd7, 0x5b, 0x97, 0xe0, 0x05, 0xb4, 0x6f, 0x45, 0x4c, 0x98, 0x2b, 0xcc, 0x02,
0xf4, 0x05, 0x78, 0xe3, 0x19, 0x96, 0x38, 0x52, 0x44, 0xd2, 0x5f, 0xb0, 0xa2, 0x82, 0x9b, 0xda,
0x7a, 0xe1, 0x47, 0x7c, 0xf0, 0x12, 0x5a, 0xa3, 0x68, 0xae, 0x37, 0x31, 0x55, 0x58, 0x2d, 0x33,
0x97, 0xde, 0xa1, 0xe0, 0x03, 0xf4, 0x46, 0xd1, 0x7c, 0x3c, 0x23, 0xd1, 0xbc, 0xb6, 0x80, 0x32,
0xae, 0x59, 0x8d, 0x43, 0x87, 0x30, 0xb8, 0x20, 0x59, 0x24, 0x69, 0x5a, 0xac, 0xde, 0x0f, 0xab,
0x54, 0xf0, 0x01, 0xc0, 0xb5, 0xe7, 0x46, 0x24, 0x68, 0x17, 0x9a, 0x93, 0xd8, 0x64, 0x6e, 0x85,
0xcd, 0x49, 0x8c, 0x3e, 0x85, 0x7e, 0xde, 0xbc, 0xd8, 0xa5, 0x2e, 0x09, 0x6d, 0xbd, 0xa3, 0x0b,
0x92, 0x29, 0xbc, 0x48, 0x5d, 0xee, 0x92, 0x08, 0xfe, 0x6c, 0xc0, 0x60, 0x2c, 0x18, 0x23, 0x91,
0xba, 0x62, 0x38, 0x41, 0x07, 0xd0, 0x9b, 0x70, 0x45, 0xe4, 0x23, 0x66, 0x6e, 0x85, 0x02, 0x6b,
0xdb, 0xc5, 0x52, 0xda, 0x16, 0x35, 0xad, 0x2d, 0xc7, 0xda, 0x96, 0x8b, 0xc1, 0x2d, 0x52, 0x60,
0xf4, 0x19, 0xc0, 0x8f, 0x4b, 0x95, 0x2e, 0xd5, 0x3b, 0xac, 0x66, 0xfe, 0xb6, 0xb1, 0x56, 0x18,
0x7d, 0x30, 0xe7, 0x4c, 0x44, 0x73, 0xbf, 0x6d, 0x0f, 0xc6, 0x00, 0x7d, 0xde, 0x6f, 0x89, 0xfa,
0x59, 0xc8, 0xb9, 0xdf, 0x31, 0x7c, 0x0e, 0x75, 0x6f, 0x8d, 0x08, 0xbb, 0xb6, 0xb7, 0xfa, 0x3b,
0xb8, 0x86, 0xe1, 0x9d, 0xc4, 0x94, 0xe7, 0x02, 0xd0, 0xb5, 0x62, 0x85, 0xcd, 0x8a, 0xf6, 0x0c,
0x0a, 0xfc, 0xa4, 0x9e, 0xe6, 0xd3, 0x7a, 0x82, 0xdf, 0x1b, 0xb0, 0x73, 0x41, 0x1e, 0x28, 0x27,
0x79, 0xb6, 0x43, 0x18, 0x4c, 0x89, 0x7c, 0xa4, 0x11, 0xa9, 0xa8, 0xbf, 0x4a, 0xa1, 0x23, 0xd8,
0x1b, 0xa5, 0x29, 0xa3, 0x91, 0x69, 0x87, 0x39, 0x7a, 0x9b, 0xf8, 0x29, 0xad, 0xaf, 0xc9, 0x34,
0x22, 0x1c, 0x4b, 0x2a, 0x8c, 0x9b, 0xed, 0xd6, 0x1a, 0x57, 0xd5, 0xfa, 0xf6, 0xba, 0xd6, 0xa7,
0xb0, 0x37, 0x8d, 0x66, 0x24, 0x5e, 0xb2, 0xa2, 0x38, 0x0f, 0x5a, 0xa3, 0x34, 0x75, 0x45, 0xe9,
0xcf, 0xa2, 0x41, 0xcd, 0xb2, 0x41, 0xba, 0x21, 0x53, 0x25, 0xb1, 0x22, 0xc9, 0x2a, 0x3f, 0xa0,
0x1c, 0x07, 0x7f, 0x6d, 0xc3, 0xce, 0xdd, 0x92, 0x53, 0x9e, 0x54, 0xee, 0x0f, 0xaf, 0xc8, 0x97,
0x3b, 0xf9, 0x12, 0x9e, 0x50, 0x9e, 0xe7, 0x75, 0x48, 0x17, 0x1b, 0xb9, 0x62, 0x5b, 0xb6, 0x58,
0x07, 0xd1, 0x2b, 0x68, 0x67, 0x0a, 0x2b, 0x62, 0x36, 0xb1, 0x7b, 0xfa, 0xf2, 0x38, 0x7f, 0x6c,
0xd6, 0x16, 0x3b, 0xce, 0xcc, 0x35, 0x08, 0xad, 0xaf, 0xee, 0x4f, 0x88, 0x79, 0x2c, 0x16, 0x53,
0x85, 0xa5, 0xca, 0x8c, 0x28, 0xda, 0xe1, 0x1a, 0x87, 0x4e, 0xe0, 0xff, 0x57, 0x04, 0xab, 0xa5,
0x24, 0x57, 0x94, 0x29, 0x22, 0x2f, 0x6d, 0x5d, 0x56, 0x27, 0x75, 0x26, 0x74, 0x0c, 0x68, 0x8d,
0x1e, 0xaf, 0x22, 0x66, 0x15, 0xd4, 0x0e, 0x6b, 0x2c, 0x1f, 0xf9, 0x4f, 0x14, 0x91, 0x99, 0xdf,
0xab, 0xf1, 0x37, 0x16, 0xdd, 0x84, 0x50, 0x5f, 0x29, 0xa9, 0xfc, 0xbe, 0x79, 0x3d, 0x72, 0x88,
0x3e, 0x87, 0x9d, 0x35, 0x7f, 0x1f, 0x8c, 0x7d, 0x9d, 0x44, 0x5f, 0x42, 0xdf, 0x36, 0xe5, 0x46,
0x24, 0xfe, 0xe0, 0xb0, 0x71, 0x34, 0x38, 0xdd, 0x7f, 0xd2, 0xae, 0x1f, 0x68, 0xa6, 0x84, 0x5c,
0x85, 0xa5, 0xa3, 0x56, 0xf2, 0x34, 0x65, 0x54, 0x8d, 0xc5, 0x92, 0x2b, 0x7f, 0x68, 0xaa, 0xab,
0x30, 0xc1, 0xaf, 0x0d, 0xe8, 0xd8, 0xee, 0xa2, 0x01, 0x74, 0xaf, 0xc5, 0xfd, 0x84, 0x53, 0xe5,
0x6d, 0xa1, 0x5d, 0x80, 0x6b, 0x71, 0xef, 0x2a, 0xf4, 0x1a, 0x68, 0x07, 0xfa, 0xe7, 0x84, 0x47,
0xb3, 0x5b, 0x2c, 0xe7, 0x5e, 0x53, 0xfb, 0x6a, 0x9b, 0x90, 0xc4, 0x6b, 0x21, 0x80, 0xce, 0x25,
0x8f, 0x29, 0x4f, 0xbc, 0x6d, 0x6d, 0xb8, 0xa0, 0x59, 0xca, 0xf0, 0xca, 0x6b, 0xeb, 0x24, 0xd3,
0x15, 0x8f, 0xc6, 0x82, 0x3f, 0xd0, 0xc4, 0xeb, 0x68, 0xc7, 0x0b, 0xa2, 0x30, 0x65, 0x5e, 0x57,
0x27, 0xbc, 0x9b, 0x49, 0x92, 0xcd, 0x04, 0x8b, 0xbd, 0x9e, 0x86, 0xd7, 0xe2, 0x7e, 0x2c, 0x09,
0x56, 0xc4, 0xeb, 0x07, 0xbf, 0x35, 0x72, 0xbd, 0xb9, 0x3d, 0x69, 0x75, 0x9e, 0xe3, 0x8c, 0x5c,
0xe6, 0xcf, 0x4e, 0x3f, 0x2c, 0xb0, 0x6e, 0xed, 0x2d, 0xe5, 0xc6, 0x64, 0x85, 0x97, 0x43, 0x6d,
0x99, 0x2e, 0x17, 0xc6, 0x62, 0x25, 0x9d, 0x43, 0xf3, 0xe8, 0x09, 0x85, 0x99, 0x7e, 0xe8, 0x8c,
0xfa, 0x5a, 0x61, 0x49, 0xb8, 0x87, 0xb8, 0x14, 0x97, 0x43, 0xa7, 0x7f, 0x74, 0x8b, 0x77, 0xf6,
0x36, 0x91, 0xe8, 0x2b, 0xe8, 0x3a, 0x84, 0x5e, 0x14, 0x67, 0x51, 0x19, 0x53, 0x07, 0xff, 0x2b,
0xd8, 0xfc, 0xdd, 0x0f, 0xb6, 0x4e, 0x1a, 0xe8, 0x3b, 0x3d, 0x52, 0x48, 0x34, 0xd7, 0xcd, 0x7e,
0x56, 0x82, 0x33, 0xe8, 0xe5, 0x03, 0x0d, 0xf9, 0xa5, 0xcb, 0xfa, 0x8c, 0xdb, 0x14, 0xfc, 0x06,
0x3a, 0xb6, 0xb7, 0x68, 0xbf, 0xfe, 0xbe, 0x1d, 0x6c, 0xe0, 0x83, 0xad, 0xa3, 0x86, 0x89, 0x1f,
0xea, 0xc9, 0x5f, 0xbc, 0xde, 0xf5, 0x95, 0x97, 0x6c, 0xe5, 0x37, 0xc1, 0xac, 0xff, 0x1a, 0x76,
0xdf, 0xa7, 0x89, 0xc4, 0x31, 0x79, 0xd6, 0xde, 0x5f, 0xc3, 0x40, 0x9b, 0xff, 0x39, 0xb6, 0x96,
0x35, 0xe1, 0x23, 0x40, 0x26, 0x97, 0xfd, 0xaf, 0x78, 0x56, 0x05, 0x6f, 0x60, 0xcf, 0x79, 0x85,
0x82, 0xb1, 0x7b, 0x1c, 0xcd, 0xff, 0x5b, 0xfc, 0xb7, 0x00, 0x6e, 0xa2, 0xea, 0xc1, 0x58, 0x86,
0x56, 0xc6, 0xec, 0xa6, 0xd0, 0x6f, 0xa0, 0x67, 0xa6, 0x98, 0x3e, 0xbd, 0x4f, 0xca, 0x53, 0xaa,
0x0c, 0xb6, 0x4d, 0x91, 0x27, 0xfa, 0xf2, 0xe9, 0x91, 0x55, 0x39, 0xf5, 0xb5, 0x19, 0x76, 0x30,
0xac, 0x06, 0x06, 0x5b, 0xe8, 0x58, 0x47, 0x30, 0xa2, 0x36, 0x75, 0xa7, 0xc6, 0xff, 0x7d, 0x1a,
0xe3, 0x7f, 0xed, 0x7f, 0x06, 0xbd, 0x7c, 0x52, 0x55, 0x44, 0xfc, 0x64, 0x78, 0x6d, 0xda, 0xce,
0xd7, 0xd0, 0xfb, 0x9e, 0x70, 0x22, 0x37, 0x2f, 0x57, 0x1f, 0x78, 0xdf, 0x31, 0xff, 0xb1, 0xaf,
0xfe, 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
浏览文件 @ ddd43d02
......@@ -110,6 +110,7 @@ message TuningMessage {
SyncConfig = 6;
Detail = 7;
Threshold = 8;
JobCreate = 9;
}
status state = 4;
int32 RandomStarts = 5;
......
common/project/projet.go
浏览文件 @ ddd43d02
......@@ -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 = "-" + out
floatOut = -floatOut
}
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
浏览文件 @ ddd43d02
......@@ -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
......@@ -168,6 +166,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)
......@@ -203,9 +208,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 {
......@@ -259,11 +266,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))
......@@ -347,13 +352,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
}
......@@ -451,12 +449,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)
......@@ -674,6 +683,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
浏览文件 @ ddd43d02
......@@ -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
浏览文件 @ ddd43d02
......@@ -623,7 +623,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.
先完成此消息的编辑！
想要评论请 注册 或