Commit d05b0a6b310964c2e5fd32ad53278ff8db0603eb
dump some useful information about view state
Dominic Tarr committed on 4/15/2017, 7:08:56 PMParent: 631d5188760440036b222ab5076289ad46fb76ea
Files changed
| index.js | changed |
| index.js | ||
|---|---|---|
| @@ -70,25 +70,35 @@ | ||
| 70 | 70 … | } |
| 71 | 71 … | return { |
| 72 | 72 … | since: ssb.since.value, |
| 73 | 73 … | plugins: plugs, |
| 74 | - sync: sync | |
| 74 … | + sync: sync, | |
| 75 | 75 … | } |
| 76 | 76 … | } |
| 77 | 77 … | |
| 78 … | + var _views, _prev | |
| 79 … | + | |
| 78 | 80 … | var state = since() |
| 79 | 81 … | setInterval(function (){ |
| 80 | 82 … | var _state = since() |
| 83 … | + if(_state.since == undefined) return | |
| 81 | 84 … | if(state && !state.sync && !_state.sync && state.since == _state.since) { |
| 82 | - console.log(state, _state) | |
| 83 | - //flume is stuck again. | |
| 84 | - require('fs').appendFileSync('stuck.log', JSON.stringify({ | |
| 85 | - time: new Date(), | |
| 86 | - state: state | |
| 87 | - }, null, 2) + '\n\n') | |
| 88 | - throw new Error('flume is stuck') | |
| 85 … | + var c = 0, t = 0 | |
| 86 … | + | |
| 87 … | + for(var k in _state.plugins) { | |
| 88 … | + c += state.plugins[k] | |
| 89 … | + t++ | |
| 90 … | + } | |
| 91 … | + | |
| 92 … | + if(c/t !== _views || c/t != _state.since) { | |
| 93 … | + console.log('Rebuilding Indexes:', c/t, _views, (c/t)/_state.since) | |
| 94 … | + } | |
| 89 | 95 … | } |
| 96 … | + else if(_state.since != _prev) | |
| 97 … | + console.log("indexes synchronised:", _state.since) | |
| 98 … | + | |
| 90 | 99 … | state = _state |
| 100 … | + _prev = state.since | |
| 91 | 101 … | }, 1000).unref() |
| 92 | 102 … | |
| 93 | 103 … | return { |
| 94 | 104 … | id : feed.id, |
| @@ -105,11 +115,10 @@ | ||
| 105 | 115 … | close : valid.async(close), |
| 106 | 116 … | |
| 107 | 117 … | publish : valid.async(feed.add, 'string|msgContent'), |
| 108 | 118 … | add : valid.async(ssb.add, 'msg'), |
| 109 | - get : valid.async(ssb.get, 'msgId'), | |
| 119 … | + get : valid.async(ssb.get, 'msgId|number'), | |
| 110 | 120 … | |
| 111 | - pre : ssb.pre, | |
| 112 | 121 … | post : ssb.post, |
| 113 | 122 … | |
| 114 | 123 … | since : since, |
| 115 | 124 … | |
| @@ -173,4 +182,22 @@ | ||
| 173 | 182 … | |
| 174 | 183 … | |
| 175 | 184 … | |
| 176 | 185 … | |
| 186 … | + | |
| 187 … | + | |
| 188 … | + | |
| 189 … | + | |
| 190 … | + | |
| 191 … | + | |
| 192 … | + | |
| 193 … | + | |
| 194 … | + | |
| 195 … | + | |
| 196 … | + | |
| 197 … | + | |
| 198 … | + | |
| 199 … | + | |
| 200 … | + | |
| 201 … | + | |
| 202 … | + | |
| 203 … | + | |
Built with git-ssb-web