blob: d2a0fc2131ce688e027fc879dbf2f34218bd948d [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
Alex Deymo759c2752014-03-17 21:09:36 -07005#ifndef CHROMEOS_PLATFORM_UPDATE_ENGINE_UTILS_H_
6#define CHROMEOS_PLATFORM_UPDATE_ENGINE_UTILS_H_
adlr@google.com3defe6a2009-12-04 20:57:17 +00007
Andrew de los Reyes81ebcd82010-03-09 15:56:18 -08008#include <algorithm>
Han Shen2643cb72012-06-26 14:45:33 -07009#include <errno.h>
adlr@google.com3defe6a2009-12-04 20:57:17 +000010#include <set>
11#include <string>
Han Shen2643cb72012-06-26 14:45:33 -070012#include <unistd.h>
adlr@google.com3defe6a2009-12-04 20:57:17 +000013#include <vector>
Darin Petkovc6c135c2010-08-11 13:36:18 -070014
Alex Vakulenko75039d72014-03-25 12:36:28 -070015#include <base/files/file_path.h>
Chris Sosafc661a12013-02-26 14:43:21 -080016#include <base/posix/eintr_wrapper.h>
Alex Vakulenko75039d72014-03-25 12:36:28 -070017#include <base/time/time.h>
Thieu Le5c7d9752010-12-15 16:09:28 -080018#include <ext2fs/ext2fs.h>
Andrew de los Reyesc7020782010-04-28 10:46:04 -070019#include <glib.h>
Jay Srinivasanf0572052012-10-23 18:12:56 -070020#include "metrics/metrics_library.h"
Darin Petkovc6c135c2010-08-11 13:36:18 -070021
adlr@google.com3defe6a2009-12-04 20:57:17 +000022#include "update_engine/action.h"
David Zeuthenb281f072014-04-02 10:20:19 -070023#include "update_engine/action_processor.h"
24#include "update_engine/connection_manager.h"
Jay Srinivasan19409b72013-04-12 19:23:36 -070025#include "update_engine/constants.h"
David Zeuthen33bae492014-02-25 16:16:18 -080026#include "update_engine/metrics.h"
adlr@google.com3defe6a2009-12-04 20:57:17 +000027
28namespace chromeos_update_engine {
29
Jay Srinivasan55f50c22013-01-10 19:24:35 -080030class SystemState;
31
adlr@google.com3defe6a2009-12-04 20:57:17 +000032namespace utils {
33
David Zeuthen27a48bc2013-08-06 12:06:29 -070034// Converts a struct timespec representing a number of seconds since
35// the Unix epoch to a base::Time. Sub-microsecond time is rounded
36// down.
37base::Time TimeFromStructTimespec(struct timespec *ts);
38
39// Converts a vector of strings to a NULL-terminated array of
40// strings. The resulting array should be freed with g_strfreev()
41// when are you done with it.
42gchar** StringVectorToGStrv(const std::vector<std::string> &vector);
43
44// Formats |vector| as a string of the form ["<elem1>", "<elem2>"].
45// Does no escaping, only use this for presentation in error messages.
46std::string StringVectorToString(const std::vector<std::string> &vector);
47
David Zeuthen8f191b22013-08-06 12:27:50 -070048// Calculates the p2p file id from payload hash and size
49std::string CalculateP2PFileId(const std::string& payload_hash,
50 size_t payload_size);
51
J. Richard Barnette63137e52013-10-28 10:57:29 -070052// Parse the firmware version from one line of output from the
53// "mosys" command.
54std::string ParseECVersion(std::string input_line);
55
J. Richard Barnette30842932013-10-28 15:04:23 -070056// Given the name of the block device of a boot partition, return the
57// name of the associated kernel partition (e.g. given "/dev/sda3",
58// return "/dev/sda2").
59const std::string KernelDeviceOfBootDevice(const std::string& boot_device);
60
Andrew de los Reyes970bb282009-12-09 16:34:04 -080061// Writes the data passed to path. The file at path will be overwritten if it
62// exists. Returns true on success, false otherwise.
63bool WriteFile(const char* path, const char* data, int data_len);
64
Andrew de los Reyes09e56d62010-04-23 13:45:53 -070065// Calls write() or pwrite() repeatedly until all count bytes at buf are
66// written to fd or an error occurs. Returns true on success.
67bool WriteAll(int fd, const void* buf, size_t count);
68bool PWriteAll(int fd, const void* buf, size_t count, off_t offset);
69
70// Calls pread() repeatedly until count bytes are read, or EOF is reached.
71// Returns number of bytes read in *bytes_read. Returns true on success.
72bool PReadAll(int fd, void* buf, size_t count, off_t offset,
73 ssize_t* out_bytes_read);
Andrew de los Reyesb10320d2010-03-31 16:44:44 -070074
Gilad Arnold19a45f02012-07-19 12:36:10 -070075// Opens |path| for reading and appends its entire content to the container
76// pointed to by |out_p|. Returns true upon successfully reading all of the
77// file's content, false otherwise, in which case the state of the output
Darin Petkov8e447e02013-04-16 16:23:50 +020078// container is unknown. ReadFileChunk starts reading the file from |offset|; if
79// |size| is not -1, only up to |size| bytes are read in.
Gilad Arnold19a45f02012-07-19 12:36:10 -070080bool ReadFile(const std::string& path, std::vector<char>* out_p);
81bool ReadFile(const std::string& path, std::string* out_p);
Darin Petkov8e447e02013-04-16 16:23:50 +020082bool ReadFileChunk(const std::string& path, off_t offset, off_t size,
83 std::vector<char>* out_p);
Gilad Arnold19a45f02012-07-19 12:36:10 -070084
85// Invokes |cmd| in a pipe and appends its stdout to the container pointed to by
86// |out_p|. Returns true upon successfully reading all of the output, false
87// otherwise, in which case the state of the output container is unknown.
88bool ReadPipe(const std::string& cmd, std::vector<char>* out_p);
89bool ReadPipe(const std::string& cmd, std::string* out_p);
adlr@google.com3defe6a2009-12-04 20:57:17 +000090
Andrew de los Reyesf4c7ef12010-04-30 10:37:00 -070091// Returns the size of the file at path. If the file doesn't exist or some
92// error occurrs, -1 is returned.
93off_t FileSize(const std::string& path);
94
adlr@google.com3defe6a2009-12-04 20:57:17 +000095std::string ErrnoNumberAsString(int err);
96
97// Strips duplicate slashes, and optionally removes all trailing slashes.
98// Does not compact /./ or /../.
99std::string NormalizePath(const std::string& path, bool strip_trailing_slash);
100
101// Returns true if the file exists for sure. Returns false if it doesn't exist,
102// or an error occurs.
103bool FileExists(const char* path);
104
Darin Petkov30291ed2010-11-12 10:23:06 -0800105// Returns true if |path| exists and is a symbolic link.
106bool IsSymlink(const char* path);
107
Alex Deymo7dc4c502014-05-20 20:09:58 -0700108// Returns true if |path| exists and is a directory.
109bool IsDir(const char* path);
110
adlr@google.com3defe6a2009-12-04 20:57:17 +0000111// The last 6 chars of path must be XXXXXX. They will be randomly changed
112// and a non-existent path will be returned. Intentionally makes a copy
113// of the string passed in.
114// NEVER CALL THIS FUNCTION UNLESS YOU ARE SURE
115// THAT YOUR PROCESS WILL BE THE ONLY THING WRITING FILES IN THIS DIRECTORY.
Andrew de los Reyes4fe15d02009-12-10 19:01:36 -0800116std::string TempFilename(std::string path);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000117
Gilad Arnoldd04f8e22014-01-09 13:13:40 -0800118// If |base_filename_template| is neither absolute (starts with "/") nor
119// explicitly relative to the current working directory (starts with "./" or
120// "../"), then it is prepended the value of TMPDIR, which defaults to /tmp if
121// it isn't set or is empty. It then calls mkstemp(3) with the resulting
122// template. Writes the name of a new temporary file to |filename|. If |fd| is
123// non-NULL, the file descriptor returned by mkstemp is written to it and kept
124// open; otherwise, it is closed. The template must end with "XXXXXX". Returns
125// true on success.
126bool MakeTempFile(const std::string& base_filename_template,
Andrew de los Reyesb10320d2010-03-31 16:44:44 -0700127 std::string* filename,
128 int* fd);
129
Gilad Arnoldd04f8e22014-01-09 13:13:40 -0800130// If |base_filename_template| is neither absolute (starts with "/") nor
131// explicitly relative to the current working directory (starts with "./" or
132// "../"), then it is prepended the value of TMPDIR, which defaults to /tmp if
133// it isn't set or is empty. It then calls mkdtemp() with the resulting
134// template. Writes the name of the new temporary directory to |dirname|.
135// The template must end with "XXXXXX". Returns true on success.
136bool MakeTempDirectory(const std::string& base_dirname_template,
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700137 std::string* dirname);
138
adlr@google.com3defe6a2009-12-04 20:57:17 +0000139// Deletes a directory and all its contents synchronously. Returns true
140// on success. This may be called with a regular file--it will just unlink it.
141// This WILL cross filesystem boundaries.
142bool RecursiveUnlinkDir(const std::string& path);
143
Alex Vakulenko4f5b1442014-02-21 12:19:44 -0800144// Returns the disk device name for a partition. For example,
145// GetDiskName("/dev/sda3") returns "/dev/sda". Returns an empty string
146// if the input device is not of the "/dev/xyz#" form.
147std::string GetDiskName(const std::string& partition_name);
Andrew de los Reyesf9714432010-05-04 10:21:23 -0700148
Alex Vakulenko4f5b1442014-02-21 12:19:44 -0800149// Returns the partition number, of partition device name. For example,
150// GetPartitionNumber("/dev/sda3") returns 3.
151// Returns 0 on failure
152int GetPartitionNumber(const std::string& partition_name);
153
154// Splits the partition device name into the block device name and partition
155// number. For example, "/dev/sda3" will be split into {"/dev/sda", 3} and
156// "/dev/mmcblk0p2" into {"/dev/mmcblk0", 2}
157// Returns false when malformed device name is passed in.
158// If both output parameters are omitted (nullptr), can be used
159// just to test the validity of the device name. Note that the function
160// simply checks if the device name looks like a valid device, no other
161// checks are performed (i.e. it doesn't check if the device actually exists).
162bool SplitPartitionName(const std::string& partition_name,
163 std::string* out_disk_name,
164 int* out_partition_num);
165
166// Builds a partition device name from the block device name and partition
167// number. For example:
168// {"/dev/sda", 1} => "/dev/sda1"
169// {"/dev/mmcblk2", 12} => "/dev/mmcblk2p12"
170// Returns empty string when invalid parameters are passed in
171std::string MakePartitionName(const std::string& disk_name,
172 int partition_num);
Andrew de los Reyesf9714432010-05-04 10:21:23 -0700173
Darin Petkovf74eb652010-08-04 12:08:38 -0700174// Returns the sysfs block device for a root block device. For
175// example, SysfsBlockDevice("/dev/sda") returns
176// "/sys/block/sda". Returns an empty string if the input device is
177// not of the "/dev/xyz" form.
178std::string SysfsBlockDevice(const std::string& device);
179
180// Returns true if the root |device| (e.g., "/dev/sdb") is known to be
181// removable, false otherwise.
182bool IsRemovableDevice(const std::string& device);
183
adlr@google.com3defe6a2009-12-04 20:57:17 +0000184// Synchronously mount or unmount a filesystem. Return true on success.
185// Mounts as ext3 with default options.
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700186bool MountFilesystem(const std::string& device, const std::string& mountpoint,
187 unsigned long flags);
Andrew de los Reyes4fe15d02009-12-10 19:01:36 -0800188bool UnmountFilesystem(const std::string& mountpoint);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000189
Darin Petkovd3f8c892010-10-12 21:38:45 -0700190// Returns the block count and the block byte size of the ext3 file system on
191// |device| (which may be a real device or a path to a filesystem image) or on
192// an opened file descriptor |fd|. The actual file-system size is |block_count|
193// * |block_size| bytes. Returns true on success, false otherwise.
194bool GetFilesystemSize(const std::string& device,
195 int* out_block_count,
196 int* out_block_size);
197bool GetFilesystemSizeFromFD(int fd,
198 int* out_block_count,
199 int* out_block_size);
200
Alex Deymo032e7722014-03-25 17:53:56 -0700201
202// Returns a human-readable string with the file format based on magic constants
203// on the header of the file.
204std::string GetFileFormat(const std::string& path);
205
Jay Srinivasan480ddfa2012-06-01 19:15:26 -0700206// Returns the string representation of the given UTC time.
207// such as "11/14/2011 14:05:30 GMT".
208std::string ToString(const base::Time utc_time);
209
Jay Srinivasanae4697c2013-03-18 17:08:08 -0700210// Returns true or false depending on the value of b.
211std::string ToString(bool b);
212
Jay Srinivasan19409b72013-04-12 19:23:36 -0700213// Returns a string representation of the given enum.
214std::string ToString(DownloadSource source);
215
Alex Deymo1c656c42013-06-28 11:02:14 -0700216// Returns a string representation of the given enum.
217std::string ToString(PayloadType payload_type);
218
Andrew de los Reyesf9714432010-05-04 10:21:23 -0700219enum BootLoader {
220 BootLoader_SYSLINUX = 0,
221 BootLoader_CHROME_FIRMWARE = 1
222};
223// Detects which bootloader this system uses and returns it via the out
224// param. Returns true on success.
225bool GetBootloader(BootLoader* out_bootloader);
226
Darin Petkova0b9e772011-10-06 05:05:56 -0700227// Returns the error message, if any, from a GError pointer. Frees the GError
228// object and resets error to NULL.
229std::string GetAndFreeGError(GError** error);
Andrew de los Reyesc7020782010-04-28 10:46:04 -0700230
Darin Petkov296889c2010-07-23 16:20:54 -0700231// Initiates a system reboot. Returns true on success, false otherwise.
232bool Reboot();
233
Andrew de los Reyes712b3ac2011-01-07 13:47:52 -0800234// Schedules a Main Loop callback to trigger the crash reporter to perform an
235// upload as if this process had crashed.
236void ScheduleCrashReporterUpload();
237
Darin Petkov5c0a8af2010-08-24 13:39:13 -0700238// Fuzzes an integer |value| randomly in the range:
239// [value - range / 2, value + range - range / 2]
240int FuzzInt(int value, unsigned int range);
241
adlr@google.com3defe6a2009-12-04 20:57:17 +0000242// Log a string in hex to LOG(INFO). Useful for debugging.
243void HexDumpArray(const unsigned char* const arr, const size_t length);
244inline void HexDumpString(const std::string& str) {
245 HexDumpArray(reinterpret_cast<const unsigned char*>(str.data()), str.size());
246}
247inline void HexDumpVector(const std::vector<char>& vect) {
248 HexDumpArray(reinterpret_cast<const unsigned char*>(&vect[0]), vect.size());
249}
250
adlr@google.com3defe6a2009-12-04 20:57:17 +0000251bool StringHasSuffix(const std::string& str, const std::string& suffix);
252bool StringHasPrefix(const std::string& str, const std::string& prefix);
253
254template<typename KeyType, typename ValueType>
255bool MapContainsKey(const std::map<KeyType, ValueType>& m, const KeyType& k) {
256 return m.find(k) != m.end();
257}
Andrew de los Reyes4fe15d02009-12-10 19:01:36 -0800258template<typename KeyType>
259bool SetContainsKey(const std::set<KeyType>& s, const KeyType& k) {
260 return s.find(k) != s.end();
261}
adlr@google.com3defe6a2009-12-04 20:57:17 +0000262
263template<typename ValueType>
264std::set<ValueType> SetWithValue(const ValueType& value) {
265 std::set<ValueType> ret;
266 ret.insert(value);
267 return ret;
268}
269
Andrew de los Reyes0ce161b2010-02-22 15:27:01 -0800270template<typename T>
271bool VectorContainsValue(const std::vector<T>& vect, const T& value) {
Darin Petkovc1a8b422010-07-19 11:34:49 -0700272 return std::find(vect.begin(), vect.end(), value) != vect.end();
Andrew de los Reyes0ce161b2010-02-22 15:27:01 -0800273}
274
Andrew de los Reyesb10320d2010-03-31 16:44:44 -0700275template<typename T>
276bool VectorIndexOf(const std::vector<T>& vect, const T& value,
277 typename std::vector<T>::size_type* out_index) {
278 typename std::vector<T>::const_iterator it = std::find(vect.begin(),
279 vect.end(),
280 value);
281 if (it == vect.end()) {
282 return false;
283 } else {
284 *out_index = it - vect.begin();
285 return true;
286 }
287}
288
Andrew de los Reyescc92cd32010-10-05 16:56:14 -0700289template<typename ValueType>
290void ApplyMap(std::vector<ValueType>* collection,
291 const std::map<ValueType, ValueType>& the_map) {
292 for (typename std::vector<ValueType>::iterator it = collection->begin();
293 it != collection->end(); ++it) {
294 typename std::map<ValueType, ValueType>::const_iterator map_it =
295 the_map.find(*it);
296 if (map_it != the_map.end()) {
297 *it = map_it->second;
298 }
299 }
300}
301
Chris Sosa4f8ee272012-11-30 13:01:54 -0800302// Cgroups cpu shares constants. 1024 is the default shares a standard process
303// gets and 2 is the minimum value. We set High as a value that gives the
304// update-engine 2x the cpu share of a standard process.
305enum CpuShares {
306 kCpuSharesHigh = 2048,
307 kCpuSharesNormal = 1024,
308 kCpuSharesLow = 2,
Darin Petkovc6c135c2010-08-11 13:36:18 -0700309};
310
Chris Sosa4f8ee272012-11-30 13:01:54 -0800311// Compares cpu shares and returns an integer that is less
312// than, equal to or greater than 0 if |shares_lhs| is,
313// respectively, lower than, same as or higher than |shares_rhs|.
314int CompareCpuShares(CpuShares shares_lhs,
315 CpuShares shares_rhs);
Darin Petkovc6c135c2010-08-11 13:36:18 -0700316
Chris Sosa4f8ee272012-11-30 13:01:54 -0800317// Sets the current process shares to |shares|. Returns true on
Darin Petkovc6c135c2010-08-11 13:36:18 -0700318// success, false otherwise.
Chris Sosa4f8ee272012-11-30 13:01:54 -0800319bool SetCpuShares(CpuShares shares);
Andrew de los Reyesf9185172010-05-03 11:07:05 -0700320
Alex Deymoc4acdf42014-05-28 21:07:10 -0700321// Assumes |data| points to a Closure. Runs it and returns FALSE;
Andrew de los Reyesf3ed8e72011-02-16 10:35:46 -0800322gboolean GlibRunClosure(gpointer data);
323
Alex Deymoc4acdf42014-05-28 21:07:10 -0700324// Destroys the Closure pointed by |data|.
325void GlibDestroyClosure(gpointer data);
326
Gilad Arnoldd7b513d2012-05-10 14:25:27 -0700327// Converts seconds into human readable notation including days, hours, minutes
328// and seconds. For example, 185 will yield 3m5s, 4300 will yield 1h11m40s, and
329// 360000 will yield 4d4h0m0s. Zero padding not applied. Seconds are always
330// shown in the result.
331std::string FormatSecs(unsigned secs);
332
333// Converts a TimeDelta into human readable notation including days, hours,
334// minutes, seconds and fractions of a second down to microsecond granularity,
335// as necessary; for example, an output of 5d2h0m15.053s means that the input
336// time was precise to the milliseconds only. Zero padding not applied, except
337// for fractions. Seconds are always shown, but fractions thereof are only shown
338// when applicable.
339std::string FormatTimeDelta(base::TimeDelta delta);
Gilad Arnold1ebd8132012-03-05 10:19:29 -0800340
Jay Srinivasan2b5a0f02012-12-19 17:25:56 -0800341// This method transforms the given error code to be suitable for UMA and
342// for error classification purposes by removing the higher order bits and
343// aggregating error codes beyond the enum range, etc. This method is
344// idempotent, i.e. if called with a value previously returned by this method,
345// it'll return the same value again.
David Zeuthena99981f2013-04-29 13:42:47 -0700346ErrorCode GetBaseErrorCode(ErrorCode code);
Jay Srinivasan2b5a0f02012-12-19 17:25:56 -0800347
David Zeuthen33bae492014-02-25 16:16:18 -0800348// Transforms a ErrorCode value into a metrics::DownloadErrorCode.
349// This obviously only works for errors related to downloading so if |code|
350// is e.g. |kErrorCodeFilesystemCopierError| then
351// |kDownloadErrorCodeInputMalformed| is returned.
352metrics::DownloadErrorCode GetDownloadErrorCode(ErrorCode code);
353
354// Transforms a ErrorCode value into a metrics::AttemptResult.
355//
356// If metrics::AttemptResult::kPayloadDownloadError is returned, you
357// can use utils::GetDownloadError() to get more detail.
358metrics::AttemptResult GetAttemptResult(ErrorCode code);
359
David Zeuthenb281f072014-04-02 10:20:19 -0700360// Calculates the internet connection type given |type| and |tethering|.
361metrics::ConnectionType GetConnectionType(NetworkConnectionType type,
362 NetworkTethering tethering);
363
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800364// Sends the error code to UMA using the metrics interface object in the given
365// system state. It also uses the system state to determine the right UMA
366// bucket for the error code.
David Zeuthena99981f2013-04-29 13:42:47 -0700367void SendErrorCodeToUma(SystemState* system_state, ErrorCode code);
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800368
David Zeuthena99981f2013-04-29 13:42:47 -0700369// Returns a string representation of the ErrorCodes (either the base
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800370// error codes or the bit flags) for logging purposes.
David Zeuthena99981f2013-04-29 13:42:47 -0700371std::string CodeToString(ErrorCode code);
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800372
Gilad Arnold30dedd82013-07-03 06:19:09 -0700373// Creates the powerwash marker file with the appropriate commands in it. Uses
374// |file_path| as the path to the marker file if non-NULL, otherwise uses the
375// global default. Returns true if successfully created. False otherwise.
376bool CreatePowerwashMarkerFile(const char* file_path);
Jay Srinivasan1c0fe792013-03-28 16:45:25 -0700377
Gilad Arnold30dedd82013-07-03 06:19:09 -0700378// Deletes the marker file used to trigger Powerwash using clobber-state. Uses
379// |file_path| as the path to the marker file if non-NULL, otherwise uses the
380// global default. Returns true if successfully deleted. False otherwise.
381bool DeletePowerwashMarkerFile(const char* file_path);
Jay Srinivasan1c0fe792013-03-28 16:45:25 -0700382
Chris Sosad317e402013-06-12 13:47:09 -0700383// Assumes you want to install on the "other" device, where the other
384// device is what you get if you swap 1 for 2 or 3 for 4 or vice versa
385// for the number at the end of the boot device. E.g., /dev/sda1 -> /dev/sda2
386// or /dev/sda4 -> /dev/sda3. See
387// http://www.chromium.org/chromium-os/chromiumos-design-docs/disk-format
388bool GetInstallDev(const std::string& boot_dev, std::string* install_dev);
389
David Zeuthen910ec5b2013-09-26 12:10:58 -0700390// Checks if xattr is supported in the directory specified by
391// |dir_path| which must be writable. Returns true if the feature is
392// supported, false if not or if an error occured.
393bool IsXAttrSupported(const base::FilePath& dir_path);
394
David Zeuthene7f89172013-10-31 10:21:04 -0700395// Decodes the data in |base64_encoded| and stores it in a temporary
396// file. Returns false if the given data is empty, not well-formed
397// base64 or if an error occurred. If true is returned, the decoded
398// data is stored in the file returned in |out_path|. The file should
399// be deleted when no longer needed.
400bool DecodeAndStoreBase64String(const std::string& base64_encoded,
401 base::FilePath *out_path);
402
David Zeuthen639aa362014-02-03 16:23:44 -0800403// Converts |time| to an Omaha InstallDate which is defined as "the
404// number of PST8PDT calendar weeks since Jan 1st 2007 0:00 PST, times
405// seven" with PST8PDT defined as "Pacific Time" (e.g. UTC-07:00 if
406// daylight savings is observed and UTC-08:00 otherwise.)
407//
408// If the passed in |time| variable is before Monday January 1st 2007
409// 0:00 PST, False is returned and the value returned in
410// |out_num_days| is undefined. Otherwise the number of PST8PDT
411// calendar weeks since that date times seven is returned in
412// |out_num_days| and the function returns True.
413//
414// (NOTE: This function does not currently take daylight savings time
415// into account so the result may up to one hour off. This is because
416// the glibc date and timezone routines depend on the TZ environment
417// variable and changing environment variables is not thread-safe. An
418// alternative, thread-safe API to use would be GDateTime/GTimeZone
419// available in GLib 2.26 or later.)
420bool ConvertToOmahaInstallDate(base::Time time, int *out_num_days);
421
David Zeuthen33bae492014-02-25 16:16:18 -0800422// This function returns the duration on the wallclock since the last
423// time it was called for the same |state_variable_key| value.
424//
425// If the function returns |true|, the duration (always non-negative)
426// is returned in |out_duration|. If the function returns |false|
427// something went wrong or there was no previous measurement.
428bool WallclockDurationHelper(SystemState* system_state,
429 const std::string& state_variable_key,
430 base::TimeDelta* out_duration);
431
432// This function returns the duration on the monotonic clock since the
433// last time it was called for the same |storage| pointer.
434//
435// You should pass a pointer to a 64-bit integer in |storage| which
436// should be initialized to 0.
437//
438// If the function returns |true|, the duration (always non-negative)
439// is returned in |out_duration|. If the function returns |false|
440// something went wrong or there was no previous measurement.
441bool MonotonicDurationHelper(SystemState* system_state,
442 int64_t* storage,
443 base::TimeDelta* out_duration);
444
adlr@google.com3defe6a2009-12-04 20:57:17 +0000445} // namespace utils
446
Jay Srinivasan08fce042012-06-07 16:31:01 -0700447
adlr@google.com3defe6a2009-12-04 20:57:17 +0000448// Class to unmount FS when object goes out of scope
449class ScopedFilesystemUnmounter {
450 public:
451 explicit ScopedFilesystemUnmounter(const std::string& mountpoint)
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800452 : mountpoint_(mountpoint),
453 should_unmount_(true) {}
adlr@google.com3defe6a2009-12-04 20:57:17 +0000454 ~ScopedFilesystemUnmounter() {
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800455 if (should_unmount_) {
456 utils::UnmountFilesystem(mountpoint_);
457 }
adlr@google.com3defe6a2009-12-04 20:57:17 +0000458 }
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800459 void set_should_unmount(bool unmount) { should_unmount_ = unmount; }
adlr@google.com3defe6a2009-12-04 20:57:17 +0000460 private:
461 const std::string mountpoint_;
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800462 bool should_unmount_;
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700463 DISALLOW_COPY_AND_ASSIGN(ScopedFilesystemUnmounter);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000464};
465
466// Utility class to close a file descriptor
467class ScopedFdCloser {
468 public:
469 explicit ScopedFdCloser(int* fd) : fd_(fd), should_close_(true) {}
adlr@google.com3defe6a2009-12-04 20:57:17 +0000470 ~ScopedFdCloser() {
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800471 if (should_close_ && fd_ && (*fd_ >= 0)) {
Gilad Arnoldf9609112012-02-29 11:38:47 -0800472 if (!close(*fd_))
473 *fd_ = -1;
adlr@google.com3defe6a2009-12-04 20:57:17 +0000474 }
475 }
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800476 void set_should_close(bool should_close) { should_close_ = should_close; }
adlr@google.com3defe6a2009-12-04 20:57:17 +0000477 private:
478 int* fd_;
479 bool should_close_;
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700480 DISALLOW_COPY_AND_ASSIGN(ScopedFdCloser);
481};
482
Gilad Arnoldf9609112012-02-29 11:38:47 -0800483// An EINTR-immune file descriptor closer.
484class ScopedEintrSafeFdCloser {
485 public:
486 explicit ScopedEintrSafeFdCloser(int* fd) : fd_(fd), should_close_(true) {}
487 ~ScopedEintrSafeFdCloser() {
488 if (should_close_ && fd_ && (*fd_ >= 0)) {
Mike Frysingerbcee2ca2014-05-14 16:28:23 -0400489 if (!IGNORE_EINTR(close(*fd_)))
Gilad Arnoldf9609112012-02-29 11:38:47 -0800490 *fd_ = -1;
491 }
492 }
493 void set_should_close(bool should_close) { should_close_ = should_close; }
494 private:
495 int* fd_;
496 bool should_close_;
497 DISALLOW_COPY_AND_ASSIGN(ScopedEintrSafeFdCloser);
498};
499
Thieu Le5c7d9752010-12-15 16:09:28 -0800500// Utility class to close a file system
501class ScopedExt2fsCloser {
502 public:
503 explicit ScopedExt2fsCloser(ext2_filsys filsys) : filsys_(filsys) {}
504 ~ScopedExt2fsCloser() { ext2fs_close(filsys_); }
505
506 private:
507 ext2_filsys filsys_;
508 DISALLOW_COPY_AND_ASSIGN(ScopedExt2fsCloser);
509};
510
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700511// Utility class to delete a file when it goes out of scope.
512class ScopedPathUnlinker {
513 public:
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800514 explicit ScopedPathUnlinker(const std::string& path)
515 : path_(path),
516 should_remove_(true) {}
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700517 ~ScopedPathUnlinker() {
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800518 if (should_remove_ && unlink(path_.c_str()) < 0) {
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700519 std::string err_message = strerror(errno);
520 LOG(ERROR) << "Unable to unlink path " << path_ << ": " << err_message;
521 }
522 }
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800523 void set_should_remove(bool should_remove) { should_remove_ = should_remove; }
524
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700525 private:
526 const std::string path_;
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800527 bool should_remove_;
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700528 DISALLOW_COPY_AND_ASSIGN(ScopedPathUnlinker);
529};
530
531// Utility class to delete an empty directory when it goes out of scope.
532class ScopedDirRemover {
533 public:
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800534 explicit ScopedDirRemover(const std::string& path)
535 : path_(path),
536 should_remove_(true) {}
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700537 ~ScopedDirRemover() {
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800538 if (should_remove_ && (rmdir(path_.c_str()) < 0)) {
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700539 PLOG(ERROR) << "Unable to remove dir " << path_;
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800540 }
541 }
542 void set_should_remove(bool should_remove) { should_remove_ = should_remove; }
543
544 protected:
545 const std::string path_;
546
547 private:
548 bool should_remove_;
549 DISALLOW_COPY_AND_ASSIGN(ScopedDirRemover);
550};
551
552// Utility class to unmount a filesystem mounted on a temporary directory and
553// delete the temporary directory when it goes out of scope.
554class ScopedTempUnmounter : public ScopedDirRemover {
555 public:
556 explicit ScopedTempUnmounter(const std::string& path) :
557 ScopedDirRemover(path) {}
558 ~ScopedTempUnmounter() {
559 utils::UnmountFilesystem(path_);
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700560 }
561 private:
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800562 DISALLOW_COPY_AND_ASSIGN(ScopedTempUnmounter);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000563};
564
565// A little object to call ActionComplete on the ActionProcessor when
566// it's destructed.
567class ScopedActionCompleter {
568 public:
569 explicit ScopedActionCompleter(ActionProcessor* processor,
570 AbstractAction* action)
571 : processor_(processor),
572 action_(action),
David Zeuthena99981f2013-04-29 13:42:47 -0700573 code_(kErrorCodeError),
adlr@google.com3defe6a2009-12-04 20:57:17 +0000574 should_complete_(true) {}
575 ~ScopedActionCompleter() {
576 if (should_complete_)
Darin Petkovc1a8b422010-07-19 11:34:49 -0700577 processor_->ActionComplete(action_, code_);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000578 }
David Zeuthena99981f2013-04-29 13:42:47 -0700579 void set_code(ErrorCode code) { code_ = code; }
adlr@google.com3defe6a2009-12-04 20:57:17 +0000580 void set_should_complete(bool should_complete) {
581 should_complete_ = should_complete;
582 }
David Zeuthen33bae492014-02-25 16:16:18 -0800583 ErrorCode get_code() const { return code_; }
Darin Petkovc1a8b422010-07-19 11:34:49 -0700584
adlr@google.com3defe6a2009-12-04 20:57:17 +0000585 private:
586 ActionProcessor* processor_;
587 AbstractAction* action_;
David Zeuthena99981f2013-04-29 13:42:47 -0700588 ErrorCode code_;
adlr@google.com3defe6a2009-12-04 20:57:17 +0000589 bool should_complete_;
590 DISALLOW_COPY_AND_ASSIGN(ScopedActionCompleter);
591};
592
David Zeuthen27a48bc2013-08-06 12:06:29 -0700593// A base::FreeDeleter that frees memory using g_free(). Useful when
594// integrating with GLib since it can be used with scoped_ptr to
595// automatically free memory when going out of scope.
596struct GLibFreeDeleter : public base::FreeDeleter {
597 inline void operator()(void *ptr) const {
598 g_free(reinterpret_cast<gpointer>(ptr));
599 }
600};
601
602// A base::FreeDeleter that frees memory using g_strfreev(). Useful
603// when integrating with GLib since it can be used with scoped_ptr to
604// automatically free memory when going out of scope.
605struct GLibStrvFreeDeleter : public base::FreeDeleter {
606 inline void operator()(void *ptr) const {
607 g_strfreev(reinterpret_cast<gchar**>(ptr));
608 }
609};
610
adlr@google.com3defe6a2009-12-04 20:57:17 +0000611} // namespace chromeos_update_engine
612
613#define TEST_AND_RETURN_FALSE_ERRNO(_x) \
614 do { \
615 bool _success = (_x); \
616 if (!_success) { \
617 std::string _msg = \
618 chromeos_update_engine::utils::ErrnoNumberAsString(errno); \
619 LOG(ERROR) << #_x " failed: " << _msg; \
620 return false; \
621 } \
622 } while (0)
623
624#define TEST_AND_RETURN_FALSE(_x) \
625 do { \
626 bool _success = (_x); \
627 if (!_success) { \
628 LOG(ERROR) << #_x " failed."; \
629 return false; \
630 } \
631 } while (0)
632
633#define TEST_AND_RETURN_ERRNO(_x) \
634 do { \
635 bool _success = (_x); \
636 if (!_success) { \
637 std::string _msg = \
638 chromeos_update_engine::utils::ErrnoNumberAsString(errno); \
639 LOG(ERROR) << #_x " failed: " << _msg; \
640 return; \
641 } \
642 } while (0)
643
644#define TEST_AND_RETURN(_x) \
645 do { \
646 bool _success = (_x); \
647 if (!_success) { \
648 LOG(ERROR) << #_x " failed."; \
649 return; \
650 } \
651 } while (0)
652
Thieu Le5c7d9752010-12-15 16:09:28 -0800653#define TEST_AND_RETURN_FALSE_ERRCODE(_x) \
654 do { \
655 errcode_t _error = (_x); \
656 if (_error) { \
657 errno = _error; \
658 LOG(ERROR) << #_x " failed: " << _error; \
659 return false; \
660 } \
661 } while (0)
662
adlr@google.com3defe6a2009-12-04 20:57:17 +0000663
664
Alex Deymo759c2752014-03-17 21:09:36 -0700665#endif // CHROMEOS_PLATFORM_UPDATE_ENGINE_UTILS_H_