Skip to content

Commit

Permalink
another offset bug
Browse files Browse the repository at this point in the history
  • Loading branch information
Dennis Dalessandro committed Feb 5, 2008
1 parent 8707d0f commit d6f5098
Showing 1 changed file with 7 additions and 6 deletions.
13 changes: 7 additions & 6 deletions src/client/sysint/sys-osd-io.sm
Original file line number Diff line number Diff line change
Expand Up @@ -265,6 +265,9 @@ static int osd_io_setup_msgpairs(struct PINT_smcb *smcb, job_status_s *js_p)
}
this_aggregate_size += sresult.bytes;

gossip_debug(GOSSIP_IO_DEBUG, "%s: Current Offset %lld\n", __func__,
lld(target_offset[0]));

#if 0
printf("SERVER INFO [%d]:\n", i);
printf("Total size %lld \n", lld(sresult.bytes));
Expand Down Expand Up @@ -363,14 +366,14 @@ static int osd_io_setup_msgpairs(struct PINT_smcb *smcb, job_status_s *js_p)
/* Build the command for this server, using physical offset. */
if (io->io_type == PVFS_IO_READ) {
osd_command_set_read(command, PVFS_OSD_DATA_PID, datafile_handle,
len, cur_offset);
len, target_offset[0]);
command->indata = p;
command->inlen_alloc = len;
command->iov_inlen = csegs_count;

} else if (io->io_type == PVFS_IO_WRITE) {
osd_command_set_write(command, PVFS_OSD_DATA_PID, datafile_handle,
len, cur_offset);
len, target_offset[0]);
command->outdata = p;
command->outlen = len;
command->iov_outlen = csegs_count;
Expand Down Expand Up @@ -574,9 +577,6 @@ static int osd_io_setup_msgpairs(struct PINT_smcb *smcb, job_status_s *js_p)

}




gossip_debug(GOSSIP_IO_DEBUG, "%s: Aggreagte Transferred: %lld\n", __func__,
lld(this_aggregate_size));

Expand Down Expand Up @@ -678,10 +678,11 @@ static int osd_io_completion_fn(
if (sm_p->msgarray[index].osd_iov != NULL)
free(sm_p->msgarray[index].osd_iov);


io->dfile_size_array[index] += result_size;
io->total_size += result_size;



return 0;
}

Expand Down

0 comments on commit d6f5098

Please sign in to comment.