- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 267 for index (0.15 sec)
-
internal/dsync/drwmutex.go
if ok { netLockCtx = context.WithValue(netLockCtx, mcontext.ContextTraceKey, tc) } for index, c := range restClnts { wg.Add(1) // broadcast lock request to all nodes go func(index int, isReadLock bool, c NetLocker) { defer wg.Done() g := Granted{index: index} if c == nil { log("dsync: nil locker\n") ch <- g return } var locked bool
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
src/encoding/json/encode.go
tag := sf.Tag.Get("json") if tag == "-" { continue } name, opts := parseTag(tag) if !isValidTag(name) { name = "" } index := make([]int, len(f.index)+1) copy(index, f.index) index[len(f.index)] = i ft := sf.Type if ft.Name() == "" && ft.Kind() == reflect.Pointer { // Follow pointer. ft = ft.Elem() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:55 UTC 2024 - 36.2K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager.go
} _, err = m.parseUserNsFileAndRecord(pod, content) return err } // isSet checks if the specified index is already set. func (m *UsernsManager) isSet(v uint32) bool { index := int(v/userNsLength) - m.off if index < 0 || index >= m.len { return true } return m.used.Has(index) } // allocateOne finds a free user namespace and allocate it to the specified pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
src/runtime/syscall_windows.go
} key := winCallbackKey{(*funcval)(fn.data), cdecl} cbsLock() // Check if this callback is already registered. if n, ok := cbs.index[key]; ok { cbsUnlock() return callbackasmAddr(n) } // Register the callback. if cbs.index == nil { cbs.index = make(map[winCallbackKey]int) } n := cbs.n if n >= len(cbs.ctxt) { cbsUnlock() throw("too many callback functions") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:12:46 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
if err != nil { return err } bucketMetas[index] = meta return nil }, index) } errs := g.Wait() for index, err := range errs { if err != nil { internalLogOnceIf(ctx, fmt.Errorf("Unable to load bucket metadata, will be retried: %w", err), "load-bucket-metadata-"+buckets[index].Name, logger.WarningKind) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.8K bytes - Viewed (0) -
callbacks/preload.go
tx.AddError(rel.Field.Set(tx.Statement.Context, reflectValue.Index(i), reflect.MakeSlice(rel.Field.IndirectFieldType, 0, 10).Interface())) default: tx.AddError(rel.Field.Set(tx.Statement.Context, reflectValue.Index(i), reflect.New(rel.Field.FieldType).Interface())) } } } for i := 0; i < reflectResults.Len(); i++ { elem := reflectResults.Index(i) for idx, field := range relForeignFields {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 10:52:33 UTC 2024 - 11.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
log.Warnf("Registry list is empty, nothing to delete") return } index, ok := c.getRegistryIndex(clusterID, providerID) if !ok { log.Warnf("Registry %s/%s is not found in the registries list, nothing to delete", providerID, clusterID) return } c.registries[index] = nil c.registries = append(c.registries[:index], c.registries[index+1:]...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
src/cmd/compile/internal/types2/check_test.go
} // len(indices) > 0 // If there are multiple matching errors, select the one with the closest column position. index := -1 // index of matching error var delta uint for _, i := range indices { if d := absDiff(gotPos.Col(), errList[i].Pos.Col()); index < 0 || d < delta { index, delta = i, d } } // The closest column position must be within expected colDelta. if delta > colDelta {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 19:45:33 UTC 2024 - 13.8K bytes - Viewed (0) -
src/runtime/mpallocbits.go
} // find searches for npages contiguous free pages in pallocBits and returns // the index where that run starts, as well as the index of the first free page // it found in the search. searchIdx represents the first known free page and // where to begin the next search from. // // If find fails to find any free space, it returns an index of ^uint(0) and // the new searchIdx should be ignored. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 18 15:13:43 UTC 2024 - 12.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/mod/sumdb/tlog/tile.go
// and least width storing the given hash storage index. // // If h ≤ 0, [TileForIndex] panics. func TileForIndex(h int, index int64) Tile { if h <= 0 { panic(fmt.Sprintf("TileForIndex: invalid height %d", h)) } t, _, _ := tileForIndex(h, index) return t } // tileForIndex returns the tile of height h ≥ 1 // storing the given hash index, which can be // reconstructed using tileHash(data[start:end]).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 13K bytes - Viewed (0)