}

// RLock calls read lock REST API.
func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
	return c.call(ctx, lockRPCRLock, &args)
}

// Lock calls lock REST API.
func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
	return c.call(ctx, lockRPCLock, &args)
}

// RUnlock calls read unlock REST API.

		return &dsync.LockArgs{}
	}, func() *dsync.LockResp {
		return &dsync.LockResp{}
	})
}

// registerLockRESTHandlers - register lock rest router.
func registerLockRESTHandlers(gm *grid.Manager) {
	lockServer := &lockRESTServer{
		ll: newLocker(),
	}

	storageRESTMethodStatInfoFile   = "/sfile"
	storageRESTMethodReadMultiple   = "/rmpl"
	storageRESTMethodCleanAbandoned = "/cln"
	storageRESTMethodDeleteBulk     = "/dblk"
	storageRESTMethodReadParts      = "/rps"
)

const (
	storageRESTVolume           = "vol"
	storageRESTVolumes          = "vols"
	storageRESTDirPath          = "dpath"
	storageRESTFilePath         = "fp"
	storageRESTVersionID        = "vid"

Harshavardhana <******@****.***> 1725901110 -0700

Klaus Post <******@****.***> 1700528975 -0800

Harshavardhana <******@****.***> 1722276604 -0700

Klaus Post <******@****.***> 1700528975 -0800

Klaus Post <******@****.***> 1700528975 -0800

Harshavardhana <******@****.***> 1721816641 -0700

	"errors"
	"net/http"
	"net/url"
	"time"

	xhttp "github.com/minio/minio/internal/http"
	"github.com/minio/minio/internal/rest"
)

// ReconnectRESTClient is a wrapper type for rest.Client which provides reconnect on first failure.
type ReconnectRESTClient struct {
	u    *url.URL
	rest *rest.Client
}

// newClient constructs a ReconnectRESTClient object with addr and endpoint initialized.