Commit graph

429 commits

Author SHA1 Message Date
Alex Grintsvayg
6fefcc4530 oops 2018-06-26 10:58:19 -04:00
Alex Grintsvayg
821cfb748e
refactor stopgroup to use context, which allows parent/child cancelations 2018-06-26 08:53:48 -04:00
Alex Grintsvayg
4e78c08818 partial switch to new stopgroup. need to refactor to take advantage of child cancelation 2018-06-25 16:49:40 -04:00
Alex Grintsvayg
66ca77b690 remove sendCancelable 2018-06-25 15:56:45 -04:00
Alex Grintsvayg
e534f5b972 correct node_finder to use loose parallelism 2018-06-25 15:48:57 -04:00
Alex Grintsvayg
ea9b181d16 broke out contact into separate file 2018-06-25 13:00:55 -04:00
Alex Grintsvayg
767e4cc548 better nodefinder logging 2018-06-22 09:30:16 -04:00
Alex Grintsvayg
8a620a82a3 minor fixes 2018-06-21 15:06:40 -04:00
Alex Grintsvayg
f61ea53c8c add token cache 2018-06-21 15:06:40 -04:00
Alex Grintsvayg
766f4f101d TODO: review this 2018-06-21 15:06:40 -04:00
Alex Grintsvayg
18caec8d40 add proto version to dht 2018-06-21 15:06:40 -04:00
Alex Grintsvayg
1c2175df39 fixed a few channel lockups, fixed announced port in dht, successfully announced and served a blob 2018-06-21 11:26:48 -04:00
Alex Grintsvayg
47a732688d small test 2018-06-19 14:06:35 -04:00
Alex Grintsvayg
5e346cc21a cluster automatically balances what nodes are announcing what hashes 2018-06-19 13:47:13 -04:00
Alex Grintsvayg
b19df481da starting to put together the pieces
- prism start command
- more configs for prism when assembling the pieces
- cluster notifies on membership change, determines hash range, announces hashes
2018-06-14 22:30:38 -04:00
Alex Grintsvayg
fc9b05b8c6 move bitmap into separate package 2018-06-14 20:10:44 -04:00
Alex Grintsvayg
5968953d05 fix some stoppers 2018-06-13 12:45:47 -04:00
Alex Grintsvayg
f0762e9c57
fix typo in dependencies 2018-06-13 12:44:09 -04:00
Alex Grintsvayg
de40df28c1
add Link to stop Stopper when an upstream Stopper is stopped 2018-06-13 12:37:21 -04:00
Mark Beamer Jr
63e58248cc Addressed code reviews. 2018-06-13 09:44:24 -04:00
Mark Beamer Jr
470e3721d0 implemented stopper pattern
-made defer adjustments inline and deleted the separate function.
-adjusted method in upload to take the only parameter it requires.
-Implemented stopper param for reflector server
-Aligned Cluster New to NewCluster
-Adjusted DHT to use StopAndWait
-Removed blocking waitgroup add
-Unified all components under prism.
-Moved defer done outside of functions.
-renamed NewCluster to New
-fixed travis errors.
2018-06-13 09:36:44 -04:00
Mark Beamer Jr
8100010220 code cleanup
-Added travis support
-updated travis to analyze code beneath the root.
-refactored upload.go to fix travis errors.
-gocyclo should ignore test files. $GOFILES needed to be adjusted.
-fix rows.Close() ignoring error. Created func to handle so defer can be used when needed also.
-fixed ignored errors.
-fixed unit test that was not passing correctly to anonymous function.
-fixed govet error for passing param inside go func.
-removed returned error, in favor of logging instead.
-added error logging for ignored error.
-fixed potential race conditions.
-removed unused append
-fixed time usage to align with go standards.
-removed unused variables
-made changes for code review.
-code comments for exported functions.
-Documented bitmap.go and insert into contact list.
-Documented dht, message, bootstrap
-Fixed comment typos
-Documented message,node, routing_table, testing in DHT package.
-Documented server, client, prism, server and shared in peer and reflector packages.
-Documented the stores in Store package.
-made defer adjustments inline and deleted the separate function.
-adjusted method in upload to take the only parameter it requires.
2018-06-13 09:29:13 -04:00
Niko Storni
d062d4ad7f
add travis CI 2018-06-11 17:53:30 -04:00
Niko Storni
e74070259e
update dependencies
fix issue preventing compilation
format project
2018-06-11 17:42:00 -04:00
Alex Grintsvayg
681a623ddf
update lockfile 2018-06-06 15:35:57 -04:00
Alex Grintsvayg
2162ea136a
Merge branch 'apiserver'
* apiserver:
  -Added API Server to lbry.go -Removed dependency on internal apis -Moved over only required packages. -Adjusted slack.go to be generic instead of hard coding channel name. -Moved over travis package from internal-apis -Added Repository struct for webhook and an IsMatch method. It is possible for any repository to send a webhook to the api and it will trigger a deploy. We should check against the owner, repo and branch. -Renamed package to api -removed util.Debugging from server.go -Added an ErrorHandling function that be used as interface for slack for internal-apis -Added Map for Header settings that can be set before the serving -Merged slack code from lbryio/boardbot -Cleaned up the slack.go code so it made more sense and flowed better -Removed gitignore entry for `.idea`, should be global -Removed debugging.go -Added option for private vs public repository for getting travis public key. -separated private vs public into if else. -Changed HeaderSettings to not be pointer. -Changed ErrorHandler to be named LogErrorFunc -removed logrus dependency, created loginfo function to handle non-error information. -Added Daemon Types and adjusted peer_list to be in line with v20 -Fixed rpcclient library usage for latest version to prevent build errors. -Changed inputs to LogError and LogInfo so that other implementations can make this customizable.
