From 83eb785fec468840f4268bd1c75f99ac9f57b9d5 Mon Sep 17 00:00:00 2001 From: Andrew Mitchell Date: Thu, 3 Jul 2014 18:09:52 -0700 Subject: [PATCH] Fixed example issue --- src/copydrive.cc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/copydrive.cc b/src/copydrive.cc index 2c3bb30..db2b20a 100644 --- a/src/copydrive.cc +++ b/src/copydrive.cc @@ -25,7 +25,7 @@ #include "kinetic/kinetic.h" -static const int kP2PBatchSize = 300; +static const int kP2PBatchSize = 10; using kinetic::KineticConnectionFactory; using kinetic::Status; using kinetic::KineticRecord; @@ -48,7 +48,7 @@ kinetic::P2PPushRequest prepare_request(const vector& if (currentDestination < destinations.size() - 1) { // Add the pipleline request onto this request's first operation - request.operations[0].request = make_shared<::kinetic::P2PPushRequest>( + request.operations[request.operations.size() - 1].request = make_shared<::kinetic::P2PPushRequest>( prepare_request(operations, destinations, currentDestination + 1)); }