- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for UInt32 (0.36 sec)
-
src/sync/atomic/doc.go
// Consider using the more ergonomic and less error-prone [Int32.And] instead. func AndInt32(addr *int32, mask int32) (old int32) // AndUint32 atomically performs a bitwise AND operation on *addr using the bitmask provided as mask // and returns the old value. // Consider using the more ergonomic and less error-prone [Uint32.And] instead. func AndUint32(addr *uint32, mask uint32) (old uint32)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 11.7K bytes - Viewed (0) -
internal/grid/muxclient.go
} m.addResponse(Response{Err: &err}) } func (m *muxClient) ack(seq uint32) { if !m.checkSeq(seq) { return } if m.acked || m.outBlock == nil { return } available := cap(m.outBlock) for i := 0; i < available; i++ { m.outBlock <- struct{}{} } m.acked = true } func (m *muxClient) unblockSend(seq uint32) { if !m.checkSeq(seq) { return } select {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
pilot/pkg/model/gateway.go
gatewayPorts := sets.New[uint32]() nonPlainTextGatewayPortsBindMap := map[uint32]sets.String{} mergedServers := make(map[ServerPort]*MergedServers) mergedQUICServers := make(map[ServerPort]*MergedServers) serverPorts := make([]ServerPort, 0) plainTextServers := make(map[uint32]ServerPort) serversByRouteName := make(map[string][]*networking.Server)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 26K bytes - Viewed (0) -
src/cmd/compile/internal/liveness/plive.go
var argsSymTmp, liveSymTmp obj.LSym args := bitvec.New(int32(maxArgs / int64(types.PtrSize))) aoff := objw.Uint32(&argsSymTmp, 0, uint32(len(lv.stackMaps))) // number of bitmaps aoff = objw.Uint32(&argsSymTmp, aoff, uint32(args.N)) // number of bits in each bitmap locals := bitvec.New(int32(maxLocals / int64(types.PtrSize))) loff := objw.Uint32(&liveSymTmp, 0, uint32(len(lv.stackMaps))) // number of bitmaps
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 15:22:22 UTC 2024 - 45.2K bytes - Viewed (0) -
src/runtime/mfinal.go
type finblock struct { _ sys.NotInHeap alllink *finblock next *finblock cnt uint32 _ int32 fin [(_FinBlockSize - 2*goarch.PtrSize - 2*4) / unsafe.Sizeof(finalizer{})]finalizer } var fingStatus atomic.Uint32 // finalizer goroutine status. const ( fingUninitialized uint32 = iota fingCreated uint32 = 1 << (iota - 1) fingRunningFinalizer fingWait fingWake )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 01:56:56 UTC 2024 - 19K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
} return ingressPortListSet } func (lb *ListenerBuilder) getFilterChainsByServicePort(enableSidecarServiceInboundListenerMerge bool) map[uint32]inboundChainConfig { chainsByPort := make(map[uint32]inboundChainConfig) ingressPortListSet := sets.New[int]() sidecarScope := lb.node.SidecarScope if sidecarScope.HasIngressListener() { ingressPortListSet = getSidecarIngressPortList(lb.node)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
internal/grid/connection.go
// We may have reads that aren't locked, so update atomically. gotState := atomic.LoadUint32((*uint32)(&c.state)) if gotState == StateShutdown || State(gotState) == s { return } if s == StateConnected { atomic.StoreInt64(&c.LastPong, time.Now().UnixNano()) } atomic.StoreUint32((*uint32)(&c.state), uint32(s)) if debugPrint { fmt.Println(c.Local, "updateState:", gotState, "->", s) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
pkg/workloadapi/workload.proto
// PorList represents the ports for a service message PortList { repeated Port ports = 1; } message Port { // Port the service is reached at (frontend). uint32 service_port = 1; // Port the service forwards to (backend). uint32 target_port = 2; } // TunnelProtocol indicates the tunneling protocol for requests. enum TunnelProtocol { // NONE means requests should be forwarded as-is, without tunneling.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 12.9K bytes - Viewed (0) -
cmd/storage-datatypes.go
// //msgp:tuple DiskInfo type DiskInfo struct { Total uint64 Free uint64 Used uint64 UsedInodes uint64 FreeInodes uint64 Major uint32 Minor uint32 NRRequests uint64 FSType string RootDisk bool Healing bool Scanning bool Endpoint string MountPath string ID string Rotational bool Metrics DiskMetrics
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 15.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go
return InboundBinding{} } // parse port port := uint32(0) if len(parts) == 2 { parsed, err := strconv.ParseUint(parts[1], 10, 32) if err != nil { log.Warnf("invalid port %s for %s.", parts[1], constants.AmbientWaypointInboundBinding) } port = uint32(parsed) } return InboundBinding{ Port: port, Protocol: protocol, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:28 UTC 2024 - 11.1K bytes - Viewed (0)