← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to storage/archive/azio.c

Merged from trunk.

Show diffs side-by-side

added added

removed removed

Lines of Context:
storage/archive/azio.c
67
67
    if (s->container.ready == AZ_THREAD_DEAD)
68
68
      break;
69
69
 
70
 
    s->container.read_size= my_pread(fd, (uchar *)buffer, AZ_BUFSIZE_READ, 
71
 
                                     offset, MYF(0));
 
70
    s->container.read_size= pread(fd, (uchar *)buffer, AZ_BUFSIZE_READ, offset);
72
71
 
73
72
    pthread_mutex_lock(&s->container.thresh_mutex);
74
73
    s->container.ready= AZ_THREAD_FINISHED; 
258
257
  else if (s->mode == 'w') 
259
258
  {
260
259
    uchar buffer[AZHEADER_SIZE + AZMETA_BUFFER_SIZE];
261
 
    my_pread(s->file, buffer, AZHEADER_SIZE + AZMETA_BUFFER_SIZE, 0,
262
 
             MYF(0));
 
260
    pread(s->file, buffer, AZHEADER_SIZE + AZMETA_BUFFER_SIZE, 0);
263
261
    read_header(s, buffer);
264
262
    s->pos= (size_t)my_seek(s->file, 0, MY_SEEK_END, MYF(0));
265
263
  }
318
316
  *(ptr + AZ_DIRTY_POS)= (unsigned char)s->dirty; /* Start of Data Block Index Block */
319
317
 
320
318
  /* Always begin at the begining, and end there as well */
321
 
  my_pwrite(s->file, (uchar*) buffer, AZHEADER_SIZE + AZMETA_BUFFER_SIZE, 0,
322
 
            MYF(0));
 
319
  pwrite(s->file, (uchar*) buffer, AZHEADER_SIZE + AZMETA_BUFFER_SIZE, 0);
323
320
}
324
321
 
325
322
/* ===========================================================================
368
365
  if (len < 2) {
369
366
    if (len) s->inbuf[0] = s->stream.next_in[0];
370
367
    errno = 0;
371
 
    len = (uInt)my_pread(s->file, (uchar *)s->inbuf + len, AZ_BUFSIZE_READ >> len, s->pos, MYF(0));
 
368
    len = (uInt)pread(s->file, (uchar *)s->inbuf + len, AZ_BUFSIZE_READ >> len, s->pos);
372
369
    s->pos+= len;
373
370
    if (len == (uInt)-1) s->z_err = Z_ERRNO;
374
371
    s->stream.avail_in += len;
624
621
    {
625
622
 
626
623
      s->stream.next_out = s->outbuf;
627
 
      if (my_pwrite(s->file, (uchar *)s->outbuf, AZ_BUFSIZE_WRITE, s->pos, 
628
 
                   MYF(0)) != AZ_BUFSIZE_WRITE) 
 
624
      if (pwrite(s->file, (uchar *)s->outbuf, AZ_BUFSIZE_WRITE, s->pos) != AZ_BUFSIZE_WRITE) 
629
625
      {
630
626
        s->z_err = Z_ERRNO;
631
627
        break;
666
662
 
667
663
    if (len != 0) 
668
664
    {
669
 
      if ((uInt)my_pwrite(s->file, (uchar *)s->outbuf, len, s->pos, MYF(0)) != len) 
 
665
      if ((uInt)pwrite(s->file, (uchar *)s->outbuf, len, s->pos) != len) 
670
666
      {
671
667
        s->z_err = Z_ERRNO;
672
668
        assert(0);
732
728
  if (s->mode == 'r') 
733
729
  {
734
730
    unsigned char buffer[AZHEADER_SIZE + AZMETA_BUFFER_SIZE];
735
 
    my_pread(s->file, (uchar*) buffer, AZHEADER_SIZE + AZMETA_BUFFER_SIZE, 0,
736
 
             MYF(0));
 
731
    pread(s->file, (uchar*) buffer, AZHEADER_SIZE + AZMETA_BUFFER_SIZE, 0);
737
732
    read_header(s, buffer); /* skip the .az header */
738
733
    azrewind(s);
739
734
 
896
891
  for (n = 0; n < 4; n++) 
897
892
  {
898
893
    buffer[0]= (int)(x & 0xff);
899
 
    my_pwrite(s->file, buffer, 1, s->pos, MYF(0));
 
894
    pwrite(s->file, buffer, 1, s->pos);
900
895
    s->pos++;
901
896
    x >>= 8;
902
897
  }
977
972
  s->frm_length= length;
978
973
  s->start+= length;
979
974
 
980
 
  my_pwrite(s->file, (uchar*) blob, s->frm_length, s->frm_start_pos, MYF(0));
 
975
  pwrite(s->file, (uchar*) blob, s->frm_length, s->frm_start_pos);
981
976
 
982
977
  write_header(s);
983
978
  s->pos= (size_t)my_seek(s->file, 0, MY_SEEK_END, MYF(0));
987
982
 
988
983
int azread_frm(azio_stream *s, char *blob)
989
984
{
990
 
  my_pread(s->file, (uchar*) blob, s->frm_length, s->frm_start_pos, MYF(0));
 
985
  pread(s->file, (uchar*) blob, s->frm_length, s->frm_start_pos);
991
986
 
992
987
  return 0;
993
988
}
1008
1003
  s->comment_length= length;
1009
1004
  s->start+= length;
1010
1005
 
1011
 
  my_pwrite(s->file, (uchar*) blob, s->comment_length, s->comment_start_pos,
1012
 
            MYF(0));
 
1006
  pwrite(s->file, (uchar*) blob, s->comment_length, s->comment_start_pos);
1013
1007
 
1014
1008
  write_header(s);
1015
1009
  s->pos= (size_t)my_seek(s->file, 0, MY_SEEK_END, MYF(0));
1019
1013
 
1020
1014
int azread_comment(azio_stream *s, char *blob)
1021
1015
{
1022
 
  my_pread(s->file, (uchar*) blob, s->comment_length, s->comment_start_pos,
1023
 
           MYF(0));
 
1016
  pread(s->file, (uchar*) blob, s->comment_length, s->comment_start_pos);
1024
1017
 
1025
1018
  return 0;
1026
1019
}
1074
1067
#ifdef AZIO_AIO
1075
1068
use_pread:
1076
1069
#endif
1077
 
    s->stream.avail_in = (uInt)my_pread(s->file, (uchar *)s->inbuf, AZ_BUFSIZE_READ, s->pos, MYF(0));
 
1070
    s->stream.avail_in = (uInt)pread(s->file, (uchar *)s->inbuf, AZ_BUFSIZE_READ, s->pos);
1078
1071
    s->pos+= s->stream.avail_in;
1079
1072
  }
1080
1073
}