Lines Matching refs:output_rowset

1811     struct rowset *output_rowset = NULL;  in toku_merge_some_files_using_dbufio()  local
1813 XMALLOC(output_rowset); // freed in cleanup in toku_merge_some_files_using_dbufio()
1814 int r = init_rowset(output_rowset, memory_per_rowset_during_merge(bl, n_sources, to_q)); in toku_merge_some_files_using_dbufio()
1844 if (row_wont_fit(output_rowset, keys[mini].size + vals[mini].size)) { in toku_merge_some_files_using_dbufio()
1846 int r = toku_queue_enq(q, (void*)output_rowset, 1, NULL); in toku_merge_some_files_using_dbufio()
1852 XMALLOC(output_rowset); // freed in cleanup in toku_merge_some_files_using_dbufio()
1854 … int r = init_rowset(output_rowset, memory_per_rowset_during_merge(bl, n_sources, to_q)); in toku_merge_some_files_using_dbufio()
1862 int r = add_row(output_rowset, &keys[mini], &vals[mini]); in toku_merge_some_files_using_dbufio()
1922 int r = toku_queue_enq(q, (void*)output_rowset, 1, NULL); in toku_merge_some_files_using_dbufio()
1926 output_rowset = NULL; in toku_merge_some_files_using_dbufio()
1937 if (output_rowset) { in toku_merge_some_files_using_dbufio()
1938 destroy_rowset(output_rowset); in toku_merge_some_files_using_dbufio()
1939 toku_free(output_rowset); in toku_merge_some_files_using_dbufio()
2515 struct rowset *output_rowset = (struct rowset *)item; in toku_loader_write_ft_from_q() local
2517 for (unsigned int i = 0; i < output_rowset->n_rows; i++) { in toku_loader_write_ft_from_q()
2518 …DBT key = make_dbt(output_rowset->data+output_rowset->rows[i].off, o… in toku_loader_write_ft_from_q()
2519 …DBT val = make_dbt(output_rowset->data+output_rowset->rows[i].off + output_rowset->rows[i].klen, o… in toku_loader_write_ft_from_q()
2580 destroy_rowset(output_rowset); in toku_loader_write_ft_from_q()
2581 toku_free(output_rowset); in toku_loader_write_ft_from_q()