Changeset 253

Timestamp:

12/19/06 14:49:17 (2 years ago)

Author:

sacha

Message:

run statistics is more generic
command center supports individual b2bparties and cpas for dynamic directive creation

Files:

• branches/message-handling-refactor-branch/bin/run-command-center.rb (modified) (4 diffs)
• branches/message-handling-refactor-branch/bin/run-statistics.sh (modified) (1 diff)

branches/message-handling-refactor-branch/bin/run-command-center.rb

@@ -126 +126 @@
-
-def short_info_structure info_structure
-syncReply: %3$*4$s dup: %5$*2$s prot: %7$*2$s end: %9$*2$s", info_structure['info']['mc-ack
+ackSigReg: %3$*2$s syncReply: %5$*4$s dup: %7$*2$s prot: %9$*2$s end: %11$*2$s", info_structure['info']['mc-ackRequested'], 6, info_structure['info']['mc-ackSignature
-end
-
@@ -163 +163 @@
-      end
-    when "S"
-
+ "#{party_name}"
-    when "C"
-      command = "sh ./run-clear-system.sh"
@@ -258 +258 @@
-      number_directives = work_directive_dynamic_menu party_name, cpas_info, number_directives
-    when "S"
-
+ Coronation Gnaraloo
-    when "1"
-      command = "sh ./run-copy-ping-directive-n.sh #{number_directives || 1} &"
@@ -385 +385 @@
-    when "S"
-      puts "Statistics"
-
+ Coronation Gnaraloo
-    when "D"
-      system "clear"

branches/message-handling-refactor-branch/bin/run-statistics.sh

@@ -19 +19 @@
-echo -n " total: "
-ls -A /var/run/hefeweizen/tmp/ | wc -l
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
-
+
+info_states_of_messages()
+{
+
+    party=$1
+    search=$2
+    search_text=$3
+    total_delivered=0
+    total_failed=0
+    total_received=0
+    total_sent=0
+    total_failed_to_send=0
+    for i in $(find $MESSAGE_DIR/$party/ -name "$search" -printf "%h\n" ); do
+
+        delivered=$(find $i -name "state__delivered" -print | wc -l)
+        let total_delivered=$total_delivered+$delivered
+        failed=$(find $i -name "state__failed" -print | wc -l)
+        let total_failed=$total_failed+$failed
+        received=$(find $i -name "state__received" -print | wc -l)
+        let total_received=$total_received+$received
+        sent=$(find $i -name "state__sent" -print | wc -l)
+        let total_sent=$total_sent+$sent
+        failed_to_send=$(find $i -name "state__failed_to_send" -print | wc -l)
+        let total_failed_to_send=$total_faild_to_send+$failed_to_send
+    done
+    echo -n "              # delivered $search_text      : "
+    echo $total_delivered
+    echo -n "              # failed $search_text         : "
+    echo $total_failed
+    echo -n "              # received $search_text       : "
+    echo $total_received
+    echo -n "              # sent $search_text           : "
+    echo $total_sent
+    echo -n "              # failed_to_send $search_text : "
+    echo $total_failed_to_send
+}
+
+info_party()
+{
+    party=$1
+    echo -n "$party number ebXML messages : "
+    ls -A $MESSAGE_DIR/$party | wc -l
+    
+    echo -n "      # user ebXML messages      : "
+    find $MESSAGE_DIR/$party/ -name "is_user_message" -print | wc -l
+    info_states_of_messages $party "is_user_message" "user ebXML message"
+    
+    echo -n "      # signal ebXML messages    : "
+    find $MESSAGE_DIR/$party/ -name "is_ebMS_signal" -print | wc -l
+    info_states_of_messages $party "is_ebMS_signal" "signal ebMS message"
+    
+    echo -n "$party number conversations  : "
+    ls -A $CONVERSATION_DIR/$party | wc -l
+    echo -n "$party outgoing directives   : "
+    ls -A $SPOOL_DIR/coronation/outgoing/directives | wc -l
+    echo -n "$party incoming directives   : "
+    ls -A $SPOOL_DIR/coronation/incoming/directives | wc -l
+    echo -n "$party incoming payloads     : "
+    ls -A $SPOOL_DIR/coronation/incoming/payloads | wc -l
+    echo -n "$party errors                : "
+    ls -A $SPOOL_DIR/coronation/errors | wc -l
+    echo
+}
+
+for i in $* ; do
+    info_party $i
+done
+
+
+
+