| 260 | type OutMapping func(curNode state.NodeId, to bindtest.ChannelEndpoint2) bindtest.ChannelEndpoint2 |
| 261 | |
| 262 | type InMemoryNetwork struct { |
| 263 | sync.Mutex |
| 264 | cfg *VirtualHarness |
| 265 | binds []conn.Bind |
| 266 | virtTun []*tuntest.ChannelTUN |
| 267 | SelfHandler PacketFilter // packet filter for handling packets destined for the current node |
| 268 | TransitHandler PacketFilter // packet filter for handling packets passing through the current node |
| 269 | EpOutMapping OutMapping |
| 270 | ready atomic.Bool |
| 271 | readyCond *sync.Cond |
| 272 | } |
| 273 | |
| 274 | func (i *InMemoryNetwork) WaitForReady() { |
| 275 | i.readyCond.L.Lock() |
nothing calls this directly
no outgoing calls
no test coverage detected