- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 375 for initiatives (0.16 sec)
-
internal/lsync/lrwmutex.go
type LRWMutex struct { id string source string isWriteLock bool ref int mu sync.Mutex // Mutex to prevent multiple simultaneous locks } // NewLRWMutex - initializes a new lsync RW mutex. func NewLRWMutex() *LRWMutex { return &LRWMutex{} } // Lock holds a write lock on lm. // // If the lock is already in use, the calling go routine // blocks until the mutex is available.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 4.8K bytes - Viewed (0) -
pilot/pkg/bootstrap/istio_ca.go
log.Infof("failed to add cacerts file watcher for %s: %v", dir, err) return err } log.Infof("Added cacerts files watcher at %v", dir) return nil } // initCACertsWatcher initializes the cacerts (/etc/cacerts) directory. // In particular it monitors 'ca-key.pem', 'ca-cert.pem', 'root-cert.pem' // and 'cert-chain.pem'. func (s *Server) initCACertsWatcher() { var err error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 20.6K bytes - Viewed (0) -
src/vendor/golang.org/x/text/unicode/norm/iter.go
asciiF iterFunc p int // current position in input source multiSeg []byte // remainder of multi-segment decomposition } type iterFunc func(*Iter) []byte // Init initializes i to iterate over src after normalizing it to Form f. func (i *Iter) Init(f Form, src []byte) { i.p = 0 if len(src) == 0 { i.setDone() i.rb.nsrc = 0 return } i.multiSeg = nil i.rb.init(f, src)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 19:27:51 UTC 2019 - 11K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/imagelocality/image_locality.go
return score, nil } // ScoreExtensions of the Score plugin. func (pl *ImageLocality) ScoreExtensions() framework.ScoreExtensions { return nil } // New initializes a new plugin and returns it. func New(_ context.Context, _ runtime.Object, h framework.Handle) (framework.Plugin, error) { return &ImageLocality{handle: h}, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 06:17:57 UTC 2024 - 5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
/** * A helper which does some thread-safe operations for aggregate futures, which must be implemented * differently in GWT. Namely: * * <ul> * <li>Lazily initializes a set of seen exceptions * <li>Decrements a counter atomically * </ul> */ @GwtCompatible(emulated = true) @ReflectionSupport(value = ReflectionSupport.Level.FULL) @ElementTypesAreNonnullByDefault
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
test/noinit.go
var pt0 = &T{} var pt0a = &T{0, 0} var pt0b = &T{X: 0} var pt1 = &T{X: 1, Y: 2} var pt1a = &T{3, 4} // The checks similar to // var copy_bx = bx // are commented out. The compiler no longer statically initializes them. // See issue 7665 and https://codereview.appspot.com/93200044. // If https://codereview.appspot.com/169040043 is submitted, and this // test is changed to pass -complete to the compiler, then we can
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 14 17:57:36 UTC 2023 - 6.8K bytes - Viewed (0) -
cmd/event-notification.go
} // Targets returns all the registered targets func (evnot *EventNotifier) Targets() []event.Target { return evnot.targetList.Targets() } // InitBucketTargets - initializes event notification system from notification.xml of all buckets. func (evnot *EventNotifier) InitBucketTargets(ctx context.Context, objAPI ObjectLayer) error { if objAPI == nil { return errServerNotInitialized }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/stablehlo/cc/saved_model_export_test.cc
StrEq("arg_0:0")); } TEST_F(ConvertMlirModuleToExportedModelTest, InitNodeNameSetToLocOfControlOutput) { // Define a module that initializes a tf.HashTableV2 whose control output node // for the initialization is named "init_op_init_all_tables". mlir::OwningOpRef<mlir::ModuleOp> module_op = ParseModuleOpString(R"mlir(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Mar 20 11:11:25 UTC 2024 - 19.6K bytes - Viewed (0) -
internal/config/policy/plugin/config.go
AuthToken: getCfg(AuthToken), Transport: transport, CloseRespFn: closeRespFn, } if err = args.Validate(); err != nil { return args, err } return args, nil } // New - initializes Authorization Management Plugin. func New(args Args) *AuthZPlugin { if args.URL == nil || args.URL.Scheme == "" && args.AuthToken == "" { return nil } return &AuthZPlugin{ args: args,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (1) -
tensorflow/c/experimental/stream_executor/stream_executor.h
int64_t* total); /*** STREAM CALLBACKS ***/ // Creates SP_Stream. This call should also allocate stream // resources on the underlying platform and initializes its // internals. void (*create_stream)(const SP_Device* device, SP_Stream* stream, TF_Status* status); // Destroys SP_Stream and deallocates any underlying resources.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 24 08:40:35 UTC 2022 - 21.6K bytes - Viewed (0)