mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-28 09:13:09 -06:00
Fixes to gobind API
This commit is contained in:
parent
e3378174d7
commit
39ba463902
|
|
@ -81,11 +81,19 @@ func (m *DendriteMonolith) SetStaticPeer(uri string) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *DendriteMonolith) DisconnectNonMulticastPeers() {
|
func (m *DendriteMonolith) DisconnectNonMulticastPeers() {
|
||||||
// TODO
|
for _, p := range m.PineconeRouter.Peers() {
|
||||||
|
if p.Zone == "static" {
|
||||||
|
_ = m.PineconeRouter.Disconnect(types.SwitchPortID(p.Port))
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *DendriteMonolith) DisconnectMulticastPeers() {
|
func (m *DendriteMonolith) DisconnectMulticastPeers() {
|
||||||
// TODO
|
for _, p := range m.PineconeRouter.Peers() {
|
||||||
|
if p.Zone != "static" {
|
||||||
|
_ = m.PineconeRouter.Disconnect(types.SwitchPortID(p.Port))
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *DendriteMonolith) DisconnectPort(port int) error {
|
func (m *DendriteMonolith) DisconnectPort(port int) error {
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue