- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 368 for unmix (0.06 sec)
-
src/os/file_unix.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build unix || (js && wasm) || wasip1 package os import ( "internal/poll" "internal/syscall/unix" "io/fs" "runtime" "sync/atomic" "syscall" _ "unsafe" // for go:linkname ) const _UTIME_OMIT = unix.UTIME_OMIT // fixLongPath is a noop on non-Windows platforms. func fixLongPath(path string) string {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 13:52:34 UTC 2024 - 14.9K bytes - Viewed (0) -
src/time/zoneinfo_test.go
if err != nil { t.Fatal(err) } s := time.Unix(test.unix, 0).In(z).Format(format) if s != test.want1 { t.Errorf("for %s %d got %q want %q", test.zone, test.unix, s, test.want1) } s = time.Unix(test.unix+1, 0).In(z).Format(format) if s != test.want2 { t.Errorf("for %s %d got %q want %q", test.zone, test.unix, s, test.want2) } } } func TestLocationNames(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 13 17:06:56 UTC 2023 - 9.9K bytes - Viewed (0) -
pkg/volume/util/hostutil/hostutil_linux.go
return false, nil } fd, errno := unix.Open(pathname, unix.O_RDONLY|unix.O_EXCL|unix.O_CLOEXEC, 0) // If the device is in use, open will return an invalid fd. // When this happens, it is expected that Close will fail and throw an error. defer unix.Close(fd) if errno == nil { // device not in use return false, nil } else if errno == unix.EBUSY { // device is in use return true, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 23 08:36:44 UTC 2023 - 10K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
// limitations under the License. package nodeagent import ( "context" "errors" "net/netip" "runtime" "sync/atomic" "testing" "time" "golang.org/x/sys/unix" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/intstr" "istio.io/istio/cni/pkg/ipset" "istio.io/istio/cni/pkg/iptables"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
src/os/readfrom_linux_test.go
}) } }) t.Run("Basic-Unix", func(t *testing.T) { for _, size := range sizes { t.Run(strconv.Itoa(size), func(t *testing.T) { testSpliceFile(t, "unix", int64(size), -1) }) } }) t.Run("TCP-To-TTY", func(t *testing.T) { testSpliceToTTY(t, "tcp", 32768) }) t.Run("Unix-To-TTY", func(t *testing.T) { testSpliceToTTY(t, "unix", 32768) }) t.Run("Limited", func(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 20.3K bytes - Viewed (0) -
src/internal/poll/fd_unix.go
// Copyright 2017 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build unix || (js && wasm) || wasip1 package poll import ( "internal/itoa" "internal/syscall/unix" "io" "sync/atomic" "syscall" ) // FD is a file descriptor. The net and os packages use this type as a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 04:09:44 UTC 2024 - 17.9K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime_test.go
}, { name: "One valid CRI socket leads to success", existingSockets: []string{"unix:///foo/bar.sock"}, expectedError: false, expectedSocket: "unix:///foo/bar.sock", }, { name: "Multiple CRI sockets lead to an error", existingSockets: []string{ "unix:///foo/bar.sock", "unix:///foo/baz.sock", }, expectedError: true, }, } for _, test := range tests {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/bucket-stats.go
func (l *ReplicationLastHour) addsize(sz int64) { min := time.Now().Unix() / 60 l.forwardTo(min) winIdx := min % 60 l.Totals[winIdx].merge(AccElem{Total: min, Size: sz, N: 1}) l.LastMin = min } // Merge all recorded counts of last hour into one func (l *ReplicationLastHour) getTotal() AccElem { var res AccElem min := time.Now().Unix() / 60 l.forwardTo(min) for _, elem := range l.Totals[:] {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider.go
StartTime: metav1.NewTime(time.Unix(0, container.CreatedAt)), CPU: &statsapi.CPUStats{}, Memory: &statsapi.MemoryStats{}, Rootfs: &statsapi.FsStats{}, Swap: &statsapi.SwapStats{}, // UserDefinedMetrics is not supported by CRI. } if stats.Cpu != nil { result.CPU.Time = metav1.NewTime(time.Unix(0, stats.Cpu.Timestamp)) if stats.Cpu.UsageCoreNanoSeconds != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 35.1K bytes - Viewed (0) -
pkg/controller/nodelifecycle/scheduler/rate_limited_queue_test.go
case "first": if !value.AddedAt.Equal(time.Unix(0, time.Millisecond.Nanoseconds())) { t.Fatalf("added time for %s is %v", value.Value, value.AddedAt) } case "second": if !value.AddedAt.Equal(time.Unix(0, 2*time.Millisecond.Nanoseconds())) { t.Fatalf("added time for %s is %v", value.Value, value.AddedAt) } if hasQueued { if !value.ProcessAt.Equal(time.Unix(0, 6*time.Millisecond.Nanoseconds())) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 17:40:33 UTC 2023 - 10K bytes - Viewed (0)