Unclear on how pipelining works with Cluster mode about hiredis-cluster HOT 6 CLOSED

std::string result; // Stores the result from the pipeline
std::string delimiter = "\n"; // Each command will be separated by a newline
size_t pos=0; // Position of the next redis command
std::string rcmd; // Redis HSET command 
std::array<char, 5000> buffer; // Holds each line of the parsed file. We assume that each line will be atmost than 5000 characters in length
std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd, "r"), pclose); // Read from the open pipeline ...
if (!pipe) {
    throw std::runtime_error("popen() failed!");
}
while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) { // fgets is useful because it will stop when it reaches \n or EOF, we use this to store each line in a buffer array and then push the command to redis...
    result += buffer.data(); 
    tot_cmds += 1;
}
// Add a newline at the end of the results (handles EOF):
result+="\n";

unsigned int remainder = tot_cmds % batch_size; // Use this to clean up any remaining commands (over/under the batch size)
  if ( tot_cmds > batch_size ){
      for ( i=0; i < tot_cmds/batch_size; i++ ) { // for each batch, do the following...
          n_cmd=0; // Reset the number of commands pushed for each batch ...
          for ( j=0; j < batch_size; j++ ) {
              pos = result.find(delimiter);
              rcmd = result.substr(0, pos);
              redisClusterAppendCommand(conn, rcmd.c_str()); // Push the current command to redis ...
              result.erase(0, pos + delimiter.length()); // We modify the string in place ...
              n_cmd+=1;
          }
          while ( n_cmd-- > 0 ) {
              status = redisClusterGetReply(conn, (void **)(void **)&reply);
              
              // Error handle the commands, we either didn't format it correctly, or the data could not be pushed for some other reason:
              if ( !reply || status==REDIS_ERR ) {
                  fprintf (stderr, "%s\n", conn->errstr);
                  tot_failures+=1;
              } else {
                  tot_successes+=1;
              }
              freeReplyObject(reply);
          }
      }
      if ( remainder != 0 ) {
          n_cmd=0;
          for ( i=0; i < remainder; i++ ) { // Handle any remaining
              pos = result.find(delimiter);
              rcmd = result.substr(0, pos);
              redisClusterAppendCommand(conn, rcmd.c_str());
              result.erase(0, pos + delimiter.length()); // We modify the string in place ...
              n_cmd+=1;
          }
          while ( n_cmd-- > 0 ) {
              status = redisClusterGetReply(conn, (void **)(void **)&reply);
              // Error handle the commands, we either didn't format it correctly, or the data could not be pushed for some other reason:
              if ( !reply || status==REDIS_ERR ) {
                  fprintf (stderr, "%s\n", conn->errstr);
                  tot_failures+=1;
              } else {
                  tot_successes+=1;
              }
              freeReplyObject(reply);
          }
      }
  } else { // If we don't have to worry about batching, just pipeline all the data because it should be safe to do so ...
      while ( (pos = result.find(delimiter)) != std::string::npos ) {
          rcmd = result.substr(0, pos);
          redisClusterAppendCommand(conn, rcmd.c_str());
          result.erase(0, pos + delimiter.length());
      }
      while ( tot_cmds-- > 0 ) {
          status = redisClusterGetReply(conn, (void **)(void **)(void **)&reply);

          // Error handle the commands, we either didn't format it correctly, or the data could not be pushed for some other reason:
          if (  !reply || status==REDIS_ERR ) {
              fprintf (stderr, "%s\n", conn->errstr);
              tot_failures+=1;
          } else {
              tot_successes+=1;
          }
          freeReplyObject(reply);
      }
  }

CONNECTED SUCCESSFULLY!
Total Replies: 2285
 error replies: 0, successful replies: 2285
real	0m0.293s
user	0m0.102s
sys	0m0.066s