| /dports/dns/yadifa/yadifa-2.5.3-10333/lib/dnscore/src/ |
| H A D | threaded_queue_slg.c | 65 q->read_page = page; in threaded_queue_slg_init()
92 page = q->read_page; in threaded_queue_slg_finalize()
110 q->read_page = NULL; in threaded_queue_slg_finalize()
180 … volatile threaded_queue_slg_page_t *page = (volatile threaded_queue_slg_page_t*)q->read_page; in threaded_queue_slg_dequeue()
217 q->read_page = (threaded_queue_slg_page_t*)page; in threaded_queue_slg_dequeue()
241 while(!((q->read_page->next == NULL) && ((q->read_page->size - q->read_index) == 0))) in threaded_queue_slg_wait_empty()
253 intptr ret = q->read_page->size; in threaded_queue_slg_size()
256 threaded_queue_slg_page_t *page = q->read_page->next; in threaded_queue_slg_size()
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in sts_initialize()
247 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
525 BlockNumber read_page; in sts_parallel_scan_next() local
539 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
540 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
541 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
545 read_page = p->read_page; in sts_parallel_scan_next()
547 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
548 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
572 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in sts_initialize()
247 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
525 BlockNumber read_page; in sts_parallel_scan_next() local
539 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
540 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
541 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
545 read_page = p->read_page; in sts_parallel_scan_next()
547 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
548 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
572 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in decode_buffer_response()
247 accessor->sts->participants[i].read_page = 0; in worker_got_chunk_cb()
525 BlockNumber read_page;
539 if (p->read_page < accessor->read_next_page)
540 p->read_page = accessor->read_next_page;
541 eof = p->read_page >= p->npages;
545 read_page = p->read_page; in _gda_web_do_server_cleanup()
547 p->read_page += STS_CHUNK_PAGES;
548 accessor->read_next_page = p->read_page;
572 read_page)));
[all …]
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in sts_initialize()
247 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
525 BlockNumber read_page; in sts_parallel_scan_next() local
539 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
540 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
541 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
545 read_page = p->read_page; in sts_parallel_scan_next()
547 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
548 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
572 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql11-server/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in sts_initialize()
247 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
525 BlockNumber read_page; in sts_parallel_scan_next() local
539 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
540 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
541 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
545 read_page = p->read_page; in sts_parallel_scan_next()
547 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
548 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
572 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in sts_initialize()
247 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
525 BlockNumber read_page; in sts_parallel_scan_next() local
539 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
540 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
541 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
545 read_page = p->read_page; in sts_parallel_scan_next()
547 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
548 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
572 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in sts_initialize()
247 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
525 BlockNumber read_page; in sts_parallel_scan_next() local
539 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
540 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
541 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
545 read_page = p->read_page; in sts_parallel_scan_next()
547 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
548 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
572 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql14-docs/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql14-client/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql12-server/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in sts_initialize()
247 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
525 BlockNumber read_page; in sts_parallel_scan_next() local
539 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
540 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
541 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
545 read_page = p->read_page; in sts_parallel_scan_next()
547 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
548 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
572 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql12-docs/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0;
247 accessor->sts->participants[i].read_page = 0;
525 BlockNumber read_page;
539 if (p->read_page < accessor->read_next_page)
540 p->read_page = accessor->read_next_page;
541 eof = p->read_page >= p->npages;
545 read_page = p->read_page;
547 p->read_page += STS_CHUNK_PAGES;
548 accessor->read_next_page = p->read_page;
572 read_page)));
[all …]
|
| /dports/databases/postgresql12-pltcl/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in sts_initialize()
247 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
525 BlockNumber read_page; in sts_parallel_scan_next() local
539 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
540 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
541 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
545 read_page = p->read_page; in sts_parallel_scan_next()
547 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
548 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
572 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0; in sts_initialize()
245 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
523 BlockNumber read_page; in sts_parallel_scan_next() local
537 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
538 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
539 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
543 read_page = p->read_page; in sts_parallel_scan_next()
545 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
546 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
570 read_page))); in sts_parallel_scan_next()
[all …]
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 160 sts->participants[i].read_page = 0;
245 accessor->sts->participants[i].read_page = 0;
523 BlockNumber read_page;
537 if (p->read_page < accessor->read_next_page)
538 p->read_page = accessor->read_next_page;
539 eof = p->read_page >= p->npages;
543 read_page = p->read_page;
545 p->read_page += STS_CHUNK_PAGES;
546 accessor->read_next_page = p->read_page;
570 read_page)));
[all …]
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in headerFrame()
247 accessor->sts->participants[i].read_page = 0;
525 BlockNumber read_page;
539 if (p->read_page < accessor->read_next_page)
540 p->read_page = accessor->read_next_page;
541 eof = p->read_page >= p->npages;
545 read_page = p->read_page;
547 p->read_page += STS_CHUNK_PAGES;
548 accessor->read_next_page = p->read_page;
572 read_page)));
[all …]
|
| /dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 162 sts->participants[i].read_page = 0; in sts_initialize()
247 accessor->sts->participants[i].read_page = 0; in sts_reinitialize()
525 BlockNumber read_page; in sts_parallel_scan_next() local
539 if (p->read_page < accessor->read_next_page) in sts_parallel_scan_next()
540 p->read_page = accessor->read_next_page; in sts_parallel_scan_next()
541 eof = p->read_page >= p->npages; in sts_parallel_scan_next()
545 read_page = p->read_page; in sts_parallel_scan_next()
547 p->read_page += STS_CHUNK_PAGES; in sts_parallel_scan_next()
548 accessor->read_next_page = p->read_page; in sts_parallel_scan_next()
572 read_page))); in sts_parallel_scan_next()
[all …]
|