class SyncExternalRoutes(SyncStep):
# XXX what does this provide?
+ requested_interval = 86400 # This step is slow like a pig. Let's run it infrequently
+
def call(self):
routes = self.manager.driver.get_external_routes()
subnets = self.manager.driver.shell.quantum.list_subnets()['subnets']
from planetstack.config import Config
class SyncNetworkSlivers(OpenStackSyncStep):
- slow=True
+ requested_interval = 3600
provides=[NetworkSliver]
def call(self):
class SyncNetworks(OpenStackSyncStep):
provides=[Network]
+ requested_interval = 0
def save_network(self, network):
if not network.network_id:
from planetstack.config import Config
class SyncSitePrivileges(OpenStackSyncStep):
+ requested_interval=0
+
provides=[SitePrivilege]
def sync_record(self, user):
if site_priv.user.kuser_id and site_priv.site.tenant_id:
class SyncSites(OpenStackSyncStep):
provides=[Site]
+ requested_interval=0
def sync_record(self, site):
save_site = False
if not site.tenant_id:
from planetstack.config import Config
class SyncSliceMemberships(OpenStackSyncStep):
+ requested_interval=0
provides=[SliceMembership]
def sync_record(self, user):
if slice_memb.user.kuser_id and slice_memb.slice.tenant_id:
class SyncSlices(OpenStackSyncStep):
provides=[Slice]
+ requested_interval=0
def sync_record(self, slice):
if not slice.tenant_id:
nova_fields = {'tenant_name': slice.name,
class SyncSliverIps(OpenStackSyncStep):
provides=[Sliver]
+ requested_interval=0
def fetch_pending(self):
slivers = Sliver.objects.filter(ip=None)
return slivers
class SyncSlivers(OpenStackSyncStep):
provides=[Sliver]
+ requested_interval=0
def sync_record(self, slice):
if not sliver.instance_id:
nics = self.get_requested_networks(sliver.slice)
class SyncUsers(OpenStackSyncStep):
provides=[User]
+ requested_interval=0
def sync_record(self, user):
name = user.email[:user.email.find('@')]
user_fields = {'name': name,