Function MergeBloatStatsBsons

pg_documentdb/src/utils/storage_utils.c:185–217

* Merges the bloat stats from all the workers into a single * CollectionBloatStats object. */

 * CollectionBloatStats object.
 */
static CollectionBloatStats
MergeBloatStatsBsons(List *workerBsons)
{
	CollectionBloatStats bloatStats;
	memset(&bloatStats, 0, sizeof(CollectionBloatStats));
	bloatStats.nullStats = true;

	ListCell *workerCell;
	foreach(workerCell, workerBsons)
	{
		pgbson *workerBson = lfirst(workerCell);
		bson_iter_t iter;
		PgbsonInitIterator(workerBson, &iter);
		while (bson_iter_next(&iter))
		{
			/* Non-Empty stats, reset nullStats */
			bloatStats.nullStats = false;

			const char *key = bson_iter_key(&iter);
			const bson_value_t *value = bson_iter_value(&iter);
			if (key[0] == 'b')
			{
				bloatStats.estimatedBloatStorage += BsonValueAsInt64(value);
			}
			else if (key[0] == 't')
			{
				bloatStats.estimatedTableStorage += BsonValueAsInt64(value);
			}
		}
	}

	return bloatStats;
}