def get_shm()

in src/worker/helpers/shmem_helper.py [0:0]

• 15 lines of code
• 4 McCabe index (conditional complexity)

    def get_shm(self):
        '''Return Shared Memory'''
        if self.isClient:
            try:
                shm = shared_memory.SharedMemory(name=self.name)
                # we need to tell the client process to not destroy memory
                resource_tracker.unregister(shm._name, "shared_memory")
                # client now knows the memory was created
                self.shmCreated = True
                return shm
            except BaseException:
                return None
        else:
            if not self.shmCreated:
                return None
            else:
                return shared_memory.SharedMemory(name=self.name)