From d6f5098c211991e5514fddf196053e7780979d0e Mon Sep 17 00:00:00 2001 From: Dennis Dalessandro Date: Tue, 5 Feb 2008 14:01:45 -0500 Subject: [PATCH] another offset bug --- src/client/sysint/sys-osd-io.sm | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/src/client/sysint/sys-osd-io.sm b/src/client/sysint/sys-osd-io.sm index fef1637..cc40db6 100644 --- a/src/client/sysint/sys-osd-io.sm +++ b/src/client/sysint/sys-osd-io.sm @@ -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)); @@ -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; @@ -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)); @@ -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; }