Method NoMoreConnections

agentprotocol/server.go:686–694

()

}

func (c *ForwardCtx) NoMoreConnections() error {
	c.stopped = true
	close(c.connectionChannel)
	return c.writePacket(
		&Packet{
			Type: PACKET_NO_MORE_CONNECTIONS,
		},
	)
}

func (c *ForwardCtx) WaitFinish() {
	c.waitGroup.Wait()