59 static HashJoinTuple ExecParallelHashTupleAlloc(HashJoinTable hashtable,
64 static inline HashJoinTuple ExecParallelHashFirstTuple(HashJoinTable table,
66 static inline HashJoinTuple ExecParallelHashNextTuple(HashJoinTable table,
67 						  HashJoinTuple tuple);
69 						  HashJoinTuple tuple,
197 	hashtable->spaceUsed += hashtable->nbuckets * sizeof(HashJoinTuple);  in MultiExecPrivateHash()
633 		hashtable->buckets.unshared = (HashJoinTuple *)  in ExecHashTableCreate()
634 			palloc0(nbuckets * sizeof(HashJoinTuple));  in ExecHashTableCreate()
755 	max_pointers = *space_allowed / sizeof(HashJoinTuple);  in ExecChooseHashTableSize()
756 	max_pointers = Min(max_pointers, MaxAllocSize / sizeof(HashJoinTuple));  in ExecChooseHashTableSize()
778 	bucket_bytes = sizeof(HashJoinTuple) * nbuckets;  in ExecChooseHashTableSize()
808 		bucket_size = (tupsize * NTUP_PER_BUCKET + sizeof(HashJoinTuple));  in ExecChooseHashTableSize()
813 		bucket_bytes = nbuckets * sizeof(HashJoinTuple);  in ExecChooseHashTableSize()
954 					 sizeof(HashJoinTuple) * hashtable->nbuckets);  in ExecHashIncreaseNumBatches()
963 		   sizeof(HashJoinTuple) * hashtable->nbuckets);  in ExecHashIncreaseNumBatches()
978 			HashJoinTuple hashTuple = (HashJoinTuple) (HASH_CHUNK_DATA(oldchunks) + idx);  in ExecHashIncreaseNumBatches()
991 				HashJoinTuple copyTuple;  in ExecHashIncreaseNumBatches()
993 				copyTuple = (HashJoinTuple) dense_alloc(hashtable, hashTupleSize);  in ExecHashIncreaseNumBatches()
1284 			HashJoinTuple hashTuple = (HashJoinTuple) (HASH_CHUNK_DATA(chunk) + idx);  in ExecParallelHashRepartitionFirst()
1286 			HashJoinTuple copyTuple;  in ExecParallelHashRepartitionFirst()
1454 		(HashJoinTuple *) repalloc(hashtable->buckets.unshared,  in ExecHashIncreaseNumBuckets()
1455 								   hashtable->nbuckets * sizeof(HashJoinTuple));  in ExecHashIncreaseNumBuckets()
1458 		   hashtable->nbuckets * sizeof(HashJoinTuple));  in ExecHashIncreaseNumBuckets()
1468 			HashJoinTuple hashTuple = (HashJoinTuple) (HASH_CHUNK_DATA(chunk) + idx);  in ExecHashIncreaseNumBuckets()
1551 					HashJoinTuple hashTuple = (HashJoinTuple) (HASH_CHUNK_DATA(chunk) + idx);  in ExecParallelHashIncreaseNumBuckets()
1608 		HashJoinTuple hashTuple;  in ExecHashTableInsert()
1614 		hashTuple = (HashJoinTuple) dense_alloc(hashtable, hashTupleSize);  in ExecHashTableInsert()
1641 				hashtable->nbuckets_optimal * 2 <= MaxAllocSize / sizeof(HashJoinTuple))  in ExecHashTableInsert()
1653 			hashtable->nbuckets_optimal * sizeof(HashJoinTuple)  in ExecHashTableInsert()
1688 		HashJoinTuple hashTuple;  in ExecParallelHashTableInsert()
1740 	HashJoinTuple hashTuple;  in ExecParallelHashTableInsertCurrentBatch()
1925 	HashJoinTuple hashTuple = hjstate->hj_CurTuple;  in ExecScanHashBucket()
1986 	HashJoinTuple hashTuple = hjstate->hj_CurTuple;  in ExecParallelScanHashBucket()
2059 	HashJoinTuple hashTuple = hjstate->hj_CurTuple;  in ExecScanHashTableForUnmatched()
2140 	hashtable->buckets.unshared = (HashJoinTuple *)  in ExecHashTableReset()
2141 		palloc0(nbuckets * sizeof(HashJoinTuple));  in ExecHashTableReset()
2158 	HashJoinTuple tuple;  in ExecHashTableResetMatchFlags()
2408 	HashJoinTuple hashTuple;  in ExecHashSkewTableInsert()
2413 	hashTuple = (HashJoinTuple) MemoryContextAlloc(hashtable->batchCxt,  in ExecHashSkewTableInsert()
2451 	HashJoinTuple hashTuple;  in ExecHashRemoveNextSkewBucket()
2470 		HashJoinTuple nextHashTuple = hashTuple->next.unshared;  in ExecHashRemoveNextSkewBucket()
2486 			HashJoinTuple copyTuple;  in ExecHashRemoveNextSkewBucket()
2492 			copyTuple = (HashJoinTuple) dense_alloc(hashtable, tupleSize);  in ExecHashRemoveNextSkewBucket()
2742 static HashJoinTuple
2750 	HashJoinTuple result;  in ExecParallelHashTupleAlloc()
2768 		result = (HashJoinTuple) (HASH_CHUNK_DATA(chunk) + chunk->used);  in ExecParallelHashTupleAlloc()
2880 	result = (HashJoinTuple) HASH_CHUNK_DATA(chunk);  in ExecParallelHashTupleAlloc()
3165 static inline HashJoinTuple
3168 	HashJoinTuple tuple;  in ExecParallelHashFirstTuple()
3173 	tuple = (HashJoinTuple) dsa_get_address(hashtable->area, p);  in ExecParallelHashFirstTuple()
3181 static inline HashJoinTuple
3182 ExecParallelHashNextTuple(HashJoinTable hashtable, HashJoinTuple tuple)  in ExecParallelHashNextTuple()
3184 	HashJoinTuple next;  in ExecParallelHashNextTuple()
3187 	next = (HashJoinTuple) dsa_get_address(hashtable->area, tuple->next.shared);  in ExecParallelHashNextTuple()
3197 						  HashJoinTuple tuple,  in ExecParallelHashPushTuple()