|
@@ -1,184 +0,0 @@
|
|
|
-/*************************************************************************/
|
|
|
-/* shared_mem_access_posix.cpp */
|
|
|
-/*************************************************************************/
|
|
|
-/* This file is part of: */
|
|
|
-/* GODOT ENGINE */
|
|
|
-/* https://godotengine.org */
|
|
|
-/*************************************************************************/
|
|
|
-/* Copyright (c) 2007-2019 Juan Linietsky, Ariel Manzur. */
|
|
|
-/* Copyright (c) 2014-2019 Godot Engine contributors (cf. AUTHORS.md) */
|
|
|
-/* */
|
|
|
-/* Permission is hereby granted, free of charge, to any person obtaining */
|
|
|
-/* a copy of this software and associated documentation files (the */
|
|
|
-/* "Software"), to deal in the Software without restriction, including */
|
|
|
-/* without limitation the rights to use, copy, modify, merge, publish, */
|
|
|
-/* distribute, sublicense, and/or sell copies of the Software, and to */
|
|
|
-/* permit persons to whom the Software is furnished to do so, subject to */
|
|
|
-/* the following conditions: */
|
|
|
-/* */
|
|
|
-/* The above copyright notice and this permission notice shall be */
|
|
|
-/* included in all copies or substantial portions of the Software. */
|
|
|
-/* */
|
|
|
-/* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
|
|
|
-/* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
|
|
|
-/* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
|
|
|
-/* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
|
|
|
-/* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
|
|
|
-/* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
|
|
|
-/* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
|
|
|
-/*************************************************************************/
|
|
|
-
|
|
|
-#include "shared_mem_access_posix.h"
|
|
|
-
|
|
|
-#if defined(UNIX_ENABLED)
|
|
|
-
|
|
|
-//#include "core/os/memory.h"
|
|
|
-#include <sys/mman.h>
|
|
|
-#include <sys/stat.h>
|
|
|
-#include <unistd.h>
|
|
|
-//#include <stdio.h>
|
|
|
-#include <fcntl.h>
|
|
|
-//#include <sys/mman.h>
|
|
|
-//#include <sys/stat.h>
|
|
|
-
|
|
|
-SharedMemAccess *SharedMemAccessPosix::create_func_posix(const String &p_name) {
|
|
|
-
|
|
|
- return memnew(SharedMemAccessPosix(p_name));
|
|
|
-}
|
|
|
-
|
|
|
-void SharedMemAccessPosix::make_default() {
|
|
|
-
|
|
|
- create_func = create_func_posix;
|
|
|
-}
|
|
|
-
|
|
|
-Error SharedMemAccessPosix::open() {
|
|
|
-
|
|
|
- ERR_EXPLAIN("Already open.");
|
|
|
- ERR_FAIL_COND_V(fd != -1, ERR_ALREADY_IN_USE);
|
|
|
-
|
|
|
- fd = shm_open(("/" + name).utf8().get_data(), O_CREAT | O_RDWR, 0600);
|
|
|
- if (fd == -1) {
|
|
|
- ERR_EXPLAIN("Cannot create/open.");
|
|
|
- ERR_FAIL_V(ERR_CANT_OPEN);
|
|
|
- }
|
|
|
-
|
|
|
- return OK;
|
|
|
-}
|
|
|
-
|
|
|
-Error SharedMemAccessPosix::close() {
|
|
|
-
|
|
|
- ERR_EXPLAIN("Not open.");
|
|
|
- ERR_FAIL_COND_V(!is_open(), ERR_UNCONFIGURED);
|
|
|
-
|
|
|
- if (!lock()) {
|
|
|
- ERR_EXPLAIN("Cannot lock.");
|
|
|
- ERR_FAIL_V(ERR_BUSY);
|
|
|
- }
|
|
|
-
|
|
|
- if (is_allocator) {
|
|
|
- shm_unlink(("/" + name).utf8().get_data());
|
|
|
- is_allocator = false;
|
|
|
- }
|
|
|
-
|
|
|
- ::close(fd);
|
|
|
- fd = -1;
|
|
|
-
|
|
|
- unlock();
|
|
|
-
|
|
|
- return OK;
|
|
|
-}
|
|
|
-
|
|
|
-_FORCE_INLINE_ bool SharedMemAccessPosix::is_open() {
|
|
|
-
|
|
|
- return fd != -1;
|
|
|
-}
|
|
|
-
|
|
|
-void *SharedMemAccessPosix::lock() {
|
|
|
-
|
|
|
- ERR_EXPLAIN("Not open.");
|
|
|
- ERR_FAIL_COND_V(!is_open(), NULL);
|
|
|
-
|
|
|
- ERR_EXPLAIN("Lock already held.");
|
|
|
- ERR_FAIL_COND_V(is_locking(), NULL);
|
|
|
-
|
|
|
- size = lseek(fd, 0, SEEK_END);
|
|
|
-
|
|
|
- lock_addr = mmap(NULL, size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
|
|
|
- if (lock_addr == MAP_FAILED) {
|
|
|
- ERR_EXPLAIN("Cannot map memory.");
|
|
|
- ERR_FAIL_V(NULL);
|
|
|
- }
|
|
|
-
|
|
|
- return lock_addr;
|
|
|
-}
|
|
|
-
|
|
|
-void SharedMemAccessPosix::unlock() {
|
|
|
-
|
|
|
- ERR_EXPLAIN("Lock not held.");
|
|
|
- ERR_FAIL_COND(!is_locking());
|
|
|
-
|
|
|
- munmap(lock_addr, size);
|
|
|
- lock_addr = NULL;
|
|
|
- size = 0;
|
|
|
-}
|
|
|
-
|
|
|
-_FORCE_INLINE_ bool SharedMemAccessPosix::is_locking() {
|
|
|
-
|
|
|
- return lock_addr;
|
|
|
-}
|
|
|
-
|
|
|
-void *SharedMemAccessPosix::set_size(uint64_t p_size) {
|
|
|
-
|
|
|
- ERR_EXPLAIN("Lock must be held to set the size.");
|
|
|
- ERR_FAIL_COND_V(!is_locking(), NULL);
|
|
|
-
|
|
|
- if (ftruncate(fd, p_size) == -1) {
|
|
|
- ERR_EXPLAIN("Cannot set new size. (Out of memory?)");
|
|
|
- ERR_FAIL_V(NULL);
|
|
|
- }
|
|
|
-
|
|
|
- munmap(lock_addr, size);
|
|
|
-
|
|
|
- // Try to remap at former address
|
|
|
- lock_addr = mmap(lock_addr, p_size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
|
|
|
- if (lock_addr == MAP_FAILED) {
|
|
|
- unlock();
|
|
|
-
|
|
|
- ERR_EXPLAIN("Cannot remap memory. Lock released.");
|
|
|
- ERR_FAIL_V(NULL);
|
|
|
- }
|
|
|
-
|
|
|
- return lock_addr;
|
|
|
-}
|
|
|
-
|
|
|
-uint64_t SharedMemAccessPosix::get_size() {
|
|
|
-
|
|
|
- ERR_EXPLAIN("Lock must be held to get the size.");
|
|
|
- ERR_FAIL_COND_V(!is_locking(), 0);
|
|
|
-
|
|
|
- return size;
|
|
|
-}
|
|
|
-
|
|
|
-SharedMemAccessPosix::SharedMemAccessPosix(const String &p_name) :
|
|
|
- name(p_name),
|
|
|
- is_allocator(false),
|
|
|
- size(0),
|
|
|
- fd(-1),
|
|
|
- lock_addr(NULL) {
|
|
|
-}
|
|
|
-
|
|
|
-SharedMemAccessPosix::~SharedMemAccessPosix() {
|
|
|
-
|
|
|
- if (is_open()) {
|
|
|
-
|
|
|
- if (is_locking()) {
|
|
|
- unlock();
|
|
|
- }
|
|
|
-
|
|
|
- if (close() != OK && is_allocator) {
|
|
|
- ERR_PRINTS("Leaking shared memory '" + name + "'.");
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-#endif
|