Merge pull request #511 from ClusterLabs/anvil-tools-dev

Anvil tools dev

Anvil/Tools/Database.pm

@@ -105,6 +105,7 @@ my $THIS_FILE = "Database.pm";
 # _add_to_local_config
 # _age_out_data
 # _archive_table
+# _check_for_duplicates
 # _find_column
 # _find_behind_database
 # _mark_database_as_behind
@@ -18150,6 +18151,9 @@ sub resync_databases
 	# We're done with the table data, clear it.
 	delete $anvil->data->{sys}{database}{table};
 	
+	# Search for duplicates from the resync
+	$anvil->Database->_check_for_duplicates({debug => 2});
+	
 	# Clear the variable that indicates we need a resync.
 	$anvil->data->{sys}{database}{resync_needed} = 0;
 	$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => $debug, list => { 'sys::database::resync_needed' => $anvil->data->{sys}{database}{resync_needed} }});
@@ -19649,6 +19653,117 @@ COPY history.".$table." (";
 }
 
 
+=head2 _check_for_duplicates
+
+This method looks for duplicate entries in the database and clears them, if found.
+
+This method takes no parameters
+
+=cut
+sub _check_for_duplicates
+{
+	my $self      = shift;
+	my $parameter = shift;
+	my $anvil     = $self->parent;
+	my $debug     = defined $parameter->{debug} ? $parameter->{debug} : 3;
+	$anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => $debug, key => "log_0125", variables => { method => "Database->_check_for_duplicates()" }});
+	
+	my $query = "
+SELECT 
+    variable_uuid, 
+    variable_section, 
+    variable_name, 
+    variable_source_table, 
+    variable_source_uuid, 
+    variable_value, 
+    modified_date 
+FROM 
+    variables 
+ORDER BY 
+    modified_date DESC;
+;";
+	$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => $debug, list => { query => $query }});
+	
+	my $results = $anvil->Database->query({query => $query, source => $THIS_FILE, line => __LINE__});
+	my $count   = @{$results};
+	$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => $debug, list => { 
+		results => $results, 
+		count   => $count, 
+	}});
+	foreach my $row (@{$results})
+	{
+		my $variable_uuid         = $row->[0]; 
+		my $variable_section      = $row->[1]; 
+		my $variable_name         = $row->[2]; 
+		my $variable_source_table = $row->[3] ? $row->[3] : "none"; 
+		my $variable_source_uuid  = $row->[4] ? $row->[4] : "none"; 
+		my $variable_value        = $row->[5]; 
+		my $modified_date         = $row->[6];
+		$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 1, list => { 
+			variable_uuid         => $variable_uuid, 
+			variable_section      => $variable_section, 
+			variable_name         => $variable_name, 
+			variable_source_table => $variable_source_table, 
+			variable_source_uuid  => $variable_source_uuid, 
+			variable_value        => $variable_value, 
+			modified_date         => $modified_date,
+		}});
+		
+		if (not $variable_source_table)
+		{
+			$variable_source_table = "none";
+			$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 1, list => { variable_source_table => $variable_source_table }});
+		}
+		if (not $variable_source_uuid)
+		{
+			$variable_source_uuid = "none";
+			$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 1, list => { variable_source_uuid => $variable_source_uuid }});
+		}
+		
+		if ((not exists $anvil->data->{duplicate_variables}{$variable_section}{$variable_name}{$variable_source_table}{$variable_source_uuid}) && 
+		    (not $anvil->data->{duplicate_variables}{$variable_section}{$variable_name}{$variable_source_table}{$variable_source_uuid}{variable_uuid}))
+		{
+			# Save it.
+			$anvil->data->{duplicate_variables}{$variable_section}{$variable_name}{$variable_source_table}{$variable_source_uuid}{variable_value} = $variable_value; 
+			$anvil->data->{duplicate_variables}{$variable_section}{$variable_name}{$variable_source_table}{$variable_source_uuid}{variable_uuid}  = $variable_uuid; 
+			$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 1, list => { 
+				"duplicate_variables::${variable_section}::${variable_name}::${variable_source_table}::${variable_source_uuid}::variable_value" => $anvil->data->{duplicate_variables}{$variable_section}{$variable_name}{$variable_source_table}{$variable_source_uuid}{variable_value},
+				"duplicate_variables::${variable_section}::${variable_name}::${variable_source_table}::${variable_source_uuid}::variable_uuid" => $anvil->data->{duplicate_variables}{$variable_section}{$variable_name}{$variable_source_table}{$variable_source_uuid}{variable_uuid},
+			}});
+		}
+		else
+		{
+			# Duplicate! This is older, so delete it.
+			$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 1, list => { 
+				"duplicate_variables::${variable_section}::${variable_name}::${variable_source_table}::${variable_source_uuid}::variable_value" => $anvil->data->{duplicate_variables}{$variable_section}{$variable_name}{$variable_source_table}{$variable_source_uuid}{variable_value},
+				"duplicate_variables::${variable_section}::${variable_name}::${variable_source_table}::${variable_source_uuid}::variable_uuid" => $anvil->data->{duplicate_variables}{$variable_section}{$variable_name}{$variable_source_table}{$variable_source_uuid}{variable_uuid},
+			}});
+			
+			$anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => 1, priority => "alert", key => "warning_0165", variables => {
+				section      => $variable_section,
+				name         => $variable_name,
+				source_table => $variable_source_table,
+				source_uuid  => $variable_source_uuid, 
+				value        => $variable_value,
+			}});
+			
+			my $queries = [];
+			push @{$queries}, "DELETE FROM history.variables WHERE variable_uuid = ".$anvil->Database->quote($variable_uuid).";";
+			push @{$queries}, "DELETE FROM variables WHERE variable_uuid = ".$anvil->Database->quote($variable_uuid).";";
+			foreach my $query (@{$queries})
+			{
+				$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 1, list => { query => $query }});
+			}
+			$anvil->Database->write({query => $queries, source => $THIS_FILE, line => __LINE__});
+		}
+	}
+	
+	# Delete to hash.
+	delete $anvil->data->{duplicate_variables};
+	
+	return(0);
+}
+
 =head2 _find_column
 
 This takes a table name and looks for a column that ends in C<< _host_uuid >> and, if found, stores it in the C<< sys::database::uuid_tables >> array.

