Fossil

    db_prepare(&s1,
      "UPDATE blob SET rcvid=%d, size=%d, content=:data WHERE rid=%d",
       g.rcvid, size, rid
    );
    blob_compress(pBlob, &cmpr);
    db_bind_blob(&s1, ":data", &cmpr);
    db_exec(&s1);
    db_multi_exec("DELETE FROM phantom WHERE rid=%d", rid);
  }else{
    /* We are creating a new entry */
    db_prepare(&s1,
      "INSERT INTO blob(rcvid,size,uuid,content)"
      "VALUES(%d,%d,'%s',:data)",
       g.rcvid, size, blob_str(&hash)
    );
    if( pBlob ){
      blob_compress(pBlob, &cmpr);
      db_bind_blob(&s1, ":data", &cmpr);
    }
    db_exec(&s1);
    rid = db_last_insert_rowid();
    if( !pBlob ){
      db_multi_exec("INSERT OR IGNORE INTO phantom VALUES(%d)", rid);
    }
  }


  /* Finish the transaction and cleanup */
  db_finalize(&s1);
  db_end_transaction(0);
  blob_reset(&hash);

    landmark[hv] = i/NHASH;
  }

  /* Begin scanning the target file and generating copy commands and
  ** literal sections of the delta.
  */
  base = 0;    /* We have already generated everything before zOut[base] */
  while( base+NHASH<lenOut ){
    int iSrc, iBlock;
    unsigned int bestCnt, bestOfst, bestLitsz;
    hash_init(&h, &zOut[base]);
    i = 0;     /* Trying to match a landmark against zOut[base+i] */
    bestCnt = 0;
    while( 1 ){
      int hv;

       " AND name NOT IN ('blob','delta','rcvfrom','user','config')");
    if( zTable==0 ) break;
    db_multi_exec("DROP TABLE %Q", zTable);
    free(zTable);
  }
  db_multi_exec(zRepositorySchema2);

  db_prepare(&s, "SELECT rid, size FROM blob");
  while( db_step(&s)==SQLITE_ROW ){
    int rid = db_column_int(&s, 0);
    int size = db_column_int(&s, 1);
    if( size>=0 ){
      Blob content;
      content_get(rid, &content);
      manifest_crosslink(rid, &content);
      blob_reset(&content);
    }else{
      db_multi_exec("INSERT INTO phantom VALUES(%d)", rid);
    }
  }

  if( errCnt && !forceFlag ){
    printf("%d errors. Rolling back changes. Use --force to force a commit.\n",
            errCnt);
    db_end_transaction(1);
  }else{

@   mid INTEGER REFERENCES blob,        -- Manifest ID where change occurs
@   pid INTEGER REFERENCES blob,        -- File ID in parent manifest
@   fid INTEGER REFERENCES blob,        -- Changed file ID in this manifest
@   fnid INTEGER REFERENCES filename    -- Name of the file
@ );
@ CREATE INDEX mlink_i1 ON mlink(mid);
@ CREATE INDEX mlink_i2 ON mlink(fnid);
@ CREATE INDEX mlink_i3 ON mlink(fid);
@ CREATE INDEX mlink_i4 ON mlink(pid);
@
@ -- Parent/child linkages
@ --
@ CREATE TABLE plink(
@   pid INTEGER REFERENCES blob,    -- Parent manifest
@   cid INTEGER REFERENCES blob,    -- Child manifest
@   isprim BOOLEAN,                 -- pid is the primary parent of cid

@   uid INTEGER REFERENCES user,
@   user TEXT,
@   comment TEXT
@ );
@ CREATE INDEX event_i1 ON event(mtime);
@ CREATE INDEX event_i2 ON event(objid);
@
@ -- A record of phantoms
@ --
@ CREATE TABLE phantom(
@   rid INTEGER PRIMARY KEY         -- Record ID of the phantom
@ );
@
@ -- Aggregated ticket information
@ --
@ CREATE TABLE tkt(
@   tktid INTEGER PRIMARY KEY,           -- Internal ticket ID
@   fnid INTEGER REFERENCES filename,    -- Name of the ticket file
@   rid INTEGER REFERENCES blob,         -- version of ticket file scanned

** referenced in the onremote table.
**
** Return the integer record ID of the similar record.  Or return
** 0 if none is found.
*/
static int similar_record(int rid, int traceFlag){
  int inCnt, outCnt;
  int i;
  Stmt q;
  int queue[100];
  static const char *azQuery[] = {

      /* Scan the delta table first */

      "SELECT srcid, EXISTS(SELECT 1 FROM onremote WHERE rid=srcid)"
      "  FROM delta"
      " WHERE rid=:x"
      "   AND NOT EXISTS(SELECT 1 FROM phantom WHERE rid=srcid)"
      " UNION ALL "
      "SELECT rid, EXISTS(SELECT 1 FROM onremote WHERE rid=delta.rid)"
      "  FROM delta"
      " WHERE srcid=:x"
      "   AND NOT EXISTS(SELECT 1 FROM phantom WHERE rid=delta.rid)",

      /* Then the plink table */
      "SELECT pid, EXISTS(SELECT 1 FROM onremote WHERE rid=pid)"
      "  FROM plink"
      " WHERE cid=:x"
      "   AND NOT EXISTS(SELECT 1 FROM phantom WHERE rid=pid)"
      " UNION ALL "
      "SELECT cid, EXISTS(SELECT 1 FROM onremote WHERE rid=cid)"
      "  FROM plink"
      " WHERE pid=:x"
      "   AND NOT EXISTS(SELECT 1 FROM phantom WHERE rid=cid)",

      /* Finally the mlink table */
      "SELECT pid, EXISTS(SELECT 1 FROM onremote WHERE rid=pid)"
      "  FROM mlink"
      " WHERE fid=:x AND pid>0"
      "   AND NOT EXISTS(SELECT 1 FROM phantom WHERE rid=pid)"
      " UNION ALL "
      "SELECT fid, EXISTS(SELECT 1 FROM onremote WHERE rid=fid)"
      "  FROM mlink"
      " WHERE pid=:x AND fid>0"
      "   AND NOT EXISTS(SELECT 1 FROM phantom WHERE rid=fid)",
  };

  for(i=0; i<sizeof(azQuery)/sizeof(azQuery[0]); i++){
    db_prepare(&q, azQuery[i]);
    queue[0] = rid;
    inCnt = 1;
    outCnt = 0;
    if( traceFlag ) printf("PASS %d\n", i+1);
    while( outCnt<inCnt ){
      int xid = queue[outCnt%64];
      outCnt++;
      db_bind_int(&q, ":x", xid);
      if( traceFlag ) printf("xid=%d\n", xid);
      while( db_step(&q)==SQLITE_ROW ){
        int nid = db_column_int(&q, 0);
        int hit = db_column_int(&q, 1);
        if( traceFlag ) printf("nid=%d hit=%d\n", nid, hit);
        if( hit  ){
          db_finalize(&q);
          return nid;
        }
        if( inCnt<sizeof(queue)/sizeof(queue[0]) ){
          int i;
          for(i=0; i<inCnt && queue[i]!=nid; i++){}
          if( i>=inCnt ){
            queue[inCnt++] = nid;
          }
        }
      }
      db_reset(&q);
    }
    db_finalize(&q);
  }
  return 0;
}

/*
** COMMAND: test-similar-record
*/
void test_similar_record(void){

  blob_zero(&uuid);
  db_blob(&uuid, "SELECT uuid FROM blob WHERE rid=%d AND size>=0", rid);
  if( blob_size(&uuid)==0 ){
    return 0;
  }
  content_get(rid, &content);

  if( blob_size(&content)>100 ){
    srcid = similar_record(rid, 0);
    if( srcid ){
      Blob src;

      content_get(srcid, &src);
      if( blob_size(&src)>100 ){
        Blob delta;
        blob_delta_create(&src, &content, &delta);
        blob_reset(&content);
        content = delta;
        blob_append(&uuid, " ", 1);
        blob_append(&content, "\n", 1);
        db_blob(&uuid, "SELECT uuid FROM blob WHERE rid=%d", srcid);







      }
      blob_reset(&src);



    }
  }
  size = blob_size(&content);
  if( pOut ){
    blob_appendf(pOut, "file %b %d\n", &uuid, size);
    blob_append(pOut, blob_buffer(&content), size);
  }else{
    cgi_printf("file %b %d\n", &uuid, size);
    cgi_append_content(blob_buffer(&content), size);
  }
  blob_reset(&content);
  blob_reset(&uuid);

  db_multi_exec("INSERT OR IGNORE INTO onremote VALUES(%d)", rid);
  return size;
}


/*
** Send all pending files.

        nErr++;
        break;
      }
      isPull = 1;
      @ push %s(db_get("server-code", "x")) %s(db_get("project-code", "x"))
      db_multi_exec(
        "INSERT OR IGNORE INTO pending(rid) "
        "SELECT mid FROM mlink JOIN blob ON mid=rid"
      );
    }else

    /*    login  USER  NONCE  SIGNATURE
    **
    ** Check for a valid login.  This has to happen before anything else.
    */

    }
    blobarray_reset(aToken, nToken);
  }

  /* The input message has now been processed.  Generate a reply. */
  if( isPush ){
    Stmt q;
    int nReq = 0;
    db_prepare(&q, "SELECT uuid, rid FROM phantom JOIN blob USING (rid)");
    while( db_step(&q)==SQLITE_ROW && nReq++ < 200 ){
      const char *zUuid = db_column_text(&q, 0);
      int rid = db_column_int(&q, 1);
      int xid = similar_record(rid, 0);
      @ gimme %s(zUuid)
      if( xid ){
        char *zXUuid = db_text(0, "SELECT uuid FROM blob WHERE rid=%d", xid);
        @ igot %s(zXUuid);
        free(zXUuid);
      }
    }
    db_finalize(&q);
  }
  if( isPull ){
    send_all_pending(0);
  }
  if( isPush || isPull ){

      nMsg++;
    }

    if( pullFlag ){
      /* Send gimme message for every phantom that we hold.
      */
      Stmt q;
      db_prepare(&q, "SELECT uuid, rid FROM phantom JOIN blob USING (rid)");
      while( db_step(&q)==SQLITE_ROW && nReq<200 ){
        const char *zUuid = db_column_text(&q, 0);
        int rid = db_column_int(&q, 1);
        int xid = similar_record(rid, 0);
        blob_appendf(&send,"gimme %s\n", zUuid);
        nReq++;
        if( xid ){
          blob_appendf(&send, "igot %z\n",
             db_text(0, "SELECT uuid FROM blob WHERE rid=%d", xid));
        }
      }
      db_finalize(&q);
    }

    if( pushFlag ){
      /* Send the server any files that the server has requested */
      nFile += send_all_pending(&send);

              "SELECT cid FROM plink WHERE pid=%d", rid
            );
            if( db_changes()>0 ){
              go = 1;
            }
          }
          if( pullFlag && !go && 
              db_exists("SELECT 1 FROM phantom WHERE rid=%d", rid) ){
            go = 1;
          }
        }else if( pullFlag ){
          go = 1;
          content_put(0, blob_str(&aToken[1]));
        }
      }else