Function downStreamOffline

agent/process/offline.go:402–428

(mgr *manager.Manager, options *initial.Options, uuid string)

}

func downStreamOffline(mgr *manager.Manager, options *initial.Options, uuid string) {
	childrenTask := &manager.ChildrenTask{ // del the child
		Mode: manager.C_DELCHILD,
		UUID: uuid,
	}

	mgr.ChildrenManager.TaskChan <- childrenTask
	<-mgr.ChildrenManager.ResultChan

	sMessage := protocol.PrepareAndDecideWhichSProtoToUpper(global.G_Component.Conn, global.G_Component.Secret, global.G_Component.UUID)

	header := &protocol.Header{
		Sender:      global.G_Component.UUID,
		Accepter:    protocol.ADMIN_UUID,
		MessageType: protocol.NODEOFFLINE,
		RouteLen:    uint32(len([]byte(protocol.TEMP_ROUTE))),
		Route:       protocol.TEMP_ROUTE,
	}

	offlineMess := &protocol.NodeOffline{
		UUIDLen: uint16(len(uuid)),
		UUID:    uuid,
	}

	protocol.ConstructMessage(sMessage, header, offlineMess, false)
	sMessage.SendMessage()
}

func tellAdminReonline(mgr *manager.Manager) {
	childrenTask := &manager.ChildrenTask{