scancore-agents/scan-cluster/scan-cluster

@@ -418,7 +418,7 @@ sub check_if_server_failed
 	my ($anvil, $server) = @_;
 	$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 3, list => { server => $server }});
 	
-	$anvil->Cluster->parse_crm_mon({debug => 3});
+	$anvil->Cluster->parse_crm_mon({debug => 2});
 	my $failed = exists $anvil->data->{crm_mon}{parsed}{'pacemaker-result'}{resources}{resource}{$server}{variables}{failed} ? $anvil->data->{crm_mon}{parsed}{'pacemaker-result'}{resources}{resource}{$server}{variables}{failed} : 0;
 	$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 3, list => { failed => $failed }});
 	if ($failed eq "true")
@@ -708,15 +708,24 @@ INSERT INTO
 	$anvil->Database->get_anvils();
 	foreach my $scan_cluster_node_name (sort {$a cmp $b} keys %{$anvil->data->{cib}{parsed}{data}{node}})
 	{
-		my $scan_cluster_node_host_uuid        = $anvil->Get->host_uuid_from_name({host_name => $scan_cluster_node_name});
+		my $scan_cluster_node_host_uuid = $anvil->Get->host_uuid_from_name({host_name => $scan_cluster_node_name}) // "";
+		$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level  => 2, list => { 
+			scan_cluster_node_name      => $scan_cluster_node_name,
+			scan_cluster_node_host_uuid => $scan_cluster_node_host_uuid, 
+		}});
+		if (not $scan_cluster_node_host_uuid)
+		{
+			# Something is wrong with this host. Does the hostname match to node name?
+			$anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => 1, key => "scan_cluster_alert_0016", variables => { node_name => $scan_cluster_node_name }});
+			next;
+		}
+		
 		my $scan_cluster_node_pacemaker_id     = $anvil->data->{cib}{parsed}{data}{node}{$scan_cluster_node_name}{node_state}{pacemaker_id};
 		my $scan_cluster_node_in_ccm           = $anvil->data->{cib}{parsed}{data}{node}{$scan_cluster_node_name}{node_state}{in_ccm};
 		my $scan_cluster_node_crmd_member      = $anvil->data->{cib}{parsed}{data}{node}{$scan_cluster_node_name}{node_state}{crmd};
 		my $scan_cluster_node_cluster_member   = $anvil->data->{cib}{parsed}{data}{node}{$scan_cluster_node_name}{node_state}{'join'};
 		my $scan_cluster_node_maintenance_mode = $anvil->data->{cib}{parsed}{data}{node}{$scan_cluster_node_name}{node_state}{'maintenance-mode'};
 		$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level  => 2, list => { 
-			scan_cluster_node_name             => $scan_cluster_node_name,
-			scan_cluster_node_host_uuid        => $scan_cluster_node_host_uuid, 
 			scan_cluster_node_pacemaker_id     => $scan_cluster_node_pacemaker_id, 
 			scan_cluster_node_in_ccm           => $scan_cluster_node_in_ccm, 
 			scan_cluster_node_crmd_member      => $scan_cluster_node_crmd_member, 
@@ -1044,7 +1053,7 @@ sub collect_data
 	my ($anvil) = @_;
 	
 	# Pick out core cluster details.
-	my $problem = $anvil->Cluster->parse_cib({debug => 3});
+	my $problem = $anvil->Cluster->parse_cib({debug => 2});
 	$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { problem => $problem }});
 	
 	# If there was a problem, we're not in the cluster.

