Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for remoteDone (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. build-logic/idea/src/main/kotlin/gradlebuild.ide.gradle.kts

                }
            }
        }
    }
    
    fun ProjectSettings.configureRunConfigurations() {
        runConfigurations {
            create<Remote>("Remote debug port 5005") {
                mode = Remote.RemoteMode.ATTACH
                transport = Remote.RemoteTransport.SOCKET
                sharedMemoryAddress = "javadebug"
                host = "localhost"
                port = 5005
            }
        }
    }
    
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Jun 26 15:42:59 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  6. 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)
Back to top