- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for chanbuf (0.14 sec)
-
src/runtime/chan.go
// operations like close(). return unsafe.Pointer(&c.buf) } func racesync(c *hchan, sg *sudog) { racerelease(chanbuf(c, 0)) raceacquireg(sg.g, chanbuf(c, 0)) racereleaseg(sg.g, chanbuf(c, 0)) raceacquire(chanbuf(c, 0)) } // Notify the race detector of a send or receive involving buffer entry idx // and a channel c or its communicating partner sg.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
src/runtime/select.go
} if msanenabled && cas.elem != nil { msanwrite(cas.elem, c.elemtype.Size_) } if asanenabled && cas.elem != nil { asanwrite(cas.elem, c.elemtype.Size_) } recvOK = true qp = chanbuf(c, c.recvx) if cas.elem != nil { typedmemmove(c.elemtype, cas.elem, qp) } typedmemclr(c.elemtype, qp) c.recvx++ if c.recvx == c.dataqsiz { c.recvx = 0 } c.qcount--
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 13 21:36:04 UTC 2024 - 15K bytes - Viewed (0) -
src/cmd/compile/internal/test/inl_test.go
"runtime": { "add", "acquirem", "add1", "addb", "adjustpanics", "adjustpointer", "alignDown", "alignUp", "bucketMask", "bucketShift", "chanbuf", "evacuated", "fastlog2", "float64bits", "funcspdelta", "getm", "getMCache", "isDirectIface", "itabHashFunc", "nextslicecap", "noescape", "pcvalueCacheKey",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 09 04:07:57 UTC 2024 - 10.7K bytes - Viewed (0) -
src/runtime/runtime-gdb.py
def __init__(self, val): self.val = val def display_hint(self): return 'array' def to_string(self): return str(self.val.type) def children(self): # see chan.c chanbuf(). et is the type stolen from hchan<T>::recvq->first->elem et = [x.type for x in self.val['recvq']['first'].type.target().fields() if x.name == 'elem'][0] ptr = (self.val.address["buf"]).cast(et)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 10 12:59:20 UTC 2023 - 15.4K bytes - Viewed (0) -
test/fixedbugs/bug222.dir/chanbug.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 24 19:48:15 UTC 2012 - 263 bytes - Viewed (0) -
test/fixedbugs/bug222.dir/chanbug2.go
// Copyright 2009 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 package Bar
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 24 02:14:15 UTC 2022 - 193 bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/problems/ConfigurationCacheReport.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.cc.impl.problems import org.apache.groovy.json.internal.CharBuf import org.gradle.api.internal.file.temp.TemporaryFileProvider import org.gradle.internal.buildoption.InternalFlag import org.gradle.internal.buildoption.InternalOptions import org.gradle.internal.concurrent.ExecutorFactory
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 11.4K bytes - Viewed (0) -
test/typeparam/mdempsky/17.go
func RangeArrayIface[V iface]() (k any, v iface) { for k, v = range [...]V{zero[V]()} { } return } func RangeChanAny[V any]() (v any) { for v = range chanOf(zero[V]()) { } return } func RangeChanIface[V iface]() (v iface) { for v = range chanOf(zero[V]()) { } return } func RangeMapAny[K comparable, V any]() (k, v any) { for k, v = range map[K]V{zero[K](): zero[V]()} { } return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 10 21:35:49 UTC 2022 - 2.1K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/problems/JsonModelWriter.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.cc.impl.problems import org.apache.groovy.json.internal.CharBuf import org.gradle.api.internal.DocumentationRegistry import org.gradle.internal.configuration.problems.documentationLinkFor import org.gradle.internal.configuration.problems.DecoratedFailure
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 8.8K bytes - Viewed (0) -
src/reflect/type.go
m sync.Map } // ChanOf returns the channel type with the given direction and element type. // For example, if t represents int, ChanOf(RecvDir, t) represents <-chan int. // // The gc runtime imposes a limit of 64 kB on channel element types. // If t's size is equal to or exceeds this limit, ChanOf panics. func ChanOf(dir ChanDir, t Type) Type { typ := t.common()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 85.5K bytes - Viewed (0)