use all cores for eventgen

Author: vans163

ex/lib/api/api_tx.ex

@@ -157,6 +157,12 @@ defmodule API.TX do
 
         tx = put_in(tx, [:tx, :action], action)
 
+        tx = if !tx[:receipt] do tx else
+          logs = Enum.map(tx.receipt.logs, fn(line)-> RocksDB.ascii_dump(line) end)
+          receipt = Map.merge(tx.receipt, %{result: RocksDB.ascii_dump(tx.receipt.result), logs: logs})
+          Map.put(tx, :receipt, receipt)
+        end
+
         if !Map.has_key?(tx, :metadata) do tx else
             put_in(tx, [:metadata, :entry_hash], Base58.encode(tx.metadata.entry_hash))
         end

ex/lib/api/db_chain.ex

@@ -55,12 +55,7 @@ defmodule DB.Chain do
           entry = DB.Entry.by_hash(map.entry_hash, db_opts)
           tx_bytes = binary_part(entry_bytes, map.index_start, map.index_size)
 
-          receipt = if map[:result] do map.result else
-            receipt = map.receipt
-            result = RocksDB.ascii_dump(receipt.result)
-            logs = Enum.map(receipt.logs, & RocksDB.ascii_dump(&1))
-            Map.merge(receipt, %{result: result, logs: logs})
-          end
+          receipt = if map[:result] do map.result else map.receipt end
 
           TX.unpack(tx_bytes)
           |> Map.put(:receipt, receipt)

ex/lib/consensus/coordination/fabric_event_gen.ex

@@ -51,10 +51,14 @@ defmodule FabricEventGen do
     end
 
     #IO.inspect API.Chain.format_entry_for_client(entry), limit: 11111
-    entry_b58 = API.Chain.format_entry_for_client(entry)
-    txs = Enum.map(entry.txs, fn(txu)->
-      API.TX.format_tx_for_client(txu)
+    txs_task = Task.async(fn ->
+      entry.txs
+      |> Task.async_stream(fn txu -> API.TX.format_tx_for_client(txu) end)
+      |> Enum.map(fn {:ok, res} -> res end)
     end)
+    entry_b58 = API.Chain.format_entry_for_client(entry)
+    txs = Task.await(txs_task, :infinity)
+
     broadcast({:update_stats_entry_tx, API.Chain.stats(), entry_b58, txs})
 
     {:noreply, state}