[Issue #228] fix decompression errors

Author: gsmolk

src/data.c

@@ -528,7 +528,7 @@ compress_and_backup_page(pgFile *file, BlockNumber blknum,
 	file->write_size += write_buffer_size;
 	file->uncompressed_size += BLCKSZ;
 
-	return write_buffer_size;
+	return compressed_size;
 }
 
 /*

src/dir.c

@@ -250,6 +250,21 @@ pgFileDelete(pgFile *file, const char *full_path)
 		elog(ERROR, "Cannot remove file \"%s\": %s", full_path,
 			strerror(errno));
 	}
+
+	if (file->n_headers > 0)
+	{
+		char full_path_hdr[MAXPGPATH];
+
+		snprintf(full_path_hdr, MAXPGPATH, "%s_hdr", full_path);
+
+		if (remove(full_path_hdr) == -1)
+		{
+			if (errno == ENOENT)
+				return;
+			elog(ERROR, "Cannot remove file \"%s\": %s", full_path_hdr,
+				strerror(errno));
+		}
+	}
 }
 
 /*

src/utils/file.c

@@ -1783,7 +1783,7 @@ static void fio_send_pages_impl(int out, char* buf)
 			headers[hdr_num].lsn = page_st.lsn;
 			headers[hdr_num].checksum = page_st.checksum;
 			headers[hdr_num].pos = hdr_cur_pos;
-			headers[hdr_num].compressed_size = hdr.size;
+			headers[hdr_num].compressed_size = compressed_size;
 
 			hdr_cur_pos += hdr.size;
 		}