cdb_findnext.c
上传用户:tany51
上传日期:2013-06-12
资源大小:1397k
文件大小:2k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* sequential cdb_find routines
  2.  *
  3.  * This file is a part of tinycdb package by Michael Tokarev, mjt@corpit.ru.
  4.  * Public domain.
  5.  */
  6. /* see cdb_find.c for comments */
  7. #include "common/setup_before.h"
  8. #include "cdb_int.h"
  9. #include "common/setup_after.h"
  10. int
  11. cdb_findinit(struct cdb_find *cdbfp, struct cdb *cdbp,
  12.              const void *key, unsigned klen)
  13. {
  14.   unsigned n, pos;
  15.   cdbfp->cdb_cdbp = cdbp;
  16.   cdbfp->cdb_key = key;
  17.   cdbfp->cdb_klen = klen;
  18.   cdbfp->cdb_hval = cdb_hash(key, klen);
  19.   cdbfp->cdb_htp = cdbp->cdb_mem + ((cdbfp->cdb_hval << 3) & 2047);
  20.   n = cdb_unpack(cdbfp->cdb_htp + 4);
  21.   cdbfp->cdb_httodo = n << 3;
  22.   if (!n)
  23.     return 0;
  24.   pos = cdb_unpack(cdbfp->cdb_htp);
  25.   if (n > (cdbp->cdb_fsize >> 3)
  26.       || pos < cdbp->cdb_dend
  27.       || pos > cdbp->cdb_fsize
  28.       || cdbfp->cdb_httodo > cdbp->cdb_fsize - pos)
  29.     return errno = EPROTO, -1;
  30.   cdbfp->cdb_htab = cdbp->cdb_mem + pos;
  31.   cdbfp->cdb_htend = cdbfp->cdb_htab + cdbfp->cdb_httodo;
  32.   cdbfp->cdb_htp = cdbfp->cdb_htab + (((cdbfp->cdb_hval >> 8) % n) << 3);
  33.   return 1;
  34. }
  35. int
  36. cdb_findnext(struct cdb_find *cdbfp) {
  37.   struct cdb *cdbp = cdbfp->cdb_cdbp;
  38.   unsigned pos, n;
  39.   unsigned klen = cdbfp->cdb_klen;
  40.   while(cdbfp->cdb_httodo) {
  41.     pos = cdb_unpack(cdbfp->cdb_htp + 4);
  42.     if (!pos)
  43.       return 0;
  44.     n = cdb_unpack(cdbfp->cdb_htp) == cdbfp->cdb_hval;
  45.     if ((cdbfp->cdb_htp += 8) >= cdbfp->cdb_htend)
  46.       cdbfp->cdb_htp = cdbfp->cdb_htab;
  47.     cdbfp->cdb_httodo -= 8;
  48.     if (n) {
  49.       if (pos > cdbp->cdb_fsize - 8)
  50. return errno = EPROTO, -1;
  51.       if (cdb_unpack(cdbp->cdb_mem + pos) == klen) {
  52. if (cdbp->cdb_fsize - klen < pos + 8)
  53.   return errno = EPROTO, -1;
  54. if (memcmp(cdbfp->cdb_key,
  55.     cdbp->cdb_mem + pos + 8, klen) == 0) {
  56.   n = cdb_unpack(cdbp->cdb_mem + pos + 4);
  57.   pos += 8;
  58.   if (cdbp->cdb_fsize < n ||
  59.               cdbp->cdb_fsize - n < pos + klen)
  60.     return errno = EPROTO, -1;
  61.   cdbp->cdb_kpos = pos;
  62.   cdbp->cdb_klen = klen;
  63.   cdbp->cdb_vpos = pos + klen;
  64.   cdbp->cdb_vlen = n;
  65.   return 1;
  66. }
  67.       }
  68.     }
  69.   }
  70.   return 0;
  71. }