зеркало из https://github.com/github/ruby.git
merge revision(s) e5a4f757bdf5dc3d8c329ddd268432f9ecc7bff6: [Backport #20086]
Fix Window private file mapping unlink EACCES issue. (#9358) * Don't return early. * Add missing `mapping` assignment. * Make debug logs conditional. --- io_buffer.c | 18 ++++++++++++------ test/ruby/test_io_buffer.rb | 32 ++++++++++++++------------------ 2 files changed, 26 insertions(+), 24 deletions(-)
This commit is contained in:
Родитель
634d4e29ef
Коммит
818b4ea9b1
18
io_buffer.c
18
io_buffer.c
|
@ -42,6 +42,8 @@ enum {
|
|||
|
||||
// This is used to validate the flags given by the user.
|
||||
RB_IO_BUFFER_FLAGS_MASK = RB_IO_BUFFER_EXTERNAL | RB_IO_BUFFER_INTERNAL | RB_IO_BUFFER_MAPPED | RB_IO_BUFFER_SHARED | RB_IO_BUFFER_LOCKED | RB_IO_BUFFER_PRIVATE | RB_IO_BUFFER_READONLY,
|
||||
|
||||
RB_IO_BUFFER_DEBUG = 0,
|
||||
};
|
||||
|
||||
struct rb_io_buffer {
|
||||
|
@ -113,6 +115,7 @@ io_buffer_map_file(struct rb_io_buffer *buffer, int descriptor, size_t size, rb_
|
|||
}
|
||||
|
||||
HANDLE mapping = CreateFileMapping(file, NULL, protect, 0, 0, NULL);
|
||||
if (RB_IO_BUFFER_DEBUG) fprintf(stderr, "io_buffer_map_file:CreateFileMapping -> %p\n", mapping);
|
||||
if (!mapping) rb_sys_fail("io_buffer_map_descriptor:CreateFileMapping");
|
||||
|
||||
void *base = MapViewOfFile(mapping, access, (DWORD)(offset >> 32), (DWORD)(offset & 0xFFFFFFFF), size);
|
||||
|
@ -213,9 +216,13 @@ io_buffer_initialize(VALUE self, struct rb_io_buffer *buffer, void *base, size_t
|
|||
buffer->size = size;
|
||||
buffer->flags = flags;
|
||||
RB_OBJ_WRITE(self, &buffer->source, source);
|
||||
|
||||
#if defined(_WIN32)
|
||||
buffer->mapping = NULL;
|
||||
#endif
|
||||
}
|
||||
|
||||
static int
|
||||
static void
|
||||
io_buffer_free(struct rb_io_buffer *buffer)
|
||||
{
|
||||
if (buffer->base) {
|
||||
|
@ -247,18 +254,17 @@ io_buffer_free(struct rb_io_buffer *buffer)
|
|||
buffer->size = 0;
|
||||
buffer->flags = 0;
|
||||
buffer->source = Qnil;
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
#if defined(_WIN32)
|
||||
if (buffer->mapping) {
|
||||
CloseHandle(buffer->mapping);
|
||||
if (RB_IO_BUFFER_DEBUG) fprintf(stderr, "io_buffer_free:CloseHandle -> %p\n", buffer->mapping);
|
||||
if (!CloseHandle(buffer->mapping)) {
|
||||
fprintf(stderr, "io_buffer_free:GetLastError -> %d\n", GetLastError());
|
||||
}
|
||||
buffer->mapping = NULL;
|
||||
}
|
||||
#endif
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
void
|
||||
|
|
|
@ -521,24 +521,20 @@ class TestIOBuffer < Test::Unit::TestCase
|
|||
def test_private
|
||||
Tempfile.create(%w"buffer .txt") do |file|
|
||||
file.write("Hello World")
|
||||
file.close
|
||||
assert_separately(["-W0", "-", file.path], "#{<<-"begin;"}\n#{<<-'end;'}")
|
||||
begin;
|
||||
file = File.open(ARGV[0], "r+")
|
||||
buffer = IO::Buffer.map(file, nil, 0, IO::Buffer::PRIVATE)
|
||||
begin
|
||||
assert buffer.private?
|
||||
refute buffer.readonly?
|
||||
|
||||
buffer.set_string("J")
|
||||
buffer = IO::Buffer.map(file, nil, 0, IO::Buffer::PRIVATE)
|
||||
begin
|
||||
assert buffer.private?
|
||||
refute buffer.readonly?
|
||||
|
||||
# It was not changed because the mapping was private:
|
||||
file.seek(0)
|
||||
assert_equal "Hello World", file.read
|
||||
ensure
|
||||
buffer&.free
|
||||
end
|
||||
end;
|
||||
buffer.set_string("J")
|
||||
|
||||
# It was not changed because the mapping was private:
|
||||
file.seek(0)
|
||||
assert_equal "Hello World", file.read
|
||||
ensure
|
||||
buffer&.free
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
@ -11,7 +11,7 @@
|
|||
# define RUBY_VERSION_MINOR RUBY_API_VERSION_MINOR
|
||||
#define RUBY_VERSION_TEENY 0
|
||||
#define RUBY_RELEASE_DATE RUBY_RELEASE_YEAR_STR"-"RUBY_RELEASE_MONTH_STR"-"RUBY_RELEASE_DAY_STR
|
||||
#define RUBY_PATCHLEVEL 0
|
||||
#define RUBY_PATCHLEVEL 1
|
||||
|
||||
#include "ruby/version.h"
|
||||
#include "ruby/internal/abi.h"
|
||||
|
|
Загрузка…
Ссылка в новой задаче