X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=js.go;h=1f2ec3985a463333781e738b291bcc00ab4d5e70;hb=bf96757828d2ae663f5f54147c0e229f74fc9357;hp=1e452ee51a02725bcae747bdc501b72d3fffe52b;hpb=c41fe0fbd726f397636b569161f286821e221885;p=goredo.git diff --git a/js.go b/js.go index 1e452ee..1f2ec39 100644 --- a/js.go +++ b/js.go @@ -24,11 +24,9 @@ import ( "fmt" "log" "os" - "os/signal" "regexp" "strconv" "sync" - "syscall" ) const ( @@ -39,7 +37,7 @@ const ( EnvJSToken = "REDO_JS_TOKEN" EnvMake = "REDO_MAKE" - MakeTypeNone = "none" + MakeTypeNone = "none" MakeTypeBmake = "bmake" MakeTypeGmake = "gmake" ) @@ -69,9 +67,18 @@ var ( jsTokens map[byte]int jsTokensM sync.Mutex - flagJobs = flag.Int("j", -1, fmt.Sprintf("number of parallel jobs (0=inf, <0=1) (%s)", EnvJobs)) + flagJobs *int ) +func init() { + cmdName := CmdName() + if !(cmdName == CmdNameRedo || cmdName == CmdNameRedoIfchange) { + return + } + flagJobs = flag.Int("j", -1, + fmt.Sprintf("number of parallel jobs (0=inf, <0=1) (%s)", EnvJobs)) +} + func jsStart(jobsEnv string) { jobs := uint64(1) var err error @@ -161,20 +168,6 @@ func jsInit() { jsTokens[jsToken]++ jsRelease("ifchange entered", jsToken) } - - killed := make(chan os.Signal, 0) - signal.Notify(killed, syscall.SIGTERM, syscall.SIGINT) - go func() { - <-killed - jsTokensM.Lock() - for token, i := range jsTokens { - for ; i > 0; i-- { - jsReleaseNoLock(token) - } - } - jsTokensM.Unlock() - os.Exit(1) - }() } func jsReleaseNoLock(token byte) { @@ -194,6 +187,16 @@ func jsRelease(ctx string, token byte) { jsTokensM.Unlock() } +func jsReleaseAll() { + jsTokensM.Lock() + for token, i := range jsTokens { + for ; i > 0; i-- { + jsReleaseNoLock(token) + } + } + jsTokensM.Unlock() +} + func jsAcquire(ctx string) byte { if JSR == nil { return BMakeGoodToken