/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 D | queue.go | 47 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 D | queue.go | 55 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 D | alpine.go | 10 func newAlpineFetchRequests(target []string) (reqs []fetchRequest) { 12 reqs = append(reqs, fetchRequest{ 15 }, fetchRequest{
|
H A D | util.go | 19 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 D | amazon.go | 86 results, err := fetchFeedFiles([]fetchRequest{{url: mirrorListURL}}) 116 reqs := []fetchRequest{} 123 reqs = append(reqs, fetchRequest{ 165 results, err := fetchFeedFiles([]fetchRequest{{url: url}})
|
H A D | oracle.go | 7 func newOracleFetchRequests() (reqs []fetchRequest) { 9 reqs = append(reqs, fetchRequest{
|
H A D | redhat.go | 7 func newRedHatFetchRequests(target []string) (reqs []fetchRequest) { 10 reqs = append(reqs, fetchRequest{
|
H A D | suse.go | 12 func newSUSEFetchRequests(suseType string, target []string) (reqs []fetchRequest) { 15 reqs = append(reqs, fetchRequest{
|
H A D | debian.go | 11 func newDebianFetchRequests(target []string) (reqs []fetchRequest) { 19 reqs = append(reqs, fetchRequest{
|
H A D | ubuntu.go | 10 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 D | queue.go | 54 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 D | fetchers_concurrent_headers.go | 57 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 D | fetchers_concurrent_bodies.go | 57 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 D | fetchers_concurrent_receipts.go | 57 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 D | EOCoreDataSource.m | 87 [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 D | EOCoreDataSource.h | 47 NSFetchRequest *fetchRequest; variable 77 - (NSFetchRequest *)fetchRequest;
|
/dports/devel/sope/SOPE/sope-core/EOCoreData/ |
H A D | EOCoreDataSource.m | 87 [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 D | EOCoreDataSource.h | 47 NSFetchRequest *fetchRequest; variable 77 - (NSFetchRequest *)fetchRequest;
|
/dports/www/carbonapi/carbonapi-0.14.1/expr/ |
H A D | expr.go | 32 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 D | NSFetchedPropertyDescription.inc | 20 function fetchRequest: NSFetchRequest; message 'fetchRequest';
|
H A D | NSPersistentStoreRequest.inc | 51 function fetchRequest: NSFetchRequest; message 'fetchRequest';
|
H A D | NSPersistentStoreResult.inc | 61 function fetchRequest: NSAsynchronousFetchRequest; message 'fetchRequest';
|
/dports/www/carbonapi/carbonapi-0.14.1/zipper/broadcast/ |
H A D | broadcast_group_test.go | 147 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 D | PersonEditorWorkflow.java | 182 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 D | fetch.ts | 11 return fetchRequest(opts, init); 15 function fetchRequest(options: TransportOptions, init: FetchTransportInit): Transport { function
|