Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for chanbuf (0.14 sec)

  1. 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)
  2. 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)
  3. src/cmd/compile/internal/test/inl_test.go

    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 09 04:07:57 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  4. 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)
  5. test/fixedbugs/bug222.dir/chanbug.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 chanbug
    var C chan<- (chan int)
    var D chan<- func()
    var E func() chan int
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jan 24 19:48:15 UTC 2012
    - 263 bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top