summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGubolin <gubolin@fantasymail.de>2015-03-08 15:04:58 +0100
committerGubolin <gubolin@fantasymail.de>2015-03-08 15:04:58 +0100
commit692486e3778a0b678151a671d4aa999e0536859f (patch)
tree76e8115600774fa7741ecdf243d84ec631897cbd
parentda6c1a37a3f760ec787299f5a7f2bbf1a149acf5 (diff)
downloadsnap-yow-692486e3778a0b678151a671d4aa999e0536859f.tar.gz
snap-yow-692486e3778a0b678151a671d4aa999e0536859f.zip
speed up connections to self
-rw-r--r--threads.js10
1 files changed, 8 insertions, 2 deletions
diff --git a/threads.js b/threads.js
index 2d1ce77..165c7fc 100644
--- a/threads.js
+++ b/threads.js
@@ -1299,16 +1299,22 @@ Process.prototype.doRemoveTemporaries = function () {
Process.prototype.sendPeerMessage = function (message, peer) {
var myself = this;
+ var stage = this.homeContext.receiver.parentThatIsA(StageMorph),
+ ide = this.homeContext.receiver.parentThatIsA(IDE_Morph);
+ console.log(peer, stage.peerId);
if (peer instanceof List) {
peer.asArray().forEach(function (singlePeer) {
myself.sendPeerMessage(message, singlePeer);
});
return;
}
+ if (peer == stage.peerId) {
+ console.log('hello self!');
+ stage.newPeerMessage(message, peer);
+ return;
+ }
- var stage = this.homeContext.receiver.parentThatIsA(StageMorph),
- ide = this.homeContext.receiver.parentThatIsA(IDE_Morph);
var connection = stage.peer.connect(peer, {reliable: true});
connection.on('open', function () {
var data;