- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 198 for pointerId (0.17 sec)
-
cmd/peer-s3-client.go
} buckets := make([]BucketInfo, 0, len(bi.Value())) for _, b := range bi.Value() { if b != nil { buckets = append(buckets, *b) } } bi.Recycle() // BucketInfo has no internal pointers, so it's safe to recycle. return buckets, nil } func (client *remotePeerS3Client) HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error) { conn := client.gridConn()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 15.4K bytes - Viewed (0) -
internal/grid/handlers.go
//nolint:staticcheck // SA6002 IT IS A GENERIC VALUE! (and always a pointer) h.reqPool.Put(r) } } // PutResponse will accept a response for reuse. // These should be returned by the caller. func (h *StreamTypeHandler[Payload, Req, Resp]) PutResponse(r Resp) { if r != h.nilResp { //nolint:staticcheck // SA6002 IT IS A GENERIC VALUE! (and always a pointer) h.respPool.Put(r) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 27.7K bytes - Viewed (0) -
src/main/webapp/js/profile.js
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Wed Sep 12 06:47:49 UTC 2018 - 1.3K bytes - Viewed (0) -
api/go1.19.txt
pkg sync/atomic, method (*Int64) Store(int64) #50860 pkg sync/atomic, method (*Int64) Swap(int64) int64 #50860 pkg sync/atomic, method (*Pointer[$0]) CompareAndSwap(*$0, *$0) bool #50860 pkg sync/atomic, method (*Pointer[$0]) Load() *$0 #50860 pkg sync/atomic, method (*Pointer[$0]) Store(*$0) #50860 pkg sync/atomic, method (*Pointer[$0]) Swap(*$0) *$0 #50860 pkg sync/atomic, method (*Uint32) Add(uint32) uint32 #50860
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Dec 02 16:29:41 UTC 2022 - 17.9K bytes - Viewed (0) -
cmd/data-scanner-metric.go
func (p *scannerMetrics) currentPathUpdater(disk, initial string) (update func(path string), done func()) { initialPtr := unsafe.Pointer(&initial) tracker := ¤tPathTracker{ name: &initialPtr, } p.currentPaths.Store(disk, tracker) return func(path string) { atomic.StorePointer(tracker.name, unsafe.Pointer(&path)) }, func() { p.currentPaths.Delete(disk) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 9.1K bytes - Viewed (0) -
istioctl/pkg/multicluster/options.go
Namespace string } // Inherit the common kubernetes flags defined in the root package. This is a bit of a hack, // but it allows us to directly get the final values for each of these flags without needing // to pass pointers-to-flags through all of the (sub)commands. func (o *KubeOptions) prepare(ctx cli.Context) { o.Namespace = ctx.Namespace() if o.Namespace == "" { o.Namespace = ctx.IstioNamespace()
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Aug 01 23:59:49 UTC 2023 - 1.6K bytes - Viewed (0) -
src/main/java/jcifs/pac/PacDataInputStream.java
short length = readShort(); short maxLength = readShort(); int pointer = readInt(); if ( maxLength < length ) { throw new PACDecodingException("Malformed string in PAC"); } return new PacUnicodeString(length, maxLength, pointer); } public String readString () throws IOException, PACDecodingException {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sat Jul 21 21:19:58 UTC 2018 - 5.1K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
func (r *RingBuffer) WriteString(s string) (n int, err error) { x := (*[2]uintptr)(unsafe.Pointer(&s)) h := [3]uintptr{x[0], x[1], x[1]} buf := *(*[]byte)(unsafe.Pointer(&h)) return r.Write(buf) } // Bytes returns all available read bytes. // It does not move the read pointer and only copy the available data. // If the dst is big enough it will be used as destination,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
schema/schema_test.go
} } func TestParseSchemaWithPointerFields(t *testing.T) { user, err := schema.Parse(&User{}, &sync.Map{}, schema.NamingStrategy{}) if err != nil { t.Fatalf("failed to parse pointer user, got error %v", err) } checkUserSchema(t, user) } func checkUserSchema(t *testing.T, user *schema.Schema) { // check schema
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Jun 20 12:19:31 UTC 2024 - 13.3K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/ndr/NdrException.java
@SuppressWarnings ( "javadoc" ) public class NdrException extends CIFSException { /** * */ private static final long serialVersionUID = 7621650016319792189L; public static final String NO_NULL_REF = "ref pointer cannot be null"; public static final String INVALID_CONFORMANCE = "invalid array conformance"; public NdrException ( String msg ) { super(msg); }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 1.3K bytes - Viewed (0)