Browse Source

*: update

pull/279/head
tnextday 10 years ago
parent
commit
67518171db
  1. 10
      go/storage/store_task.go
  2. 4
      go/storage/store_task_cli.go

10
go/storage/store_task.go

@ -8,12 +8,10 @@ import (
"github.com/chrislusf/seaweedfs/go/glog" "github.com/chrislusf/seaweedfs/go/glog"
) )
type TaskType string
const ( const (
TaskVacuum TaskType = "VACUUM"
TaskReplica TaskType = "REPLICA"
TaskBalance TaskType = "BALANCE"
TaskVacuum = "VACUUM"
TaskReplica = "REPLICA"
TaskBalance = "BALANCE"
) )
var ( var (
@ -87,7 +85,7 @@ func (tm *TaskManager) NewTask(s *Store, args url.Values) (tid string, e error)
return tid, ErrTaskExists return tid, ErrTaskExists
} }
var tw TaskWorker var tw TaskWorker
switch TaskType(tt) {
switch tt {
case TaskVacuum: case TaskVacuum:
tw, e = NewVacuumTask(s, args) tw, e = NewVacuumTask(s, args)
case TaskReplica: case TaskReplica:

4
go/storage/store_task_cli.go

@ -20,9 +20,9 @@ type TaskCli struct {
DataNode string DataNode string
} }
func NewTaskCli(dataNode string, task TaskType, params TaskParams) (*TaskCli, error) {
func NewTaskCli(dataNode string, task string, params TaskParams) (*TaskCli, error) {
args := url.Values{} args := url.Values{}
args.Set("task", string(task))
args.Set("task", task)
for k, v := range params { for k, v := range params {
args.Set(k, v) args.Set(k, v)
} }

Loading…
Cancel
Save