blob: c820ab2e8234a0708f3ba328e22b0c58d137eab2 [file] [log] [blame]
Gilad Arnoldd7b513d2012-05-10 14:25:27 -07001// Copyright (c) 2012 The Chromium OS Authors. All rights reserved.
adlr@google.com3defe6a2009-12-04 20:57:17 +00002// Use of this source code is governed by a BSD-style license that can be
3// found in the LICENSE file.
4
Gilad Arnoldcf175a02014-07-10 16:48:47 -07005#ifndef UPDATE_ENGINE_UTILS_H_
6#define UPDATE_ENGINE_UTILS_H_
adlr@google.com3defe6a2009-12-04 20:57:17 +00007
Han Shen2643cb72012-06-26 14:45:33 -07008#include <errno.h>
Alex Vakulenkod2779df2014-06-16 13:19:00 -07009#include <unistd.h>
10
11#include <algorithm>
12#include <map>
Ben Chan02f7c1d2014-10-18 15:18:02 -070013#include <memory>
adlr@google.com3defe6a2009-12-04 20:57:17 +000014#include <set>
15#include <string>
16#include <vector>
Darin Petkovc6c135c2010-08-11 13:36:18 -070017
Alex Vakulenko75039d72014-03-25 12:36:28 -070018#include <base/files/file_path.h>
Chris Sosafc661a12013-02-26 14:43:21 -080019#include <base/posix/eintr_wrapper.h>
Alex Vakulenko75039d72014-03-25 12:36:28 -070020#include <base/time/time.h>
Alex Vakulenkof68bbbc2015-02-09 12:53:18 -080021#include <chromeos/secure_blob.h>
Andrew de los Reyesc7020782010-04-28 10:46:04 -070022#include <glib.h>
Jay Srinivasanf0572052012-10-23 18:12:56 -070023#include "metrics/metrics_library.h"
Darin Petkovc6c135c2010-08-11 13:36:18 -070024
adlr@google.com3defe6a2009-12-04 20:57:17 +000025#include "update_engine/action.h"
David Zeuthenb281f072014-04-02 10:20:19 -070026#include "update_engine/action_processor.h"
27#include "update_engine/connection_manager.h"
Jay Srinivasan19409b72013-04-12 19:23:36 -070028#include "update_engine/constants.h"
Nam T. Nguyenf1d582e2014-12-08 15:07:17 -080029#include "update_engine/file_descriptor.h"
David Zeuthen33bae492014-02-25 16:16:18 -080030#include "update_engine/metrics.h"
adlr@google.com3defe6a2009-12-04 20:57:17 +000031
32namespace chromeos_update_engine {
33
Jay Srinivasan55f50c22013-01-10 19:24:35 -080034class SystemState;
35
adlr@google.com3defe6a2009-12-04 20:57:17 +000036namespace utils {
37
David Zeuthen27a48bc2013-08-06 12:06:29 -070038// Converts a struct timespec representing a number of seconds since
39// the Unix epoch to a base::Time. Sub-microsecond time is rounded
40// down.
41base::Time TimeFromStructTimespec(struct timespec *ts);
42
Alex Vakulenko88b591f2014-08-28 16:48:57 -070043// Converts a vector of strings to a NUL-terminated array of
David Zeuthen27a48bc2013-08-06 12:06:29 -070044// strings. The resulting array should be freed with g_strfreev()
45// when are you done with it.
Alex Deymof329b932014-10-30 01:37:48 -070046gchar** StringVectorToGStrv(const std::vector<std::string> &vec_str);
David Zeuthen27a48bc2013-08-06 12:06:29 -070047
Alex Deymof329b932014-10-30 01:37:48 -070048// Formats |vec_str| as a string of the form ["<elem1>", "<elem2>"].
David Zeuthen27a48bc2013-08-06 12:06:29 -070049// Does no escaping, only use this for presentation in error messages.
Alex Deymof329b932014-10-30 01:37:48 -070050std::string StringVectorToString(const std::vector<std::string> &vec_str);
David Zeuthen27a48bc2013-08-06 12:06:29 -070051
David Zeuthen8f191b22013-08-06 12:27:50 -070052// Calculates the p2p file id from payload hash and size
53std::string CalculateP2PFileId(const std::string& payload_hash,
54 size_t payload_size);
55
J. Richard Barnette63137e52013-10-28 10:57:29 -070056// Parse the firmware version from one line of output from the
57// "mosys" command.
58std::string ParseECVersion(std::string input_line);
59
J. Richard Barnette30842932013-10-28 15:04:23 -070060// Given the name of the block device of a boot partition, return the
61// name of the associated kernel partition (e.g. given "/dev/sda3",
62// return "/dev/sda2").
63const std::string KernelDeviceOfBootDevice(const std::string& boot_device);
64
Andrew de los Reyes970bb282009-12-09 16:34:04 -080065// Writes the data passed to path. The file at path will be overwritten if it
66// exists. Returns true on success, false otherwise.
Alex Vakulenkof68bbbc2015-02-09 12:53:18 -080067bool WriteFile(const char* path, const void* data, int data_len);
Andrew de los Reyes970bb282009-12-09 16:34:04 -080068
Andrew de los Reyes09e56d62010-04-23 13:45:53 -070069// Calls write() or pwrite() repeatedly until all count bytes at buf are
70// written to fd or an error occurs. Returns true on success.
71bool WriteAll(int fd, const void* buf, size_t count);
72bool PWriteAll(int fd, const void* buf, size_t count, off_t offset);
73
Nam T. Nguyenf1d582e2014-12-08 15:07:17 -080074bool WriteAll(FileDescriptorPtr fd, const void* buf, size_t count);
75bool PWriteAll(FileDescriptorPtr fd,
76 const void* buf,
77 size_t count,
78 off_t offset);
79
Andrew de los Reyes09e56d62010-04-23 13:45:53 -070080// Calls pread() repeatedly until count bytes are read, or EOF is reached.
81// Returns number of bytes read in *bytes_read. Returns true on success.
82bool PReadAll(int fd, void* buf, size_t count, off_t offset,
83 ssize_t* out_bytes_read);
Andrew de los Reyesb10320d2010-03-31 16:44:44 -070084
Nam T. Nguyenf1d582e2014-12-08 15:07:17 -080085bool PReadAll(FileDescriptorPtr fd, void* buf, size_t count, off_t offset,
86 ssize_t* out_bytes_read);
87
Gilad Arnold19a45f02012-07-19 12:36:10 -070088// Opens |path| for reading and appends its entire content to the container
89// pointed to by |out_p|. Returns true upon successfully reading all of the
90// file's content, false otherwise, in which case the state of the output
Darin Petkov8e447e02013-04-16 16:23:50 +020091// container is unknown. ReadFileChunk starts reading the file from |offset|; if
92// |size| is not -1, only up to |size| bytes are read in.
Alex Vakulenkof68bbbc2015-02-09 12:53:18 -080093bool ReadFile(const std::string& path, chromeos::Blob* out_p);
Gilad Arnold19a45f02012-07-19 12:36:10 -070094bool ReadFile(const std::string& path, std::string* out_p);
Darin Petkov8e447e02013-04-16 16:23:50 +020095bool ReadFileChunk(const std::string& path, off_t offset, off_t size,
Alex Vakulenkof68bbbc2015-02-09 12:53:18 -080096 chromeos::Blob* out_p);
Gilad Arnold19a45f02012-07-19 12:36:10 -070097
98// Invokes |cmd| in a pipe and appends its stdout to the container pointed to by
99// |out_p|. Returns true upon successfully reading all of the output, false
100// otherwise, in which case the state of the output container is unknown.
Gilad Arnold19a45f02012-07-19 12:36:10 -0700101bool ReadPipe(const std::string& cmd, std::string* out_p);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000102
Gabe Blackb92cd2e2014-09-08 02:47:41 -0700103// Returns the size of the block device at path, or the file descriptor fd. If
104// an error occurs, -1 is returned.
105off_t BlockDevSize(const std::string& path);
106off_t BlockDevSize(int fd);
107
108// Returns the size of the file at path, or the file desciptor fd. If the file
109// is actually a block device, this function will automatically call
110// BlockDevSize. If the file doesn't exist or some error occurrs, -1 is
111// returned.
Andrew de los Reyesf4c7ef12010-04-30 10:37:00 -0700112off_t FileSize(const std::string& path);
Gabe Blackb92cd2e2014-09-08 02:47:41 -0700113off_t FileSize(int fd);
Andrew de los Reyesf4c7ef12010-04-30 10:37:00 -0700114
adlr@google.com3defe6a2009-12-04 20:57:17 +0000115std::string ErrnoNumberAsString(int err);
116
117// Strips duplicate slashes, and optionally removes all trailing slashes.
118// Does not compact /./ or /../.
119std::string NormalizePath(const std::string& path, bool strip_trailing_slash);
120
121// Returns true if the file exists for sure. Returns false if it doesn't exist,
122// or an error occurs.
123bool FileExists(const char* path);
124
Darin Petkov30291ed2010-11-12 10:23:06 -0800125// Returns true if |path| exists and is a symbolic link.
126bool IsSymlink(const char* path);
127
Alex Deymo7dc4c502014-05-20 20:09:58 -0700128// Returns true if |path| exists and is a directory.
129bool IsDir(const char* path);
130
Nam T. Nguyena78b28c2015-03-06 22:30:12 -0800131// Try attaching UBI |volume_num|. If there is any error executing required
132// commands to attach the volume, this function returns false. This function
133// only returns true if "/dev/ubi%d_0" becomes available in |timeout| seconds.
134bool TryAttachingUbiVolume(int volume_num, int timeout);
135
Gilad Arnoldd04f8e22014-01-09 13:13:40 -0800136// If |base_filename_template| is neither absolute (starts with "/") nor
137// explicitly relative to the current working directory (starts with "./" or
138// "../"), then it is prepended the value of TMPDIR, which defaults to /tmp if
139// it isn't set or is empty. It then calls mkstemp(3) with the resulting
140// template. Writes the name of a new temporary file to |filename|. If |fd| is
Alex Vakulenko88b591f2014-08-28 16:48:57 -0700141// non-null, the file descriptor returned by mkstemp is written to it and
142// kept open; otherwise, it is closed. The template must end with "XXXXXX".
143// Returns true on success.
Gilad Arnoldd04f8e22014-01-09 13:13:40 -0800144bool MakeTempFile(const std::string& base_filename_template,
Andrew de los Reyesb10320d2010-03-31 16:44:44 -0700145 std::string* filename,
146 int* fd);
147
Gilad Arnoldd04f8e22014-01-09 13:13:40 -0800148// If |base_filename_template| is neither absolute (starts with "/") nor
149// explicitly relative to the current working directory (starts with "./" or
150// "../"), then it is prepended the value of TMPDIR, which defaults to /tmp if
151// it isn't set or is empty. It then calls mkdtemp() with the resulting
152// template. Writes the name of the new temporary directory to |dirname|.
153// The template must end with "XXXXXX". Returns true on success.
154bool MakeTempDirectory(const std::string& base_dirname_template,
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700155 std::string* dirname);
156
Alex Vakulenko4f5b1442014-02-21 12:19:44 -0800157// Returns the disk device name for a partition. For example,
158// GetDiskName("/dev/sda3") returns "/dev/sda". Returns an empty string
159// if the input device is not of the "/dev/xyz#" form.
160std::string GetDiskName(const std::string& partition_name);
Andrew de los Reyesf9714432010-05-04 10:21:23 -0700161
Alex Vakulenko4f5b1442014-02-21 12:19:44 -0800162// Returns the partition number, of partition device name. For example,
163// GetPartitionNumber("/dev/sda3") returns 3.
164// Returns 0 on failure
165int GetPartitionNumber(const std::string& partition_name);
166
167// Splits the partition device name into the block device name and partition
168// number. For example, "/dev/sda3" will be split into {"/dev/sda", 3} and
169// "/dev/mmcblk0p2" into {"/dev/mmcblk0", 2}
170// Returns false when malformed device name is passed in.
Alex Vakulenko88b591f2014-08-28 16:48:57 -0700171// If both output parameters are omitted (null), can be used
Alex Vakulenko4f5b1442014-02-21 12:19:44 -0800172// just to test the validity of the device name. Note that the function
173// simply checks if the device name looks like a valid device, no other
174// checks are performed (i.e. it doesn't check if the device actually exists).
175bool SplitPartitionName(const std::string& partition_name,
176 std::string* out_disk_name,
177 int* out_partition_num);
178
179// Builds a partition device name from the block device name and partition
180// number. For example:
181// {"/dev/sda", 1} => "/dev/sda1"
182// {"/dev/mmcblk2", 12} => "/dev/mmcblk2p12"
183// Returns empty string when invalid parameters are passed in
184std::string MakePartitionName(const std::string& disk_name,
185 int partition_num);
Andrew de los Reyesf9714432010-05-04 10:21:23 -0700186
Nam T. Nguyena78b28c2015-03-06 22:30:12 -0800187// Similar to "MakePartitionName" but returns a name that is suitable for
188// mounting. On NAND system we can write to "/dev/ubiX_0", which is what
189// MakePartitionName returns, but we cannot mount that device. To mount, we
190// have to use "/dev/ubiblockX_0" for rootfs. Stateful and OEM partitions are
191// mountable with "/dev/ubiX_0". The input is a partition device such as
192// /dev/sda3. Return empty string on error.
193std::string MakePartitionNameForMount(const std::string& part_name);
194
Darin Petkovf74eb652010-08-04 12:08:38 -0700195// Returns the sysfs block device for a root block device. For
196// example, SysfsBlockDevice("/dev/sda") returns
197// "/sys/block/sda". Returns an empty string if the input device is
198// not of the "/dev/xyz" form.
199std::string SysfsBlockDevice(const std::string& device);
200
201// Returns true if the root |device| (e.g., "/dev/sdb") is known to be
202// removable, false otherwise.
203bool IsRemovableDevice(const std::string& device);
204
adlr@google.com3defe6a2009-12-04 20:57:17 +0000205// Synchronously mount or unmount a filesystem. Return true on success.
Alex Deymo4c82df32014-11-10 22:25:57 -0800206// When mounting, it will attempt to mount the the device as "ext3", "ext2" and
207// "squashfs", with the passed |flags| options.
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700208bool MountFilesystem(const std::string& device, const std::string& mountpoint,
Alex Vakulenkod2779df2014-06-16 13:19:00 -0700209 unsigned long flags); // NOLINT(runtime/int)
Andrew de los Reyes4fe15d02009-12-10 19:01:36 -0800210bool UnmountFilesystem(const std::string& mountpoint);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000211
Alex Deymo192393b2014-11-10 15:58:38 -0800212// Returns the block count and the block byte size of the file system on
Darin Petkovd3f8c892010-10-12 21:38:45 -0700213// |device| (which may be a real device or a path to a filesystem image) or on
214// an opened file descriptor |fd|. The actual file-system size is |block_count|
215// * |block_size| bytes. Returns true on success, false otherwise.
216bool GetFilesystemSize(const std::string& device,
217 int* out_block_count,
218 int* out_block_size);
219bool GetFilesystemSizeFromFD(int fd,
220 int* out_block_count,
221 int* out_block_size);
222
Alex Deymo192393b2014-11-10 15:58:38 -0800223// Determines the block count and block size of the ext3 fs. At least 2048 bytes
224// are required to parse the first superblock. Returns whether the buffer
225// contains a valid ext3 filesystem and the values were parsed.
226bool GetExt3Size(const uint8_t* buffer, size_t buffer_size,
227 int* out_block_count,
228 int* out_block_size);
229
230// Determines the block count and block size of the squashfs v4 fs. At least 96
231// bytes are required to parse the header of the filesystem. Since squashfs
232// doesn't define a physical block size, a value of 4096 is used for the block
233// size, which is the default padding when creating the filesystem.
234// Returns whether the buffer contains a valid squashfs v4 header and the size
235// was parsed. Only little endian squashfs is supported.
236bool GetSquashfs4Size(const uint8_t* buffer, size_t buffer_size,
237 int* out_block_count,
238 int* out_block_size);
239
Alex Deymo719bfff2014-07-11 12:12:32 -0700240// Returns the path of the passed |command| on the board. This uses the
241// environment variable SYSROOT to determine the path to the command on the
242// board instead of the path on the running environment.
243std::string GetPathOnBoard(const std::string& command);
Alex Deymo032e7722014-03-25 17:53:56 -0700244
245// Returns a human-readable string with the file format based on magic constants
246// on the header of the file.
247std::string GetFileFormat(const std::string& path);
248
Jay Srinivasan480ddfa2012-06-01 19:15:26 -0700249// Returns the string representation of the given UTC time.
250// such as "11/14/2011 14:05:30 GMT".
251std::string ToString(const base::Time utc_time);
252
Jay Srinivasanae4697c2013-03-18 17:08:08 -0700253// Returns true or false depending on the value of b.
254std::string ToString(bool b);
255
Jay Srinivasan19409b72013-04-12 19:23:36 -0700256// Returns a string representation of the given enum.
257std::string ToString(DownloadSource source);
258
Alex Deymo1c656c42013-06-28 11:02:14 -0700259// Returns a string representation of the given enum.
260std::string ToString(PayloadType payload_type);
261
Andrew de los Reyes712b3ac2011-01-07 13:47:52 -0800262// Schedules a Main Loop callback to trigger the crash reporter to perform an
263// upload as if this process had crashed.
264void ScheduleCrashReporterUpload();
265
Darin Petkov5c0a8af2010-08-24 13:39:13 -0700266// Fuzzes an integer |value| randomly in the range:
267// [value - range / 2, value + range - range / 2]
268int FuzzInt(int value, unsigned int range);
269
adlr@google.com3defe6a2009-12-04 20:57:17 +0000270// Log a string in hex to LOG(INFO). Useful for debugging.
Alex Vakulenkof68bbbc2015-02-09 12:53:18 -0800271void HexDumpArray(const uint8_t* const arr, const size_t length);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000272inline void HexDumpString(const std::string& str) {
Alex Vakulenkof68bbbc2015-02-09 12:53:18 -0800273 HexDumpArray(reinterpret_cast<const uint8_t*>(str.data()), str.size());
adlr@google.com3defe6a2009-12-04 20:57:17 +0000274}
Alex Vakulenkof68bbbc2015-02-09 12:53:18 -0800275inline void HexDumpVector(const chromeos::Blob& vect) {
276 HexDumpArray(vect.data(), vect.size());
adlr@google.com3defe6a2009-12-04 20:57:17 +0000277}
278
adlr@google.com3defe6a2009-12-04 20:57:17 +0000279template<typename KeyType, typename ValueType>
280bool MapContainsKey(const std::map<KeyType, ValueType>& m, const KeyType& k) {
281 return m.find(k) != m.end();
282}
Andrew de los Reyes4fe15d02009-12-10 19:01:36 -0800283template<typename KeyType>
284bool SetContainsKey(const std::set<KeyType>& s, const KeyType& k) {
285 return s.find(k) != s.end();
286}
adlr@google.com3defe6a2009-12-04 20:57:17 +0000287
Andrew de los Reyes0ce161b2010-02-22 15:27:01 -0800288template<typename T>
289bool VectorContainsValue(const std::vector<T>& vect, const T& value) {
Darin Petkovc1a8b422010-07-19 11:34:49 -0700290 return std::find(vect.begin(), vect.end(), value) != vect.end();
Andrew de los Reyes0ce161b2010-02-22 15:27:01 -0800291}
292
Andrew de los Reyesb10320d2010-03-31 16:44:44 -0700293template<typename T>
294bool VectorIndexOf(const std::vector<T>& vect, const T& value,
295 typename std::vector<T>::size_type* out_index) {
296 typename std::vector<T>::const_iterator it = std::find(vect.begin(),
297 vect.end(),
298 value);
299 if (it == vect.end()) {
300 return false;
301 } else {
302 *out_index = it - vect.begin();
303 return true;
304 }
305}
306
Andrew de los Reyescc92cd32010-10-05 16:56:14 -0700307template<typename ValueType>
308void ApplyMap(std::vector<ValueType>* collection,
309 const std::map<ValueType, ValueType>& the_map) {
310 for (typename std::vector<ValueType>::iterator it = collection->begin();
311 it != collection->end(); ++it) {
312 typename std::map<ValueType, ValueType>::const_iterator map_it =
313 the_map.find(*it);
314 if (map_it != the_map.end()) {
315 *it = map_it->second;
316 }
317 }
318}
319
Chris Sosa4f8ee272012-11-30 13:01:54 -0800320// Cgroups cpu shares constants. 1024 is the default shares a standard process
321// gets and 2 is the minimum value. We set High as a value that gives the
322// update-engine 2x the cpu share of a standard process.
323enum CpuShares {
324 kCpuSharesHigh = 2048,
325 kCpuSharesNormal = 1024,
326 kCpuSharesLow = 2,
Darin Petkovc6c135c2010-08-11 13:36:18 -0700327};
328
Chris Sosa4f8ee272012-11-30 13:01:54 -0800329// Sets the current process shares to |shares|. Returns true on
Darin Petkovc6c135c2010-08-11 13:36:18 -0700330// success, false otherwise.
Chris Sosa4f8ee272012-11-30 13:01:54 -0800331bool SetCpuShares(CpuShares shares);
Andrew de los Reyesf9185172010-05-03 11:07:05 -0700332
Alex Deymoc4acdf42014-05-28 21:07:10 -0700333// Assumes |data| points to a Closure. Runs it and returns FALSE;
Andrew de los Reyesf3ed8e72011-02-16 10:35:46 -0800334gboolean GlibRunClosure(gpointer data);
335
Alex Deymoc4acdf42014-05-28 21:07:10 -0700336// Destroys the Closure pointed by |data|.
337void GlibDestroyClosure(gpointer data);
338
Gilad Arnoldd7b513d2012-05-10 14:25:27 -0700339// Converts seconds into human readable notation including days, hours, minutes
340// and seconds. For example, 185 will yield 3m5s, 4300 will yield 1h11m40s, and
341// 360000 will yield 4d4h0m0s. Zero padding not applied. Seconds are always
342// shown in the result.
343std::string FormatSecs(unsigned secs);
344
345// Converts a TimeDelta into human readable notation including days, hours,
346// minutes, seconds and fractions of a second down to microsecond granularity,
347// as necessary; for example, an output of 5d2h0m15.053s means that the input
348// time was precise to the milliseconds only. Zero padding not applied, except
349// for fractions. Seconds are always shown, but fractions thereof are only shown
David Zeuthen973449e2014-08-18 16:18:23 -0400350// when applicable. If |delta| is negative, the output will have a leading '-'
351// followed by the absolute duration.
Gilad Arnoldd7b513d2012-05-10 14:25:27 -0700352std::string FormatTimeDelta(base::TimeDelta delta);
Gilad Arnold1ebd8132012-03-05 10:19:29 -0800353
Jay Srinivasan2b5a0f02012-12-19 17:25:56 -0800354// This method transforms the given error code to be suitable for UMA and
355// for error classification purposes by removing the higher order bits and
356// aggregating error codes beyond the enum range, etc. This method is
357// idempotent, i.e. if called with a value previously returned by this method,
358// it'll return the same value again.
David Zeuthena99981f2013-04-29 13:42:47 -0700359ErrorCode GetBaseErrorCode(ErrorCode code);
Jay Srinivasan2b5a0f02012-12-19 17:25:56 -0800360
David Zeuthen33bae492014-02-25 16:16:18 -0800361// Transforms a ErrorCode value into a metrics::DownloadErrorCode.
362// This obviously only works for errors related to downloading so if |code|
Gilad Arnoldd1c4d2d2014-06-05 14:07:53 -0700363// is e.g. |ErrorCode::kFilesystemCopierError| then
David Zeuthen33bae492014-02-25 16:16:18 -0800364// |kDownloadErrorCodeInputMalformed| is returned.
365metrics::DownloadErrorCode GetDownloadErrorCode(ErrorCode code);
366
367// Transforms a ErrorCode value into a metrics::AttemptResult.
368//
369// If metrics::AttemptResult::kPayloadDownloadError is returned, you
370// can use utils::GetDownloadError() to get more detail.
371metrics::AttemptResult GetAttemptResult(ErrorCode code);
372
David Zeuthenb281f072014-04-02 10:20:19 -0700373// Calculates the internet connection type given |type| and |tethering|.
374metrics::ConnectionType GetConnectionType(NetworkConnectionType type,
375 NetworkTethering tethering);
376
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800377// Sends the error code to UMA using the metrics interface object in the given
378// system state. It also uses the system state to determine the right UMA
379// bucket for the error code.
David Zeuthena99981f2013-04-29 13:42:47 -0700380void SendErrorCodeToUma(SystemState* system_state, ErrorCode code);
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800381
David Zeuthena99981f2013-04-29 13:42:47 -0700382// Returns a string representation of the ErrorCodes (either the base
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800383// error codes or the bit flags) for logging purposes.
David Zeuthena99981f2013-04-29 13:42:47 -0700384std::string CodeToString(ErrorCode code);
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800385
Gilad Arnold30dedd82013-07-03 06:19:09 -0700386// Creates the powerwash marker file with the appropriate commands in it. Uses
Alex Vakulenko88b591f2014-08-28 16:48:57 -0700387// |file_path| as the path to the marker file if non-null, otherwise uses the
Gilad Arnold30dedd82013-07-03 06:19:09 -0700388// global default. Returns true if successfully created. False otherwise.
389bool CreatePowerwashMarkerFile(const char* file_path);
Jay Srinivasan1c0fe792013-03-28 16:45:25 -0700390
Gilad Arnold30dedd82013-07-03 06:19:09 -0700391// Deletes the marker file used to trigger Powerwash using clobber-state. Uses
Alex Vakulenko88b591f2014-08-28 16:48:57 -0700392// |file_path| as the path to the marker file if non-null, otherwise uses the
Gilad Arnold30dedd82013-07-03 06:19:09 -0700393// global default. Returns true if successfully deleted. False otherwise.
394bool DeletePowerwashMarkerFile(const char* file_path);
Jay Srinivasan1c0fe792013-03-28 16:45:25 -0700395
Chris Sosad317e402013-06-12 13:47:09 -0700396// Assumes you want to install on the "other" device, where the other
397// device is what you get if you swap 1 for 2 or 3 for 4 or vice versa
398// for the number at the end of the boot device. E.g., /dev/sda1 -> /dev/sda2
399// or /dev/sda4 -> /dev/sda3. See
400// http://www.chromium.org/chromium-os/chromiumos-design-docs/disk-format
401bool GetInstallDev(const std::string& boot_dev, std::string* install_dev);
402
David Zeuthene7f89172013-10-31 10:21:04 -0700403// Decodes the data in |base64_encoded| and stores it in a temporary
404// file. Returns false if the given data is empty, not well-formed
405// base64 or if an error occurred. If true is returned, the decoded
406// data is stored in the file returned in |out_path|. The file should
407// be deleted when no longer needed.
408bool DecodeAndStoreBase64String(const std::string& base64_encoded,
409 base::FilePath *out_path);
410
David Zeuthen639aa362014-02-03 16:23:44 -0800411// Converts |time| to an Omaha InstallDate which is defined as "the
412// number of PST8PDT calendar weeks since Jan 1st 2007 0:00 PST, times
413// seven" with PST8PDT defined as "Pacific Time" (e.g. UTC-07:00 if
414// daylight savings is observed and UTC-08:00 otherwise.)
415//
416// If the passed in |time| variable is before Monday January 1st 2007
417// 0:00 PST, False is returned and the value returned in
418// |out_num_days| is undefined. Otherwise the number of PST8PDT
419// calendar weeks since that date times seven is returned in
420// |out_num_days| and the function returns True.
421//
422// (NOTE: This function does not currently take daylight savings time
423// into account so the result may up to one hour off. This is because
424// the glibc date and timezone routines depend on the TZ environment
425// variable and changing environment variables is not thread-safe. An
426// alternative, thread-safe API to use would be GDateTime/GTimeZone
427// available in GLib 2.26 or later.)
428bool ConvertToOmahaInstallDate(base::Time time, int *out_num_days);
429
David Zeuthen33bae492014-02-25 16:16:18 -0800430// This function returns the duration on the wallclock since the last
431// time it was called for the same |state_variable_key| value.
432//
433// If the function returns |true|, the duration (always non-negative)
434// is returned in |out_duration|. If the function returns |false|
435// something went wrong or there was no previous measurement.
436bool WallclockDurationHelper(SystemState* system_state,
437 const std::string& state_variable_key,
438 base::TimeDelta* out_duration);
439
440// This function returns the duration on the monotonic clock since the
441// last time it was called for the same |storage| pointer.
442//
443// You should pass a pointer to a 64-bit integer in |storage| which
444// should be initialized to 0.
445//
446// If the function returns |true|, the duration (always non-negative)
447// is returned in |out_duration|. If the function returns |false|
448// something went wrong or there was no previous measurement.
449bool MonotonicDurationHelper(SystemState* system_state,
450 int64_t* storage,
451 base::TimeDelta* out_duration);
452
Allie Wood78750a42015-02-11 15:42:11 -0800453// This function looks for a configuration file at |path|. If it finds that
454// file, it will try get the PAYLOAD_MINOR_VERSION value from it and set
455// |minor_version| to that value.
456//
457// The function will return |true| if it succeeds at finding the file and
458// value and setting it, and |false| otherwise.
459bool GetMinorVersion(base::FilePath path, uint32_t* minor_version);
460
adlr@google.com3defe6a2009-12-04 20:57:17 +0000461} // namespace utils
462
Jay Srinivasan08fce042012-06-07 16:31:01 -0700463
adlr@google.com3defe6a2009-12-04 20:57:17 +0000464// Utility class to close a file descriptor
465class ScopedFdCloser {
466 public:
467 explicit ScopedFdCloser(int* fd) : fd_(fd), should_close_(true) {}
adlr@google.com3defe6a2009-12-04 20:57:17 +0000468 ~ScopedFdCloser() {
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800469 if (should_close_ && fd_ && (*fd_ >= 0)) {
Gilad Arnoldf9609112012-02-29 11:38:47 -0800470 if (!close(*fd_))
471 *fd_ = -1;
adlr@google.com3defe6a2009-12-04 20:57:17 +0000472 }
473 }
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800474 void set_should_close(bool should_close) { should_close_ = should_close; }
adlr@google.com3defe6a2009-12-04 20:57:17 +0000475 private:
476 int* fd_;
477 bool should_close_;
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700478 DISALLOW_COPY_AND_ASSIGN(ScopedFdCloser);
479};
480
Gilad Arnoldf9609112012-02-29 11:38:47 -0800481// An EINTR-immune file descriptor closer.
482class ScopedEintrSafeFdCloser {
483 public:
484 explicit ScopedEintrSafeFdCloser(int* fd) : fd_(fd), should_close_(true) {}
485 ~ScopedEintrSafeFdCloser() {
486 if (should_close_ && fd_ && (*fd_ >= 0)) {
Mike Frysingerbcee2ca2014-05-14 16:28:23 -0400487 if (!IGNORE_EINTR(close(*fd_)))
Gilad Arnoldf9609112012-02-29 11:38:47 -0800488 *fd_ = -1;
489 }
490 }
491 void set_should_close(bool should_close) { should_close_ = should_close; }
492 private:
493 int* fd_;
494 bool should_close_;
495 DISALLOW_COPY_AND_ASSIGN(ScopedEintrSafeFdCloser);
496};
497
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700498// Utility class to delete a file when it goes out of scope.
499class ScopedPathUnlinker {
500 public:
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800501 explicit ScopedPathUnlinker(const std::string& path)
502 : path_(path),
503 should_remove_(true) {}
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700504 ~ScopedPathUnlinker() {
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800505 if (should_remove_ && unlink(path_.c_str()) < 0) {
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700506 std::string err_message = strerror(errno);
507 LOG(ERROR) << "Unable to unlink path " << path_ << ": " << err_message;
508 }
509 }
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800510 void set_should_remove(bool should_remove) { should_remove_ = should_remove; }
511
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700512 private:
513 const std::string path_;
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800514 bool should_remove_;
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700515 DISALLOW_COPY_AND_ASSIGN(ScopedPathUnlinker);
516};
517
518// Utility class to delete an empty directory when it goes out of scope.
519class ScopedDirRemover {
520 public:
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800521 explicit ScopedDirRemover(const std::string& path)
522 : path_(path),
523 should_remove_(true) {}
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700524 ~ScopedDirRemover() {
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800525 if (should_remove_ && (rmdir(path_.c_str()) < 0)) {
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700526 PLOG(ERROR) << "Unable to remove dir " << path_;
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800527 }
528 }
529 void set_should_remove(bool should_remove) { should_remove_ = should_remove; }
530
531 protected:
532 const std::string path_;
533
534 private:
535 bool should_remove_;
536 DISALLOW_COPY_AND_ASSIGN(ScopedDirRemover);
537};
538
539// Utility class to unmount a filesystem mounted on a temporary directory and
540// delete the temporary directory when it goes out of scope.
541class ScopedTempUnmounter : public ScopedDirRemover {
542 public:
543 explicit ScopedTempUnmounter(const std::string& path) :
544 ScopedDirRemover(path) {}
545 ~ScopedTempUnmounter() {
546 utils::UnmountFilesystem(path_);
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700547 }
548 private:
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800549 DISALLOW_COPY_AND_ASSIGN(ScopedTempUnmounter);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000550};
551
552// A little object to call ActionComplete on the ActionProcessor when
553// it's destructed.
554class ScopedActionCompleter {
555 public:
556 explicit ScopedActionCompleter(ActionProcessor* processor,
557 AbstractAction* action)
558 : processor_(processor),
559 action_(action),
Gilad Arnoldd1c4d2d2014-06-05 14:07:53 -0700560 code_(ErrorCode::kError),
adlr@google.com3defe6a2009-12-04 20:57:17 +0000561 should_complete_(true) {}
562 ~ScopedActionCompleter() {
563 if (should_complete_)
Darin Petkovc1a8b422010-07-19 11:34:49 -0700564 processor_->ActionComplete(action_, code_);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000565 }
David Zeuthena99981f2013-04-29 13:42:47 -0700566 void set_code(ErrorCode code) { code_ = code; }
adlr@google.com3defe6a2009-12-04 20:57:17 +0000567 void set_should_complete(bool should_complete) {
568 should_complete_ = should_complete;
569 }
David Zeuthen33bae492014-02-25 16:16:18 -0800570 ErrorCode get_code() const { return code_; }
Darin Petkovc1a8b422010-07-19 11:34:49 -0700571
adlr@google.com3defe6a2009-12-04 20:57:17 +0000572 private:
573 ActionProcessor* processor_;
574 AbstractAction* action_;
David Zeuthena99981f2013-04-29 13:42:47 -0700575 ErrorCode code_;
adlr@google.com3defe6a2009-12-04 20:57:17 +0000576 bool should_complete_;
577 DISALLOW_COPY_AND_ASSIGN(ScopedActionCompleter);
578};
579
David Zeuthen27a48bc2013-08-06 12:06:29 -0700580// A base::FreeDeleter that frees memory using g_free(). Useful when
Ben Chan02f7c1d2014-10-18 15:18:02 -0700581// integrating with GLib since it can be used with std::unique_ptr to
David Zeuthen27a48bc2013-08-06 12:06:29 -0700582// automatically free memory when going out of scope.
583struct GLibFreeDeleter : public base::FreeDeleter {
584 inline void operator()(void *ptr) const {
585 g_free(reinterpret_cast<gpointer>(ptr));
586 }
587};
588
589// A base::FreeDeleter that frees memory using g_strfreev(). Useful
Ben Chan02f7c1d2014-10-18 15:18:02 -0700590// when integrating with GLib since it can be used with std::unique_ptr to
David Zeuthen27a48bc2013-08-06 12:06:29 -0700591// automatically free memory when going out of scope.
592struct GLibStrvFreeDeleter : public base::FreeDeleter {
593 inline void operator()(void *ptr) const {
594 g_strfreev(reinterpret_cast<gchar**>(ptr));
595 }
596};
597
adlr@google.com3defe6a2009-12-04 20:57:17 +0000598} // namespace chromeos_update_engine
599
600#define TEST_AND_RETURN_FALSE_ERRNO(_x) \
601 do { \
Nam T. Nguyen2b67a592014-12-03 14:56:00 -0800602 bool _success = static_cast<bool>(_x); \
adlr@google.com3defe6a2009-12-04 20:57:17 +0000603 if (!_success) { \
604 std::string _msg = \
605 chromeos_update_engine::utils::ErrnoNumberAsString(errno); \
606 LOG(ERROR) << #_x " failed: " << _msg; \
607 return false; \
608 } \
609 } while (0)
610
611#define TEST_AND_RETURN_FALSE(_x) \
612 do { \
Nam T. Nguyen2b67a592014-12-03 14:56:00 -0800613 bool _success = static_cast<bool>(_x); \
adlr@google.com3defe6a2009-12-04 20:57:17 +0000614 if (!_success) { \
615 LOG(ERROR) << #_x " failed."; \
616 return false; \
617 } \
618 } while (0)
619
620#define TEST_AND_RETURN_ERRNO(_x) \
621 do { \
Nam T. Nguyen2b67a592014-12-03 14:56:00 -0800622 bool _success = static_cast<bool>(_x); \
adlr@google.com3defe6a2009-12-04 20:57:17 +0000623 if (!_success) { \
624 std::string _msg = \
625 chromeos_update_engine::utils::ErrnoNumberAsString(errno); \
626 LOG(ERROR) << #_x " failed: " << _msg; \
627 return; \
628 } \
629 } while (0)
630
631#define TEST_AND_RETURN(_x) \
632 do { \
Nam T. Nguyen2b67a592014-12-03 14:56:00 -0800633 bool _success = static_cast<bool>(_x); \
adlr@google.com3defe6a2009-12-04 20:57:17 +0000634 if (!_success) { \
635 LOG(ERROR) << #_x " failed."; \
636 return; \
637 } \
638 } while (0)
639
Thieu Le5c7d9752010-12-15 16:09:28 -0800640#define TEST_AND_RETURN_FALSE_ERRCODE(_x) \
641 do { \
642 errcode_t _error = (_x); \
643 if (_error) { \
644 errno = _error; \
645 LOG(ERROR) << #_x " failed: " << _error; \
646 return false; \
647 } \
648 } while (0)
649
Gilad Arnoldcf175a02014-07-10 16:48:47 -0700650#endif // UPDATE_ENGINE_UTILS_H_