disks := z.serverPools[0].GetDisks(0)()
	distribution := []int{16, 14, 12, 10, 8, 6, 4, 2, 1, 3, 5, 7, 9, 11, 13, 15}
	shuffledDisks := shuffleDisks(disks, distribution)
	// From the "distribution" above you can notice that:
	// 1st data block is in the 9th disk (i.e distribution index 8)
	// 2nd data block is in the 8th disk (i.e distribution index 7) and so on.
	if shuffledDisks[0] != disks[8] ||

		offset |= 0x6 << 12
	case 4:
		offset |= 0x2 << 12
	default:
		return 0, errors.New("invalid register numbers in ARM64 register list")
	}
	offset |= arrangement
	// arm64 uses the 60th bit to differentiate from other archs
	// For more details, refer to: obj/arm64/list7.go
	offset |= 1 << 60
	return offset, nil

            }
        } else if (logger.isDebugEnabled()) {
            logger.debug("Visited urlQueue: {}", urlQueue);
        }
    }

    /**
     * Creates an access result from response data and result data.
     *
     * @param responseData the response data
     * @param resultData the result data
     * @return the created access result
     */

                    }
                }
            }
        } catch (IOException e) {
            log.error("Failed to load persisted handles from directory: " + stateDirectory, e);
        }
    }

    /**
     * Get existing handle data for reconnection
     * @param path the file path
     * @return the file ID if available, null otherwise
     */

    }

    @Test
    @DisplayName("Test maxOutputResponse calculation with transaction buffer size")
    void testMaxOutputResponseCalculation() {
        // Test that maxOutputResponse is properly calculated from transaction buffer size
        when(mockConfig.getTransactionBufferSize()).thenReturn(8192);

        Smb2IoctlRequest request = new Smb2IoctlRequest(mockConfig, TEST_CONTROL_CODE);

        assertNotNull(request);

        Smb2LeaseKey key = leaseManager.requestLease(path, initialState);
        leaseManager.updateLease(key, initialState);

        // Call with default timeout (should use 60 seconds from config)
        leaseManager.handleLeaseBreakWithTimeout(key, newState);

        LeaseEntry entry = leaseManager.getLease(key);
        assertNotNull(entry);
        assertEquals(newState, entry.getLeaseState());

        // Act
        SmbFileHandleImpl result = SmbCopyUtil.openCopyTargetFile(dest, attrs, alsoRead);

        // Assert
        assertSame(handle, result, "Should return handle from dest.openUnshared");

        ArgumentCaptor<Integer> accessCaptor = ArgumentCaptor.forClass(Integer.class);
        verify(dest, times(1)).openUnshared(anyInt(), accessCaptor.capture(), anyInt(), eq(attrs), anyInt());

                return Stream.empty();
            }
        };
    }

    /**
     * Creates new instance of problem collector with configuration from the provided session.
     *
     * @param <P> the type of problem
     * @param protoSession the session containing configuration for the problem collector
     * @return a new problem collector instance
     */

            verify(mockStrategies.get(2), Mockito.never()).apply(Mockito.any(), Mockito.any());
        }

        @Test
        @DisplayName("should aggregate results from multiple strategies")
        void shouldAggregateResultsFromMultipleStrategies() throws Exception {
            UpgradeContext context = createMockContext();
            Map<Path, Document> pomMap = Map.of(

The same models are shared among requests, so, it's not one model per request, or one per user or something similar.

Let's imagine that loading the model can **take quite some time**, because it has to read a lot of **data from disk**. So you don't want to do it for every request.