Lines Matching refs:taskData
121 std::string taskData = std::string(buffer); in RemoteAccessService() local
126 ALOGD("Task for client: %s, data: [%s], latency: %d\n", clientId.c_str(), taskData.c_str(), in RemoteAccessService()
129 mInjectDebugTaskThread = std::thread([this, clientId, taskData, latencyInSec] { in RemoteAccessService()
131 if (auto result = deliverRemoteTaskThroughCallback(clientId, taskData); !result.ok()) { in RemoteAccessService()
133 clientId.c_str(), taskData.c_str(), result.error().message().c_str()); in RemoteAccessService()
137 taskData.c_str()); in RemoteAccessService()
190 std::string_view taskData) { in deliverRemoteTaskThroughCallback() argument
202 callback->onRemoteTaskRequested(clientId, stringToBytes(taskData)); in deliverRemoteTaskThroughCallback()
377 if (scheduleInfo.taskData.size() > scheduleInfo.MAX_TASK_DATA_SIZE_IN_BYTES) { in scheduleTask()
386 request.mutable_scheduleinfo()->set_data(scheduleInfo.taskData.data(), in scheduleTask()
387 scheduleInfo.taskData.size()); in scheduleTask()
492 .taskData = stringToBytes(rpcScheduleInfo.data()), in getAllPendingScheduledTasks()
627 std::string_view taskData) { in debugInjectTask() argument
629 if (auto result = deliverRemoteTaskThroughCallback(clientIdCopy, taskData); !result.ok()) { in debugInjectTask()
634 taskData.data()); in debugInjectTask()
638 std::string_view taskData, in debugInjectTaskNextReboot() argument
654 if (taskData.find("\n") != std::string::npos) { in debugInjectTaskNextReboot()
658 debugTaskFile << clientId << "\n" << taskData << "\n" << latencyInSec; in debugInjectTaskNextReboot()
662 clientId.data(), taskData.data(), latencyInSec); in debugInjectTaskNextReboot()