Function ResultSet_Reply

src/resultset/resultset.c:225–260

flush resultset to network

// flush resultset to network
void ResultSet_Reply
(
	ResultSet *set  // resultset to reply with
) {
	ASSERT(set != NULL);

	uint64_t row_count = ResultSet_RowCount(set);

	// check to see if we've encountered a run-time error
	// if so, emit it as the only response
	if(ErrorCtx_EncounteredError()) {
		ErrorCtx_EmitException();
		return;
	}

	// set up the results array and emit the header if the query requires one
	_ResultSet_ReplyWithPreamble(set);

	// emit resultset
	if(set->column_count > 0) {
		RedisModule_ReplyWithArray(set->ctx, row_count);
		SIValue *row[set->column_count];
		uint64_t cells = DataBlock_ItemCount(set->cells);
		// for each row
		for(uint64_t i = 0; i < cells; i += set->column_count) {
			// for each column
			for(uint j = 0; j < set->column_count; j++) {
				row[j] = DataBlock_GetItem(set->cells, i + j);
			}

			set->formatter->EmitRow(set->ctx, set->gc, row, set->column_count);
		}
	}

	ResultSetStat_emit(set->ctx, &set->stats); // response with statistics
}

void ResultSet_Clear(ResultSet *set) {
	ASSERT(set != NULL);