Fix warning in Xcode 26 in client service for thread performance checker.

PiperOrigin-RevId: 796623220

Author: eDO Team

Channel/Sources/EDOChannel.h

@@ -94,6 +94,25 @@ typedef void (^EDOChannelSentHandler)(id<EDOChannel> channel, NSError *_Nullable
  */
 - (void)receiveDataWithHandler:(EDOChannelReceiveHandler _Nullable)handler;
 
+/**
+ * Schedule the block for the next received data to process.
+ *
+ * When the new data is received, the handler will be dispatched on the given @c queue. If the data
+ * is received without scheduling any block, it is up to the implementation to ignore or buffer it
+ * locally, i.e. TCP socket may allow some system buffer to temporarily cache the data. For the
+ * request/response style communication, it is better to call this in the sentCompletion block to
+ * avoid race condition as the scheduled receive block may not be in the same order of the
+ * @c sendData:withCompletionHandler.
+ *
+ * @param queue   The dispatch queue on which the handler will be dispatched.
+ * @param handler The handler to be dispatched when the data is received.
+ * @remark Once it schedules the block to receive data, it will retain itself until the data is
+ *         received or it becomes invalid by calling @c invalidate or it detects the other end
+ *         closes the channel.
+ */
+- (void)receiveDataWithQueue:(dispatch_queue_t)queue
+                     handler:(EDOChannelReceiveHandler _Nullable)handler;
+
 /**
  * Invalidate this channel.
  *

Channel/Sources/EDOSocketChannel.m

@@ -111,7 +111,12 @@ - (void)sendData:(NSData *)data withCompletionHandler:(EDOChannelSentHandler)han
 }
 
 - (void)receiveDataWithHandler:(EDOChannelReceiveHandler)handler {
-  dispatch_queue_t handlerQueue = self.handlerQueue;
+  [self receiveDataWithQueue:self.handlerQueue handler:handler];
+}
+
+- (void)receiveDataWithQueue:(dispatch_queue_t)queue
+                     handler:(EDOChannelReceiveHandler _Nullable)handler {
+  dispatch_queue_t handlerQueue = queue;
   dispatch_io_t channel = self.channel;
   if (!channel) {
     dispatch_async(handlerQueue, ^{

Service/Sources/EDOClientService.m

@@ -262,13 +262,13 @@ + (EDOServiceResponse *)sendSynchronousRequest:(EDOServiceRequest *)request
   while (currentAttempt < maxAttempts) {
     NSError *connectionError;
     uint64_t connectionStartTime = mach_absolute_time();
-    dispatch_queue_t connectionQueue = nil;
     dispatch_queue_t executionQueue = executor.executionQueue;
-    if (executionQueue) {
-      dispatch_queue_attr_t queueAttributes = dispatch_queue_attr_make_with_qos_class(
-          DISPATCH_QUEUE_SERIAL, dispatch_queue_get_qos_class(executionQueue, nil), 0);
-      connectionQueue = dispatch_queue_create("com.google.edo.connectChannel", queueAttributes);
-    }
+    dispatch_qos_class_t qosClass =
+        executionQueue ? dispatch_queue_get_qos_class(executionQueue, nil) : qos_class_self();
+    dispatch_queue_attr_t queueAttributes =
+        dispatch_queue_attr_make_with_qos_class(DISPATCH_QUEUE_SERIAL, qosClass, 0);
+    dispatch_queue_t connectionQueue =
+        dispatch_queue_create("com.google.edo.connectChannel", queueAttributes);
     id<EDOChannel> channel = [EDOChannelPool.sharedChannelPool channelWithPort:port
                                                                connectionQueue:connectionQueue
                                                                          error:&connectionError];
@@ -427,7 +427,8 @@ + (NSData *)sendRequestData:(NSData *)requestData withChannel:(id<EDOChannel>)ch
       };
 
   // Check ping response to make sure channel is healthy.
-  [channel receiveDataWithHandler:receiveHandler];
+  [channel receiveDataWithQueue:dispatch_get_global_queue(qos_class_self(), 0)
+                        handler:receiveHandler];
 
   dispatch_time_t timeoutInSeconds = dispatch_time(DISPATCH_TIME_NOW, kPingTimeoutSeconds);
   long result = dispatch_semaphore_wait(waitLock, timeoutInSeconds);