scancore-agents/scan-cluster/scan-cluster.xml

@@ -40,6 +40,7 @@ In Maintenance Mode: ..... [#!variable!maintenance_mode!#]
 		<key name="scan_cluster_alert_0013">The server: [#!variable!server!#] was found to be failed in pacemaker, but it was successfully recovered. This does NOT mean the server rebooted, but it may have. Checking the server is advised.</key>
 		<key name="scan_cluster_alert_0014">The server: [#!variable!server!#] was found to be failed in pacemaker. The attempt to recover it appears to have failed. The server might well still be running ok, checking the server is advised.</key>
 		<key name="scan_cluster_alert_0015">The server: [#!variable!server!#] had been found to be failed in pacemaker. It's now recovered. This does NOT mean the server rebooted, but it may have. Checking the server is advised.</key>
+		<key name="scan_cluster_alert_0016">The node name: [#!variable!node_name!#] failed to translate to a host UUID. Does the node name match the host name?</key>
 		
 		<!-- Log entries -->
 		<key name="scan_cluster_log_0001">Starting: [#!variable!program!#].</key>

share/words.xml

@@ -3179,6 +3179,7 @@ Proceed? [y/N]</key>
 		<key name="message_0354">This host is now configured to map the network.</key>
 		<key name="message_0355">This host is already NOT configured to map the network.</key>
 		<key name="message_0356">This host is no longer configured to map the network.</key>
+		<key name="message_0357">No hosts with IPMI found, done.</key>
 
 		<!-- Translate names (protocols, etc) -->
 		<key name="name_0001">Normal Password</key>	<!-- none in mail-server -->
@@ -3952,6 +3953,7 @@ We will try to proceed anyway.</key>
 </key>
 		<key name="warning_0163"><![CDATA[Failed to read the definition file: [#!variable!file!#] for the server: [#!variable!server_name!#] on the host: [#!variable!host_name!#]. If the host is online, it should update the next time scan-server runs.]]></key>
 		<key name="warning_0164"><![CDATA[Failed to update the definition file: [#!variable!file!#] for the server: [#!variable!server_name!#] on the host: [#!variable!host_name!#]. If the host is online, it should update the next time scan-server runs.]]></key>
+		<key name="warning_0165"><![CDATA[A duplicate variable was found! Section: [#!variable!section!#], name: [#!variable!name!#], source table: [#!variable!source_table!#], source_uuid: [#!variable!source_uuid!#], value: [#!variable!value!#]. This is older, so it will be deleted.]]></key>
 		
 	</language>
 	<!-- 日本語 -->

tools/anvil-configure-host

@@ -50,7 +50,7 @@ if (($< != 0) && ($> != 0))
 }
 
 # Connect
-$anvil->Database->connect();
+$anvil->Database->connect({debug => 2, check_for_resync => 1});
 $anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => 1, 'print' => 1, key => "message_0031"});
 $anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => 2, 'print' => 1, key => "log_0132"});
 if (not $anvil->data->{sys}{database}{connections})

tools/anvil-daemon

@@ -580,6 +580,16 @@ sub handle_periodic_tasks
 		$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { host_type => $host_type }});
 		if ($host_type eq "striker")
 		{
+			# Look for duplicates if we're the primary DB.
+			$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { 
+				"sys::database::primary_db" => $anvil->data->{sys}{database}{primary_db},
+				"Get->host_uuid"            => $anvil->Get->host_uuid, 
+			}});
+			if ($anvil->Get->host_uuid eq $anvil->data->{sys}{database}{primary_db})
+			{
+				$anvil->Database->_check_for_duplicates({debug => 2});
+			}
+			
 			# This can take a while, but it's been optimized to minimize how long it takes to 
 			# run. To be safe, we'll still background it.
 			my $shell_call = $anvil->data->{path}{exe}{'striker-get-screenshots'}.$anvil->Log->switches;

tools/striker-boot-machine

@@ -151,11 +151,16 @@ sub find_boot_method
 	}
 	
 	my $host_count = @{$hosts};
+	$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { host_count => $host_count }});
+	if (not $host_count)
+	{
+		$anvil->Log->entry({source => $THIS_FILE, line => __LINE__, 'print' => 1, level => 1, key => "message_0357"});
+		$anvil->Job->update_progress({progress => 100, message => "message_0357"});
+		$anvil->nice_exit({exit_code => 0});
+	}
+	
 	my $steps = int((80 / $host_count) / 3);
-	$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { 
+	$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { steps => $steps }});
-		host_count => $host_count, 
-		steps      => $steps,
-	}});
 	
 	$anvil->data->{sys}{progress} = 5;
 	foreach my $host_name (sort {$a cmp $b} @{$hosts})

