LBRYCommunity/reflector.go
1
0
Fork 0
Code Issues 7 Pull requests Projects Releases 10 Packages Wiki Activity

when reflecting a sdblob, insert all the stream and intermediate blobs using a transaction #50

Closed
shyba wants to merge 39 commits from insert_under_tx into master
pull from: insert_under_tx
merge into: LBRYCommunity:master
Conversation 5 Commits 39 Files changed 51 +9 -3
2 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit b97595311f - Show all commits

6
peer/http3/server.go
View file

@ -70,7 +70,11 @@ func (s *Server) Start(address string) error {
} }
r := mux.NewRouter() r := mux.NewRouter()
r.HandleFunc("/get/{hash}", func(w http.ResponseWriter, r *http.Request) { r.HandleFunc("/get/{hash}", func(w http.ResponseWriter, r *http.Request) {
enqueue(&blobRequest{request: r, reply: w}) waiter := stop.New()
enqueue(&blobRequest{request: r, reply: w, finished: waiter})
select {
case <-waiter.Ch():
}
}) })
r.HandleFunc("/has/{hash}", func(w http.ResponseWriter, r *http.Request) { r.HandleFunc("/has/{hash}", func(w http.ResponseWriter, r *http.Request) {
vars := mux.Vars(r) vars := mux.Vars(r)

2
peer/http3/worker.go
View file

@ -11,6 +11,7 @@ import (
type blobRequest struct { type blobRequest struct {
request *http.Request request *http.Request
reply http.ResponseWriter reply http.ResponseWriter
finished *stop.Group
} }
var getReqCh = make(chan *blobRequest) var getReqCh = make(chan *blobRequest)
@ -37,4 +38,5 @@ func enqueue(b *blobRequest) {
func process(server *Server, r *blobRequest) { func process(server *Server, r *blobRequest) {
server.HandleGetBlob(r.reply, r.request) server.HandleGetBlob(r.reply, r.request)
r.finished.Done()
} }