- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 121 for idempotent (0.28 sec)
-
cni/pkg/iptables/iptables_test.go
if err != nil { t.Fatal(err) } compareToGolden(t, false, tt.name, ext.ExecutedAll) *ext = dep.DependenciesStub{} // run another time to make sure we are idempotent err = iptConfigurator.CreateInpodRules(&probeSNATipv4, &probeSNATipv6) if err != nil { t.Fatal(err) } compareToGolden(t, false, tt.name, ext.ExecutedAll) } func ipstr(ipv6 bool) string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 20:16:04 UTC 2024 - 3.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/upload/findwork.go
} // find all the files that look like counter files or reports // that need to be uploaded. (There may be unexpected leftover files // and uploading is supposed to be idempotent.) func (u *uploader) findWork() work { localdir, uploaddir := u.dir.LocalDir(), u.dir.UploadDir() var ans work fis, err := os.ReadDir(localdir) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 21:12:15 UTC 2024 - 3.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/ir/tf_traits.h
return {}; } } // namespace detail // This class adds property that the operation is idempotent. // This means a unary to unary operation "f" that satisfies f(f(x)) = f(x), // or a binary operation "g" that satisfies g(x, x) = x. template <typename ConcreteType> class IsIdempotent : public TraitBase<ConcreteType, IsIdempotent> { public: static LogicalResult verifyTrait(Operation* op) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 12.7K bytes - Viewed (0) -
src/internal/runtime/atomic/atomic_wasm.go
//go:noinline func And8(ptr *uint8, val uint8) { *ptr = *ptr & val } //go:nosplit //go:noinline func Or8(ptr *uint8, val uint8) { *ptr = *ptr | val } // NOTE: Do not add atomicxor8 (XOR is not idempotent). //go:nosplit //go:noinline func And(ptr *uint32, val uint32) { *ptr = *ptr & val } //go:nosplit //go:noinline func Or(ptr *uint32, val uint32) { *ptr = *ptr | val }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 5.4K bytes - Viewed (0) -
src/net/http/httputil/persist.go
r := sc.r lastbody := sc.lastbody sc.lastbody = nil sc.mu.Unlock() // Make sure body is fully consumed, even if user does not call body.Close if lastbody != nil { // body.Close is assumed to be idempotent and multiple calls to // it should return the error that its first invocation // returned. err = lastbody.Close() if err != nil { sc.mu.Lock() defer sc.mu.Unlock() sc.re = err
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
* note that the execution order of all listeners is ultimately chosen by the implementations of * the supplied executors. * * <p>This method is idempotent. Calling it several times in parallel is semantically equivalent * to calling it exactly once. * * @since 10.0 (present in 1.0 as {@code run}) */ public void execute() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionList.java
* note that the execution order of all listeners is ultimately chosen by the implementations of * the supplied executors. * * <p>This method is idempotent. Calling it several times in parallel is semantically equivalent * to calling it exactly once. * * @since 10.0 (present in 1.0 as {@code run}) */ public void execute() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/volume/downwardapi/downwardapi.go
return volume.Attributes{ ReadOnly: true, Managed: true, SELinuxRelabel: true, } } // SetUp puts in place the volume plugin. // This function is not idempotent by design. We want the data to be refreshed periodically. // The internal sync interval of kubelet will drive the refresh of data. // TODO: Add volume specific ticker and refresh loop
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir.go
if ed.mounter == nil { return fmt.Errorf("memory storage requested, but mounter is nil") } if err := ed.setupDir(dir); err != nil { return err } // Make SetUp idempotent. medium, isMnt, _, err := ed.mountDetector.GetMountMedium(dir, ed.medium) if err != nil { return err } // If the directory is a mountpoint with medium memory, there is no
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
log.Debugf("ignoring error deleting optional iptables rule: %v", err) } } } return errors.Join(delErrs...) } // Setup iptables rules for in-pod mode. Ideally this should be an idempotent function. // NOTE that this expects to be run from within the pod network namespace! func (cfg *IptablesConfigurator) CreateInpodRules(hostProbeSNAT, hostProbeV6SNAT *netip.Addr) error { // Append our rules here
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 19.9K bytes - Viewed (0)