in src/worker/helpers/shmem_helper.py [0:0]
def resize_shm(self, data=None, size=None):
'''
Allow the client or server to resize the memory space
'''
# Return nothing if shared mem has not been created
if not self.shmCreated:
return None
if self.isClient:
# allow client to switch to server mode, creating shmem is only
# allowed in server mode
self.isClient = False
# resource_tracker.register(self.name, "shared_memory")
shm = self.create_shm(data, size)
resource_tracker.unregister(shm._name, "shared_memory")
self.isClient = True # switch back to client mode
else:
return self.create_shm(data, size)