libtran.c
上传用户:dgyhgb
上传日期:2007-01-07
资源大小:676k
文件大小:6k
源码类别:

SQL Server

开发平台:

Unix_Linux

  1. /*
  2.  *  libtran.c  -
  3.  *
  4.  *  This file is a part of GNU SQL Server
  5.  *
  6.  *  Copyright (c) 1996, 1997, Free Software Foundation, Inc
  7.  *  Developed at the Institute of System Programming
  8.  *  This file is written by  Vera Ponomarenko
  9.  *
  10.  *  This program is free software; you can redistribute it and/or modify
  11.  *  it under the terms of the GNU General Public License as published by
  12.  *  the Free Software Foundation; either version 2 of the License, or
  13.  *  (at your option) any later version.
  14.  *
  15.  *  This program is distributed in the hope that it will be useful,
  16.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  17.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18.  *  GNU General Public License for more details.
  19.  *
  20.  *  You should have received a copy of the GNU General Public License
  21.  *  along with this program; if not, write to the Free Software
  22.  *  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  23.  *
  24.  *  Contacts:   gss@ispras.ru
  25.  *
  26.  */
  27. /* $Id: libtran.c,v 1.247 1997/04/10 06:57:28 vera Exp $ */
  28. #include "xmem.h"
  29. #include "destrn.h"
  30. #include "sctp.h"
  31. #include "f1f2decl.h"
  32. extern struct d_r_t *firstrel;
  33. extern CPNM curcpn;
  34. extern char **scptab;
  35. extern struct ldesind **TAB_IFAM;
  36. extern i4_t TIFAM_SZ;
  37. extern i2_t maxscan;
  38. extern u2_t S_SC_S;
  39. u2_t 
  40. scscal (char *a)
  41. {
  42.   char *c;
  43.   
  44.   for (c = a; (*a & EOSC) == 0; a++);
  45.   return (a + 1 - c);
  46. }
  47. i4_t 
  48. CCS (char *asp)
  49. {
  50.   i4_t n;
  51.   i2_t *a;
  52.   i4_t i, k;
  53.   for (n = 0, a = (i2_t *) asp, k = BD_PAGESIZE / 2, i = 0; i < k; i++)
  54.     n += *a++;
  55.   return (n);
  56. }
  57. #define DIASZ_REL (1+size4b)
  58. struct d_sc_i *
  59. rel_scan (u2_t sn, i4_t rn, char *ob, i2_t *n, u2_t fnum,
  60.           u2_t *fl, char *sc, u2_t slsz, u2_t fmnum, u2_t *fml)
  61. {
  62.   char *a;
  63.   struct d_sc_i *scind;
  64.   struct ldesscan *disc;
  65.   u2_t val;
  66.   i4_t sst;
  67.   scind = (struct d_sc_i *) lusc (n, scisize, ob, SCR, WSC,
  68. fnum, fl, sc, slsz, fmnum, fml, DIASZ_REL + size2b);
  69.   disc = &scind->dessc;
  70.   disc->curlpn = (u2_t) ~ 0;
  71.   a = (char *) scind + scisize + (fnum + fmnum) * size2b + size2b + slsz;
  72.   disc->dpnsc = a;
  73.   val = DIASZ_REL;
  74.   t2bpack (val, a);
  75.   a +=size2b;
  76.   disc->dpnsval = a + 1;
  77.   disc->cur_key = NULL;
  78.   sst = 1;
  79.   sct (&a, sst++, EQ);
  80.   sct (&a, sst, ENDSC);
  81.   t4bpack (rn, a);
  82.   tab_difam (sn);
  83.   disc->pdi = (struct ldesind *) TAB_IFAM[sn];
  84.   return (scind);
  85. }
  86. int
  87. tab_difam (u2_t sn)
  88. {
  89.   struct ldesind *difam;
  90.   struct des_field *df;
  91.   u2_t *a;
  92.   if (sn < (u2_t) TIFAM_SZ && TAB_IFAM[sn] != NULL)
  93.     return (OK);
  94.   difam = (struct ldesind *) xmalloc (ldisize + 2 * size2b + 2 * rfsize);
  95.   difam->ldi.unindex = 0;
  96.   difam->ldi.rootpn = S_SC_S;
  97.   difam->ldi.kifn = 1;
  98.   difam->i_segn = sn;
  99.   a = (u2_t *) ((char *) difam + ldisize);
  100.   *a++ = 0;
  101.   a++;
  102.   df = (struct des_field *) a;
  103.   df->field_type = T2B;
  104.   df->field_size = size2b;
  105.   df++;
  106.   difam->pdf = df;
  107.   df->field_type = T4B;
  108.   df->field_size = size4b;
  109.   if (sn >= (u2_t) TIFAM_SZ)
  110.     {
  111.       TAB_IFAM = (struct ldesind **) xrealloc (TAB_IFAM,
  112.      (sn + 1) * sizeof (struct ldesind **));
  113.       TIFAM_SZ = sn + 1;
  114.     }
  115.   TAB_IFAM[sn] = difam;
  116.   return (OK);
  117. }
  118. void
  119. sct (char **a, i4_t st, unsigned char t)
  120. {
  121.   if (st % 2)
  122.     **a = t;
  123.   else
  124.     *(*a)++ |= t << 4; 
  125. }
  126. unsigned char
  127. selsc1 (char **a, i4_t st)
  128. {
  129.   if (st % 2)
  130.     return (**a) & MSKB4B;
  131.   else
  132.     return (*(*a)++ & MSKS4B) >> 4;
  133. }
  134. void
  135. delscan (i2_t scnum)
  136. {
  137.   char **t;
  138.   
  139.   t = scptab + scnum;
  140.   xfree (*t);
  141.   *t = NULL;
  142. }
  143. void
  144. dfunpack (struct d_r_t *desrel, u2_t size, char *pnt)
  145. {
  146.   bcopy (pnt, (char *) (desrel + 1), size);
  147. }
  148. void
  149. drbdunpack (struct d_r_bd *drbd, char *pnt)
  150. {
  151.   bcopy (pnt, (char *) drbd, drbdsize);
  152. }
  153. struct d_r_t *
  154. crtrd (struct id_rel *pidrel, char *a)
  155. {
  156.   u2_t size;
  157.   struct d_r_t *desrel;
  158.   struct d_r_bd drbd;
  159.   a += scscal (a);
  160.   drbdunpack (&drbd, a);
  161.   if (pidrel->urn.obnum != drbd.relnum)
  162.     return (NULL);
  163.   size = drbd.fieldnum * rfsize;
  164.   desrel = (struct d_r_t *) xmalloc (size + sizeof (struct d_r_t));
  165.   desrel->desrbd = drbd;
  166.   dfunpack (desrel, size, a + drbdsize);
  167.   desrel->pid = NULL;
  168.   desrel->drlist = firstrel;
  169.   firstrel = desrel;
  170.   desrel->segnr = pidrel->urn.segnum;
  171.   desrel->pn_r = pidrel->pagenum;
  172.   desrel->ind_r = pidrel->index;
  173.   desrel->oscnum = 0;
  174.   desrel->cpndr = curcpn;
  175.   return (desrel);
  176. }
  177. void
  178. crtid (struct ldesind *desind, struct d_r_t *desrel)
  179. {
  180.   struct des_field *df2;
  181.   u2_t kn;
  182.   desind->pdf = (struct des_field *) (desrel + 1);
  183.   desind->cpndi = curcpn;
  184.   desind->i_segn = desrel->segnr;
  185.   desind->dri = desrel;
  186.   desind->oscni = 0;
  187.   kn = desind->ldi.kifn & ~UNIQ & MSK21B;
  188.   if (kn % 2 != 0)
  189.     kn += 1;
  190.   df2 = (struct des_field *) ((char *) desind + ldisize + kn * size2b);
  191.   df2->field_type = T4B;
  192.   df2->field_size = size4b;
  193. }
  194. char *
  195. lusc (i2_t * num, u2_t size, char *aob, i4_t type, i4_t mode, u2_t fn, u2_t * fl, char *selc, u2_t selsize, u2_t fmn, u2_t * fml, u2_t dsize)
  196. {
  197.   u2_t i, *a;
  198.   struct d_mesc *scpr;
  199.   char *s;
  200.   s = (char *) xmalloc (size + size2b + selsize + size2b * (fn + fmn) + dsize);
  201.   *num = lunt (&scptab, &maxscan, DTSCAN);
  202.   a = (u2_t *) (s + size);
  203.   for (i = 0; i < fn; i++)
  204.     *a++ = *fl++;
  205.   for (i = 0; i < fmn; i++)
  206.     *a++ = *fml++;
  207.   *a = selsize;
  208.   bcopy (selc, (char *) a + size2b, selsize);
  209.   *(scptab + *num) = s;
  210.   scpr = (struct d_mesc *) s;
  211.   scpr->obsc = type;
  212.   scpr->modesc = mode;
  213.   scpr->prcrt = 0;
  214.   scpr->pobsc = aob;
  215.   scpr->cpnsc = curcpn;
  216.   scpr->ndc = 0;
  217.   scpr->fnsc = fn;
  218.   scpr->fmnsc = fmn;
  219.   scpr->pslc = (char *) a;
  220.   return (s);
  221. }
  222. i2_t
  223. lunt (char ***tab, i2_t * maxn, i2_t delta)
  224. {
  225.   char **s;
  226.   i2_t num, newmax, n;
  227.   for (num = 0, s = *tab; num < *maxn && s[num] != NULL;)
  228.     num++;
  229.   if (num == *maxn)
  230.     {
  231.       newmax = *maxn + delta;
  232.       *tab = (char **) xrealloc ((void *) (*tab), sizeof(char*) * newmax);
  233.       for (n = *maxn, s = *tab; n < newmax; n++)
  234. s[n] = NULL;
  235.       *maxn = newmax;
  236.     }
  237.   return (num);
  238. }