File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 25
25
26
26
#include " kinetic/kinetic.h"
27
27
28
- static const int kP2PBatchSize = 300 ;
28
+ static const int kP2PBatchSize = 10 ;
29
29
using kinetic::KineticConnectionFactory;
30
30
using kinetic::Status;
31
31
using kinetic::KineticRecord;
@@ -48,7 +48,7 @@ kinetic::P2PPushRequest prepare_request(const vector<kinetic::P2PPushOperation>&
48
48
49
49
if (currentDestination < destinations.size () - 1 ) {
50
50
// Add the pipleline request onto this request's first operation
51
- request.operations [0 ].request = make_shared<::kinetic::P2PPushRequest>(
51
+ request.operations [request. operations . size () - 1 ].request = make_shared<::kinetic::P2PPushRequest>(
52
52
prepare_request (operations, destinations, currentDestination + 1 ));
53
53
}
54
54
You can’t perform that action at this time.
0 commit comments