Lines Matching refs:command

363     RpcWireHeader command{  in transact()  local
364 .command = RPC_COMMAND_TRANSACT, in transact()
368 if (!rpcSend(fd, "transact header", &command, sizeof(command))) { in transact()
395 RpcWireHeader command; in waitForReply() local
397 if (!rpcRec(fd, "command header", &command, sizeof(command))) { in waitForReply()
401 if (command.command == RPC_COMMAND_REPLY) break; in waitForReply()
403 status_t status = processServerCommand(fd, session, command); in waitForReply()
407 CommandData data(command.bodySize); in waitForReply()
412 if (!rpcRec(fd, "reply body", data.data(), command.bodySize)) { in waitForReply()
416 if (command.bodySize < sizeof(RpcWireReply)) { in waitForReply()
418 sizeof(RpcWireReply), command.bodySize); in waitForReply()
426 reply->ipcSetDataReference(rpcReply->data, command.bodySize - offsetof(RpcWireReply, data), in waitForReply()
451 .command = RPC_COMMAND_DEC_STRONG, in sendDecStrong()
463 RpcWireHeader command; in getAndExecuteCommand() local
464 if (!rpcRec(fd, "command header", &command, sizeof(command))) { in getAndExecuteCommand()
468 return processServerCommand(fd, session, command); in getAndExecuteCommand()
472 const RpcWireHeader& command) { in processServerCommand() argument
473 switch (command.command) { in processServerCommand()
475 return processTransact(fd, session, command); in processServerCommand()
477 return processDecStrong(fd, command); in processServerCommand()
485 ALOGE("Unknown RPC command %d - terminating session", command.command); in processServerCommand()
490 const RpcWireHeader& command) { in processTransact() argument
491 LOG_ALWAYS_FATAL_IF(command.command != RPC_COMMAND_TRANSACT, "command: %d", command.command); in processTransact()
493 CommandData transactionData(command.bodySize); in processTransact()
692 .command = RPC_COMMAND_REPLY, in processTransactInternal()
705 status_t RpcState::processDecStrong(const base::unique_fd& fd, const RpcWireHeader& command) { in processDecStrong() argument
706 LOG_ALWAYS_FATAL_IF(command.command != RPC_COMMAND_DEC_STRONG, "command: %d", command.command); in processDecStrong()
708 CommandData commandData(command.bodySize); in processDecStrong()
716 if (command.bodySize < sizeof(RpcWireAddress)) { in processDecStrong()
718 sizeof(RpcWireAddress), command.bodySize); in processDecStrong()