tests/index.jsView |
---|
16 | 16 … | if (port) { |
17 | 17 … | this.kernel.ports.bind('root', port) |
18 | 18 … | } |
19 | 19 … | } |
20 | | - static get type () { |
| 20 … | + static get typeId () { |
21 | 21 … | return 9 |
22 | 22 … | } |
23 | 23 … | } |
24 | 24 … | |
38 | 38 … | |
39 | 39 … | const hypervisor = new Hypervisor(node.dag) |
40 | 40 … | hypervisor.registerContainer(testVMContainer) |
41 | 41 … | |
42 | | - const rootContainer = await hypervisor.createInstance(testVMContainer.type) |
| 42 … | + const rootContainer = await hypervisor.createInstance(testVMContainer.typeId) |
43 | 43 … | |
44 | 44 … | const [portRef1, portRef2] = rootContainer.ports.createChannel() |
45 | 45 … | const initMessage = rootContainer.createMessage({ |
46 | 46 … | data: Buffer.from('test code'), |
47 | 47 … | ports: [portRef2] |
48 | 48 … | }) |
49 | 49 … | |
50 | | - rootContainer.createInstance(testVMContainer.type, initMessage) |
| 50 … | + rootContainer.createInstance(testVMContainer.typeId, initMessage) |
51 | 51 … | |
52 | 52 … | rootContainer.ports.bind('first', portRef1) |
53 | 53 … | message = rootContainer.createMessage() |
54 | 54 … | rootContainer.send(portRef1, message) |
70 | 70 … | |
71 | 71 … | const hypervisor = new Hypervisor(node.dag) |
72 | 72 … | hypervisor.registerContainer(testVMContainer) |
73 | 73 … | |
74 | | - const root = await hypervisor.createInstance(testVMContainer.type) |
| 74 … | + const root = await hypervisor.createInstance(testVMContainer.typeId) |
75 | 75 … | const [portRef1, portRef2] = root.ports.createChannel() |
76 | 76 … | |
77 | 77 … | root.ports.bind('one', portRef1) |
78 | | - root.createInstance(testVMContainer.type, root.createMessage({ |
| 78 … | + root.createInstance(testVMContainer.typeId, root.createMessage({ |
79 | 79 … | ports: [portRef2] |
80 | 80 … | })) |
81 | 81 … | |
82 | 82 … | const stateRoot = await hypervisor.createStateRoot(Infinity) |
93 | 93 … | class testVMContainer2 extends BaseContainer { |
94 | 94 … | onMessage (m) { |
95 | 95 … | t.true(m === message, 'should recive a message') |
96 | 96 … | } |
97 | | - static get type () { |
| 97 … | + static get typeId () { |
98 | 98 … | return 99 |
99 | 99 … | } |
100 | 100 … | } |
101 | 101 … | |
102 | 102 … | class testVMContainer extends BaseContainer { |
103 | 103 … | onMessage (m) { |
104 | 104 … | const [portRef1, portRef2] = this.kernel.ports.createChannel() |
105 | | - this.kernel.createInstance(testVMContainer2.type, this.kernel.createMessage({ |
| 105 … | + this.kernel.createInstance(testVMContainer2.typeId, this.kernel.createMessage({ |
106 | 106 … | ports: [portRef2] |
107 | 107 … | })) |
108 | 108 … | this.kernel.ports.bind('child', portRef1) |
109 | 109 … | this.kernel.incrementTicks(2) |
114 | 114 … | const hypervisor = new Hypervisor(node.dag) |
115 | 115 … | hypervisor.registerContainer(testVMContainer) |
116 | 116 … | hypervisor.registerContainer(testVMContainer2) |
117 | 117 … | |
118 | | - const root = await hypervisor.createInstance(testVMContainer.type) |
| 118 … | + const root = await hypervisor.createInstance(testVMContainer.typeId) |
119 | 119 … | const [portRef1, portRef2] = root.ports.createChannel() |
120 | | - root.createInstance(testVMContainer.type, root.createMessage({ |
| 120 … | + root.createInstance(testVMContainer.typeId, root.createMessage({ |
121 | 121 … | ports: [portRef2] |
122 | 122 … | })) |
123 | 123 … | |
124 | 124 … | root.ports.bind('first', portRef1) |
150 | 150 … | }, 200) |
151 | 151 … | }) |
152 | 152 … | } |
153 | 153 … | |
154 | | - static get type () { |
| 154 … | + static get typeId () { |
155 | 155 … | return 99 |
156 | 156 … | } |
157 | 157 … | } |
158 | 158 … | |
159 | 159 … | class testVMContainer extends BaseContainer { |
160 | 160 … | onMessage (m) { |
161 | 161 … | const [portRef1, portRef2] = this.kernel.ports.createChannel() |
162 | | - this.kernel.createInstance(testVMContainer2.type, this.kernel.createMessage({ |
| 162 … | + this.kernel.createInstance(testVMContainer2.typeId, this.kernel.createMessage({ |
163 | 163 … | ports: [portRef2] |
164 | 164 … | })) |
165 | 165 … | this.kernel.ports.bind('child', portRef1) |
166 | 166 … | this.kernel.send(portRef1, m) |
171 | 171 … | const hypervisor = new Hypervisor(node.dag) |
172 | 172 … | hypervisor.registerContainer(testVMContainer) |
173 | 173 … | hypervisor.registerContainer(testVMContainer2) |
174 | 174 … | |
175 | | - let root = await hypervisor.createInstance(testVMContainer.type) |
| 175 … | + let root = await hypervisor.createInstance(testVMContainer.typeId) |
176 | 176 … | const rootId = root.id |
177 | 177 … | const [portRef1, portRef2] = root.ports.createChannel() |
178 | | - root.createInstance(testVMContainer.type, root.createMessage({ |
| 178 … | + root.createInstance(testVMContainer.typeId, root.createMessage({ |
179 | 179 … | ports: [portRef2] |
180 | 180 … | })) |
181 | 181 … | |
182 | 182 … | root.ports.bind('first', portRef1) |
223 | 223 … | const message3 = this.kernel.createMessage({ |
224 | 224 … | ports: [portRef6] |
225 | 225 … | }) |
226 | 226 … | |
227 | | - this.kernel.createInstance(Root.type, message1) |
228 | | - this.kernel.createInstance(Root.type, message2) |
229 | | - this.kernel.createInstance(Root.type, message3) |
| 227 … | + this.kernel.createInstance(Root.typeId, message1) |
| 228 … | + this.kernel.createInstance(Root.typeId, message2) |
| 229 … | + this.kernel.createInstance(Root.typeId, message3) |
230 | 230 … | |
231 | 231 … | throw new Error('it is a trap!!!') |
232 | 232 … | } |
233 | 233 … | } |
234 | 234 … | |
235 | 235 … | const hypervisor = new Hypervisor(node.dag) |
236 | 236 … | |
237 | 237 … | hypervisor.registerContainer(Root) |
238 | | - const root = await hypervisor.createInstance(Root.type) |
| 238 … | + const root = await hypervisor.createInstance(Root.typeId) |
239 | 239 … | await root.message(root.createMessage()) |
240 | 240 … | const stateRoot = await hypervisor.createStateRoot() |
241 | 241 … | |
242 | 242 … | t.deepEquals(stateRoot, { |
265 | 265 … | const message2 = this.kernel.createMessage({ |
266 | 266 … | ports: [portRef4] |
267 | 267 … | }) |
268 | 268 … | |
269 | | - this.kernel.createInstance(First.type, message1) |
270 | | - this.kernel.createInstance(Second.type, message2) |
| 269 … | + this.kernel.createInstance(First.typeId, message1) |
| 270 … | + this.kernel.createInstance(Second.typeId, message2) |
271 | 271 … | |
272 | 272 … | this.kernel.send(portRef1, this.kernel.createMessage()) |
273 | 273 … | this.kernel.send(portRef3, this.kernel.createMessage()) |
274 | 274 … | } else if (runs === 1) { |
287 | 287 … | data: 'first' |
288 | 288 … | })) |
289 | 289 … | } |
290 | 290 … | |
291 | | - static get type () { |
| 291 … | + static get typeId () { |
292 | 292 … | return 99 |
293 | 293 … | } |
294 | 294 … | } |
295 | 295 … | |
300 | 300 … | data: 'second' |
301 | 301 … | })) |
302 | 302 … | } |
303 | 303 … | |
304 | | - static get type () { |
| 304 … | + static get typeId () { |
305 | 305 … | return 299 |
306 | 306 … | } |
307 | 307 … | } |
308 | 308 … | |
311 | 311 … | hypervisor.registerContainer(Root) |
312 | 312 … | hypervisor.registerContainer(First) |
313 | 313 … | hypervisor.registerContainer(Second) |
314 | 314 … | |
315 | | - const root = await hypervisor.createInstance(Root.type) |
| 315 … | + const root = await hypervisor.createInstance(Root.typeId) |
316 | 316 … | |
317 | 317 … | const [portRef1, portRef2] = root.ports.createChannel() |
318 | | - root.createInstance(Root.type, root.createMessage({ |
| 318 … | + root.createInstance(Root.typeId, root.createMessage({ |
319 | 319 … | ports: [portRef2] |
320 | 320 … | })) |
321 | 321 … | |
322 | 322 … | root.ports.bind('first', portRef1) |
345 | 345 … | const message2 = this.kernel.createMessage({ |
346 | 346 … | ports: [portRef4] |
347 | 347 … | }) |
348 | 348 … | |
349 | | - this.kernel.createInstance(First.type, message1) |
350 | | - this.kernel.createInstance(Second.type, message2) |
| 349 … | + this.kernel.createInstance(First.typeId, message1) |
| 350 … | + this.kernel.createInstance(Second.typeId, message2) |
351 | 351 … | |
352 | 352 … | this.kernel.send(portRef1, this.kernel.createMessage()) |
353 | 353 … | this.kernel.send(portRef3, this.kernel.createMessage()) |
354 | 354 … | } else if (runs === 1) { |
358 | 358 … | t.equals(m.data, 'first', 'should recive the first message') |
359 | 359 … | } |
360 | 360 … | } |
361 | 361 … | |
362 | | - static get type () { |
| 362 … | + static get typeId () { |
363 | 363 … | return 99 |
364 | 364 … | } |
365 | 365 … | } |
366 | 366 … | |
371 | 371 … | data: 'first' |
372 | 372 … | })) |
373 | 373 … | } |
374 | 374 … | |
375 | | - static get type () { |
| 375 … | + static get typeId () { |
376 | 376 … | return 299 |
377 | 377 … | } |
378 | 378 … | } |
379 | 379 … | |
391 | 391 … | hypervisor.registerContainer(Root) |
392 | 392 … | hypervisor.registerContainer(First) |
393 | 393 … | hypervisor.registerContainer(Second) |
394 | 394 … | |
395 | | - const root = await hypervisor.createInstance(Root.type) |
| 395 … | + const root = await hypervisor.createInstance(Root.typeId) |
396 | 396 … | |
397 | 397 … | const [portRef1, portRef2] = root.ports.createChannel() |
398 | | - root.createInstance(Root.type, root.createMessage({ |
| 398 … | + root.createInstance(Root.typeId, root.createMessage({ |
399 | 399 … | ports: [portRef2] |
400 | 400 … | })) |
401 | 401 … | |
402 | 402 … | root.ports.bind('first', portRef1) |
424 | 424 … | const message2 = this.kernel.createMessage({ |
425 | 425 … | ports: [portRef4] |
426 | 426 … | }) |
427 | 427 … | |
428 | | - this.kernel.createInstance(First.type, message1) |
429 | | - this.kernel.createInstance(Second.type, message2) |
| 428 … | + this.kernel.createInstance(First.typeId, message1) |
| 429 … | + this.kernel.createInstance(Second.typeId, message2) |
430 | 430 … | |
431 | 431 … | this.kernel.send(portRef1, this.kernel.createMessage()) |
432 | 432 … | this.kernel.send(portRef3, this.kernel.createMessage()) |
433 | 433 … | |
438 | 438 … | } else if (runs === 2) { |
439 | 439 … | t.equals(m.data, 'second', 'should recived the second message') |
440 | 440 … | } |
441 | 441 … | } |
442 | | - static get type () { |
| 442 … | + static get typeId () { |
443 | 443 … | return 299 |
444 | 444 … | } |
445 | 445 … | } |
446 | 446 … | |
450 | 450 … | this.kernel.send(m.fromPort, this.kernel.createMessage({ |
451 | 451 … | data: 'first' |
452 | 452 … | })) |
453 | 453 … | } |
454 | | - static get type () { |
| 454 … | + static get typeId () { |
455 | 455 … | return 2 |
456 | 456 … | } |
457 | 457 … | } |
458 | 458 … | |
470 | 470 … | hypervisor.registerContainer(Root) |
471 | 471 … | hypervisor.registerContainer(First) |
472 | 472 … | hypervisor.registerContainer(Second) |
473 | 473 … | |
474 | | - const root = await hypervisor.createInstance(Root.type) |
| 474 … | + const root = await hypervisor.createInstance(Root.typeId) |
475 | 475 … | const [portRef1, portRef2] = root.ports.createChannel() |
476 | | - root.createInstance(Root.type, root.createMessage({ |
| 476 … | + root.createInstance(Root.typeId, root.createMessage({ |
477 | 477 … | ports: [portRef2] |
478 | 478 … | })) |
479 | 479 … | |
480 | 480 … | root.ports.bind('first', portRef1) |
502 | 502 … | const message2 = this.kernel.createMessage({ |
503 | 503 … | ports: [portRef4] |
504 | 504 … | }) |
505 | 505 … | |
506 | | - this.kernel.createInstance(First.type, message1) |
507 | | - this.kernel.createInstance(Second.type, message2) |
| 506 … | + this.kernel.createInstance(First.typeId, message1) |
| 507 … | + this.kernel.createInstance(Second.typeId, message2) |
508 | 508 … | |
509 | 509 … | this.kernel.send(portRef1, this.kernel.createMessage()) |
510 | 510 … | this.kernel.send(portRef3, this.kernel.createMessage()) |
511 | 511 … | |
517 | 517 … | runs++ |
518 | 518 … | t.equals(m.data, 'second', 'should recived the second message') |
519 | 519 … | } |
520 | 520 … | } |
521 | | - static get type () { |
| 521 … | + static get typeId () { |
522 | 522 … | return 299 |
523 | 523 … | } |
524 | 524 … | } |
525 | 525 … | |
529 | 529 … | this.kernel.send(m.fromPort, this.kernel.createMessage({ |
530 | 530 … | data: 'first' |
531 | 531 … | })) |
532 | 532 … | } |
533 | | - static get type () { |
| 533 … | + static get typeId () { |
534 | 534 … | return 29 |
535 | 535 … | } |
536 | 536 … | } |
537 | 537 … | |
541 | 541 … | this.kernel.send(m.fromPort, this.kernel.createMessage({ |
542 | 542 … | data: 'second' |
543 | 543 … | })) |
544 | 544 … | } |
545 | | - static get type () { |
| 545 … | + static get typeId () { |
546 | 546 … | return 2 |
547 | 547 … | } |
548 | 548 … | } |
549 | 549 … | |
563 | 563 … | hypervisor.registerContainer(First) |
564 | 564 … | hypervisor.registerContainer(Second) |
565 | 565 … | hypervisor.registerContainer(Waiter) |
566 | 566 … | |
567 | | - const root = await hypervisor.createInstance(Root.type) |
| 567 … | + const root = await hypervisor.createInstance(Root.typeId) |
568 | 568 … | const [portRef1, portRef2] = root.ports.createChannel() |
569 | 569 … | |
570 | 570 … | const message = root.createMessage() |
571 | 571 … | root.send(portRef1, message) |
572 | 572 … | root.ports.bind('first', portRef1) |
573 | | - root.createInstance(Root.type, root.createMessage({ |
| 573 … | + root.createInstance(Root.typeId, root.createMessage({ |
574 | 574 … | ports: [portRef2] |
575 | 575 … | })) |
576 | 576 … | |
577 | 577 … | const [portRef3, portRef4] = root.ports.createChannel() |
578 | 578 … | root.ports.bind('sencond', portRef3) |
579 | | - root.createInstance(Waiter.type, root.createMessage({ |
| 579 … | + root.createInstance(Waiter.typeId, root.createMessage({ |
580 | 580 … | ports: [portRef4] |
581 | 581 … | })) |
582 | 582 … | |
583 | 583 … | root.incrementTicks(100) |
606 | 606 … | const message2 = this.kernel.createMessage({ |
607 | 607 … | ports: [portRef4] |
608 | 608 … | }) |
609 | 609 … | |
610 | | - this.kernel.createInstance(First.type, message1) |
611 | | - this.kernel.createInstance(Second.type, message2) |
| 610 … | + this.kernel.createInstance(First.typeId, message1) |
| 611 … | + this.kernel.createInstance(Second.typeId, message2) |
612 | 612 … | |
613 | 613 … | this.kernel.send(portRef1, this.kernel.createMessage()) |
614 | 614 … | this.kernel.send(portRef3, this.kernel.createMessage()) |
615 | 615 … | |
620 | 620 … | } else if (runs === 2) { |
621 | 621 … | t.equals(m.data, 'first', 'should recive the first message') |
622 | 622 … | } |
623 | 623 … | } |
624 | | - static get type () { |
| 624 … | + static get typeId () { |
625 | 625 … | return 299 |
626 | 626 … | } |
627 | 627 … | } |
628 | 628 … | |
632 | 632 … | this.kernel.send(m.fromPort, this.kernel.createMessage({ |
633 | 633 … | data: 'first' |
634 | 634 … | })) |
635 | 635 … | } |
636 | | - static get type () { |
| 636 … | + static get typeId () { |
637 | 637 … | return 29 |
638 | 638 … | } |
639 | 639 … | } |
640 | 640 … | |
644 | 644 … | this.kernel.send(m.fromPort, this.kernel.createMessage({ |
645 | 645 … | data: 'second' |
646 | 646 … | })) |
647 | 647 … | } |
648 | | - static get type () { |
| 648 … | + static get typeId () { |
649 | 649 … | return 2 |
650 | 650 … | } |
651 | 651 … | } |
652 | 652 … | |
655 | 655 … | hypervisor.registerContainer(Root) |
656 | 656 … | hypervisor.registerContainer(First) |
657 | 657 … | hypervisor.registerContainer(Second) |
658 | 658 … | |
659 | | - const root = await hypervisor.createInstance(Root.type) |
| 659 … | + const root = await hypervisor.createInstance(Root.typeId) |
660 | 660 … | const [portRef1, portRef2] = root.ports.createChannel() |
661 | 661 … | const message = root.createMessage() |
662 | 662 … | |
663 | 663 … | root.send(portRef1, message) |
664 | 664 … | root.ports.bind('first', portRef1) |
665 | | - root.createInstance(Root.type, root.createMessage({ |
| 665 … | + root.createInstance(Root.typeId, root.createMessage({ |
666 | 666 … | ports: [portRef2] |
667 | 667 … | })) |
668 | 668 … | }) |
669 | 669 … | |
688 | 688 … | const message2 = this.kernel.createMessage({ |
689 | 689 … | ports: [portRef4] |
690 | 690 … | }) |
691 | 691 … | |
692 | | - this.kernel.createInstance(First.type, message1) |
693 | | - this.kernel.createInstance(Second.type, message2) |
| 692 … | + this.kernel.createInstance(First.typeId, message1) |
| 693 … | + this.kernel.createInstance(Second.typeId, message2) |
694 | 694 … | |
695 | 695 … | this.kernel.send(portRef1, this.kernel.createMessage()) |
696 | 696 … | this.kernel.send(portRef3, this.kernel.createMessage()) |
697 | 697 … | |
702 | 702 … | } else if (runs === 2) { |
703 | 703 … | t.equals(m.data, 'second', 'should recived the second message') |
704 | 704 … | } |
705 | 705 … | } |
706 | | - static get type () { |
| 706 … | + static get typeId () { |
707 | 707 … | return 299 |
708 | 708 … | } |
709 | 709 … | } |
710 | 710 … | |
714 | 714 … | this.kernel.send(m.fromPort, this.kernel.createMessage({ |
715 | 715 … | data: 'first' |
716 | 716 … | })) |
717 | 717 … | } |
718 | | - static get type () { |
| 718 … | + static get typeId () { |
719 | 719 … | return 29 |
720 | 720 … | } |
721 | 721 … | } |
722 | 722 … | |
734 | 734 … | hypervisor.registerContainer(Root) |
735 | 735 … | hypervisor.registerContainer(First) |
736 | 736 … | hypervisor.registerContainer(Second) |
737 | 737 … | |
738 | | - const root = await hypervisor.createInstance(Root.type) |
| 738 … | + const root = await hypervisor.createInstance(Root.typeId) |
739 | 739 … | const [portRef1, portRef2] = root.ports.createChannel() |
740 | 740 … | const message = root.createMessage() |
741 | 741 … | |
742 | 742 … | root.send(portRef1, message) |
743 | 743 … | root.ports.bind('first', portRef1) |
744 | | - root.createInstance(Root.type, root.createMessage({ |
| 744 … | + root.createInstance(Root.typeId, root.createMessage({ |
745 | 745 … | ports: [portRef2] |
746 | 746 … | })) |
747 | 747 … | }) |
748 | 748 … | |
760 | 760 … | this.kernel.ports.bind('one', portRef1) |
761 | 761 … | const message1 = this.kernel.createMessage({ |
762 | 762 … | ports: [portRef2] |
763 | 763 … | }) |
764 | | - this.kernel.createInstance(First.type, message1) |
| 764 … | + this.kernel.createInstance(First.typeId, message1) |
765 | 765 … | } else { |
766 | 766 … | this.kernel.send(one, this.kernel.createMessage()) |
767 | 767 … | this.kernel.send(one, this.kernel.createMessage()) |
768 | 768 … | } |
769 | 769 … | } |
770 | | - static get type () { |
| 770 … | + static get typeId () { |
771 | 771 … | return 299 |
772 | 772 … | } |
773 | 773 … | } |
774 | 774 … | |
787 | 787 … | |
788 | 788 … | hypervisor.registerContainer(Root) |
789 | 789 … | hypervisor.registerContainer(First) |
790 | 790 … | |
791 | | - const root = await hypervisor.createInstance(Root.type) |
| 791 … | + const root = await hypervisor.createInstance(Root.typeId) |
792 | 792 … | const [portRef1, portRef2] = root.ports.createChannel() |
793 | 793 … | root.ports.bind('first', portRef1) |
794 | | - root.createInstance(Root.type, root.createMessage({ |
| 794 … | + root.createInstance(Root.typeId, root.createMessage({ |
795 | 795 … | ports: [portRef2] |
796 | 796 … | })) |
797 | 797 … | |
798 | 798 … | const message = root.createMessage() |
807 | 807 … | t.plan(4) |
808 | 808 … | const hypervisor = new Hypervisor(node.dag) |
809 | 809 … | hypervisor.registerContainer(BaseContainer) |
810 | 810 … | |
811 | | - const root = await hypervisor.createInstance(BaseContainer.type) |
| 811 … | + const root = await hypervisor.createInstance(BaseContainer.typeId) |
812 | 812 … | |
813 | 813 … | const [portRef1, portRef2] = root.ports.createChannel() |
814 | | - root.createInstance(BaseContainer.type, root.createMessage({ |
| 814 … | + root.createInstance(BaseContainer.typeId, root.createMessage({ |
815 | 815 … | ports: [portRef2] |
816 | 816 … | })) |
817 | 817 … | root.ports.bind('test', portRef1) |
818 | 818 … | |
855 | 855 … | const message1 = this.kernel.createMessage({ |
856 | 856 … | ports: [portRef2] |
857 | 857 … | }) |
858 | 858 … | |
859 | | - this.kernel.createInstance(First.type, message1) |
| 859 … | + this.kernel.createInstance(First.typeId, message1) |
860 | 860 … | this.kernel.send(portRef1, this.kernel.createMessage()) |
861 | 861 … | this.kernel.incrementTicks(6) |
862 | 862 … | } |
863 | 863 … | } |
866 | 866 … | onMessage (m) { |
867 | 867 … | this.kernel.incrementTicks(2) |
868 | 868 … | this.kernel.ports.delete('root') |
869 | 869 … | } |
870 | | - static get type () { |
| 870 … | + static get typeId () { |
871 | 871 … | return 299 |
872 | 872 … | } |
873 | 873 … | } |
874 | 874 … | |
876 | 876 … | |
877 | 877 … | hypervisor.registerContainer(Root) |
878 | 878 … | hypervisor.registerContainer(First) |
879 | 879 … | |
880 | | - const root = await hypervisor.createInstance(Root.type) |
| 880 … | + const root = await hypervisor.createInstance(Root.typeId) |
881 | 881 … | const [portRef1, portRef2] = root.ports.createChannel() |
882 | 882 … | root.ports.bind('first', portRef1) |
883 | | - root.createInstance(Root.type, root.createMessage({ |
| 883 … | + root.createInstance(Root.typeId, root.createMessage({ |
884 | 884 … | ports: [portRef2] |
885 | 885 … | })) |
886 | 886 … | |
887 | 887 … | const message = root.createMessage() |
898 | 898 … | '/': 'zdpuAqFMWKsATaU1gJwMTegcw18GFQ7szZix3QNgMN2sYm2vh' |
899 | 899 … | } |
900 | 900 … | class Root extends BaseContainer { |
901 | 901 … | onMessage (m) { |
902 | | - this.kernel.createInstance(Root.type) |
| 902 … | + this.kernel.createInstance(Root.typeId) |
903 | 903 … | } |
904 | 904 … | } |
905 | 905 … | |
906 | 906 … | const hypervisor = new Hypervisor(node.dag) |
907 | 907 … | |
908 | 908 … | hypervisor.registerContainer(Root) |
909 | 909 … | |
910 | | - const root = await hypervisor.createInstance(Root.type) |
| 910 … | + const root = await hypervisor.createInstance(Root.typeId) |
911 | 911 … | const [portRef1, portRef2] = root.ports.createChannel() |
912 | 912 … | root.ports.bind('first', portRef1) |
913 | | - root.createInstance(Root.type, root.createMessage({ |
| 913 … | + root.createInstance(Root.typeId, root.createMessage({ |
914 | 914 … | ports: [portRef2] |
915 | 915 … | })) |
916 | 916 … | |
917 | 917 … | const message = root.createMessage() |
928 | 928 … | } |
929 | 929 … | class Root extends BaseContainer { |
930 | 930 … | onMessage (m) { |
931 | 931 … | const [, portRef2] = this.kernel.ports.createChannel() |
932 | | - this.kernel.createInstance(Sub.type, this.kernel.createMessage({ |
| 932 … | + this.kernel.createInstance(Sub.typeId, this.kernel.createMessage({ |
933 | 933 … | ports: [portRef2] |
934 | 934 … | })) |
935 | 935 … | } |
936 | 936 … | } |
939 | 939 … | onInitailize (message) { |
940 | 940 … | this.kernel.ports.bind('root', message.ports[0]) |
941 | 941 … | const [portRef1, portRef2] = root.ports.createChannel() |
942 | 942 … | root.ports.bind('child', portRef1) |
943 | | - root.createInstance(Root.type, root.createMessage({ |
| 943 … | + root.createInstance(Root.typeId, root.createMessage({ |
944 | 944 … | ports: [portRef2] |
945 | 945 … | })) |
946 | 946 … | } |
947 | | - static get type () { |
| 947 … | + static get typeId () { |
948 | 948 … | return 299 |
949 | 949 … | } |
950 | 950 … | } |
951 | 951 … | |
953 | 953 … | |
954 | 954 … | hypervisor.registerContainer(Root) |
955 | 955 … | hypervisor.registerContainer(Sub) |
956 | 956 … | |
957 | | - const root = await hypervisor.createInstance(Root.type) |
| 957 … | + const root = await hypervisor.createInstance(Root.typeId) |
958 | 958 … | const [portRef1, portRef2] = root.ports.createChannel() |
959 | 959 … | root.ports.bind('first', portRef1) |
960 | | - root.createInstance(Root.type, root.createMessage({ |
| 960 … | + root.createInstance(Root.typeId, root.createMessage({ |
961 | 961 … | ports: [portRef2] |
962 | 962 … | })) |
963 | 963 … | |
964 | 964 … | root.send(portRef1, root.createMessage()) |
979 | 979 … | this.kernel.send(port, m) |
980 | 980 … | this.kernel.ports.unbind('test1') |
981 | 981 … | } else { |
982 | 982 … | const [portRef1, portRef2] = this.kernel.ports.createChannel() |
983 | | - this.kernel.createInstance(Sub.type, this.kernel.createMessage({ |
| 983 … | + this.kernel.createInstance(Sub.typeId, this.kernel.createMessage({ |
984 | 984 … | ports: [portRef2] |
985 | 985 … | })) |
986 | 986 … | this.kernel.ports.bind('test1', portRef1) |
|
987 | 987 … | |
988 | 988 … | const [portRef3, portRef4] = this.kernel.ports.createChannel() |
989 | | - this.kernel.createInstance(Sub.type, this.kernel.createMessage({ |
| 989 … | + this.kernel.createInstance(Sub.typeId, this.kernel.createMessage({ |
990 | 990 … | ports: [portRef4] |
991 | 991 … | })) |
992 | 992 … | this.kernel.ports.bind('test2', portRef3) |
993 | 993 … | this.kernel.send(portRef3, this.kernel.createMessage({ |
1009 | 1009 … | } else if (message.data === 'bindPort') { |
1010 | 1010 … | this.kernel.ports.bind('channel', message.ports[0]) |
1011 | 1011 … | } |
1012 | 1012 … | } |
1013 | | - static get type () { |
| 1013 … | + static get typeId () { |
1014 | 1014 … | return 299 |
1015 | 1015 … | } |
1016 | 1016 … | } |
1017 | 1017 … | |
1019 | 1019 … | |
1020 | 1020 … | hypervisor.registerContainer(Root) |
1021 | 1021 … | hypervisor.registerContainer(Sub) |
1022 | 1022 … | |
1023 | | - const root = await hypervisor.createInstance(Root.type) |
| 1023 … | + const root = await hypervisor.createInstance(Root.typeId) |
1024 | 1024 … | const [portRef1, portRef2] = root.ports.createChannel() |
1025 | 1025 … | root.ports.bind('first', portRef1) |
1026 | | - root.createInstance(Root.type, root.createMessage({ |
| 1026 … | + root.createInstance(Root.typeId, root.createMessage({ |
1027 | 1027 … | ports: [portRef2] |
1028 | 1028 … | })) |
1029 | 1029 … | |
1030 | 1030 … | root.send(portRef1, root.createMessage()) |
1047 | 1047 … | this.kernel.ports.unbind('test1') |
1048 | 1048 … | this.kernel.ports.unbind('test2') |
1049 | 1049 … | } else { |
1050 | 1050 … | const [portRef1, portRef2] = this.kernel.ports.createChannel() |
1051 | | - this.kernel.createInstance(Sub.type, this.kernel.createMessage({ |
| 1051 … | + this.kernel.createInstance(Sub.typeId, this.kernel.createMessage({ |
1052 | 1052 … | ports: [portRef2] |
1053 | 1053 … | })) |
1054 | 1054 … | this.kernel.ports.bind('test1', portRef1) |
1055 | 1055 … | |
1056 | 1056 … | const [portRef3, portRef4] = this.kernel.ports.createChannel() |
1057 | | - this.kernel.createInstance(Sub.type, this.kernel.createMessage({ |
| 1057 … | + this.kernel.createInstance(Sub.typeId, this.kernel.createMessage({ |
1058 | 1058 … | ports: [portRef4] |
1059 | 1059 … | })) |
1060 | 1060 … | this.kernel.ports.bind('test2', portRef3) |
1061 | 1061 … | this.kernel.send(portRef3, this.kernel.createMessage({ |
1077 | 1077 … | } else if (message.data === 'bindPort') { |
1078 | 1078 … | this.kernel.ports.bind('channel', message.ports[0]) |
1079 | 1079 … | } |
1080 | 1080 … | } |
1081 | | - static get type () { |
| 1081 … | + static get typeId () { |
1082 | 1082 … | return 299 |
1083 | 1083 … | } |
1084 | 1084 … | } |
1085 | 1085 … | |
1087 | 1087 … | |
1088 | 1088 … | hypervisor.registerContainer(Root) |
1089 | 1089 … | hypervisor.registerContainer(Sub) |
1090 | 1090 … | |
1091 | | - const root = await hypervisor.createInstance(Root.type) |
| 1091 … | + const root = await hypervisor.createInstance(Root.typeId) |
1092 | 1092 … | |
1093 | 1093 … | const [portRef1, portRef2] = root.ports.createChannel() |
1094 | 1094 … | root.ports.bind('first', portRef1) |
1095 | | - root.createInstance(Root.type, root.createMessage({ |
| 1095 … | + root.createInstance(Root.typeId, root.createMessage({ |
1096 | 1096 … | ports: [portRef2] |
1097 | 1097 … | })) |
1098 | 1098 … | |
1099 | 1099 … | root.send(portRef1, root.createMessage()) |
1123 | 1123 … | const hypervisor = new Hypervisor(node.dag) |
1124 | 1124 … | |
1125 | 1125 … | hypervisor.registerContainer(testVMContainer) |
1126 | 1126 … | |
1127 | | - const rootContainer = await hypervisor.createInstance(testVMContainer.type) |
| 1127 … | + const rootContainer = await hypervisor.createInstance(testVMContainer.typeId) |
1128 | 1128 … | |
1129 | 1129 … | const [portRef1, portRef2] = rootContainer.ports.createChannel() |
1130 | 1130 … | const initMessage = rootContainer.createMessage({ |
1131 | 1131 … | ports: [portRef2] |
1132 | 1132 … | }) |
1133 | 1133 … | |
1134 | | - rootContainer.createInstance(testVMContainer.type, initMessage) |
| 1134 … | + rootContainer.createInstance(testVMContainer.typeId, initMessage) |
1135 | 1135 … | |
1136 | 1136 … | rootContainer.ports.bind('first', portRef1) |
1137 | 1137 … | const message = rootContainer.createMessage() |
1138 | 1138 … | const rPort = rootContainer.getResponsePort(message) |
1154 | 1154 … | } |
1155 | 1155 … | |
1156 | 1156 … | const hypervisor = new Hypervisor(node.dag) |
1157 | 1157 … | hypervisor.registerContainer(testVMContainer) |
1158 | | - await hypervisor.createInstance(testVMContainer.type) |
| 1158 … | + await hypervisor.createInstance(testVMContainer.typeId) |
1159 | 1159 … | hypervisor.getInstance(hypervisor.ROOT_ID) |
1160 | 1160 … | }) |
1161 | 1161 … | |
1162 | 1162 … | tape('large code size', async t => { |
1167 | 1167 … | } |
1168 | 1168 … | |
1169 | 1169 … | const hypervisor = new Hypervisor(node.dag) |
1170 | 1170 … | hypervisor.registerContainer(testVMContainer) |
1171 | | - await hypervisor.createInstance(testVMContainer.type, new Message({data: content})) |
| 1171 … | + await hypervisor.createInstance(testVMContainer.typeId, new Message({data: content})) |
1172 | 1172 … | const instance = await hypervisor.getInstance(hypervisor.ROOT_ID) |
1173 | 1173 … | t.equals(content.length, instance.code.length) |
1174 | 1174 … | }) |
1175 | 1175 … | }) |