Create a new distributed-shared object (not backed by a shared memory block) and return its id to be used in a Proxy Object.
(self, c, typeid, /, *args, **kwargs)
| 1303 | util.debug(f"SharedMemoryServer started by pid {getpid()}") |
| 1304 | |
| 1305 | def create(self, c, typeid, /, *args, **kwargs): |
| 1306 | """Create a new distributed-shared object (not backed by a shared |
| 1307 | memory block) and return its id to be used in a Proxy Object.""" |
| 1308 | # Unless set up as a shared proxy, don't make shared_memory_context |
| 1309 | # a standard part of kwargs. This makes things easier for supplying |
| 1310 | # simple functions. |
| 1311 | if hasattr(self.registry[typeid][-1], "_shared_memory_proxy"): |
| 1312 | kwargs['shared_memory_context'] = self.shared_memory_context |
| 1313 | return Server.create(self, c, typeid, *args, **kwargs) |
| 1314 | |
| 1315 | def shutdown(self, c): |
| 1316 | "Call unlink() on all tracked shared memory, terminate the Server." |