2018-06-05 15:15:03 -04:00
Mark Beamer Jr
afffa668a9 -Added API Server to lbry.go
-Removed dependency on internal apis
-Moved over only required packages.
-Adjusted slack.go to be generic instead of hard coding channel name.
-Moved over travis package from internal-apis
-Added Repository struct for webhook and an IsMatch method. It is possible for any repository to send a webhook to the api and it will trigger a deploy. We should check against the owner, repo and branch.
-Renamed package to api
-removed util.Debugging from server.go
-Added an ErrorHandling function that be used as interface for slack for internal-apis
-Added Map for Header settings that can be set before the serving
-Merged slack code from lbryio/boardbot
-Cleaned up the slack.go code so it made more sense and flowed better
-Removed gitignore entry for `.idea`, should be global
-Removed debugging.go
-Added option for private vs public repository for getting travis public key.
-separated private vs public into if else.
-Changed HeaderSettings to not be pointer.
-Changed ErrorHandler to be named LogErrorFunc
-removed logrus dependency, created loginfo function to handle non-error information.
-Added Daemon Types and adjusted peer_list to be in line with v20
-Fixed rpcclient library usage for latest version to prevent build errors.
-Changed inputs to LogError and LogInfo so that other implementations can make this customizable.
2018-05-27 11:30:04 -04:00
Alex Grintsvayg
79527da8a9 get rid of ReadDeadline, switch to updated stopOnce 2018-05-24 17:49:43 -04:00
Alex Grintsvayg
6a0cab5f62 update stopper 2018-05-24 13:05:05 -04:00
Alex Grintsvayg
2a6ea528bd
update stoponce 2018-05-24 12:59:34 -04:00
Alex Grintsvayg
1c31e54860 self-store 2018-05-22 12:27:49 -04:00
Alex Grintsvayg
13321b53b4 reannounce 2018-05-22 12:16:08 -04:00
Alex Grintsvayg
14cceda81e added routing table saving, bitmap operations, lots of tests 2018-05-19 13:06:19 -04:00
Alex Grintsvayg
b9ee0b0644 added upload command, --conf and --verbose flags 2018-05-14 20:55:48 -04:00
Alex Grintsvayg
611635c87d large dht test is a real test 2018-05-13 21:38:30 -04:00
Alex Grintsvayg
03a1e61d57 added concurrent dht test 2018-05-13 21:17:29 -04:00
Alex Grintsvayg
a656ad8a14
add crypto package 2018-05-13 21:09:40 -04:00
Alex Grintsvayg
ffd8c891db bootstrap node, bucket grooming 2018-05-13 17:33:49 -04:00
Alex Grintsvayg
1f7841e4d0 minor refactor 2018-05-01 16:18:38 -04:00
Alex Grintsvayg
079a6bf610 move most dht code into Node 2018-04-27 20:16:12 -04:00
Niko Storni
9ecbedadf5
add temporary limit for huge channels 2018-04-25 17:07:18 -04:00
Niko Storni
623a5971d9 human readable video names 2018-04-25 15:43:20 -04:00
Niko Storni
e976cd0fa0 add playlist position
add delete function
2018-04-25 14:56:26 -04:00
Alex Grintsvayg
34ab2cd1ae actually this is the correct behavior 2018-04-24 21:13:48 -04:00
Alex Grintsvayg
a232f02e2d expose how many initial nodes are found 2018-04-24 21:13:37 -04:00
Alex Grintsvayg
8f5313fe76 fix rt updates, add Ping method 2018-04-24 18:12:17 -04:00
Alex Grintsvayg
8a5917a982 bind all ports by default 2018-04-24 17:20:03 -04:00
Alex Grintsvayg
3070798f97 dht quirk 2018-04-24 17:19:16 -04:00
Niko Storni
5d6204a349
improve daemon shutdown detection 2018-04-24 14:50:10 -04:00
Niko Storni
160b08811f fix shutdown race condition
increase number of addresses to use
2018-04-20 15:06:55 -04:00