raised reassembly timeout a bit.

Author: sbazerque

src/mesh/agents/network/SecureNetworkAgent.ts

@@ -342,7 +342,7 @@ class SecureNetworkAgent implements Agent {
         const toRemove = new Array<string>();
 
         for (const [id, partialMsg] of this.messageFragments.entries()) {
-            const timeout = Math.max(8000, 400 * partialMsg.fragCount) + partialMsg.created;
+            const timeout = Math.max(12000, 600 * partialMsg.fragCount) + partialMsg.created;
             const updateTimeout = Math.max(timeout, 6000 + partialMsg.updated);
             const now = Date.now();
 

src/mesh/agents/state/history/HistorySynchronizer.ts

@@ -955,16 +955,24 @@ class HistorySynchronizer {
                 try {
 
                     // throws if validation fails
+                    const t1 = Date.now()
                     await HashedObject.fromContextWithValidation(reqInfo.receivedObjects as Context, literal.hash);
+                    const t2 = Date.now()
+
+                    console.log('validated ' + literal.hash + ' in ' + (t2 - t1) + 'ms')
 
                     reqInfo.nextOpSequence = reqInfo.nextOpSequence as number + 1;
 
+                    const s1 = Date.now()
                     await this.syncAgent.store.saveWithContext(literal.hash, reqInfo.receivedObjects as Context);
+                    const s2 = Date.now()
+
+                    console.log('saved ' + literal.hash + ' in ' + (s2 - s1) + 'ms')
 
                     // FIXME: there's no validation of the op matching the actual causal history op
                     // TODO:  validate, remove op and all history following if op does not match
 
-                    this.opXferLog.debug('\n'+this.logPrefix+'\nReceived op ' + literal.hash + ' from request ' + reqInfo.request.requestId);
+                    this.opXferLog.debug('\n'+this.logPrefix+'\nReceived op ' + literal.hash + ' from request ' + reqInfo.request.requestId + '(was requested: ' + (reqInfo.request.requestedOps !== undefined && reqInfo.request.requestedOps.indexOf(literal.hash) >= 0) + ') ');
 
                     const removed = this.checkRequestRemoval(reqInfo);
 

src/storage/store/Store.ts

@@ -347,7 +347,6 @@ class Store {
             }
 
         }
-
     }
 
     async loadLiteral(hash: Hash): Promise<Literal | undefined> {