dstIndex += 4;

        SMBUtil.writeInt2(4, dst, dstIndex); // NameOffset (from start of context)
        dstIndex += 2;

        SMBUtil.writeInt2(4, dst, dstIndex); // NameLength
        dstIndex += 2;

        SMBUtil.writeInt2(0, dst, dstIndex); // Reserved
        dstIndex += 2;

        SMBUtil.writeInt2(24, dst, dstIndex); // DataOffset (from start of context)

        assertDoesNotThrow(() -> SingletonContext.init(props));
        CIFSContext context = SingletonContext.getInstance();
        assertNotNull(context);
        assertEquals("CustomOS", context.getConfig().getNativeOs());
        assertEquals("CustomLanman", context.getConfig().getNativeLanman());
    }

    @Test
    void testInitAlreadyInitializedThrowsException() throws CIFSException {

type WarmBackend interface {
	Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error)
	PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error)
	Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error)
	Remove(ctx context.Context, object string, rv remoteVersionID) error

            int bytesRead = context.decode(buffer, 0, 8);

            assertEquals(8, bytesRead);
            assertNotNull(context.getHashAlgos());
            assertEquals(2, context.getHashAlgos().length);
            assertEquals(0x01, context.getHashAlgos()[0]);
            assertEquals(0x02, context.getHashAlgos()[1]);
            assertNotNull(context.getSalt());
            assertEquals(0, context.getSalt().length);
        }

// TransitionObject - transition object content to target tier.
func (s *erasureSets) TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error {
	return s.getHashedSet(object).TransitionObject(ctx, bucket, object, opts)
}

// RestoreTransitionedObject - restore transitioned object content locally on this cluster.

                    // Multiple threads accessing context simultaneously
                    for (int j = 0; j < 50; j++) {
                        context.getConfig();
                        context.getBufferCache();
                        context.getDfs();
                        context.getNameServiceClient();
                        context.getSIDResolver();
                        context.getTransportPool();

            when(transportPool.getChallenge(context, address)).thenReturn(challenge);
            doNothing().when(transportPool).logon(context, address);

            // When
            byte[] retrievedChallenge = transportPool.getChallenge(context, address);
            transportPool.logon(context, address);

            // Then
            assertNotNull(retrievedChallenge);

		})
	}
	return stats
}

func targetStatus(ctx context.Context, h logger.Target) madmin.Status {
	if h.IsOnline(ctx) {
		return madmin.Status{Status: string(madmin.ItemOnline)}
	}
	return madmin.Status{Status: string(madmin.ItemOffline)}
}

// fetchLoggerInfo return log info
func fetchLoggerInfo(ctx context.Context) ([]madmin.Logger, []madmin.Audit) {
	var loggerInfo []madmin.Logger

	if t, ok := config.Tiers[tierName]; ok {
		return t.Type, true
	}
	return madmin.Unsupported, false
}

// Add adds tier to config if it passes all validations.
func (config *TierConfigMgr) Add(ctx context.Context, tier madmin.TierConfig, ignoreInUse bool) error {
	config.Lock()
	defer config.Unlock()

	// check if tier name is in all caps
	tierName := tier.Name
	if tierName != strings.ToUpper(tierName) {

func (client *peerRESTClient) GetLocks(ctx context.Context) (lockMap map[string][]lockRequesterInfo, err error) {
	resp, err := getLocksRPC.Call(ctx, client.gridConn(), grid.NewMSS())
	if err != nil || resp == nil {
		return nil, err
	}
	return *resp, nil
}

// LocalStorageInfo - fetch server information for a remote node.
func (client *peerRESTClient) LocalStorageInfo(ctx context.Context, metrics bool) (info StorageInfo, err error) {