← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/uniques.cc

  • Committer: Brian Aker
  • Date: 2009-02-21 00:18:15 UTC
  • Revision ID: brian@tangent.org-20090221001815-x20e8h71e984lvs1
Completion (?) of uint conversion.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/uniques.cc
432
432
  QUEUE queue;
433
433
  if (end <= begin ||
434
434
      merge_buffer_size < (ulong) (key_length * (end - begin + 1)) ||
435
 
      init_queue(&queue, (uint) (end - begin), offsetof(BUFFPEK, key), 0,
 
435
      init_queue(&queue, (uint32_t) (end - begin), offsetof(BUFFPEK, key), 0,
436
436
                 buffpek_compare, &compare_context))
437
437
    return 1;
438
438
  /* we need space for one key when a piece of merge buffer is re-read */
439
439
  merge_buffer_size-= key_length;
440
440
  unsigned char *save_key_buff= merge_buffer + merge_buffer_size;
441
 
  uint32_t max_key_count_per_piece= (uint) (merge_buffer_size/(end-begin) /
 
441
  uint32_t max_key_count_per_piece= (uint32_t) (merge_buffer_size/(end-begin) /
442
442
                                        key_length);
443
443
  /* if piece_size is aligned reuse_freed_buffer will always hit */
444
444
  uint32_t piece_size= max_key_count_per_piece * key_length;
456
456
    top->base= merge_buffer + (top - begin) * piece_size;
457
457
    top->max_keys= max_key_count_per_piece;
458
458
    bytes_read= read_to_buffer(file, top, key_length);
459
 
    if (bytes_read == (uint) (-1))
 
459
    if (bytes_read == (uint32_t) (-1))
460
460
      goto end;
461
461
    assert(bytes_read);
462
462
    queue_insert(&queue, (unsigned char *) top);
485
485
      memcpy(save_key_buff, old_key, key_length);
486
486
      old_key= save_key_buff;
487
487
      bytes_read= read_to_buffer(file, top, key_length);
488
 
      if (bytes_read == (uint) (-1))
 
488
      if (bytes_read == (uint32_t) (-1))
489
489
        goto end;
490
490
      else if (bytes_read > 0)      /* top->key, top->mem_count are reset */
491
491
        queue_replaced(&queue);     /* in read_to_buffer */
522
522
    }
523
523
    while (--top->mem_count);
524
524
    bytes_read= read_to_buffer(file, top, key_length);
525
 
    if (bytes_read == (uint) (-1))
 
525
    if (bytes_read == (uint32_t) (-1))
526
526
      goto end;
527
527
  }
528
528
  while (bytes_read);
622
622
  sort_param.sort_form=table;
623
623
  sort_param.rec_length= sort_param.sort_length= sort_param.ref_length=
624
624
    size;
625
 
  sort_param.keys= (uint) (max_in_memory_size / sort_param.sort_length);
 
625
  sort_param.keys= (uint32_t) (max_in_memory_size / sort_param.sort_length);
626
626
  sort_param.not_killable=1;
627
627
 
628
628
  if (!(sort_buffer=(unsigned char*) malloc((sort_param.keys+1) *