Commit 0cd12b40 authored by Ignacio Corderi's avatar Ignacio Corderi
Browse files

Changed background operations to new definition

parent 93485ab5

CHANGES.md

+4 −0
Original line number Diff line number Diff line
@@ -2,8 +2,12 @@ Changes since 0.8.0 
===========================

This section will document changes to the library since the last release



## Important

- Kinetic Protocol version updated to [3.0.5](https://github.com/Seagate/kinetic-protocol/tree/3.0.5)



## New features

- Added timeout, time_quanta, priority and early_exit support

- Pin size added to limits



Changes from 0.7.3 to 0.8.0

===========================

kinetic/operations.py

+6 −12
Original line number Diff line number Diff line
@@ -435,12 +435,9 @@ class MediaScan(BaseOperation): 


        m = self.m



        m.header.messageType = messages.Command.BACKOP

        m.header.messageType = messages.Command.MEDIASCAN



        op = m.body.backgroundOperation

        op.backOpType = messages.Command.BackgroundOperation.MEDIASCAN



        kr = op.range

        kr = m.body.range

        kr.startKey = startKey

        kr.endKey = endKey

        kr.startKeyInclusive = startKeyInclusive
@@ -450,7 +447,7 @@ class MediaScan(BaseOperation): 
        return (m, None)



    def parse(self, m, value):

        r = m.body.backgroundOperation.range

        r = m.body.range

        return ([k for k in r.keys], r.endKey)
@@ -467,12 +464,9 @@ class MediaOptimize(BaseOperation): 


        m = self.m



        m.header.messageType = messages.Command.BACKOP

        m.header.messageType = messages.Command.MEDIAOPTIMIZE



        op = m.body.backgroundOperation

        op.backOpType = messages.Command.BackgroundOperation.MEDIAOPTIMIZE



        kr = op.range

        kr = m.body.range

        kr.startKey = startKey

        kr.endKey = endKey

        kr.startKeyInclusive = startKeyInclusive
@@ -482,7 +476,7 @@ class MediaOptimize(BaseOperation): 
        return (m, None)



    def parse(self, m, value):

        r = m.body.backgroundOperation.range

        r = m.body.range

        return ([k for k in r.keys], r.endKey)