Addressed review comments

internal/iothread/cmd_compose.go

@@ -263,10 +263,10 @@ func composeFlushDB(responses ...ops.StoreResponse) interface{} {
 	return clientio.OK
 }
 
-// composeMSet processes responses from multiple shards for an "MSet" operation
-// (Multi-set operation). It loops through the responses to check if any shard returned an error.
+// composePFMerge processes responses from multiple shards for an "PFMerge" operation.
+// It loops through the responses to check if any shard returned an error.
 // If an error is detected, it immediately returns that error. Otherwise, it returns "OK"
-// to indicate that all "MSet" operations across shards were successful.
+// to indicate that all merged HyperLogLog is set to the destination variable successfully.
 func composePFMerge(responses ...ops.StoreResponse) interface{} {
 	for idx := range responses {
 		if responses[idx].EvalResponse.Error != nil {

internal/iothread/cmd_decompose.go

@@ -121,8 +121,9 @@ func decomposeCopy(ctx context.Context, thread *BaseIOThread, cd *cmd.DiceDBCmd)
 	return decomposedCmds, nil
 }
 
-// decomposeMSet decomposes the PFMERGE command into individual GET commands for each HLL.
-// For each key it creates a separate GET command to get the value at the given key.
+// decomposePFMerge decomposes the PFMERGE command into individual GET commands for each HLL.
+// For each key it creates a separate GET command to get the value at the given key, and waits for all responses to be
+// returned before proceeding.
 func decomposePFMerge(ctx context.Context, thread *BaseIOThread, cd *cmd.DiceDBCmd) ([]*cmd.DiceDBCmd, error) {
 	// Waiting for GET command response for all the keys to be merged
 	resp := make([]*object.InternalObj, 0, len(cd.Args)-1)

internal/iothread/iothread.go

@@ -43,7 +43,7 @@ import (
 	"github.com/google/uuid"
 )
 
-const defaultRequestTimeout = 600 * time.Second
+const defaultRequestTimeout = 6 * time.Second
 
 var requestCounter uint32