Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for remoteDone (0.11 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/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)
  3. 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)
  4. 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)
Back to top