Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for chanbuf (0.23 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. 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)
  5. 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)
  6. 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)
  7. src/reflect/all_test.go

    	}
    
    	// check that type already in binary is found
    	type T1 int
    	checkSameType(t, ChanOf(BothDir, TypeOf(T1(1))), (chan T1)(nil))
    
    	// Check arrow token association in undefined chan types.
    	var left chan<- chan T
    	var right chan (<-chan T)
    	tLeft := ChanOf(SendDir, ChanOf(BothDir, TypeOf(T(""))))
    	tRight := ChanOf(BothDir, ChanOf(RecvDir, TypeOf(T(""))))
    	if tLeft != TypeOf(left) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 218.8K bytes
    - Viewed (0)
  8. src/net/http/server.go

    	// written.
    	trailers []string
    
    	handlerDone atomic.Bool // set true when the handler exits
    
    	// Buffers for Date, Content-Length, and status code
    	dateBuf   [len(TimeFormat)]byte
    	clenBuf   [10]byte
    	statusBuf [3]byte
    
    	// closeNotifyCh is the channel returned by CloseNotify.
    	// TODO(bradfitz): this is currently (for Go 1.8) always
    	// non-nil. Make this lazily-created again as it used to be?
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 123.4K bytes
    - Viewed (0)
  9. src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go

    		{"Append", Func, 0},
    		{"AppendSlice", Func, 0},
    		{"Array", Const, 0},
    		{"ArrayOf", Func, 5},
    		{"Bool", Const, 0},
    		{"BothDir", Const, 0},
    		{"Chan", Const, 0},
    		{"ChanDir", Type, 0},
    		{"ChanOf", Func, 1},
    		{"Complex128", Const, 0},
    		{"Complex64", Const, 0},
    		{"Copy", Func, 0},
    		{"DeepEqual", Func, 0},
    		{"Float32", Const, 0},
    		{"Float64", Const, 0},
    		{"Func", Const, 0},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 534.2K bytes
    - Viewed (0)
Back to top