- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 4,605 for statx (0.23 sec)
-
staging/src/k8s.io/apiserver/pkg/apis/apiserver/validation/validation.go
if err != nil { allErrs = append(allErrs, err...) } else if compilationResult != nil && structuredAuthnFeatureEnabled { state.usesEmailClaim = state.usesEmailClaim || usesEmailClaim(compilationResult.AST) state.usesEmailVerifiedClaim = state.usesEmailVerifiedClaim || usesEmailVerifiedClaim(compilationResult.AST) state.mapper.Username = authenticationcel.NewClaimsMapper([]authenticationcel.CompilationResult{*compilationResult}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 31.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/changedetection/state/CachingFileHasher.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.api.internal.changedetection.state; import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Objects; import org.gradle.api.internal.cache.StringInterner; import org.gradle.cache.IndexedCache;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 10 13:47:15 UTC 2023 - 5.3K bytes - Viewed (0) -
pkg/kubelet/cm/qos_container_manager_linux.go
} m.getNodeAllocatable = getNodeAllocatable m.activePods = activePods // update qos cgroup tiers on startup and in periodic intervals // to ensure desired state is in sync with actual state. go wait.Until(func() { err := m.UpdateCgroups() if err != nil { klog.InfoS("Failed to reserve QoS requests", "err", err) } }, periodicQOSCgroupUpdateInterval, wait.NeverStop)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 20:42:59 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager.go
// TODO: Until the bug - https://github.com/golang/go/issues/33357 is fixed, os.stat wouldn't return the // right mode(socket) on windows. Hence deleting the file, without checking whether // its a socket, on windows. stat, err := os.Lstat(filePath) if err != nil { klog.ErrorS(err, "Failed to stat file", "path", filePath) continue } if stat.IsDir() { continue } err = os.RemoveAll(filePath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
boolean isRunning(); /** Returns the lifecycle state of the service. */ State state(); /** * If the service is {@linkplain State#STARTING starting} or {@linkplain State#RUNNING running}, * this initiates service shutdown and returns immediately. If the service is {@linkplain * State#NEW new}, it is {@linkplain State#TERMINATED terminated} without having been started nor
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K bytes - Viewed (0) -
src/testing/fstest/testfs.go
t.errorf("%s: mismatch:\n\tentry.Info() = %s\n\tfile.Stat() = %s\n", path, feinfo, finfo) } } // Stat should be the same as Open+Stat, even for symlinks. info2, err := fs.Stat(t.fsys, path) if err != nil { t.errorf("%s: fs.Stat: %w", path, err) return } finfo2 := formatInfo(info2) if finfo2 != finfo { t.errorf("%s: fs.Stat(...) = %s\n\twant %s", path, finfo2, finfo) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 16.3K bytes - Viewed (0) -
src/vendor/golang.org/x/crypto/chacha20poly1305/chacha20poly1305_amd64.go
) // setupState writes a ChaCha20 input matrix to state. See // https://tools.ietf.org/html/rfc7539#section-2.3. func setupState(state *[16]uint32, key *[32]byte, nonce []byte) { state[0] = 0x61707865 state[1] = 0x3320646e state[2] = 0x79622d32 state[3] = 0x6b206574 state[4] = binary.LittleEndian.Uint32(key[0:4]) state[5] = binary.LittleEndian.Uint32(key[4:8]) state[6] = binary.LittleEndian.Uint32(key[8:12])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 2.4K bytes - Viewed (0) -
internal/grid/grid_test.go
runtime.Gosched() stats := c.Stats() if stats.IncomingStreams != 0 { if i > 0 { time.Sleep(100 * time.Millisecond) continue } var found []uint64 c.inStream.Range(func(key uint64, value *muxServer) bool { found = append(found, key) return true }) t.Errorf("expected no active streams, got %d incoming: %v", stats.IncomingStreams, found) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
src/encoding/gob/dec_helpers.go
} real := float64FromBits(state.decodeUint()) imag := float64FromBits(state.decodeUint()) slice[i] = complex(real, imag) } return true } func decFloat32Array(state *decoderState, v reflect.Value, length int, ovfl error) bool { // Can only slice if it is addressable. if !v.CanAddr() { return false } return decFloat32Slice(state, v.Slice(0, v.Len()), length, ovfl) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 24 19:28:46 UTC 2023 - 15.4K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager_test.go
return string(policyTypeMock) } func (p *mockPolicy) Start(s state.State) error { return p.err } func (p *mockPolicy) Allocate(s state.State, pod *v1.Pod, container *v1.Container) error { return p.err } func (p *mockPolicy) RemoveContainer(s state.State, podUID string, containerName string) { }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 05 13:01:40 UTC 2023 - 70.2K bytes - Viewed (0)