diff options
| author | Dmitry Vyukov <dvyukov@google.com> | 2015-10-20 12:08:11 +0200 |
|---|---|---|
| committer | Dmitry Vyukov <dvyukov@google.com> | 2015-10-20 15:46:04 +0200 |
| commit | 304c1de38905484d6d7ae585cd9a9e97bdfaf28d (patch) | |
| tree | b0b507d58b85fe6816c78eb4fb80e832119b00fc /tools | |
| parent | a8c682fe99f6f4efbfd6f640870d956c814e26bf (diff) | |
add threaded and timeout flags to execlog
Diffstat (limited to 'tools')
| -rw-r--r-- | tools/execlog/execlog.go | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/tools/execlog/execlog.go b/tools/execlog/execlog.go index 0325f0ef0..b1ee9fba8 100644 --- a/tools/execlog/execlog.go +++ b/tools/execlog/execlog.go @@ -21,6 +21,8 @@ var ( flagExecutor = flag.String("executor", "", "path to executor binary") flagLog = flag.String("log", "", "comma-delimited list of log files to execute") flagProcs = flag.Int("procs", 1, "number of parallel processes to execute the log") + flagThreaded = flag.Bool("threaded", false, "use threaded mode in executor") + flagTimeout = flag.Duration("timeout", 5*time.Second, "execution timeout") ) func main() { @@ -63,7 +65,11 @@ func main() { var pos uint32 for p := 0; p < *flagProcs; p++ { go func() { - env, err := ipc.MakeEnv(*flagExecutor, 5*time.Second, 0) + var flags uint64 + if *flagThreaded { + flags |= ipc.FlagThreaded + } + env, err := ipc.MakeEnv(*flagExecutor, *flagTimeout, 0) if err != nil { log.Fatalf("failed to create ipc env: %v", err) } |
