spdf/elektron
Archived
1
0
Fork 0
Code Issues 4 Pull requests 1 Projects Releases Packages Wiki Activity

Added the ability to prefix a pcplog

Browse source
This commit is contained in:
Renan DelValle 2016-09-27 20:22:07 -04:00
parent 23d7014cfe
commit 52d012a7ee
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
scheduler.go
View file

@ -286,12 +286,14 @@ func (s *electronScheduler) Error(_ sched.SchedulerDriver, err string) {
var master = flag.String("master", "xavier:5050", "Location of leading Mesos master") var master = flag.String("master", "xavier:5050", "Location of leading Mesos master")
var tasksFile = flag.String("workload", "", "JSON file containing task definitions") var tasksFile = flag.String("workload", "", "JSON file containing task definitions")
var ignoreWatts = flag.Bool("ignoreWatts", false, "Ignore watts in offers") var ignoreWatts = flag.Bool("ignoreWatts", false, "Ignore watts in offers")
var pcplogPrefix = flag.String("logPrefix", "", "Prefix for pcplog")
// Short hand args // Short hand args
func init(){ func init(){
flag.StringVar(master, "m", "xavier:5050", "Location of leading Mesos master (shorthand)") flag.StringVar(master, "m", "xavier:5050", "Location of leading Mesos master (shorthand)")
flag.StringVar(tasksFile, "w", "", "JSON file containing task definitions (shorthand)") flag.StringVar(tasksFile, "w", "", "JSON file containing task definitions (shorthand)")
flag.BoolVar(ignoreWatts, "i", false, "Ignore watts in offers (shorthand)") flag.BoolVar(ignoreWatts, "i", false, "Ignore watts in offers (shorthand)")
flag.StringVar(pcplogPrefix, "p", "", "Prefix for pcplog")
} }
func main() { func main() {
@ -329,7 +331,7 @@ func main() {
return return
} }
go pcp.Start(scheduler.pcpLog, &scheduler.recordPCP) go pcp.Start(scheduler.pcpLog, &scheduler.recordPCP, *pcplogPrefix)
time.Sleep(1 * time.Second) time.Sleep(1 * time.Second)
// Catch interrupt // Catch interrupt