- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for subSys (0.18 sec)
-
cmd/license-update.go
return } if result.Dynamic { if err := applyDynamicConfigForSubSys(GlobalContext, objectAPI, result.Cfg, result.SubSys); err != nil { subnetLogIf(ctx, fmt.Errorf("error applying subnet dynamic config: %w", err)) return } globalNotificationSys.SignalConfigReload(result.SubSys) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
internal/config/lambda/parse.go
func TestSubSysLambdaTargets(ctx context.Context, cfg config.Config, subSys string, transport *http.Transport) error { if err := checkValidLambdaKeysForSubSys(subSys, cfg[subSys]); err != nil { return err } targetList, err := fetchSubSysTargets(ctx, cfg, subSys, transport) if err != nil { return err } for _, target := range targetList { defer target.Close() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
src/packaging/rpm/init.d/fess
export FESS_CONF_PATH export FESS_VAR_PATH export FESS_DICTIONARY_PATH export FESS_HEAP_SIZE export SEARCH_ENGINE_HOME export SEARCH_ENGINE_HTTP_URL export FESS_JAVA_OPTS export JAVA_HOME lockfile=/var/lock/subsys/$prog # backwards compatibility for old config sysconfig files, pre 0.90.1 if [ -n $USER ] && [ -z $FESS_USER ] ; then FESS_USER=$USER fi checkJava() { if [ -x "$JAVA_HOME/bin/java" ]; then
Shell Script - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sun Jan 15 06:32:15 GMT 2023 - 3.7K bytes - Viewed (1) -
cni/pkg/nodeagent/fakes_test.go
func (f *fakeNs) Close() error { f.closed.Store(true) return nil } func fakeFs() fs.FS { subFs, err := fs.Sub(fakeProc, "testdata") if err != nil { panic(err) } subFs, err = fs.Sub(subFs, "cgroupns") if err != nil { panic(err) } return &fakeFsWithFakeFds{ReadDirFS: subFs.(fs.ReadDirFS)} } type fakeFsWithFakeFds struct { fs.ReadDirFS } type fakeFileFakeFds struct { fs.File
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/pubsub/pubsub.go
if wg != nil { wg.Done() } // Clean up and de-register the subscriber ps.Lock() defer ps.Unlock() var remainTypes Mask for i, s := range ps.subs { if s == sub { ps.subs = append(ps.subs[:i], ps.subs[i+1:]...) } else { remainTypes.Merge(s.types) } } atomic.StoreUint64(&ps.types, uint64(remainTypes)) atomic.AddInt32(&ps.numSubscribers, -1) }()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
t.Fatalf("unexpected error: %v", err) } if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil { t.Fatalf("unexpected error: %v", err) } ps.Lock() defer ps.Unlock() if len(ps.subs) != 2 || ps.NumSubscribers(MaskAll) != 2 || ps.Subscribers() != 2 { t.Fatalf("expected 2 subscribers") } } func TestNumSubscribersMask(t *testing.T) { ps := New[Maskable, Mask](2) ch1 := make(chan Maskable, 1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.8K bytes - Viewed (0)