Signed-off-by: Nikita Zinkevich <n.zinkevich@yadro.com>

@@ -20,0 +23,4 @@
+}
+
+type MultipartInfoStream interface {
+	Next(marker, uploadID string) (*MultipartInfo, error)

@@ -515,0 +516,4 @@
+	isTruncated := true
+	var last data.MultipartInfo
+	var info *data.MultipartInfo
+	for uploadsCount <= p.MaxUploads {

@@ -515,0 +531,4 @@
+			last = *info
+		}
+		upload := uploadInfoFromMultipartInfo(info, p.Prefix, p.Delimiter)
+		if upload != nil {

@@ -556,0 +574,4 @@
+	owner := n.BearerOwner(ctx)
+	cacheKey := cache.CreateListMultipartSessionCacheKey(p.Bkt.CID, p.Prefix, p.KeyMarker, p.UploadIDMarker)
+	session = n.cache.GetListMultipartSession(owner, cacheKey)
+	if session == nil {

@@ -556,0 +575,4 @@
+	cacheKey := cache.CreateListMultipartSessionCacheKey(p.Bkt.CID, p.Prefix, p.KeyMarker, p.UploadIDMarker)
+	session = n.cache.GetListMultipartSession(owner, cacheKey)
+	if session == nil {
+		ctx, cancel := context.WithCancel(ctx)

@@ -44,3 +44,3 @@
 	GetVersions(ctx context.Context, bktInfo *data.BucketInfo, objectName string) ([]*data.NodeVersion, error)
 	GetLatestVersion(ctx context.Context, bktInfo *data.BucketInfo, objectName string) (*data.NodeVersion, error)
-	InitVersionsByPrefixStream(ctx context.Context, bktInfo *data.BucketInfo, prefix string, latestOnly bool) (data.VersionsStream, error)
+	InitVersionsByPrefixStream(ctx context.Context, bktInfo *data.BucketInfo, prefix, treeID string, latestOnly bool) (data.VersionsStream, error)

@@ -900,28 +900,10 @@ func (s *DummySubTreeStream) Next() (NodeResponse, error) {
 	return s.data, nil
 }
 
-type MultiID []uint64

@@ -1084,0 +1084,4 @@
+	}, nil
+}
+
+func (c *Tree) InitMultipartsByPrefixStream(ctx context.Context, bktInfo *data.BucketInfo, prefix, treeID string, latestOnly bool) (data.VersionsStream, error) {

@@ -556,0 +577,4 @@
+	cacheKey := cache.CreateListMultipartSessionCacheKey(p.Bkt.CID, p.Prefix, p.KeyMarker, p.UploadIDMarker)
+	session = n.cache.GetListMultipartSession(owner, cacheKey)
+	if session == nil || session.Acquired.Swap(true) {
+		ctx, cancel := context.WithCancel(context.Background())

@@ -74,3 +74,3 @@
 	}
 
-	commonVersionsListingParams struct {
+	commonListingParams struct {

@@ -80,3 +80,3 @@
 		MaxKeys   int
 		Marker    string
-		Bookmark  string
+		// key to store session in cache

@@ -0,0 +31,4 @@
+	// DefaultListMultipartSessionCacheLifetime is a default lifetime of entries in cache of ListMultipartUploads.
+	DefaultListMultipartSessionCacheLifetime = time.Second * 60
+	// DefaultListMultipartSessionCacheSize is a default size of cache of ListMultipartUploads.
+	DefaultListMultipartSessionCacheSize = 100

@@ -540,3 +553,1 @@
-		uploads = uploads[:p.MaxUploads]
-		result.NextUploadIDMarker = uploads[len(uploads)-1].UploadID
-		result.NextKeyMarker = uploads[len(uploads)-1].Key
+		result.NextUploadIDMarker = info.UploadID

@@ -515,0 +521,4 @@
+				break
+			}
+			n.reqLogger(ctx).Warn(logs.CouldNotGetMultipartUploadInfo, zap.Error(err))
+			continue

@@ -553,6 +567,40 @@ func (n *Layer) ListMultipartUploads(ctx context.Context, p *ListMultipartUpload
 	return &result, nil

@@ -1340,0 +1344,4 @@
+}
+
+func (c *Tree) GetMultipartUploadsByPrefix(ctx context.Context, bktInfo *data.BucketInfo, params data.MultipartStreamParams) (data.MultipartInfoStream, error) {
+	stream, err := c.getSubTreeByPrefixStream(ctx, bktInfo, systemTree, params.Prefix)

@@ -1253,6 +1211,26 @@ func formFilePath(node NodeResponse, fileName string, namesMap map[uint64]string
 	return filepath, nil
 }
 
+func formFilePathV2(node treeNode, filename string, namesMap map[uint64]*treeNode) (string, error) {

@@ -1329,0 +1313,4 @@
+			continue
+		}
+
+		m.nodeNames[tNode.ID[0]] = tNode

@@ -531,2 +542,2 @@
-		if p.UploadIDMarker != "" {
-			uploads = trimAfterUploadIDAndKey(p.KeyMarker, p.UploadIDMarker, uploads)
+	isTruncated := true
+	next, err := session.Stream.Next(ctx)

@@ -1340,0 +1316,4 @@
+		if filePath, err = formFilePath(tNode, fileName, m.nodePaths); err != nil {
+			if errors.Is(err, errParentPathNotFound) {
+				filePath = fileName
+				m.nodePaths[tNode.ID[0]] = filePath

@@ -1340,3 +1341,4 @@
 	if err != nil {
 		return nil, err
 	}
+	if node.ID[0] == m.rootID[0] {

@@ -1344,3 +1355,1 @@
-	var parentPrefix string
-	if parentFilePath != "" { // The root of subTree can also have a parent
-		parentPrefix = strings.TrimSuffix(parentFilePath, separator) + separator // To avoid 'foo//bar'
+func (m *multipartInfoStream) getTreeNodeFromStream(stream SubTreeStream) (*treeNode, error) {

@@ -515,0 +520,4 @@
+	for uploadsCount < p.MaxUploads {
+		info, err = session.Stream.Next(ctx)
+		if err != nil {
+			if err == io.EOF {

@@ -1340,0 +1300,4 @@
+		tNode, err = m.getTreeNodeFromStream(m.currentStream)
+		if err != nil {
+			if err == io.EOF {
+				var err2 error

@@ -1340,0 +1309,4 @@
+			return nil, err
+		}
+		var ok bool
+		fileName, ok = tNode.FileName()

@@ -1340,0 +1314,4 @@
+			continue
+		}
+		if filePath, err = formFilePath(tNode, fileName, m.nodePaths); err != nil {
+			if errors.Is(err, errParentPathNotFound) {

@@ -1340,0 +1326,4 @@
+			continue
+		}
+		if id, ok := tNode.Meta[uploadIDKV]; ok {
+			if m.keyMarker == "" || filePath > m.keyMarker || (filePath == m.keyMarker && m.uploadID != "" && id > m.uploadID) {