AnonymousBuffer.cpp 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101
  1. /*
  2. * Copyright (c) 2021, Andreas Kling <kling@serenityos.org>
  3. *
  4. * SPDX-License-Identifier: BSD-2-Clause
  5. */
  6. #include <LibCore/AnonymousBuffer.h>
  7. #include <LibIPC/Decoder.h>
  8. #include <LibIPC/Encoder.h>
  9. #include <LibIPC/File.h>
  10. #include <fcntl.h>
  11. #include <stdio.h>
  12. #include <sys/mman.h>
  13. #if defined(__serenity__)
  14. # include <serenity.h>
  15. #endif
  16. #if defined(__linux__) && !defined(MFD_CLOEXEC)
  17. # include <linux/memfd.h>
  18. # include <sys/syscall.h>
  19. static int memfd_create(const char* name, unsigned int flags)
  20. {
  21. return syscall(SYS_memfd_create, name, flags);
  22. }
  23. #endif
  24. namespace Core {
  25. AnonymousBuffer AnonymousBuffer::create_with_size(size_t size)
  26. {
  27. int fd = -1;
  28. #if defined(__serenity__)
  29. fd = anon_create(round_up_to_power_of_two(size, PAGE_SIZE), O_CLOEXEC);
  30. if (fd < 0) {
  31. perror("anon_create");
  32. return {};
  33. }
  34. #elif defined(__linux__)
  35. fd = memfd_create("", MFD_CLOEXEC);
  36. if (fd < 0) {
  37. perror("memfd_create");
  38. return {};
  39. }
  40. if (ftruncate(fd, size) < 0) {
  41. close(fd);
  42. perror("ftruncate");
  43. return {};
  44. }
  45. #endif
  46. if (fd < 0)
  47. return {};
  48. return create_from_anon_fd(fd, size);
  49. }
  50. RefPtr<AnonymousBufferImpl> AnonymousBufferImpl::create(int fd, size_t size)
  51. {
  52. auto* data = mmap(nullptr, round_up_to_power_of_two(size, PAGE_SIZE), PROT_READ | PROT_WRITE, MAP_FILE | MAP_SHARED, fd, 0);
  53. if (data == MAP_FAILED) {
  54. perror("mmap");
  55. return {};
  56. }
  57. return adopt_ref(*new AnonymousBufferImpl(fd, size, data));
  58. }
  59. AnonymousBufferImpl::~AnonymousBufferImpl()
  60. {
  61. if (m_fd != -1) {
  62. auto rc = close(m_fd);
  63. VERIFY(rc == 0);
  64. }
  65. auto rc = munmap(m_data, round_up_to_power_of_two(m_size, PAGE_SIZE));
  66. VERIFY(rc == 0);
  67. }
  68. AnonymousBuffer AnonymousBuffer::create_from_anon_fd(int fd, size_t size)
  69. {
  70. auto impl = AnonymousBufferImpl::create(fd, size);
  71. if (!impl)
  72. return {};
  73. return AnonymousBuffer(impl.release_nonnull());
  74. }
  75. AnonymousBuffer::AnonymousBuffer(NonnullRefPtr<AnonymousBufferImpl> impl)
  76. : m_impl(move(impl))
  77. {
  78. }
  79. AnonymousBufferImpl::AnonymousBufferImpl(int fd, size_t size, void* data)
  80. : m_fd(fd)
  81. , m_size(size)
  82. , m_data(data)
  83. {
  84. }
  85. AnonymousBuffer::~AnonymousBuffer()
  86. {
  87. }
  88. }