* Get the first tuple in a given bucket identified by number. */
| 3930 | * Get the first tuple in a given bucket identified by number. |
| 3931 | */ |
| 3932 | static inline HashJoinTuple |
| 3933 | ExecParallelHashFirstTuple(HashJoinTable hashtable, int bucketno) |
| 3934 | { |
| 3935 | HashJoinTuple tuple; |
| 3936 | dsa_pointer p; |
| 3937 | |
| 3938 | Assert(hashtable->parallel_state); |
| 3939 | p = dsa_pointer_atomic_read(&hashtable->buckets.shared[bucketno]); |
| 3940 | tuple = (HashJoinTuple) dsa_get_address(hashtable->area, p); |
| 3941 | |
| 3942 | return tuple; |
| 3943 | } |
| 3944 | |
| 3945 | /* |
| 3946 | * Get the next tuple in the same bucket as 'tuple'. |
no test coverage detected