← Back to branch summary

~mdcallag/+junk/5.1-map

« back to all changes in this revision

Viewing changes to storage/archive/azio.c

  • Committer: msvensson at pilot
  • Date: 2007-04-24 09:11:45 UTC
  • mfrom: (2469.1.106)
  • Revision ID: sp1r-msvensson@pilot.blaudden-20070424091145-10463
Merge pilot.blaudden:/home/msvensson/mysql/my51-m-mysql_upgrade
into  pilot.blaudden:/home/msvensson/mysql/mysql-5.1-maint

Show diffs side-by-side

added added

removed removed

Lines of Context:
storage/archive/azio.c
55
55
  s->stream.zalloc = (alloc_func)0;
56
56
  s->stream.zfree = (free_func)0;
57
57
  s->stream.opaque = (voidpf)0;
58
 
  memset(s->inbuf, 0, AZ_BUFSIZE);
59
 
  memset(s->outbuf, 0, AZ_BUFSIZE);
 
58
  memset(s->inbuf, 0, AZ_BUFSIZE_READ);
 
59
  memset(s->outbuf, 0, AZ_BUFSIZE_WRITE);
60
60
  s->stream.next_in = s->inbuf;
61
61
  s->stream.next_out = s->outbuf;
62
62
  s->stream.avail_in = s->stream.avail_out = 0;
109
109
      return Z_NULL;
110
110
    }
111
111
  }
112
 
  s->stream.avail_out = AZ_BUFSIZE;
 
112
  s->stream.avail_out = AZ_BUFSIZE_WRITE;
113
113
 
114
114
  errno = 0;
115
115
  s->file = fd < 0 ? my_open(path, Flags, MYF(0)) : fd;
159
159
  char buffer[AZHEADER_SIZE + AZMETA_BUFFER_SIZE];
160
160
  char *ptr= buffer;
161
161
 
162
 
  s->block_size= AZ_BUFSIZE;
 
162
  s->block_size= AZ_BUFSIZE_WRITE;
163
163
  s->version = (unsigned char)az_magic[1];
164
164
  s->minor_version = (unsigned char)az_magic[2];
165
165
 
224
224
  if (s->stream.avail_in == 0) 
225
225
  {
226
226
    errno = 0;
227
 
    s->stream.avail_in = my_read(s->file, (byte *)s->inbuf, AZ_BUFSIZE, MYF(0));
 
227
    s->stream.avail_in = my_read(s->file, (byte *)s->inbuf, AZ_BUFSIZE_READ, MYF(0));
228
228
    if (s->stream.avail_in == 0) 
229
229
    {
230
230
      s->z_eof = 1;
260
260
  if (len < 2) {
261
261
    if (len) s->inbuf[0] = s->stream.next_in[0];
262
262
    errno = 0;
263
 
    len = (uInt)my_read(s->file, (byte *)s->inbuf + len, AZ_BUFSIZE >> len, MYF(0));
 
263
    len = (uInt)my_read(s->file, (byte *)s->inbuf + len, AZ_BUFSIZE_READ >> len, MYF(0));
264
264
    if (len == 0) s->z_err = Z_ERRNO;
265
265
    s->stream.avail_in += len;
266
266
    s->stream.next_in = s->inbuf;
455
455
    if (s->stream.avail_in == 0 && !s->z_eof) {
456
456
 
457
457
      errno = 0;
458
 
      s->stream.avail_in = (uInt)my_read(s->file, (byte *)s->inbuf, AZ_BUFSIZE, MYF(0));
 
458
      s->stream.avail_in = (uInt)my_read(s->file, (byte *)s->inbuf, AZ_BUFSIZE_READ, MYF(0));
459
459
      if (s->stream.avail_in == 0) 
460
460
      {
461
461
        s->z_eof = 1;
522
522
    {
523
523
 
524
524
      s->stream.next_out = s->outbuf;
525
 
      if (my_write(s->file, (byte *)s->outbuf, AZ_BUFSIZE, MYF(0)) != AZ_BUFSIZE) 
 
525
      if (my_write(s->file, (byte *)s->outbuf, AZ_BUFSIZE_WRITE, 
 
526
                   MYF(0)) != AZ_BUFSIZE_WRITE) 
526
527
      {
527
528
        s->z_err = Z_ERRNO;
528
529
        break;
529
530
      }
530
 
      s->stream.avail_out = AZ_BUFSIZE;
 
531
      s->stream.avail_out = AZ_BUFSIZE_WRITE;
531
532
    }
532
533
    s->in += s->stream.avail_in;
533
534
    s->out += s->stream.avail_out;
563
564
 
564
565
  for (;;) 
565
566
  {
566
 
    len = AZ_BUFSIZE - s->stream.avail_out;
 
567
    len = AZ_BUFSIZE_WRITE - s->stream.avail_out;
567
568
 
568
569
    if (len != 0) 
569
570
    {
574
575
        return Z_ERRNO;
575
576
      }
576
577
      s->stream.next_out = s->outbuf;
577
 
      s->stream.avail_out = AZ_BUFSIZE;
 
578
      s->stream.avail_out = AZ_BUFSIZE_WRITE;
578
579
    }
579
580
    if (done) break;
580
581
    s->out += s->stream.avail_out;
675
676
    /* There was a zmemzero here if inbuf was null -Brian */
676
677
    while (offset > 0)  
677
678
    {
678
 
      uInt size = AZ_BUFSIZE;
679
 
      if (offset < AZ_BUFSIZE) size = (uInt)offset;
 
679
      uInt size = AZ_BUFSIZE_WRITE;
 
680
      if (offset < AZ_BUFSIZE_WRITE) size = (uInt)offset;
680
681
 
681
682
      size = azwrite(s, s->inbuf, size);
682
683
      if (size == 0) return -1L;
719
720
  }
720
721
  while (offset > 0)  {
721
722
    int error;
722
 
    unsigned int size = AZ_BUFSIZE;
723
 
    if (offset < AZ_BUFSIZE) size = (int)offset;
 
723
    unsigned int size = AZ_BUFSIZE_READ;
 
724
    if (offset < AZ_BUFSIZE_READ) size = (int)offset;
724
725
 
725
726
    size = azread(s, s->outbuf, size, &error);
726
727
    if (error <= 0) return -1L;