- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for remoteDone (0.14 sec)
-
src/net/pipe.go
done2 := make(chan struct{}) p1 := &pipe{ rdRx: cb1, rdTx: cn1, wrTx: cb2, wrRx: cn2, localDone: done1, remoteDone: done2, readDeadline: makePipeDeadline(), writeDeadline: makePipeDeadline(), } p2 := &pipe{ rdRx: cb2, rdTx: cn2, wrTx: cb1, wrRx: cn1, localDone: done2, remoteDone: done1, readDeadline: makePipeDeadline(), writeDeadline: makePipeDeadline(), } return p1, p2 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.4K bytes - Viewed (0) -
internal/grid/grid_test.go
register(local) register(remote) remoteConn := local.Connection(remoteHost) const testPayload = "Hello Grid World!" remoteConn.debugMsg(debugSetClientPingDuration, 100*time.Millisecond) defer remoteConn.debugMsg(debugSetClientPingDuration, clientPingInterval) ctx, cancel := context.WithTimeout(context.Background(), time.Minute) defer cancel() st, err := remoteConn.NewStream(ctx, handlerTest, []byte(testPayload))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
internal/grid/connection_test.go
// local to remote remoteConn := local.Connection(remoteHost) errFatal(remoteConn.WaitForConnect(context.Background())) const testPayload = "Hello Grid World!" gotResp := make(chan struct{}) go func() { start := time.Now() t.Log("Roundtrip: sending request") resp, err := remoteConn.Request(context.Background(), handlerTest, []byte(testPayload))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 6K bytes - Viewed (0) -
pkg/scheduler/internal/cache/node_tree.go
return fmt.Errorf("node %q in group %q was not found", n.Name, zone) } // removeZone removes a zone from tree. // This function must be called while writer locks are hold. func (nt *nodeTree) removeZone(zone string) { delete(nt.tree, zone) for i, z := range nt.zones { if z == zone { nt.zones = append(nt.zones[:i], nt.zones[i+1:]...) return } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 4.5K bytes - Viewed (0) -
build-logic/idea/src/main/kotlin/gradlebuild.ide.gradle.kts
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 26 15:42:59 UTC 2023 - 3.6K bytes - Viewed (0) -
src/net/http/request.go
// work, but it will not cause an allocation. if ascii.Is(v) { return v, nil } return idna.Lookup.ToASCII(v) } // removeZone removes IPv6 zone identifier from host. // E.g., "[fe80::1%en0]:8080" to "[fe80::1]:8080" func removeZone(host string) string { if !strings.HasPrefix(host, "[") { return host } i := strings.LastIndex(host, "]") if i < 0 { return host }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 49.4K bytes - Viewed (0)