Misc

storage/innobase/buf/buf0dblwr.cc

@@ -659,7 +659,8 @@ buf_dblwr_update(
 			mutex_exit(&buf_dblwr->mutex);
 			/* This will finish the batch. Sync data files
 			to the disk. */
-			fil_flush_file_spaces(FIL_TABLESPACE);
+			if (bpage->isShared == 0)
+				fil_flush_file_spaces(FIL_TABLESPACE);
 			mutex_enter(&buf_dblwr->mutex);
 
 			/* We can now reuse the doublewrite memory buffer: */
@@ -1154,12 +1155,15 @@ buf_dblwr_flush_buffered_writes(void)
 #if 1
 			fil_share_complete_io( get_space_id(buf_dblwr->buf_block_arr[i]),
 								buf_block_get_page_no((buf_block_t*)buf_dblwr->buf_block_arr[i]));
-			if (fil_share_is_table(get_space_id(buf_dblwr->buf_block_arr[i])))
+			if (fil_share_is_table(get_space_id(buf_dblwr->buf_block_arr[i]))) {
+				buf_dblwr->buf_block_arr[i]->isShared = 1;
 				buf_page_io_complete(buf_dblwr->buf_block_arr[i]);
+				buf_dblwr->buf_block_arr[i]->isShared = 0;
+			}
 				//buf_page_share_complete(buf_dblwr->buf_block_arr[i]);
 #endif
         }
-		fsync(share_fd); /// FIXME: is this really needed? 
+		//fsync(share_fd); /// FIXME: is this really needed? 
     } else {
         /* Up to this point first_free and buf_dblwr->first_free are
            same because we have set the buf_dblwr->batch_running flag
@@ -1426,9 +1430,11 @@ buf_dblwr_write_single_page(
 				buf_block_get_page_no((buf_block_t*)bpage));
 		fil_share_complete_io(TRX_SYS_SPACE, offset);
 
+		bpage->isShared = 1;
 		if (fil_share_is_table(get_space_id(bpage)))
 			buf_page_io_complete(bpage);
-		fsync(share_fd); /// FIXME: is this really needed? 
+		bpage->isShared = 0;
+		//fsync(share_fd); /// FIXME: is this really needed? 
 #endif
     } else{
         /* We know that the write has been flushed to disk now

storage/innobase/buf/buf0lru.cc

@@ -850,8 +850,7 @@ buf_LRU_remove_pages(
 		buf_flush_dirty_pages(buf_pool, id, true, trx);
 		/* Ensure that all asynchronous IO is completed. */
 		os_aio_wait_until_no_pending_writes();
-		if (srv_use_share == 0) //ogh: we don't need flush
-			fil_flush(id);
+		fil_flush(id);
 		break;
 	}
 }

storage/innobase/fil/fil0fil.cc

@@ -1060,9 +1060,7 @@ fil_mutex_enter_and_prepare_for_io(
 
 		/* Flush tablespaces so that we can close modified
 		files in the LRU list */
-		if (srv_use_share == 0) { //ogh
-			fil_flush_file_spaces(FIL_TABLESPACE);
-		}
+		fil_flush_file_spaces(FIL_TABLESPACE);
 
 		os_thread_sleep(20000);
 
@@ -5591,7 +5589,7 @@ fil_get_fd_offset(
 		offset = ((os_offset_t) block_offset << zip_size_shift);
 	}
 
-#if 1 || defined(DEBUG_SHARE)
+#if 0 || defined(DEBUG_SHARE)
 	ib_logf(IB_LOG_LEVEL_INFO,
 		"Fille name: %s", node->name);
 	ib_logf(IB_LOG_LEVEL_INFO,

storage/innobase/include/buf0buf.h

@@ -1632,6 +1632,8 @@ struct buf_page_t{
 					or buf_block_t::mutex. */
 # endif /* UNIV_DEBUG_FILE_ACCESSES || UNIV_DEBUG */
 #endif /* !UNIV_HOTBACKUP */
+	//ogh
+	unsigned isShared;
 };
 
 /** The buffer control block structure */

storage/innobase/log/log0log.cc

@@ -2090,7 +2090,7 @@ log_checkpoint(
 		recv_apply_hashed_log_recs(TRUE);
 	}
 
-	if (!srv_use_share && srv_unix_file_flush_method != SRV_UNIX_NOSYNC) { //ogh
+	if (srv_unix_file_flush_method != SRV_UNIX_NOSYNC) { //ogh
 		fil_flush_file_spaces(FIL_TABLESPACE);
 	}