MCPcopy Index your code
hub / github.com/totaljs/framework / message

Function message

cluster.js:380–425  ·  view source on GitHub ↗
(m)

Source from the content-addressed store, hash-verified

378}
379
380function message(m) {
381
382 if (m === 'total:ready') {
383 CONTINUE = true;
384 this.$ready = true;
385 return;
386 }
387
388 if (m === 'total:ping') {
389 this.$ping = Date.now() - this.$ping_beg;
390 return;
391 }
392
393 if (m === 'total:update') {
394 for (var i = 1, length = FORKS.length; i < length; i++)
395 FORKS[i] && FORKS[i].$ready && FORKS[i].send(m);
396 return;
397 }
398
399 if (m.TYPE === 'master') {
400 if (MASTER && MASTER[m.name]) {
401 for (var i = 0, length = MASTER[m.name].length; i < length; i++)
402 MASTER[m.name][i](m.a, m.b, m.c, m.d, m.e);
403 }
404 } else if (m.TYPE === 'snapshot') {
405 var is = false;
406 STATS[i];
407 for (var i = 0; i < STATS.length; i++) {
408 if (STATS[i].id === m.data.id) {
409 m.data.ping = this.$ping;
410 STATS[i] = m.data;
411 is = true;
412 break;
413 }
414 }
415 !is && STATS.push(m.data);
416 } else {
417
418 if (m.target === 'master') {
419 exports.res(m);
420 } else {
421 for (var i = 0, length = FORKS.length; i < length; i++)
422 FORKS[i] && FORKS[i].$ready && FORKS[i].send(m);
423 }
424 }
425}
426
427function mastersend(m) {
428 for (var i = 0, length = FORKS.length; i < length; i++)

Callers 1

cluster.jsFile · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected