Commit b8e0bc3a authored by Jan Lindström's avatar Jan Lindström

Additional windows fixes.

parent 6cde211d
...@@ -1204,16 +1204,7 @@ os_aio_windows_handle( ...@@ -1204,16 +1204,7 @@ os_aio_windows_handle(
parameters are valid and can be used to parameters are valid and can be used to
restart the operation, for example */ restart the operation, for example */
void** message2, void** message2,
ulint* type, /*!< out: OS_FILE_WRITE or ..._READ */ ulint* type); /*!< out: OS_FILE_WRITE or ..._READ */
ulint* write_size,/*!< in/out: Actual write size initialized
after fist successfull trim
operation for this page and if
initialized we do not trim again if
actual page size does not decrease. */
ibool page_compression, /*!< in: is page compression used
on this file space */
ulint page_compression_level); /*!< page compression
level to be used */
#endif #endif
/**********************************************************************//** /**********************************************************************//**
......
...@@ -4949,8 +4949,7 @@ os_aio_func( ...@@ -4949,8 +4949,7 @@ os_aio_func(
retval = os_aio_windows_handle( retval = os_aio_windows_handle(
ULINT_UNDEFINED, slot->pos, ULINT_UNDEFINED, slot->pos,
&dummy_mess1, &dummy_mess2, &dummy_mess1, &dummy_mess2,
&dummy_type, &dummy_type);
write_size, page_compression, page_compression_level);
return(retval); return(retval);
} }
...@@ -5007,16 +5006,7 @@ os_aio_windows_handle( ...@@ -5007,16 +5006,7 @@ os_aio_windows_handle(
parameters are valid and can be used to parameters are valid and can be used to
restart the operation, for example */ restart the operation, for example */
void** message2, void** message2,
ulint* type, /*!< out: OS_FILE_WRITE or ..._READ */ ulint* type) /*!< out: OS_FILE_WRITE or ..._READ */
ulint* write_size,/*!< in/out: Actual write size initialized
after fist successfull trim
operation for this page and if
initialized we do not trim again if
actual page size does not decrease. */
ibool page_compression, /*!< in: is page compression used
on this file space */
ulint page_compression_level) /*!< page compression
level to be used */
{ {
ulint orig_seg = segment; ulint orig_seg = segment;
os_aio_array_t* array; os_aio_array_t* array;
...@@ -5123,7 +5113,7 @@ os_aio_windows_handle( ...@@ -5123,7 +5113,7 @@ os_aio_windows_handle(
switch (slot->type) { switch (slot->type) {
case OS_FILE_WRITE: case OS_FILE_WRITE:
if (slot->message1 && if (slot->message1 &&
page_compression && slot->page_compression &&
slot->page_buf) { slot->page_buf) {
ret = WriteFile(slot->file, slot->page_buf, ret = WriteFile(slot->file, slot->page_buf,
(DWORD) slot->len, &len, (DWORD) slot->len, &len,
...@@ -5164,7 +5154,7 @@ os_aio_windows_handle( ...@@ -5164,7 +5154,7 @@ os_aio_windows_handle(
ret_val = ret && len == slot->len; ret_val = ret && len == slot->len;
} }
if (slot->message1 && page_compression) { if (slot->message1 && slot->page_compression) {
// We allocate memory for page compressed buffer if and only // We allocate memory for page compressed buffer if and only
// if it is not yet allocated. // if it is not yet allocated.
if (slot->page_buf == NULL) { if (slot->page_buf == NULL) {
......
...@@ -1243,16 +1243,7 @@ os_aio_windows_handle( ...@@ -1243,16 +1243,7 @@ os_aio_windows_handle(
restart the operation, for example */ restart the operation, for example */
void** message2, void** message2,
ulint* type, /*!< out: OS_FILE_WRITE or ..._READ */ ulint* type, /*!< out: OS_FILE_WRITE or ..._READ */
ulint* space_id, ulint* space_id);
ulint* write_size,/*!< in/out: Actual write size initialized
after fist successfull trim
operation for this page and if
initialized we do not trim again if
actual page size does not decrease. */
ibool page_compression, /*!< in: is page compression used
on this file space */
ulint page_compression_level); /*!< page compression
level to be used */
#endif #endif
......
...@@ -5090,16 +5090,7 @@ os_aio_windows_handle( ...@@ -5090,16 +5090,7 @@ os_aio_windows_handle(
restart the operation, for example */ restart the operation, for example */
void** message2, void** message2,
ulint* type, /*!< out: OS_FILE_WRITE or ..._READ */ ulint* type, /*!< out: OS_FILE_WRITE or ..._READ */
ulint* space_id, ulint* space_id)
ulint* write_size,/*!< in/out: Actual write size initialized
after fist successfull trim
operation for this page and if
initialized we do not trim again if
actual page size does not decrease. */
ibool page_compression, /*!< in: is page compression used
on this file space */
ulint page_compression_level) /*!< page compression
level to be used */
{ {
ulint orig_seg = segment; ulint orig_seg = segment;
os_aio_slot_t* slot; os_aio_slot_t* slot;
...@@ -5186,7 +5177,7 @@ os_aio_windows_handle( ...@@ -5186,7 +5177,7 @@ os_aio_windows_handle(
switch (slot->type) { switch (slot->type) {
case OS_FILE_WRITE: case OS_FILE_WRITE:
if (slot->message1 && page_compression && slot->page_buf) { if (slot->message1 && slot->page_compression && slot->page_buf) {
ret_val = os_file_write(slot->name, slot->file, slot->page_buf, ret_val = os_file_write(slot->name, slot->file, slot->page_buf,
slot->control.Offset, slot->control.OffsetHigh, slot->len); slot->control.Offset, slot->control.OffsetHigh, slot->len);
} else { } else {
...@@ -5222,7 +5213,7 @@ os_aio_windows_handle( ...@@ -5222,7 +5213,7 @@ os_aio_windows_handle(
ret_val = ret && len == slot->len; ret_val = ret && len == slot->len;
} }
if (slot->message1 && page_compression) { if (slot->message1 && slot->page_compression) {
// We allocate memory for page compressed buffer if and only // We allocate memory for page compressed buffer if and only
// if it is not yet allocated. // if it is not yet allocated.
if (slot->page_buf == NULL) { if (slot->page_buf == NULL) {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment