Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
BaiXuePrincess
milvus
提交
3d411fba
milvus
项目概览
BaiXuePrincess
/
milvus
与 Fork 源项目一致
从无法访问的项目Fork
通知
7
Star
4
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
milvus
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
3d411fba
编写于
8月 24, 2019
作者:
W
wxyu
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
MS-414 Add TaskType in Scheduler::Task
Former-commit-id: 3c53eb8285f4572e07d63234d12ae3595cb5885e
上级
35fe00ff
变更
6
隐藏空白更改
内联
并排
Showing
6 changed file
with
20 addition
and
5 deletion
+20
-5
cpp/CHANGELOG.md
cpp/CHANGELOG.md
+1
-0
cpp/src/scheduler/task/DeleteTask.cpp
cpp/src/scheduler/task/DeleteTask.cpp
+1
-1
cpp/src/scheduler/task/SearchTask.cpp
cpp/src/scheduler/task/SearchTask.cpp
+3
-2
cpp/src/scheduler/task/Task.h
cpp/src/scheduler/task/Task.h
+12
-1
cpp/src/scheduler/task/TestTask.cpp
cpp/src/scheduler/task/TestTask.cpp
+2
-0
cpp/src/scheduler/task/TestTask.h
cpp/src/scheduler/task/TestTask.h
+1
-1
未找到文件。
cpp/CHANGELOG.md
浏览文件 @
3d411fba
...
...
@@ -50,6 +50,7 @@ Please mark all change in change log and use the ticket from JIRA.
-
MS-408 - Add device_id in resource construct function
-
MS-409 - Using new scheduler
-
MS-410 - Add resource config comment
-
MS-414 - Add TaskType in Scheduler::Task
## New Feature
-
MS-343 - Implement ResourceMgr
...
...
cpp/src/scheduler/task/DeleteTask.cpp
浏览文件 @
3d411fba
...
...
@@ -12,7 +12,7 @@ namespace milvus {
namespace
engine
{
XDeleteTask
::
XDeleteTask
(
DeleteContextPtr
&
delete_context
)
:
delete_context_ptr_
(
delete_context
)
{}
:
Task
(
TaskType
::
DeleteTask
),
delete_context_ptr_
(
delete_context
)
{}
void
XDeleteTask
::
Load
(
LoadType
type
,
uint8_t
device_id
)
{
...
...
cpp/src/scheduler/task/SearchTask.cpp
浏览文件 @
3d411fba
...
...
@@ -81,11 +81,12 @@ CollectFileMetrics(int file_type, size_t file_size) {
}
}
XSearchTask
::
XSearchTask
(
TableFileSchemaPtr
file
)
:
file_
(
file
)
{
XSearchTask
::
XSearchTask
(
TableFileSchemaPtr
file
)
:
Task
(
TaskType
::
SearchTask
),
file_
(
file
)
{
index_engine_
=
EngineFactory
::
Build
(
file_
->
dimension_
,
file_
->
location_
,
(
EngineType
)
file_
->
engine_type_
,
(
MetricType
)
file_
->
metric_type_
,
(
MetricType
)
file_
->
metric_type_
,
file_
->
nlist_
);
}
...
...
cpp/src/scheduler/task/Task.h
浏览文件 @
3d411fba
...
...
@@ -21,13 +21,20 @@ enum class LoadType {
GPU2CPU
,
};
enum
class
TaskType
{
SearchTask
,
DeleteTask
,
TestTask
,
};
class
Task
;
using
TaskPtr
=
std
::
shared_ptr
<
Task
>
;
class
Task
{
public:
Task
()
=
default
;
explicit
Task
(
TaskType
type
)
:
type_
(
type
)
{}
virtual
void
Load
(
LoadType
type
,
uint8_t
device_id
)
=
0
;
...
...
@@ -39,9 +46,13 @@ public:
virtual
TaskPtr
Clone
()
=
0
;
inline
TaskType
Type
()
const
{
return
type_
;
}
public:
std
::
vector
<
SearchContextPtr
>
search_contexts_
;
ScheduleTaskPtr
task_
;
TaskType
type_
;
};
...
...
cpp/src/scheduler/task/TestTask.cpp
浏览文件 @
3d411fba
...
...
@@ -11,6 +11,8 @@ namespace zilliz {
namespace
milvus
{
namespace
engine
{
TestTask
::
TestTask
()
:
Task
(
TaskType
::
TestTask
)
{}
void
TestTask
::
Load
(
LoadType
type
,
uint8_t
device_id
)
{
load_count_
++
;
...
...
cpp/src/scheduler/task/TestTask.h
浏览文件 @
3d411fba
...
...
@@ -14,7 +14,7 @@ namespace engine {
class
TestTask
:
public
Task
{
public:
TestTask
()
=
default
;
TestTask
();
public:
void
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录