File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -21,7 +21,7 @@ def create_shm(self):
2121 self .arr = np .ndarray (self .shape , dtype = self .dtype , buffer = self .shm .buf )
2222
2323 def link_shm (self ):
24- self .shm = shared_memory . SharedMemory ( name = self .name , create = False , size = self .dest_size )
24+ self .shm = create_or_link_shm ( self .name , self .dest_size )
2525 assert self .shm .size == self .dest_size
2626 self .arr = np .ndarray (self .shape , dtype = self .dtype , buffer = self .shm .buf )
2727 return
Original file line number Diff line number Diff line change @@ -26,7 +26,7 @@ def create_or_link_shm(name, expected_size):
2626 try :
2727 try :
2828 shm = shared_memory .SharedMemory (name = safe_name , create = True , size = expected_size )
29- logger .info (f"Created new shared memory: { name } ({ expected_size = } )" )
29+ logger .info (f"Created new shared memory: { name } (size= { expected_size } )" )
3030 return shm
3131 except FileExistsError :
3232 try :
@@ -37,7 +37,7 @@ def create_or_link_shm(name, expected_size):
3737 except Exception as e :
3838 logger .error (f"Unexpected error attaching to shared memory { name } : { e } " )
3939 raise
40- logger .info (f"Attached to existing shared memory: { name } ({ expected_size = } )" )
40+ logger .info (f"Attached to existing shared memory: { name } (size= { expected_size } )" )
4141 return shm
4242 except Exception as e :
4343 logger .error (f"Unexpected error creating shared memory { safe_name } : { e } " )
You can’t perform that action at this time.
0 commit comments