| 963 | |
| 964 | |
| 965 | ResourceProviderMessage |
| 966 | ResourceProviderManagerProcess::createUpdateOperationStatus( |
| 967 | const OperationStatus& operationStatus, |
| 968 | const Option<id::UUID>& operationUuid, |
| 969 | const Option<FrameworkID>& frameworkId, |
| 970 | const Option<OperationStatus>& latestStatus) |
| 971 | { |
| 972 | ResourceProviderMessage::UpdateOperationStatus body; |
| 973 | body.update.mutable_status()->CopyFrom(operationStatus); |
| 974 | |
| 975 | if (operationUuid.isSome()) { |
| 976 | body.update.mutable_operation_uuid()->CopyFrom( |
| 977 | protobuf::createUUID(operationUuid.get())); |
| 978 | } |
| 979 | |
| 980 | if (frameworkId.isSome()) { |
| 981 | body.update.mutable_framework_id()->CopyFrom(frameworkId.get()); |
| 982 | } |
| 983 | |
| 984 | if (latestStatus.isSome()) { |
| 985 | body.update.mutable_latest_status()->CopyFrom(latestStatus.get()); |
| 986 | } |
| 987 | |
| 988 | ResourceProviderMessage message; |
| 989 | message.type = ResourceProviderMessage::Type::UPDATE_OPERATION_STATUS; |
| 990 | message.updateOperationStatus = std::move(body); |
| 991 | |
| 992 | return message; |
| 993 | } |
| 994 | |
| 995 | |
| 996 | void ResourceProviderManagerProcess::updateState( |
nothing calls this directly
no test coverage detected