- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 226 for nbrecv (0.19 sec)
-
src/main/java/jcifs/util/transport/Transport.java
protected abstract Long peekKey () throws IOException; protected abstract void doSend ( Request request ) throws IOException; protected abstract void doRecv ( Response response ) throws IOException; protected abstract void doSkip ( Long key ) throws IOException; /** * * @return whether the transport is disconnected */
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Nov 01 18:12:21 UTC 2020 - 24.1K bytes - Viewed (0) -
pilot/test/xdstest/grpc.go
"istio.io/istio/pkg/log" "istio.io/istio/pkg/sleep" ) type slowClientStream struct { grpc.ClientStream recv, send time.Duration } func (w *slowClientStream) RecvMsg(m any) error { if w.recv > 0 { sleep.UntilContext(w.Context(), w.recv) log.Infof("delayed recv for %v", w.recv) } return w.ClientStream.RecvMsg(m) } func (w *slowClientStream) SendMsg(m any) error { if w.send > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.4K bytes - Viewed (0) -
test/ken/chan.go
go sel(ca[0], ca[1], ca[2], ca[3], nc, nc, nc, nc) } // select send to direct recv func test3(c int) { ca := mkchan(c, 4) changeNproc(4) go recv(ca[0]) go recv(ca[1]) go recv(ca[2]) go recv(ca[3]) changeNproc(1) go sel(nc, nc, nc, nc, ca[0], ca[1], ca[2], ca[3]) } // select send to select recv func test4(c int) { ca := mkchan(c, 4) changeNproc(2)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 24 05:24:24 UTC 2012 - 4.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/stdlib/stdlib.go
// // Example: "(*Buffer).Grow" -> (true, "Buffer", "Grow") func (sym *Symbol) SplitMethod() (ptr bool, recv, name string) { if sym.Kind != Method { panic("not a method") } recv, name, _ = strings.Cut(sym.Name, ".") recv = recv[len("(") : len(recv)-len(")")] ptr = recv[0] == '*' if ptr { recv = recv[len("*"):] } return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 2.4K bytes - Viewed (0) -
src/cmd/compile/internal/types2/signature.go
} if cause != "" { check.errorf(recv, InvalidRecv, "invalid receiver type %s (%s)", rtyp, cause) } case *Basic: check.errorf(recv, InvalidRecv, "cannot define new methods on non-local type %s", rtyp) default: check.errorf(recv, InvalidRecv, "invalid receiver type %s", recv.typ) } }).describef(recv, "validate receiver %s", recv) } sig.params = NewTuple(params...)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 21:33:05 UTC 2024 - 12.6K bytes - Viewed (0) -
test/chan/select7.go
select { case <-c: case <-c2: } } func send1(recv func(<-chan int)) { c := make(chan int) go recv(c) runtime.Gosched() c <- 1 } func send2(recv func(<-chan int)) { c := make(chan int) go recv(c) runtime.Gosched() select { case c <- 1: } } func send3(recv func(<-chan int)) { c := make(chan int) go recv(c) runtime.Gosched() c2 := make(chan int) select {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 932 bytes - Viewed (0) -
src/cmd/compile/internal/types2/selection.go
func (s *Selection) Type() Type { switch s.kind { case MethodVal: // The type of x.f is a method with its receiver type set // to the type of x. sig := *s.obj.(*Func).typ.(*Signature) recv := *sig.recv recv.typ = s.recv sig.recv = &recv return &sig case MethodExpr: // The type of x.f is a function (without receiver) // and an additional first argument with the same type as x.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 22 19:32:17 UTC 2024 - 5.8K bytes - Viewed (0) -
src/go/types/selection.go
func (s *Selection) Type() Type { switch s.kind { case MethodVal: // The type of x.f is a method with its receiver type set // to the type of x. sig := *s.obj.(*Func).typ.(*Signature) recv := *sig.recv recv.typ = s.recv sig.recv = &recv return &sig case MethodExpr: // The type of x.f is a function (without receiver) // and an additional first argument with the same type as x.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 18:48:38 UTC 2024 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/decorated_watcher.go
var recv, send watch.Event var ok bool defer close(d.resultCh) for { select { case recv, ok = <-d.w.ResultChan(): if !ok { // The underlying channel was closed, cancel our context d.cancel() return } switch recv.Type { case watch.Added, watch.Modified, watch.Deleted, watch.Bookmark: d.decorator(recv.Object) send = recv case watch.Error:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 02 19:25:31 UTC 2021 - 2.3K bytes - Viewed (1) -
src/cmd/compile/internal/types/type.go
// parameters, and results, any of which may be nil. func NewSignature(recv *Field, params, results []*Field) *Type { startParams := 0 if recv != nil { startParams = 1 } startResults := startParams + len(params) allParams := make([]*Field, startResults+len(results)) if recv != nil { allParams[0] = recv } copy(allParams[startParams:], params) copy(allParams[startResults:], results)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:29:45 UTC 2024 - 49.5K bytes - Viewed (0)