Commit f48f7d17 authored by Ignacio Corderi's avatar Ignacio Corderi
Browse files

Support for new Device GetLog

parent ab5d26b9
Loading
Loading
Loading
Loading
+5 −0
Original line number Diff line number Diff line
@@ -2,12 +2,17 @@ Changes since 0.7.1
===========================
This section will document changes to the library since the last release

## Important
Kinetic Protocol version updated to 2.0.5

## New features
- Added zero copy support on puts and gets (Requires splice system call)
- Added IPv6 address support on all clients (Issue #8)
- Added new exception type ClusterVersionFailureException (Requires drive version 2.0.4)
- Added new Device specific GetLog (Requires protocol 2.0.5)

## Bug Fixes
- Fixed bug on invalid magix number (PR #11 contributed by @rpcope1, ASOKVAD-313)
- Fixex bug that caused close() and connect() to fail on a connection that faulted (Issue #7)
- Fixed a bug that caused the AsyncClient to crash when calling close()

Compare 389e63f8 to 80b18b44
Original line number Diff line number Diff line
Subproject commit 389e63f814cc0b5d699104c08854b5b9c1abab38
Subproject commit 80b18b440c05c5994cb1bd555f680f8f62bb0337
+8 −3
Original line number Diff line number Diff line
@@ -350,7 +350,6 @@ class Flush(object):
    def parse(m, value):
        return


    @staticmethod
    def onError(e):
        raise e
@@ -361,17 +360,23 @@ class Flush(object):
class GetLog(object):

    @staticmethod
    def build(types):
    def build(types, device=None):
        m = messages.Message()
        m.command.header.messageType = messages.Message.GETLOG

        log = m.command.body.getLog
        log.type.extend(types) #type is actually a repeatable field

        if device:
            log.device.name = device

        return (m, None)

    @staticmethod
    def parse(m, value):
        if value:
            (m.command.body.getLog, value)
        else:
            return m.command.body.getLog

    @staticmethod