Method Bind

integration/harness.go:346–390

(node state.NodeId)

}

func (i *InMemoryNetwork) Bind(node state.NodeId) conn.Bind {
	i.Lock()
	defer i.Unlock()
	epSendMapping := func(to bindtest.ChannelEndpoint2) bindtest.ChannelEndpoint2 {
		return i.EpOutMapping(node, to)
	}
	bp := bindtest.NewChannelBind2()

	remote := bp[0] // simulate an actual port opening
	open, _, err := remote.Open(0)
	if err != nil {
		return nil
	}
	numId := i.cfg.IndexOf(node)
	i.binds[numId] = remote
	go func() {
		// bind listener routine for packets sent from this node
		bufSize := remote.BatchSize()
		pktBuf := make([][]byte, bufSize)
		pktBuf[0] = make([]byte, device.MaxMessageSize)
		lenBuf := make([]int, bufSize)
		epBuf := make([]conn.Endpoint, bufSize)
		i.WaitForReady()
		for {
			for _, recv := range open {
				n, err := recv(pktBuf, lenBuf, epBuf)
				if err != nil {
					if !errors.Is(err, net.ErrClosed) {
						panic(err)
					}
					return
				}
				for pi := range n {
					if lenBuf[pi] == 0 {
						continue
					}
					toIp := epBuf[pi].(bindtest.ChannelEndpoint2)
					fromIp := epSendMapping(toIp)
					i.virtualInternet(slices.Clone(pktBuf[pi]), lenBuf[pi], fromIp, toIp)
				}
			}
		}
	}()
	return bp[1]
}

func (i *InMemoryNetwork) Tun(node state.NodeId) tun.Device {
	i.Lock()