tools/striker-manage-peers

@@ -60,7 +60,11 @@ if (($< != 0) && ($> != 0))
 }
 
 # We'll try to connect in case we're adding additional peers.
-$anvil->Database->connect();
+$anvil->data->{sys}{database}{resync_needed} = 1;
+$anvil->Database->connect({
+	debug            => 2,
+	check_for_resync => 1,
+});
 $anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => 2, secure => 0, key => "log_0132"});
 
 # Am I adding, editing or deleting?
@@ -537,7 +541,8 @@ sub process_entry
 			# Re-read the config.
 			$anvil->refresh();
 			
-			# Connect, and configure, if needed.
+			# Flag a resync, connect, and configure, if needed.
+			$anvil->data->{sys}{database}{resync_needed} = 1;
 			$anvil->Database->connect({
 				debug               => 3,
 				check_for_resync    => 1,
@@ -621,7 +626,12 @@ sub process_entry
 				
 				sleep 1;
 				
-				$anvil->Database->connect({check_for_resync => 1, db_uuid => $host_uuid});
+				$anvil->data->{sys}{database}{resync_needed} = 1;
+				$anvil->Database->connect({
+					debug            => 2,
+					check_for_resync => 1, 
+					db_uuid          => $host_uuid,
+				});
 				$anvil->Log->entry({source => $THIS_FILE, line => __LINE__, level => 2, secure => 0, key => "log_0132"});
 			}
 		}