| >>> Running simulations with nodes: 1000, sources: 5, messages: 60, rng-state: #(3906201752 593635287 270152346 3570226858 1968263816 2261421116) | |
| +++ gossipsub/v1.0 | |
| === simulation summary === | |
| nodes: 1000 | |
| messages: 60 | |
| sources: 5 | |
| publish: 60 | |
| deliver: 60000 | |
| !!pubsub.message: 377370 | |
| !!pubsub.connect: 20000 |
| >>> Running simulations with nodes: 500, sources: 5, messages: 60, rng-state: #(450148173 3493484164 3958739570 345133728 1597196054 3722366174) | |
| +++ gossipsub/v1.0 | |
| === simulation summary === | |
| nodes: 500 | |
| messages: 60 | |
| sources: 5 | |
| publish: 60 | |
| deliver: 30000 | |
| !!pubsub.message: 189451 | |
| !!pubsub.connect: 10000 |
| >>> Running simulations with nodes: 250, sources: 5, messages: 60, rng-state: #(1288990669 1488285165 2465753151 3626470647 1609608140 743526869) | |
| +++ gossipsub/v1.0 | |
| === simulation summary === | |
| nodes: 250 | |
| messages: 60 | |
| sources: 5 | |
| publish: 60 | |
| deliver: 15000 | |
| !!pubsub.message: 96320 | |
| !!pubsub.connect: 5000 |
The gossipsub simulator now has experimental support for episub -- see also the discussion in the specs repo.
The episub extension comes with two new control messages, CHOKE and
UNCHOKE. Choking a peer means instructing it to not directly
forward messages, except self-published through flood publish, even
though it remains in the mesh; instead the peer sends gossip.
Unchoking a peer means instructing it to resume forwarding messages.
| #include <pthread.h> | |
| #include <sys/types.h> | |
| u_int64_t goid(void) { | |
| return (u_int64_t)pthread_self(); | |
| } |
| (import :std/srfi/1 | |
| :std/misc/list | |
| :gerbil/gambit/os) | |
| (export main) | |
| (def (accum1 lst) | |
| (let lp ((rest lst) (r [])) | |
| (match rest | |
| ([e . rest] | |
| (lp rest (cons e r))) |
| ;; -*- Gerbil -*- | |
| (import :std/sugar | |
| :std/getopt | |
| :std/iter | |
| :std/srfi/1 | |
| :std/misc/pqueue | |
| :std/misc/shuffle | |
| :gerbil/gambit) | |
| (export main) |
| Cloning into '.'... | |
| Switched to a new branch 'make' | |
| Pulling cache layers for index.docker.io/gerbil/scheme:latest... | |
| Done! | |
| KernelVersion: 4.4.0-1060-aws | |
| Components: [{u'Version': u'18.03.1-ee-3', u'Name': u'Engine', u'Details': {u'KernelVersion': u'4.4.0-1060-aws', u'Os': u'linux', u'BuildTime': u'2018-08-30T18:42:30.000000000+00:00', u'ApiVersion': u'1.37', u'MinAPIVersion': u'1.12', u'GitCommit': u'b9a5c95', u'Arch': u'amd64', u'Experimental': u'false', u'GoVersion': u'go1.10.2'}}] | |
| Arch: amd64 | |
| BuildTime: 2018-08-30T18:42:30.000000000+00:00 | |
| ApiVersion: 1.37 | |
| Platform: {u'Name': u''} |
Configuration parameters for a topic:
// P1
TimeInMeshWeight float64
TimeInMeshQuantum time.Duration
TimeInMeshCap float64
| aggregate message rate 120/s | |
| message/mesh peer with 6 mesh peers -> 20/s; with 12 -> 10/s | |
| 30 -> sum(n = 0...30, 10 * expt(.97, n)) -> 19.966431048561404 | |
| maximum in 2min, +1; in 30s +.25 | |
| TimeInMeshWeight 1/120 | |
| TimeInMeshQuantum -> 1s | |
| TimeInMeshCap -> 120 |