- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for getp2 (0.08 sec)
-
pkg/scheduler/framework/plugins/volumebinding/assume_cache_test.go
// Get object that doesn't exist pv, err := cache.GetPV("nothere") if err == nil { t.Errorf("GetPV() returned unexpected success") } if pv != nil { t.Errorf("GetPV() returned unexpected PV %q", pv.Name) } // Add a bunch of PVs pvs := map[string]*v1.PersistentVolume{} for i := 0; i < 10; i++ { pv := makePV(fmt.Sprintf("test-pv%v", i), "").withVersion("1").PersistentVolume pvs[pv.Name] = pv
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 12.8K bytes - Viewed (0) -
src/time/zoneinfo_read.go
// 42 off[4] // 46 name[namelen] // 46+namelen+xlen+fclen - next header // if get4(buf) != zcheader { break } meth := get2(buf[10:]) size := get4(buf[24:]) namelen := get2(buf[28:]) xlen := get2(buf[30:]) fclen := get2(buf[32:]) off := get4(buf[42:]) zname := buf[46 : 46+namelen] buf = buf[46+namelen+xlen+fclen:] if string(zname) != name { continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 14.4K bytes - Viewed (0) -
operator/pkg/manifest/shared.go
ret := "" for _, sf := range setFlags { p, v := getPV(sf) if p == path { ret = v } // if set multiple times, return last set value } return ret } // getPV returns the path and value components for the given set flag string, which must be in path=value format. func getPV(setFlag string) (path string, value string) { pv := strings.Split(setFlag, "=")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 03 06:27:07 UTC 2024 - 19.7K bytes - Viewed (0) -
test/chan/powser1.go
case it = <-dat[0]: out[0] = it dat[0] = nil case it = <-dat[1]: out[1] = it dat[1] = nil } } return out } // Get one rat from each of 2 demand channels func get2(in0 *dch, in1 *dch) []rat { return getn([]*dch{in0, in1}) } func copy(in *dch, out *dch) { for { <-out.req out.dat <- get(in) } } func repeat(dat rat, out *dch) { for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 25 22:22:20 UTC 2020 - 12.7K bytes - Viewed (0) -
src/cmd/link/internal/ld/macho.go
var linkeditSeg, textSeg *macho.Segment loadOff := int64(machoHeaderSize64) get32 := mf.ByteOrder.Uint32 for _, l := range mf.Loads { data := l.Raw() cmd, sz := get32(data), get32(data[4:]) if cmd == LC_CODE_SIGNATURE { sigOff = int64(get32(data[8:])) sigSz = int64(get32(data[12:])) csCmdOff = loadOff } if seg, ok := l.(*macho.Segment); ok { switch seg.Name {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 15:32:53 UTC 2024 - 43.9K bytes - Viewed (0) -
test/chan/powser2.go
case it = <-dat[0]: out[0] = it dat[0] = nil case it = <-dat[1]: out[1] = it dat[1] = nil } } return out } // Get one item from each of 2 demand channels func get2(in0 *dch, in1 *dch) []item { return getn([]*dch{in0, in1}) } func copy(in *dch, out *dch) { for { <-out.req out.dat <- get(in) } } func repeat(dat item, out *dch) { for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 25 22:22:20 UTC 2020 - 13.3K bytes - Viewed (0) -
src/cmd/go/internal/cache/prog.go
writeMu sync.Mutex } // ProgCmd is a command that can be issued to a child process. // // If the interface needs to grow, we can add new commands or new versioned // commands like "get2". type ProgCmd string const ( cmdGet = ProgCmd("get") cmdPut = ProgCmd("put") cmdClose = ProgCmd("close") ) // ProgRequest is the JSON-encoded message that's sent from cmd/go to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 14 19:23:25 UTC 2023 - 11.8K bytes - Viewed (0) -
src/cmd/compile/internal/test/inl_test.go
"(*mspan).base", "(*mspan).markBitsForBase", "(*mspan).markBitsForIndex", "(*mspan).writeUserArenaHeapBits", "(*muintptr).set", "(*puintptr).set", "(*wbBuf).get1", "(*wbBuf).get2", // Trace-related ones. "traceLocker.ok", "traceEnabled", }, "runtime/internal/sys": {}, "runtime/internal/math": { "MulUintptr", }, "bytes": { "(*Buffer).Bytes",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 09 04:07:57 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
if len(boundClaims) == 0 { return } var errs []error for _, pvc := range boundClaims { pvName := pvc.Spec.VolumeName pv, err := b.pvCache.GetPV(pvName) if err != nil { errs = append(errs, err) continue } // if the PersistentVolume is local and has node affinity matching specific node(s), // add them to the eligible nodes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0)