proxy: allow several instances with subpartitions having same reference

slapos/proxy/schema.sql

@@ -28,8 +28,7 @@ CREATE TABLE IF NOT EXISTS partition%(version)s (
   slave_instance_list TEXT,
   software_type VARCHAR(255),
   partition_reference VARCHAR(255), -- name of the instance
-  requested_by VARCHAR(255), -- only used for debugging,
-                             -- slapproxy does not support proper scope
+  requested_by VARCHAR(255),
   requested_state VARCHAR(255) NOT NULL DEFAULT 'started',
   timestamp REAL,
   CONSTRAINT uniq PRIMARY KEY (reference, computer_reference)

slapos/proxy/views.py

@@ -525,7 +525,9 @@ def requestComputerPartition():
     requested_computer_id = parsed_request_dict['filter_kw'].get('computer_guid', app.config['computer_id'])
     matching_partition = getAllocatedSlaveInstance(slave_reference, requested_computer_id)
   else:
-    matching_partition = getAllocatedInstance(parsed_request_dict['partition_reference'])
+    matching_partition = getAllocatedInstance(
+      parsed_request_dict['partition_reference'],
+      parsed_request_dict['partition_id'])
 
   if matching_partition:
     # Then the instance is already allocated, just update it
@@ -716,17 +718,14 @@ def forwardRequestToExternalMaster(master_url, request_form):
   partition._software_release_document = request_form['software_release'] # type: ignore
   return dumps(partition)
 
-def getAllocatedInstance(partition_reference):
+def getAllocatedInstance(partition_reference, requested_by):
   """
   Look for existence of instance, if so return the
   corresponding partition dict, else return None
   """
-  args = []
-  a = args.append
-  table = 'partition'
-  q = 'SELECT * FROM %s WHERE partition_reference=?'
-  a(partition_reference)
-  return execute_db(table, q, args, one=True)
+  return execute_db('partition',
+    'SELECT * FROM %s WHERE partition_reference is ? AND requested_by is ?',
+    (partition_reference, requested_by or None), one=True)
 
 def getAllocatedSlaveInstance(slave_reference, requested_computer_id):
   """
@@ -768,9 +767,7 @@ def requestNotSlave(software_release, software_type, partition_reference, partit
   instance_xml = dict2xml(partition_parameter_kw)
   requested_computer_id = filter_kw['computer_guid']
 
-  partition = execute_db('partition',
-    'SELECT * FROM %s WHERE partition_reference=?',
-    (partition_reference,), one=True)
+  partition = getAllocatedInstance(partition_reference, partition_id)
 
   args = []
   a = args.append

slapos/tests/test_slapproxy/database_dump_version_current.sql

@@ -31,8 +31,7 @@ CREATE TABLE partition16 (
   slave_instance_list TEXT,
   software_type VARCHAR(255),
   partition_reference VARCHAR(255), -- name of the instance
-  requested_by VARCHAR(255), -- only used for debugging,
-                             -- slapproxy does not support proper scope
+  requested_by VARCHAR(255),
   requested_state VARCHAR(255) NOT NULL DEFAULT 'started',
   timestamp REAL,
   CONSTRAINT uniq PRIMARY KEY (reference, computer_reference)