Commit 3eb56931 authored by plensing's avatar plensing
Browse files

Added explicit flush to blocking and nonblocking API.

parent ad398d5a

include/kinetic/blocking_kinetic_connection.h

+2 −0
Original line number Diff line number Diff line
@@ -134,6 +134,8 @@ class BlockingKineticConnection : public BlockingKineticConnectionInterface { 
    KineticStatus P2PPush(const shared_ptr<const P2PPushRequest> push_request,

            unique_ptr<vector<KineticStatus>>& operation_statuses);



    KineticStatus Flush();



    KineticStatus SetClusterVersion(int64_t cluster_version);

    KineticStatus UpdateFirmware(const shared_ptr<const string> new_firmware);

    KineticStatus SetACLs(const shared_ptr<const list<ACL>> acls);

include/kinetic/blocking_kinetic_connection_interface.h

+1 −0
Original line number Diff line number Diff line
@@ -117,6 +117,7 @@ class BlockingKineticConnectionInterface { 
            unique_ptr<vector<KineticStatus>>& operation_statuses) = 0;

    virtual KineticStatus P2PPush(const shared_ptr<const P2PPushRequest> push_request,

            unique_ptr<vector<KineticStatus>>& operation_statuses) = 0;

    virtual KineticStatus Flush() = 0;



    virtual KineticStatus SetClusterVersion(int64_t cluster_version) = 0;

    virtual KineticStatus UpdateFirmware(const shared_ptr<const string> new_firmware) = 0;

include/kinetic/nonblocking_kinetic_connection.h

+1 −0
Original line number Diff line number Diff line
@@ -68,6 +68,7 @@ class NonblockingKineticConnection : public NonblockingKineticConnectionInterfac 
            const shared_ptr<P2PPushCallbackInterface> callback);

    HandlerKey GetLog(const shared_ptr<GetLogCallbackInterface> callback);

    HandlerKey GetLog(const vector<Command_GetLog_Type>& types, const shared_ptr<GetLogCallbackInterface> callback);

    HandlerKey Flush(const shared_ptr<SimpleCallbackInterface> callback);



    HandlerKey UpdateFirmware(const shared_ptr<const string> new_firmware, const shared_ptr<SimpleCallbackInterface> callback);

    HandlerKey SetClusterVersion(int64_t new_cluster_version, const shared_ptr<SimpleCallbackInterface> callback);

include/kinetic/nonblocking_kinetic_connection_interface.h

+1 −0
Original line number Diff line number Diff line
@@ -285,6 +285,7 @@ public: 
    virtual HandlerKey GetLog(const shared_ptr<GetLogCallbackInterface> callback) = 0;

    virtual HandlerKey GetLog(const vector<Command_GetLog_Type>& types,

            const shared_ptr<GetLogCallbackInterface> callback) = 0;

    virtual HandlerKey Flush(const shared_ptr<SimpleCallbackInterface> callback) = 0;



    virtual HandlerKey UpdateFirmware(const shared_ptr<const string> new_firmware,

        const shared_ptr<SimpleCallbackInterface> callback) = 0;

include/kinetic/threadsafe_blocking_kinetic_connection.h

+2 −0
Original line number Diff line number Diff line
@@ -134,6 +134,8 @@ class ThreadsafeBlockingKineticConnection : public BlockingKineticConnectionInte 
      KineticStatus P2PPush(const shared_ptr<const P2PPushRequest> push_request,

              unique_ptr<vector<KineticStatus>>& operation_statuses);



      KineticStatus Flush();



      KineticStatus SetClusterVersion(int64_t cluster_version);

      KineticStatus UpdateFirmware(const shared_ptr<const string> new_firmware);

      KineticStatus SetACLs(const shared_ptr<const list<ACL>> acls);