Function cmp_loop

src/gpre/cmp.cpp:999–1094

//

static void cmp_loop( gpre_req* request)
{
	gpre_nod* req_node = request->req_node;
	gpre_rse* selection = request->req_rse;

	gpre_port* primary = request->req_primary;
	make_send(primary, request);
	request->add_byte(blr_begin);
	gpre_nod* counter = MSC_node(nod_value, 1);
	for (ref* reference = primary->por_references; reference; reference = reference->ref_next)
	{
		if (reference->ref_field == count_field)
			counter->nod_arg[0] = (gpre_nod*) reference;
	}

	request->add_byte(blr_assignment);
	CME_expr(lit0, request);
	CME_expr(counter, request);

	gpre_ctx* for_context = selection->rse_context[0];
	gpre_ctx* update_context = request->req_update;

	request->add_byte(blr_for);
	CME_rse(selection, request);
	request->add_byte(blr_begin);

	const bool isReturning = request->req_flags & REQ_sql_returning;
	gpre_nod* node = (req_node->nod_type == nod_list) ? req_node->nod_arg[0] : req_node;

	switch (node->nod_type)
	{
	case nod_modify:
		{
			const int blr_op = isReturning ? blr_modify2 : blr_modify;
			request->add_byte(blr_op);
			request->add_byte(for_context->ctx_internal);
			request->add_byte(update_context->ctx_internal);
			cmp_assignment_list(node->nod_arg[0], request);
			if (isReturning)
				cmp_returning(request, node->nod_arg[1]);
		}
		break;
	case nod_store:
		cmp_store(request, node);
		break;
	case nod_erase:
		if (isReturning)
		{
			request->add_byte(blr_begin);
			cmp_returning(request, node->nod_arg[0]);
			request->add_byte(blr_erase);
			request->add_byte(for_context->ctx_internal);
			request->add_byte(blr_end);
		}
		else
		{
			request->add_byte(blr_erase);
			request->add_byte(for_context->ctx_internal);