def create_shm()

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

• 19 lines of code
• 5 McCabe index (conditional complexity)

    def create_shm(self, data=None, size=1024):
        '''
        Create memory of data size or of specified size. If data assign data.
        '''
        # client does not need to create shared mem just retrieve
        if self.isClient:
            shm = self.get_shm()
        else:
            if self.shmCreated:
                self.delete_shm()  # delete old shared memory
            if data:  # If data provided creat shm of size data and assign
                size = len(data.encode("utf8"))
                shm = shared_memory.SharedMemory(
                    create=True, size=size, name=self.name)
                shm.buf[:size] = bytes(data, 'UTF-8')
            else:  # Create shm of specified size
                shm = shared_memory.SharedMemory(
                    create=True, size=size, name=self.name)
        self.shmCreated = True
        return shm