File: gtcmtr_query.c

package info (click to toggle)
fis-gtm 6.3-007-1
  • links: PTS, VCS
  • area: main
  • in suites: bullseye, buster, sid
  • size: 36,284 kB
  • sloc: ansic: 328,861; asm: 5,182; csh: 5,102; sh: 1,918; awk: 291; makefile: 69; sed: 13
file content (146 lines) | stat: -rwxr-xr-x 5,317 bytes parent folder | download | duplicates (3)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
/****************************************************************
 *								*
 *	Copyright 2001, 2013 Fidelity Information Services, Inc	*
 *								*
 *	This source code contains the intellectual property	*
 *	of its copyright holder(s), and is made available	*
 *	under a license.  If you do not know the terms of	*
 *	the license, please stop and do not read further.	*
 *								*
 ****************************************************************/

#include "mdef.h"

#include <stddef.h>

#include "gtm_string.h"

#include "copy.h"
#include "gdsroot.h"
#include "gtm_facility.h"
#include "fileinfo.h"
#include "gdsbt.h"
#include "gdsfhead.h"
#include "cmidef.h"
#include "hashtab_mname.h"	/* needed for cmmdef.h */
#include "cmmdef.h"
#include "gtcm_find_region.h"
#include "gtcm_bind_name.h"
#include "gtcmtr_protos.h"
#include "gv_xform_key.h"
#include "gvcst_protos.h"	/* for gvcst_query,gvcst_queryget prototype */

GBLREF connection_struct *curr_entry;
GBLREF gv_namehead	*gv_target;
GBLREF gv_key		*gv_currkey;
GBLREF gv_key		*gv_altkey;
GBLREF gd_region        *gv_cur_region;

bool gtcmtr_query(void)
{
	unsigned char	*ptr, *gv_key_top_ptr, regnum;
	unsigned short	top, old_top;
	unsigned short	key_len, tmp_len, tot_val_len;
	cm_region_list	*reg_ref;
	mval		val;
	boolean_t	found, was_null;
	uint4		msg_len;

	ptr = curr_entry->clb_ptr->mbf;
	assert(CMMS_Q_QUERY == *ptr);
	ptr++;
	GET_USHORT(tmp_len, ptr);
	ptr += SIZEOF(short);
	regnum = *ptr++;
	reg_ref = gtcm_find_region(curr_entry, regnum);
	tmp_len--;	/* subtract size of regnum */
	assert(0 == offsetof(gv_key, top));
	GET_USHORT(old_top, ptr); /* old_top = ((gv_key *)ptr)->top; */
	CM_GET_GVCURRKEY(ptr, tmp_len);
	assert(1 == gv_currkey->base[gv_currkey->end - 2]);
	assert(0 != gv_currkey->prev || KEY_DELIMITER == gv_currkey->base[gv_currkey->end - 3]);
	gtcm_bind_name(reg_ref->reghead, FALSE); /* gtcm_bind_name sets gv_target; do not use gv_target before gtcm_bind_name */
	if (gv_target->nct || gv_target->collseq)
	{ /* undo client appended 01 00 00 before user provided collation routine gets control */
		if (0 == gv_currkey->prev ||
			1 != gv_currkey->base[gv_currkey->prev] || 0 != gv_currkey->base[gv_currkey->prev + 1])
		{ /* name level $Q, or last subscript of incoming key not null */
			DEBUG_ONLY(was_null = FALSE;)
			gv_currkey->end -= 2;
			gv_currkey->base[gv_currkey->end] = KEY_DELIMITER;
		} else
		{ /* last subscript of incoming key null */
			DEBUG_ONLY(was_null = TRUE;)
			if (0 == gv_cur_region->std_null_coll)
				gv_currkey->base[gv_currkey->prev] = STR_SUB_PREFIX;
			else
			{
				gv_currkey->end -= 2;
				gv_currkey->base[gv_currkey->end] = KEY_DELIMITER;
			}
		}
		gv_xform_key(gv_currkey, FALSE);
		/* redo append 01 00 00 now that we are done with collation */
		if (0 == gv_currkey->prev || KEY_DELIMITER != gv_currkey->base[gv_currkey->end - 3] ||
				 gv_currkey->base[gv_currkey->end - 2] != (0 == gv_cur_region->std_null_coll ? STR_SUB_PREFIX :
				 	SUBSCRIPT_STDCOL_NULL))
		{
			assert(!was_null); /* null to non null transformation not allowed */
			GVKEY_INCREMENT_QUERY(gv_currkey);
		} else
		{
			if (0 == gv_cur_region->std_null_coll)
				gv_currkey->base[gv_currkey->prev] = 1;
			else
				GVKEY_INCREMENT_QUERY(gv_currkey);
		}
	}
	found = (0 != gv_target->root) ? (curr_entry->query_is_queryget ? gvcst_queryget(&val) : gvcst_query()) : FALSE;
	if (found)
	{
		if (gv_target->nct || gv_target->collseq)
			gv_xform_key(gv_altkey, TRUE);
		/* key_len = SIZEOF(gv_key) + gv_altkey->end; */
		key_len = gv_altkey->end + SIZEOF(unsigned short) + SIZEOF(unsigned short) + SIZEOF(unsigned short) + SIZEOF(char);
		tot_val_len = (curr_entry->query_is_queryget ? val.str.len + SIZEOF(unsigned short) : 0);
		/* ushort <- uint4 assignment lossy? */
		assert((uint4)tot_val_len == (curr_entry->query_is_queryget ? val.str.len + SIZEOF(unsigned short) : 0));
	} else
		key_len = tot_val_len = 0;
	msg_len = SIZEOF(unsigned char) + SIZEOF(unsigned short) + SIZEOF(unsigned char) + key_len + tot_val_len;
	if (msg_len > curr_entry->clb_ptr->mbl)
		cmi_realloc_mbf(curr_entry->clb_ptr, msg_len);
	ptr = curr_entry->clb_ptr->mbf;
	*ptr++ = CMMS_R_QUERY;
	tmp_len = key_len + 1;
	PUT_USHORT(ptr, tmp_len);
	ptr += SIZEOF(unsigned short);
	*ptr++ = regnum;
	gv_key_top_ptr = ptr;
	if (found)
	{
		/* memcpy(ptr, gv_altkey, key_len); */ /* this memcpy modified to the following PUTs and memcpy; vinu, 07/18/01 */

		/* we are going to set ((gv_key *)ptr)->top to old_top, why even bother setting it to now to gv_altkey->top?
		 * vinu, 07/18/01 */

		/* PUT_USHORT(ptr, gv_altkey->top); */
		ptr += SIZEOF(unsigned short);
		PUT_USHORT(ptr, gv_altkey->end);
		ptr += SIZEOF(unsigned short);
		PUT_USHORT(ptr, gv_altkey->prev);
		ptr += SIZEOF(unsigned short);
		memcpy(ptr, gv_altkey->base, key_len - SIZEOF(unsigned short) - SIZEOF(unsigned short) - SIZEOF(unsigned short));
		ptr += (key_len - SIZEOF(unsigned short) - SIZEOF(unsigned short) - SIZEOF(unsigned short));
		if (curr_entry->query_is_queryget)
		{
			tmp_len = tot_val_len - SIZEOF(unsigned short);
			PUT_USHORT(ptr, tmp_len);
			ptr += SIZEOF(unsigned short);
			memcpy(ptr, val.str.addr, tmp_len);
		}
	}
	PUT_USHORT(gv_key_top_ptr, old_top); /* ((gv_key *)ptr)->top = old_top; */
	curr_entry->clb_ptr->cbl = msg_len;
	return TRUE;
}