Browse Source

Rename 'PROVIDER_TYPE_ENDPOINT_OPTIONS' constant to 'PROVIDER_TYPE_SOURCE_ENDPOINT_OPTIONS'.

Nashwan Azhari 7 years ago
parent
commit
4d1e756ef9
3 changed files with 4 additions and 4 deletions
  1. 1 1
      coriolis/constants.py
  2. 1 1
      coriolis/providers/factory.py
  3. 2 2
      coriolis/worker/rpc/server.py

+ 1 - 1
coriolis/constants.py

@@ -60,7 +60,7 @@ PROVIDER_TYPE_ENDPOINT_INSTANCES = 32
 PROVIDER_TYPE_OS_MORPHING = 64
 PROVIDER_TYPE_OS_MORPHING = 64
 PROVIDER_TYPE_ENDPOINT_NETWORKS = 128
 PROVIDER_TYPE_ENDPOINT_NETWORKS = 128
 PROVIDER_TYPE_INSTANCE_FLAVOR = 256
 PROVIDER_TYPE_INSTANCE_FLAVOR = 256
-PROVIDER_TYPE_ENDPOINT_OPTIONS = 512
+PROVIDER_TYPE_DESTINATION_ENDPOINT_OPTIONS = 512
 PROVIDER_TYPE_SETUP_LIBS = 1024
 PROVIDER_TYPE_SETUP_LIBS = 1024
 PROVIDER_TYPE_VALIDATE_MIGRATION_EXPORT = 2048
 PROVIDER_TYPE_VALIDATE_MIGRATION_EXPORT = 2048
 PROVIDER_TYPE_VALIDATE_REPLICA_EXPORT = 4096
 PROVIDER_TYPE_VALIDATE_REPLICA_EXPORT = 4096

+ 1 - 1
coriolis/providers/factory.py

@@ -23,7 +23,7 @@ PROVIDER_TYPE_MAP = {
     constants.PROVIDER_TYPE_IMPORT: base.BaseImportProvider,
     constants.PROVIDER_TYPE_IMPORT: base.BaseImportProvider,
     constants.PROVIDER_TYPE_REPLICA_IMPORT: base.BaseReplicaImportProvider,
     constants.PROVIDER_TYPE_REPLICA_IMPORT: base.BaseReplicaImportProvider,
     constants.PROVIDER_TYPE_ENDPOINT: base.BaseEndpointProvider,
     constants.PROVIDER_TYPE_ENDPOINT: base.BaseEndpointProvider,
-    constants.PROVIDER_TYPE_ENDPOINT_OPTIONS:
+    constants.PROVIDER_TYPE_DESTINATION_ENDPOINT_OPTIONS:
         base.BaseEndpointDestinationOptionsProvider,
         base.BaseEndpointDestinationOptionsProvider,
     constants.PROVIDER_TYPE_ENDPOINT_INSTANCES:
     constants.PROVIDER_TYPE_ENDPOINT_INSTANCES:
         base.BaseEndpointInstancesProvider,
         base.BaseEndpointInstancesProvider,

+ 2 - 2
coriolis/worker/rpc/server.py

@@ -5,7 +5,6 @@ import multiprocessing
 
 
 import os
 import os
 import shutil
 import shutil
-import time
 import signal
 import signal
 import sys
 import sys
 import eventlet
 import eventlet
@@ -273,7 +272,8 @@ class WorkerServerEndpoint(object):
     def get_endpoint_destination_options(
     def get_endpoint_destination_options(
             self, ctxt, platform_name, connection_info, env, option_names):
             self, ctxt, platform_name, connection_info, env, option_names):
         provider = providers_factory.get_provider(
         provider = providers_factory.get_provider(
-            platform_name, constants.PROVIDER_TYPE_ENDPOINT_OPTIONS, None)
+            platform_name,
+            constants.PROVIDER_TYPE_DESTINATION_ENDPOINT_OPTIONS, None)
 
 
         secret_connection_info = utils.get_secret_connection_info(
         secret_connection_info = utils.get_secret_connection_info(
             ctxt, connection_info)
             ctxt, connection_info)