Home
last modified time | relevance | path

Searched refs:fetchRequest (Results 1 – 25 of 59) sorted by relevance

123

/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/eth/downloader/
H A Dqueue.go47 type fetchRequest struct { struct
105 headerPendPool: make(map[string]*fetchRequest),
109 blockPendPool: make(map[string]*fetchRequest),
113 receiptPendPool: make(map[string]*fetchRequest),
130 q.headerPendPool = make(map[string]*fetchRequest)
134 q.blockPendPool = make(map[string]*fetchRequest)
139 q.receiptPendPool = make(map[string]*fetchRequest)
445 request := &fetchRequest{
488 …pendPool map[string]*fetchRequest, donePool map[common.Hash]struct{}, isNoop func(*types.Header) b…
555 request := &fetchRequest{
[all …]
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/les/downloader/
H A Dqueue.go55 type fetchRequest struct { struct
168 q.headerPendPool = make(map[string]*fetchRequest)
172 q.blockPendPool = make(map[string]*fetchRequest)
176 q.receiptPendPool = make(map[string]*fetchRequest)
442 request := &fetchRequest{
484 pendPool map[string]*fetchRequest, kind uint) (*fetchRequest, bool, bool) {
560 request := &fetchRequest{
570 func (q *queue) CancelHeaders(request *fetchRequest) {
578 func (q *queue) CancelBodies(request *fetchRequest) {
586 func (q *queue) CancelReceipts(request *fetchRequest) {
[all …]
/dports/security/vuls/vuls-0.13.7/vendor/github.com/kotakanbe/goval-dictionary/fetcher/
H A Dalpine.go10 func newAlpineFetchRequests(target []string) (reqs []fetchRequest) {
12 reqs = append(reqs, fetchRequest{
15 }, fetchRequest{
H A Dutil.go19 type fetchRequest struct { struct
33 func fetchFeedFiles(reqs []fetchRequest) (results []FetchResult, err error) { argument
34 reqChan := make(chan fetchRequest, len(reqs))
101 func fetchFileConcurrently(req fetchRequest, concurrency int) (body []byte, err error) { argument
137 func fetchFileWithUA(req fetchRequest) (body []byte, err error) { argument
H A Damazon.go86 results, err := fetchFeedFiles([]fetchRequest{{url: mirrorListURL}})
116 reqs := []fetchRequest{}
123 reqs = append(reqs, fetchRequest{
165 results, err := fetchFeedFiles([]fetchRequest{{url: url}})
H A Doracle.go7 func newOracleFetchRequests() (reqs []fetchRequest) {
9 reqs = append(reqs, fetchRequest{
H A Dredhat.go7 func newRedHatFetchRequests(target []string) (reqs []fetchRequest) {
10 reqs = append(reqs, fetchRequest{
H A Dsuse.go12 func newSUSEFetchRequests(suseType string, target []string) (reqs []fetchRequest) {
15 reqs = append(reqs, fetchRequest{
H A Ddebian.go11 func newDebianFetchRequests(target []string) (reqs []fetchRequest) {
19 reqs = append(reqs, fetchRequest{
H A Dubuntu.go10 func newUbuntuFetchRequests(target []string) (reqs []fetchRequest) {
22 reqs = append(reqs, fetchRequest{
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/eth/downloader/
H A Dqueue.go54 type fetchRequest struct { struct
172 q.headerPendPool = make(map[string]*fetchRequest)
176 q.blockPendPool = make(map[string]*fetchRequest)
180 q.receiptPendPool = make(map[string]*fetchRequest)
416 func (q *queue) ReserveHeaders(p *peerConnection, count int) *fetchRequest {
445 request := &fetchRequest{
457 func (q *queue) ReserveBodies(p *peerConnection, count int) (*fetchRequest, bool, bool) {
467 func (q *queue) ReserveReceipts(p *peerConnection, count int) (*fetchRequest, bool, bool) {
487 pendPool map[string]*fetchRequest, kind uint) (*fetchRequest, bool, bool) {
563 request := &fetchRequest{
[all …]
H A Dfetchers_concurrent_headers.go57 func (q *headerQueue) reserve(peer *peerConnection, items int) (*fetchRequest, bool, bool) {
76 func (q *headerQueue) request(peer *peerConnection, req *fetchRequest, resCh chan *eth.Response) (*…
H A Dfetchers_concurrent_bodies.go57 func (q *bodyQueue) reserve(peer *peerConnection, items int) (*fetchRequest, bool, bool) {
76 func (q *bodyQueue) request(peer *peerConnection, req *fetchRequest, resCh chan *eth.Response) (*et…
H A Dfetchers_concurrent_receipts.go57 func (q *receiptQueue) reserve(peer *peerConnection, items int) (*fetchRequest, bool, bool) {
76 func (q *receiptQueue) request(peer *peerConnection, req *fetchRequest, resCh chan *eth.Response) (… argument
/dports/devel/sope2/SOPE/sope-core/EOCoreData/
H A DEOCoreDataSource.m87 [self->fetchRequest release]; self->fetchRequest = nil;
220 if (_fr == self->fetchRequest)
234 ASSIGN(self->fetchRequest, _fr);
236 - (NSFetchRequest *)fetchRequest { method
237 return self->fetchRequest;
275 if (self->fetchRequest == nil) {
277 self->fetchRequest = [[fs fetchRequestWithEntity:[self entity]] retain];
280 if (debugOn) NSLog(@" request: %@", self->fetchRequest);
283 executeFetchRequest:self->fetchRequest error:&error];
352 fs = [_unarchiver decodeObjectForKey:@"fetchRequest"];
H A DEOCoreDataSource.h47 NSFetchRequest *fetchRequest; variable
77 - (NSFetchRequest *)fetchRequest;
/dports/devel/sope/SOPE/sope-core/EOCoreData/
H A DEOCoreDataSource.m87 [self->fetchRequest release]; self->fetchRequest = nil;
220 if (_fr == self->fetchRequest)
234 ASSIGN(self->fetchRequest, _fr);
236 - (NSFetchRequest *)fetchRequest { method
237 return self->fetchRequest;
275 if (self->fetchRequest == nil) {
277 self->fetchRequest = [[fs fetchRequestWithEntity:[self entity]] retain];
280 if (debugOn) NSLog(@" request: %@", self->fetchRequest);
283 executeFetchRequest:self->fetchRequest error:&error];
352 fs = [_unarchiver decodeObjectForKey:@"fetchRequest"];
H A DEOCoreDataSource.h47 NSFetchRequest *fetchRequest; variable
77 - (NSFetchRequest *)fetchRequest;
/dports/www/carbonapi/carbonapi-0.14.1/expr/
H A Dexpr.go32 fetchRequest := pb.FetchRequest{
40 Metric: fetchRequest.PathExpression,
41 From: fetchRequest.StartTime,
42 Until: fetchRequest.StopTime,
60 multiFetchRequest.Metrics = append(multiFetchRequest.Metrics, fetchRequest)
/dports/lang/fpc-source/fpc-3.2.2/packages/cocoaint/src/coredata/
H A DNSFetchedPropertyDescription.inc20 function fetchRequest: NSFetchRequest; message 'fetchRequest';
H A DNSPersistentStoreRequest.inc51 function fetchRequest: NSFetchRequest; message 'fetchRequest';
H A DNSPersistentStoreResult.inc61 function fetchRequest: NSAsynchronousFetchRequest; message 'fetchRequest';
/dports/www/carbonapi/carbonapi-0.14.1/zipper/broadcast/
H A Dbroadcast_group_test.go147 fetchRequest *protov3.MultiFetchRequest member
162 fetchRequest: &protov3.MultiFetchRequest{
242 fetchRequest: &protov3.MultiFetchRequest{
311 fetchRequest: &protov3.MultiFetchRequest{
380 fetchRequest: &protov3.MultiFetchRequest{
469 fetchRequest: &protov3.MultiFetchRequest{
1125 s.AddFetchResponse(tt.fetchRequest, resp.Response, resp.Stats, resp.Errors)
1132 res, _, err := b.Fetch(ctx, tt.fetchRequest)
/dports/devel/RStudio/rstudio-2021.09.1-372/src/gwt/lib/gwt/2.8.1/samples/DynaTableRf/src/main/java/com/google/gwt/sample/dynatablerf/client/
H A DPersonEditorWorkflow.java182 Request<PersonProxy> fetchRequest = requestFactory.find(person.stableId()); in fetchAndEdit() local
185 fetchRequest.with(editorDriver.getPaths()); in fetchAndEdit()
188 fetchRequest.to(new Receiver<PersonProxy>() { in fetchAndEdit()
/dports/net/evans/evans-0.9.1/vendor/github.com/improbable-eng/grpc-web/client/grpc-web/src/transports/http/
H A Dfetch.ts11 return fetchRequest(opts, init);
15 function fetchRequest(options: TransportOptions, init: FetchTransportInit): Transport { function

123