fix qa failures caused by libvalkey migration

Author: sfeifer

qa/1543.out

@@ -59,7 +59,9 @@ _filter_key_server_err()
 {
     sed \
     -e 's;ERR syntax error;expected error;' \
-    -e 's;Parse command error.*;expected error;'
+    -e 's;Failed to find keys of command.*;expected error;' \
+    -e 's;Unknown command.*;expected error;' \
+    -e 's;Command parse error;expected error;'
 }
 
 _stop_auto_restart pmproxy

qa/1602

@@ -96,7 +96,35 @@ fi
 
 echo; echo === /metrics webapi listing. The instname label should appear only once.
 curl -Gs 'http://localhost:44322/metrics?names=openmetrics.duplicate_instname_label.somemetric' \
-| _filter_openmetrics_labels
+| _filter_openmetrics_labels \
+| awk '{
+    if (match($0, /\{[^}]+\}/)) {
+        prefix = substr($0, 1, RSTART-1)
+        labels_str = substr($0, RSTART+1, RLENGTH-2)
+        suffix = substr($0, RSTART+RLENGTH)
+        
+        split("", labels)
+        n = split(labels_str, pairs, ",")
+        for (i = 1; i <= n; i++) {
+            split(pairs[i], kv, "=")
+            labels[kv[1]] = kv[2]
+        }
+        
+        order = "script agent hostname instid instname domainname machineid source"
+        split(order, keys, " ")
+        result = ""
+        for (i = 1; i <= 8; i++) {
+            key = keys[i]
+            if (key in labels) {
+                if (result != "") result = result ","
+                result = result key "=" labels[key]
+            }
+        }
+        print prefix "{" result "}" suffix
+    } else {
+        print
+    }
+}'
 
 echo; echo === verify metric name validity using pminfo
 pminfo -v openmetrics

qa/1727

@@ -56,6 +56,45 @@ _filter_opentelemetry_labels()
     # end
 }
 
+_reorder_labels()
+{
+    awk '
+    /^[^#].*{.*=.*}/ {
+        match($0, /^([^{]+){([^}]+)}(.*)$/, a)
+        metric = a[1]
+        labels_str = a[2]
+        rest = a[3]
+        
+        delete labels
+        n = split(labels_str, pairs, ",")
+        for (i = 1; i <= n; i++) {
+            match(pairs[i], /^([^=]+)=(.+)$/, kv)
+            key = kv[1]
+            value = kv[2]
+            labels[key] = value
+        }
+        
+        order = "url agent hostname domainname machineid source my_sum_attribute"
+        split(order, order_arr, " ")
+        
+        output = metric "{"
+        first = 1
+        for (i = 1; i <= length(order_arr); i++) {
+            key = order_arr[i]
+            if (key in labels) {
+                if (!first) output = output ","
+                output = output key "=" labels[key]
+                first = 0
+            }
+        }
+        output = output "}" rest
+        print output
+        next
+    }
+    {print}
+    '
+}
+
 need_restore=true
 _prepare_pmda opentelemetry
 trap "_cleanup; exit \$status" 0 1 2 3 15
@@ -83,7 +122,7 @@ fi
 
 echo; echo === /metrics webapi listing. The instname label should appear only once.
 curl -Gs 'http://localhost:44322/metrics?names=opentelemetry.duplicate.somemetric' \
-| _filter_opentelemetry_labels
+| _filter_opentelemetry_labels | _reorder_labels
 
 echo; echo === verify metric name validity using pminfo
 pminfo -v opentelemetry

qa/1890

@@ -11,14 +11,14 @@ Check bpf metrics have appeared ... X metrics and X values
 == Running pmdabpf with valgrind
 === std out ===
 
-bpf.disk.all.latency PMID: 157.1.0 [Disk latency]
-    Data Type: 64-bit unsigned int  InDom: 157.3 0x27400003
+bpf.disk.all.latency PMID: 157.0.0 [Disk latency]
+    Data Type: 64-bit unsigned int  InDom: 157.2 0x27400002
     Semantics: counter  Units: microsec
 Help:
 Disk latency histogram across all disks, for both reads and writes.
 
-bpf.runq.latency PMID: 157.0.0 [Run queue latency (ns)]
-    Data Type: 64-bit unsigned int  InDom: 157.2 0x27400002
+bpf.runq.latency PMID: 157.1.0 [Run queue latency (ns)]
+    Data Type: 64-bit unsigned int  InDom: 157.3 0x27400003
     Semantics: counter  Units: nanosec
 Help:
 Run queue latency from task switches,

qa/1900.out

@@ -300,4 +300,5 @@ PCP_WEB_1.23 {
     dictGetKey;
     dictInitIterator;
     dictSetVal;
+    keySlotsContextFree;
 } PCP_WEB_1.22;

qa/662.out

@@ -32,6 +32,7 @@
 
 #include <valkey/valkey.h>
 #include <valkey/async.h>
+#include <valkey/cluster.h>
 
 #define RESP_OK			VALKEY_OK
 #define RESP_ERR		VALKEY_ERR
@@ -91,6 +92,9 @@
 #define keyClusterAsyncFormattedCommand valkeyClusterAsyncFormattedCommand
 #define keyClusterAsyncFormattedCommandToNode valkeyClusterAsyncFormattedCommandToNode
 
+/* valkey cluster options */
+#define KEYOPT_BLOCKING_INITIAL_UPDATE VALKEY_OPT_BLOCKING_INITIAL_UPDATE
+
 extern const char *resp_reply_type(respReply *);
 extern int keysAsyncEnableKeepAlive(keysAsyncContext *);
 

src/libpcp_web/src/exports.in

@@ -133,7 +133,7 @@ key_map_publish(keyMapBaton *baton)
     sdsfree(msg);
     sdsfree(key);
 
-    keySlotsRequest(baton->slots, cmd, key_map_publish_callback, baton);
+    keySlotsRequestFirstNode(baton->slots, cmd, key_map_publish_callback, baton);
     sdsfree(cmd);
 }