fix

circle/dashboard/views.py

@@ -241,7 +241,7 @@ class VmDetailView(CheckedDetailView):
             'new_name': self.__set_name,
             'new_name': self.__set_name,
             'new_description': self.__set_description,
             'new_description': self.__set_description,
             'new_tag': self.__add_tag,
             'new_tag': self.__add_tag,
-            'deploy_locall': self.donothing,
+            'deploy_local': self.__deploy_local,
             'to_remove': self.__remove_tag,
             'to_remove': self.__remove_tag,
             'port': self.__add_port,
             'port': self.__add_port,
             'new_network_vlan': self.__new_network,
             'new_network_vlan': self.__new_network,
@@ -250,9 +250,6 @@ class VmDetailView(CheckedDetailView):
             if request.POST.get(k) is not None:
             if request.POST.get(k) is not None:
                 return v(request)
                 return v(request)
 
 
-    def donothing(self, request):
-        pass
-
     def __deploy_local(self, request):
     def __deploy_local(self, request):
         self.object = self.get_object()
         self.object = self.get_object()
         if not self.object.has_level(request.user, 'owner'):
         if not self.object.has_level(request.user, 'owner'):

circle/vm/models/instance.py

@@ -31,6 +31,7 @@ from .node import Node, Trait
 
 
 import random
 import random
 import string
 import string
+import socket
 
 
 logger = getLogger(__name__)
 logger = getLogger(__name__)
 pre_state_changed = Signal(providing_args=["new_state"])
 pre_state_changed = Signal(providing_args=["new_state"])
@@ -792,7 +793,7 @@ class Instance(AclBase, VirtualMachineDescModel, StatusModel, OperatedMixin,
                                            queue=queue_name
                                            queue=queue_name
                                            ).get(timeout=timeout)
                                            ).get(timeout=timeout)
 
 
-    def __deployii_local_vm(self, act, timeout=15):
+    def __deploy_local_vm(self, act, timeout=15):
         """Local deploy the virtual machine.
         """Local deploy the virtual machine.
 
 
         :param self: The virtual machine.
         :param self: The virtual machine.
@@ -803,10 +804,15 @@ class Instance(AclBase, VirtualMachineDescModel, StatusModel, OperatedMixin,
         # create hardlink
         # create hardlink
         hlinkname = ''.join(random.choice(string.ascii_uppercase +
         hlinkname = ''.join(random.choice(string.ascii_uppercase +
                                           string.digits) for _ in range(20))
                                           string.digits) for _ in range(20))
-        remotedest = '/home/gergo/vmdisks/' + hlinkname
+        remotedest = hlinkname
         localsrc = descriptor['disk_list'][0]['source']
         localsrc = descriptor['disk_list'][0]['source']
         descriptor['disk_list'][0]['source'] = remotedest
         descriptor['disk_list'][0]['source'] = remotedest
-        return ""
+        originalname = localsrc.split("/")
+        originalname = originalname[len(originalname)-1]
+        hlmakersocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        hlmakersocket.connect(('localhost', 40000))
+        hlmakersocket.send(originalname + "/" + hlinkname)
+        return descriptor
 
 
     def deploy_local(self, user=None, task_uuid=None):
     def deploy_local(self, user=None, task_uuid=None):
         """Deploy new virtual machine with network
         """Deploy new virtual machine with network
@@ -831,8 +837,7 @@ ecuted
         with instance_activity(code_suffix='local_deploy', instance=self,
         with instance_activity(code_suffix='local_deploy', instance=self,
                                on_commit=__on_commit, task_uuid=task_uuid,
                                on_commit=__on_commit, task_uuid=task_uuid,
                                user=user) as act:
                                user=user) as act:
-            return ""
-#            return self.__deploy_local_vm(act)
+            return self.__deploy_local_vm(act)
 
 
     def migrate_vm(self, to_node, timeout=120):
     def migrate_vm(self, to_node, timeout=120):
         queue_name = self.get_remote_queue_name('vm')
         queue_name = self.get_remote_queue_name('vm')