Lines Matching refs:task
429 var task = channelTaskFactory.FromAsync( in TrySendMessage()
433 return WaitSendOrReceiveTask(task, size); in TrySendMessage()
469 var task = channelTaskFactory.FromAsync( in TryReceive()
473 var isSuccess = WaitSendOrReceiveTask(task, size); in TryReceive()
493 private bool WaitSendOrReceiveTask(Task<int> task, int size) in WaitSendOrReceiveTask() argument
497 task.Wait(timeout, channelTaskFactory.CancellationToken); in WaitSendOrReceiveTask()
512 if(task.Status != TaskStatus.RanToCompletion) in WaitSendOrReceiveTask()
514 if(task.Status == TaskStatus.Canceled) in WaitSendOrReceiveTask()
520 … logger.DebugLog("Error while trying to Send/Receive. Task status: {0}", task.Status); in WaitSendOrReceiveTask()
525 if(task.Result != size) in WaitSendOrReceiveTask()
527 …to Send/Receive. Unexpected number of sent/received bytes: {0} (expected {1})", task.Result, size); in WaitSendOrReceiveTask()
531 logger.NoisyLog("Message sent/received succesfully", task.Status); in WaitSendOrReceiveTask()