Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

New net interface #69

Merged
merged 221 commits into from
Sep 22, 2014
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
221 commits
Select commit Hold shift + click to select a range
d934806
panic -> error
jbenet Aug 30, 2014
71ec4f9
Drop -> CloseConnection
jbenet Aug 30, 2014
2563e92
network.Find -> network.GetPeer
jbenet Aug 30, 2014
161f815
added mux
jbenet Sep 11, 2014
be01dcf
mux test stop.
jbenet Sep 11, 2014
5c79fc4
message pkg
jbenet Sep 11, 2014
c59125b
moved conn to own pkg
jbenet Sep 11, 2014
ffad3bb
removed logging in conn_test
jbenet Sep 11, 2014
06b651c
Service + request
jbenet Sep 11, 2014
035d600
Godeps: use in net + new multiaddr
jbenet Sep 14, 2014
0ac4a2b
swarm rewrite, doesnt yet work (tests)
jbenet Sep 14, 2014
453a667
moved stuff
jbenet Sep 14, 2014
a273a03
remove handshake for now (need to merge and move)
jbenet Sep 14, 2014
d6e8e55
rmv old swarm
jbenet Sep 14, 2014
2b03664
net interface
jbenet Sep 14, 2014
67e76c0
godeps multiaddr + swarm move.
jbenet Sep 14, 2014
c787ada
better handshake for all.
jbenet Sep 14, 2014
5684fa2
removed old identify
jbenet Sep 14, 2014
f71be6e
merge wind HoC
jbenet Sep 14, 2014
c141233
starting to integrate new net
jbenet Sep 14, 2014
add0f3f
feat(net:message) get net package from e2430ae4279
Sep 13, 2014
455c658
refactor(bitswap) leverage third-party pubsub lib
Sep 11, 2014
b28343c
refactor(bitswap) meslistener -> notifications
Sep 11, 2014
d294f7d
fix(bitswap:notifications) shutdown on bs.Halt()
Sep 11, 2014
7c37812
style(bitswap:notifications) rm explicit returns
Sep 11, 2014
b1155a0
fix(bitswap:notifications) close chan on Publish
Sep 12, 2014
cc163a9
docs(bitswap:notifications) Subscribe
Sep 12, 2014
a7ef095
refactor(bitswap:notifications) move, rename
Sep 12, 2014
2f4175a
test(bitswap:notifications) check if chan is open
Sep 12, 2014
2422497
feat(bitswap:msg) add ToNet() method
Sep 13, 2014
7099988
feat(bitswap:msg) define interfaces
Sep 13, 2014
2163956
feat(bitswap:msg) impl FromSwarm method
Sep 13, 2014
282acb8
refactor(bitswap:msg) add, use getters
Sep 13, 2014
b8bd2bc
refactor(bitswap:msg) move to package
Sep 13, 2014
7fcb5d3
feat(bs:net) impl service wrapper
Sep 13, 2014
baafc6f
style(bs:notific) let struct field be value
Sep 13, 2014
a3487eb
fix(bs:net) add peer to receiver interface
Sep 13, 2014
78f0f5b
refac(bs:msg) let msg.Blocks() return []blocks
Sep 13, 2014
96ab834
feat(util) add u.Key().ToDatastore() method
Sep 14, 2014
806b3c2
refac(bs:msg) msg.Wantlist() returns []u.Key
Sep 14, 2014
2edc03a
style(bs:tx) rename network -> transmission
Sep 14, 2014
5b5e17e
style(bs:tx) rename receiver -> forwarder
Sep 14, 2014
556da76
fix(cmd:ipfs) import err identify -> spipe
Sep 14, 2014
6821624
fix(net) use NetMessage interface
Sep 14, 2014
0d3b0f1
fix(bs:msg) remove swarm.Message
Sep 14, 2014
6aecb80
chore(core) add TODOs to use contexts
Sep 14, 2014
0075a47
fix(bs) remove concrete refs to swarm and dht
Sep 14, 2014
ab460ed
refactor(bs, core) rename bitswap objects
Sep 14, 2014
b17bc2d
feat(net:service) add sender interface
Sep 14, 2014
dde6ad4
todo(blockservice, core) add notes
Sep 15, 2014
2738d72
feat(bitswap) add interface
Sep 15, 2014
5426a1b
refactor(blockservice) use bitswap.Exchange interface
Sep 15, 2014
f9650a7
allow service to have nil handler
jbenet Sep 15, 2014
cb230b6
bugfix: service has a Start func
jbenet Sep 15, 2014
c7148cd
Service: remove RequestID from SendMessage
jbenet Sep 16, 2014
9849794
Move Sender interface to network pkg
jbenet Sep 16, 2014
b0d0b5f
better protobuf Makefile with wildcard.
jbenet Sep 16, 2014
865109f
expose handler in inet
jbenet Sep 16, 2014
27d0e69
core dht setup
jbenet Sep 16, 2014
bccb3e8
goroutine note comment
jbenet Sep 16, 2014
1461fee
simpler, clearer dht message
jbenet Sep 16, 2014
9c5c49b
starting on dht-- msg handler
jbenet Sep 16, 2014
2f2808e
handleGetValue
jbenet Sep 16, 2014
e872482
refactor symbol
jbenet Sep 16, 2014
2522625
lint nit
jbenet Sep 16, 2014
9eb41e7
ping + find peer
jbenet Sep 16, 2014
69ed45c
refactor peer distance search + handleGetProviders
jbenet Sep 16, 2014
c4536d1
comment out diagnostic
jbenet Sep 16, 2014
d91955b
moved handlers to own file
jbenet Sep 16, 2014
ad14d6c
refac(bitswap:interface) GetBlock, HaveBlock -> Block, HasBlock
Sep 15, 2014
adf62a3
refac(bitswap:notif) replace block generating func
Sep 15, 2014
770cdeb
feat(bitswap) impl offline exchange
Sep 15, 2014
e07d341
refac(bitswap:message) accept block by value
Sep 15, 2014
0ab86de
refac(bitswap:exch) HasBlock(ptr) -> HasBlock(val)
Sep 15, 2014
fda94d9
refactor(bitswap) rm SetStrategy method
Sep 15, 2014
06b5804
wip(bitswap) port service wrapper
Sep 16, 2014
6fa0e21
refactor(bitswap) rename bitswap/transmission -> bitswap/network
Sep 16, 2014
503b1aa
feat(net:service) add SetHandler method
Sep 16, 2014
c34d4df
feat(bitswap:network) define a service interface for use with net/ser…
Sep 16, 2014
014157c
refac(bitswap) simply network interfaces
Sep 16, 2014
0fca986
uncomment all handlers
jbenet Sep 16, 2014
5206408
check type assertion
jbenet Sep 16, 2014
3711d54
getValueSingle using SendRequest
jbenet Sep 16, 2014
4cc1f60
Peerstore -- threadsafe collection
jbenet Sep 16, 2014
c08b895
Peerstore - threadsafe peer collection
jbenet Sep 16, 2014
9c6a3b2
peerstore test
jbenet Sep 16, 2014
70ea4f5
added peerstore to core
jbenet Sep 16, 2014
34a0580
godep multiaddr update
jbenet Sep 16, 2014
71e411e
Peer: only add addresses once.
jbenet Sep 16, 2014
5dea384
peer: golint
jbenet Sep 16, 2014
c4fa995
Peer: change locking to whole Peer object.
jbenet Sep 16, 2014
e4e0210
add Peerstore to dht
jbenet Sep 16, 2014
3ae7021
getFromPeerList and peerFromInfo
jbenet Sep 16, 2014
0773e58
updated Update function
jbenet Sep 16, 2014
15a823d
newMessage and more impl.
jbenet Sep 16, 2014
881447e
refac(bitswap) use blockstore
Sep 16, 2014
03ffdbf
refac(bitswap): privatize bitswap
Sep 16, 2014
c07578d
chore(util) rm unused DatastoreKey method
Sep 16, 2014
e4bceca
refac(bitswap) privatize strategies
Sep 16, 2014
b36670d
refac(bitswap) privatize ledger
Sep 16, 2014
7622c4b
refac(bitswap) define Directory interface
Sep 16, 2014
b838cc0
cleaner KeySpace abstraction.
jbenet Sep 17, 2014
ab04137
SortByDistance copy fix
jbenet Sep 17, 2014
ac9745b
moved keyspace
jbenet Sep 17, 2014
6c00938
kbucket use new keyspace
jbenet Sep 17, 2014
e62b822
refactored keyspace Adjusted -> Bytes
jbenet Sep 17, 2014
a21c1b6
PeerQueue (based on XOR distance metric)
jbenet Sep 17, 2014
51eeec1
sync safety to pq
jbenet Sep 17, 2014
9e2c3fb
expose Len on PQ
jbenet Sep 17, 2014
ae1f768
separate to ensure sync safety
jbenet Sep 17, 2014
551c409
chan queue
jbenet Sep 17, 2014
67bd041
got everything to build
jbenet Sep 17, 2014
29322a2
tests compile
jbenet Sep 17, 2014
56e6c45
fix(routing/dht) match the routing interface
Sep 17, 2014
547f9e1
fix(core) patiently convince the core to compile
Sep 17, 2014
8308837
chore(bitswap) remove dead/unused wantlist code
Sep 17, 2014
cff3a86
refac(bitswap) privatize send block
Sep 17, 2014
4448494
feat(bitswap:strategy) add interfaces
Sep 17, 2014
b8fcc13
refac(bitswap) inline helper methods
Sep 18, 2014
2dc8bc8
chore(bitswap) rm vestigial fields
Sep 18, 2014
36ce8a2
chore(bitswap) rm halt chan since bitswap has no daemon
Sep 18, 2014
2d6e422
style(bitswap) sort in c'tor
Sep 18, 2014
b8133a4
refac(bit swap) move ledger to strategy package
Sep 18, 2014
22539cf
fix(bitswap:strategy) move key set
Sep 18, 2014
2080201
feat(bit swap) stub out a concrete strategist
Sep 18, 2014
b77a785
fix(dht) remove deprecated Start() call
Sep 18, 2014
98c3afe
clean up channel use
jbenet Sep 18, 2014
a114e9c
better query processing (runner)
jbenet Sep 19, 2014
dc0fbfd
added some logging
jbenet Sep 19, 2014
69b1ce4
nil muxer
jbenet Sep 19, 2014
25d0ce8
NoResponse service
jbenet Sep 19, 2014
7a785de
sync counter for processing things
jbenet Sep 19, 2014
700b6ab
remove start
jbenet Sep 19, 2014
313f3c8
muxer construction
jbenet Sep 19, 2014
9ea715c
comment out dht_test for now.
jbenet Sep 19, 2014
4284e8e
config: use PeerID in bootstrap config
jbenet Sep 19, 2014
d040104
handshake: setting remote key expects it to match
jbenet Sep 19, 2014
569268c
peer.DecodePrettyID
jbenet Sep 19, 2014
de7af50
dht.Connect(Peer)
jbenet Sep 19, 2014
f41817c
use Alpha as the concurrency.
jbenet Sep 19, 2014
1439a53
handshake: bugfix (secure -> insecure chan) + logs
jbenet Sep 19, 2014
f763461
secured net logs
jbenet Sep 19, 2014
9dd39de
Fixed connections all over.
jbenet Sep 19, 2014
043c09e
fixed get/put
jbenet Sep 19, 2014
be8e086
fix(bitswap) implement, test concrete strategist
Sep 18, 2014
b780694
fix(bitswap) init wantlist
Sep 18, 2014
de9fcf5
style(bitswap) rename strategist -> strategy
Sep 18, 2014
7970572
style(bitswap) remove unnecessary interface
Sep 18, 2014
fd086b9
refac(exchange) bitswap -> exchange/bitswap
Sep 19, 2014
e1fe4f6
refac(exchange) rename exchange.Interface to match golang conventions
Sep 19, 2014
ded1f8f
fix(bitswap) compiler errors
Sep 19, 2014
5cec619
test(exch:bs:strategy) test accounting consistency
Sep 19, 2014
335b50f
style(ex:bitswap) put public methods at top
Sep 19, 2014
d82a251
refac(exch:bitswap) always notify strategy when message sent
Sep 19, 2014
85f84fe
refac(ex:bs) remove local peer ref until shown to be necessary
Sep 19, 2014
81da645
chore(bitswap) remove unused const
Sep 19, 2014
0bd8f20
refac(routing) replace timeout -> ctx
Sep 19, 2014
252be07
refac(bitswap) let adapter be created with nil delegate
Sep 19, 2014
42770cc
refac(exchange) replace timeout -> context in API
Sep 19, 2014
1054b8d
fix(bitswap) use passed ctx
Sep 19, 2014
e907b2e
feat(exchange) pass ctx to exchange.HasBlock(...)
Sep 19, 2014
9a18fd6
chore(exch, bitswap) misc trivial cleanup
Sep 19, 2014
74e81e0
refac(bitswap) extract const
Sep 19, 2014
98a6e9f
feat(exch:bitswap) simply get method
Sep 19, 2014
71aed67
feat(bitswap) broadcast block to routing, peers on receipt
Sep 19, 2014
071a664
style(exch:bitswap) rename variable
Sep 19, 2014
0c67019
style(exch:bitswap) rename adapter, session, etc.
Sep 19, 2014
7975ffe
fix(exchange) package name
Sep 19, 2014
c80c8aa
test(bitswap:testnet)
Sep 19, 2014
6e1c3b3
fix(bitswap) check for nil in public interface
Sep 19, 2014
543dfee
refac(bitswap) less concurrency while testing and iterating
Sep 19, 2014
9f685af
test(bitswap)
Sep 19, 2014
a8a7caa
refac(bitswap:testnet) give testnet its own package
Sep 19, 2014
57e088b
fix(bitswap:testnet) use peer.Map
Sep 19, 2014
800af9c
fix(bitswap:message) don't use proto internally
Sep 19, 2014
ddf889d
test(bitswap) send block from one instance to another
Sep 19, 2014
6e7a12d
refac(exch:offline) move offline exchange to its own package
Sep 19, 2014
afb1d01
provider testing
jbenet Sep 19, 2014
aa29603
dht tests pass again
jbenet Sep 20, 2014
d17fcc1
fix security comment #92
jbenet Sep 20, 2014
a5fb640
test(bitswap) enable get block test
Sep 19, 2014
331fcd1
chore(bitswap) rm unused helper func
Sep 19, 2014
5aa6ccb
refac(bitswap) nil slices are 'range'able
Sep 19, 2014
251f1d7
test(bitswap) add SessionGenerator
Sep 19, 2014
8213cfb
docs(bitswap:strat) interface comments
Sep 20, 2014
88f5be3
test(bitswap:testnet) shuffle the providers
Sep 20, 2014
d0a5339
feat(bitswap) ACTIVATE FULL CONCURRENCY cap'n
Sep 19, 2014
b7b0465
test(bitswap) test with swarm of ~500 instances
Sep 20, 2014
d1c4ffb
init -f fix and output
jbenet Sep 20, 2014
315e121
feat(bitswap:message) implement FromNet
Sep 20, 2014
8ed04cf
fixed test
jbenet Sep 20, 2014
74a0aa5
fixed [%s] bug
jbenet Sep 20, 2014
370d259
this warning should only print out on debug
jbenet Sep 20, 2014
b053896
uncommenting global debug
jbenet Sep 20, 2014
da20887
ipfs add should output hash to user
jbenet Sep 20, 2014
6807b6e
added mars.i.ipfs.io as a bootstrap node
jbenet Sep 20, 2014
64ba4cd
output + linting
jbenet Sep 20, 2014
1653304
adjusted what Address means in config
jbenet Sep 21, 2014
81b4b38
RPC Address init + checks
jbenet Sep 21, 2014
b30dd47
Peerstore fix (ptr to iface)
jbenet Sep 21, 2014
8c35988
add bootstrap peers to peerstore.
jbenet Sep 21, 2014
52cefb1
Routing uses context now
jbenet Sep 22, 2014
8d29a32
core bugfix -- connect ctx
jbenet Sep 22, 2014
8112fae
get bitswap working with dht
jbenet Sep 22, 2014
814cb99
misc(crypto) remove stale test
Sep 20, 2014
60798b8
style(bitswap) make signature more readable
Sep 20, 2014
7d62be7
chore(bitswap) cleanup
Sep 21, 2014
b5ea124
style(bitswap) swap argument order
Sep 21, 2014
b4ef99b
fix(exch) name the error
Sep 21, 2014
b806270
test(bitswap) test sending wantlist to peers
Sep 22, 2014
2179b5d
fix(bitswap:testnet) Provide takes ctx
Sep 22, 2014
39ad222
fix(bitswap) keep interface the same
Sep 22, 2014
d514b91
fix(routing:dht) implement FindProvidersAsync in terms of FindProviders
Sep 22, 2014
faee10e
test(bitswap) send entire wantlist to peers
Sep 22, 2014
767d6ca
refac(bitswap, util) extract KeySet
Sep 22, 2014
9d7ae40
feat(bitswap) expose ability to toggle "niceness"
Sep 22, 2014
b85d155
doc(bitswap:strat) add note to remove blocks from peer's wantlist after
Sep 22, 2014
197046c
fix(routing:dht) add ctx args
Sep 22, 2014
2d2aee1
fix(daemon) multiaddr in test
Sep 22, 2014
7cac1ef
fix(net:swarm) test... use netmsg interface
Sep 22, 2014
cb968c6
chore(net:swarm) temporarily skip test
Sep 22, 2014
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 12 additions & 3 deletions Godeps/Godeps.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading