summaryrefslogtreecommitdiff
path: root/threads.js
diff options
context:
space:
mode:
authorGubolin <gubolin@fantasymail.de>2015-03-20 20:53:20 +0100
committerGubolin <gubolin@fantasymail.de>2015-03-20 20:53:20 +0100
commit121cf8b3658909f79571b621e9a9916c7f601dfc (patch)
treeff2136892b76a278ecdb721894c628a08d66e9d9 /threads.js
parent9163b3ca714086e1877249bf38e47040bd1b3e67 (diff)
downloadsnap-yow-121cf8b3658909f79571b621e9a9916c7f601dfc.tar.gz
snap-yow-121cf8b3658909f79571b621e9a9916c7f601dfc.zip
create one peer per IDE
Diffstat (limited to 'threads.js')
-rw-r--r--threads.js14
1 files changed, 7 insertions, 7 deletions
diff --git a/threads.js b/threads.js
index d8ec04f..573b7fe 100644
--- a/threads.js
+++ b/threads.js
@@ -1308,12 +1308,12 @@ Process.prototype.sendPeerMessage = function (message, peer) {
});
return;
}
- if (peer == stage.peer.id) {
+ if (peer == ide.peer.id) {
stage.newPeerMessage(message, peer);
return;
}
- var connection = stage.peer.connect(peer, {reliable: true});
+ var connection = ide.peer.connect(peer, {reliable: true});
connection.on('open', function () {
var data;
if (typeof message == "string") {
@@ -1331,11 +1331,11 @@ Process.prototype.reportPeerList = function () {
var myself = this;
if (!this.context.wait) {
- var stage = this.homeContext.receiver.parentThatIsA(StageMorph);
- stage.peer.listAllPeers(function (peers) {
+ this.context.wait = true;
+ var ide = this.homeContext.receiver.parentThatIsA(IDE_Morph);
+ ide.peer.listAllPeers(function (peers) {
myself.context.result = new List(peers);
});
- this.context.wait = true;
} else if (this.context.result) {
return this.context.result;
}
@@ -1345,8 +1345,8 @@ Process.prototype.reportPeerList = function () {
};
Process.prototype.reportPeerId = function () {
- var stage = this.homeContext.receiver.parentThatIsA(StageMorph);
- return stage.peer.id;
+ var ide = this.homeContext.receiver.parentThatIsA(IDE_Morph);
+ return ide.peer.id;
};
// Process lists primitives