blob: e83db5cc86e1ec6ff8605d5662b7c6adc8ffaf9c [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
Andrew de los Reyesf3ed8e72011-02-16 10:35:46 -0800321// Assumes data points to a Closure. Runs it and returns FALSE;
322gboolean GlibRunClosure(gpointer data);
323
Gilad Arnoldd7b513d2012-05-10 14:25:27 -0700324// Converts seconds into human readable notation including days, hours, minutes
325// and seconds. For example, 185 will yield 3m5s, 4300 will yield 1h11m40s, and
326// 360000 will yield 4d4h0m0s. Zero padding not applied. Seconds are always
327// shown in the result.
328std::string FormatSecs(unsigned secs);
329
330// Converts a TimeDelta into human readable notation including days, hours,
331// minutes, seconds and fractions of a second down to microsecond granularity,
332// as necessary; for example, an output of 5d2h0m15.053s means that the input
333// time was precise to the milliseconds only. Zero padding not applied, except
334// for fractions. Seconds are always shown, but fractions thereof are only shown
335// when applicable.
336std::string FormatTimeDelta(base::TimeDelta delta);
Gilad Arnold1ebd8132012-03-05 10:19:29 -0800337
Jay Srinivasan2b5a0f02012-12-19 17:25:56 -0800338// This method transforms the given error code to be suitable for UMA and
339// for error classification purposes by removing the higher order bits and
340// aggregating error codes beyond the enum range, etc. This method is
341// idempotent, i.e. if called with a value previously returned by this method,
342// it'll return the same value again.
David Zeuthena99981f2013-04-29 13:42:47 -0700343ErrorCode GetBaseErrorCode(ErrorCode code);
Jay Srinivasan2b5a0f02012-12-19 17:25:56 -0800344
David Zeuthen33bae492014-02-25 16:16:18 -0800345// Transforms a ErrorCode value into a metrics::DownloadErrorCode.
346// This obviously only works for errors related to downloading so if |code|
347// is e.g. |kErrorCodeFilesystemCopierError| then
348// |kDownloadErrorCodeInputMalformed| is returned.
349metrics::DownloadErrorCode GetDownloadErrorCode(ErrorCode code);
350
351// Transforms a ErrorCode value into a metrics::AttemptResult.
352//
353// If metrics::AttemptResult::kPayloadDownloadError is returned, you
354// can use utils::GetDownloadError() to get more detail.
355metrics::AttemptResult GetAttemptResult(ErrorCode code);
356
David Zeuthenb281f072014-04-02 10:20:19 -0700357// Calculates the internet connection type given |type| and |tethering|.
358metrics::ConnectionType GetConnectionType(NetworkConnectionType type,
359 NetworkTethering tethering);
360
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800361// Sends the error code to UMA using the metrics interface object in the given
362// system state. It also uses the system state to determine the right UMA
363// bucket for the error code.
David Zeuthena99981f2013-04-29 13:42:47 -0700364void SendErrorCodeToUma(SystemState* system_state, ErrorCode code);
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800365
David Zeuthena99981f2013-04-29 13:42:47 -0700366// Returns a string representation of the ErrorCodes (either the base
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800367// error codes or the bit flags) for logging purposes.
David Zeuthena99981f2013-04-29 13:42:47 -0700368std::string CodeToString(ErrorCode code);
Jay Srinivasan55f50c22013-01-10 19:24:35 -0800369
Gilad Arnold30dedd82013-07-03 06:19:09 -0700370// Creates the powerwash marker file with the appropriate commands in it. Uses
371// |file_path| as the path to the marker file if non-NULL, otherwise uses the
372// global default. Returns true if successfully created. False otherwise.
373bool CreatePowerwashMarkerFile(const char* file_path);
Jay Srinivasan1c0fe792013-03-28 16:45:25 -0700374
Gilad Arnold30dedd82013-07-03 06:19:09 -0700375// Deletes the marker file used to trigger Powerwash using clobber-state. Uses
376// |file_path| as the path to the marker file if non-NULL, otherwise uses the
377// global default. Returns true if successfully deleted. False otherwise.
378bool DeletePowerwashMarkerFile(const char* file_path);
Jay Srinivasan1c0fe792013-03-28 16:45:25 -0700379
Chris Sosad317e402013-06-12 13:47:09 -0700380// Assumes you want to install on the "other" device, where the other
381// device is what you get if you swap 1 for 2 or 3 for 4 or vice versa
382// for the number at the end of the boot device. E.g., /dev/sda1 -> /dev/sda2
383// or /dev/sda4 -> /dev/sda3. See
384// http://www.chromium.org/chromium-os/chromiumos-design-docs/disk-format
385bool GetInstallDev(const std::string& boot_dev, std::string* install_dev);
386
David Zeuthen910ec5b2013-09-26 12:10:58 -0700387// Checks if xattr is supported in the directory specified by
388// |dir_path| which must be writable. Returns true if the feature is
389// supported, false if not or if an error occured.
390bool IsXAttrSupported(const base::FilePath& dir_path);
391
David Zeuthene7f89172013-10-31 10:21:04 -0700392// Decodes the data in |base64_encoded| and stores it in a temporary
393// file. Returns false if the given data is empty, not well-formed
394// base64 or if an error occurred. If true is returned, the decoded
395// data is stored in the file returned in |out_path|. The file should
396// be deleted when no longer needed.
397bool DecodeAndStoreBase64String(const std::string& base64_encoded,
398 base::FilePath *out_path);
399
David Zeuthen639aa362014-02-03 16:23:44 -0800400// Converts |time| to an Omaha InstallDate which is defined as "the
401// number of PST8PDT calendar weeks since Jan 1st 2007 0:00 PST, times
402// seven" with PST8PDT defined as "Pacific Time" (e.g. UTC-07:00 if
403// daylight savings is observed and UTC-08:00 otherwise.)
404//
405// If the passed in |time| variable is before Monday January 1st 2007
406// 0:00 PST, False is returned and the value returned in
407// |out_num_days| is undefined. Otherwise the number of PST8PDT
408// calendar weeks since that date times seven is returned in
409// |out_num_days| and the function returns True.
410//
411// (NOTE: This function does not currently take daylight savings time
412// into account so the result may up to one hour off. This is because
413// the glibc date and timezone routines depend on the TZ environment
414// variable and changing environment variables is not thread-safe. An
415// alternative, thread-safe API to use would be GDateTime/GTimeZone
416// available in GLib 2.26 or later.)
417bool ConvertToOmahaInstallDate(base::Time time, int *out_num_days);
418
David Zeuthen33bae492014-02-25 16:16:18 -0800419// This function returns the duration on the wallclock since the last
420// time it was called for the same |state_variable_key| value.
421//
422// If the function returns |true|, the duration (always non-negative)
423// is returned in |out_duration|. If the function returns |false|
424// something went wrong or there was no previous measurement.
425bool WallclockDurationHelper(SystemState* system_state,
426 const std::string& state_variable_key,
427 base::TimeDelta* out_duration);
428
429// This function returns the duration on the monotonic clock since the
430// last time it was called for the same |storage| pointer.
431//
432// You should pass a pointer to a 64-bit integer in |storage| which
433// should be initialized to 0.
434//
435// If the function returns |true|, the duration (always non-negative)
436// is returned in |out_duration|. If the function returns |false|
437// something went wrong or there was no previous measurement.
438bool MonotonicDurationHelper(SystemState* system_state,
439 int64_t* storage,
440 base::TimeDelta* out_duration);
441
adlr@google.com3defe6a2009-12-04 20:57:17 +0000442} // namespace utils
443
Jay Srinivasan08fce042012-06-07 16:31:01 -0700444
adlr@google.com3defe6a2009-12-04 20:57:17 +0000445// Class to unmount FS when object goes out of scope
446class ScopedFilesystemUnmounter {
447 public:
448 explicit ScopedFilesystemUnmounter(const std::string& mountpoint)
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800449 : mountpoint_(mountpoint),
450 should_unmount_(true) {}
adlr@google.com3defe6a2009-12-04 20:57:17 +0000451 ~ScopedFilesystemUnmounter() {
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800452 if (should_unmount_) {
453 utils::UnmountFilesystem(mountpoint_);
454 }
adlr@google.com3defe6a2009-12-04 20:57:17 +0000455 }
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800456 void set_should_unmount(bool unmount) { should_unmount_ = unmount; }
adlr@google.com3defe6a2009-12-04 20:57:17 +0000457 private:
458 const std::string mountpoint_;
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800459 bool should_unmount_;
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700460 DISALLOW_COPY_AND_ASSIGN(ScopedFilesystemUnmounter);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000461};
462
463// Utility class to close a file descriptor
464class ScopedFdCloser {
465 public:
466 explicit ScopedFdCloser(int* fd) : fd_(fd), should_close_(true) {}
adlr@google.com3defe6a2009-12-04 20:57:17 +0000467 ~ScopedFdCloser() {
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800468 if (should_close_ && fd_ && (*fd_ >= 0)) {
Gilad Arnoldf9609112012-02-29 11:38:47 -0800469 if (!close(*fd_))
470 *fd_ = -1;
adlr@google.com3defe6a2009-12-04 20:57:17 +0000471 }
472 }
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800473 void set_should_close(bool should_close) { should_close_ = should_close; }
adlr@google.com3defe6a2009-12-04 20:57:17 +0000474 private:
475 int* fd_;
476 bool should_close_;
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700477 DISALLOW_COPY_AND_ASSIGN(ScopedFdCloser);
478};
479
Gilad Arnoldf9609112012-02-29 11:38:47 -0800480// An EINTR-immune file descriptor closer.
481class ScopedEintrSafeFdCloser {
482 public:
483 explicit ScopedEintrSafeFdCloser(int* fd) : fd_(fd), should_close_(true) {}
484 ~ScopedEintrSafeFdCloser() {
485 if (should_close_ && fd_ && (*fd_ >= 0)) {
Mike Frysingerbcee2ca2014-05-14 16:28:23 -0400486 if (!IGNORE_EINTR(close(*fd_)))
Gilad Arnoldf9609112012-02-29 11:38:47 -0800487 *fd_ = -1;
488 }
489 }
490 void set_should_close(bool should_close) { should_close_ = should_close; }
491 private:
492 int* fd_;
493 bool should_close_;
494 DISALLOW_COPY_AND_ASSIGN(ScopedEintrSafeFdCloser);
495};
496
Thieu Le5c7d9752010-12-15 16:09:28 -0800497// Utility class to close a file system
498class ScopedExt2fsCloser {
499 public:
500 explicit ScopedExt2fsCloser(ext2_filsys filsys) : filsys_(filsys) {}
501 ~ScopedExt2fsCloser() { ext2fs_close(filsys_); }
502
503 private:
504 ext2_filsys filsys_;
505 DISALLOW_COPY_AND_ASSIGN(ScopedExt2fsCloser);
506};
507
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700508// Utility class to delete a file when it goes out of scope.
509class ScopedPathUnlinker {
510 public:
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800511 explicit ScopedPathUnlinker(const std::string& path)
512 : path_(path),
513 should_remove_(true) {}
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700514 ~ScopedPathUnlinker() {
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800515 if (should_remove_ && unlink(path_.c_str()) < 0) {
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700516 std::string err_message = strerror(errno);
517 LOG(ERROR) << "Unable to unlink path " << path_ << ": " << err_message;
518 }
519 }
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800520 void set_should_remove(bool should_remove) { should_remove_ = should_remove; }
521
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700522 private:
523 const std::string path_;
Darin Petkov52dcaeb2011-01-14 15:33:06 -0800524 bool should_remove_;
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700525 DISALLOW_COPY_AND_ASSIGN(ScopedPathUnlinker);
526};
527
528// Utility class to delete an empty directory when it goes out of scope.
529class ScopedDirRemover {
530 public:
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800531 explicit ScopedDirRemover(const std::string& path)
532 : path_(path),
533 should_remove_(true) {}
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700534 ~ScopedDirRemover() {
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800535 if (should_remove_ && (rmdir(path_.c_str()) < 0)) {
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700536 PLOG(ERROR) << "Unable to remove dir " << path_;
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800537 }
538 }
539 void set_should_remove(bool should_remove) { should_remove_ = should_remove; }
540
541 protected:
542 const std::string path_;
543
544 private:
545 bool should_remove_;
546 DISALLOW_COPY_AND_ASSIGN(ScopedDirRemover);
547};
548
549// Utility class to unmount a filesystem mounted on a temporary directory and
550// delete the temporary directory when it goes out of scope.
551class ScopedTempUnmounter : public ScopedDirRemover {
552 public:
553 explicit ScopedTempUnmounter(const std::string& path) :
554 ScopedDirRemover(path) {}
555 ~ScopedTempUnmounter() {
556 utils::UnmountFilesystem(path_);
Andrew de los Reyes09e56d62010-04-23 13:45:53 -0700557 }
558 private:
Darin Petkov6f03a3b2010-11-10 14:27:14 -0800559 DISALLOW_COPY_AND_ASSIGN(ScopedTempUnmounter);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000560};
561
562// A little object to call ActionComplete on the ActionProcessor when
563// it's destructed.
564class ScopedActionCompleter {
565 public:
566 explicit ScopedActionCompleter(ActionProcessor* processor,
567 AbstractAction* action)
568 : processor_(processor),
569 action_(action),
David Zeuthena99981f2013-04-29 13:42:47 -0700570 code_(kErrorCodeError),
adlr@google.com3defe6a2009-12-04 20:57:17 +0000571 should_complete_(true) {}
572 ~ScopedActionCompleter() {
573 if (should_complete_)
Darin Petkovc1a8b422010-07-19 11:34:49 -0700574 processor_->ActionComplete(action_, code_);
adlr@google.com3defe6a2009-12-04 20:57:17 +0000575 }
David Zeuthena99981f2013-04-29 13:42:47 -0700576 void set_code(ErrorCode code) { code_ = code; }
adlr@google.com3defe6a2009-12-04 20:57:17 +0000577 void set_should_complete(bool should_complete) {
578 should_complete_ = should_complete;
579 }
David Zeuthen33bae492014-02-25 16:16:18 -0800580 ErrorCode get_code() const { return code_; }
Darin Petkovc1a8b422010-07-19 11:34:49 -0700581
adlr@google.com3defe6a2009-12-04 20:57:17 +0000582 private:
583 ActionProcessor* processor_;
584 AbstractAction* action_;
David Zeuthena99981f2013-04-29 13:42:47 -0700585 ErrorCode code_;
adlr@google.com3defe6a2009-12-04 20:57:17 +0000586 bool should_complete_;
587 DISALLOW_COPY_AND_ASSIGN(ScopedActionCompleter);
588};
589
David Zeuthen27a48bc2013-08-06 12:06:29 -0700590// A base::FreeDeleter that frees memory using g_free(). Useful when
591// integrating with GLib since it can be used with scoped_ptr to
592// automatically free memory when going out of scope.
593struct GLibFreeDeleter : public base::FreeDeleter {
594 inline void operator()(void *ptr) const {
595 g_free(reinterpret_cast<gpointer>(ptr));
596 }
597};
598
599// A base::FreeDeleter that frees memory using g_strfreev(). Useful
600// when integrating with GLib since it can be used with scoped_ptr to
601// automatically free memory when going out of scope.
602struct GLibStrvFreeDeleter : public base::FreeDeleter {
603 inline void operator()(void *ptr) const {
604 g_strfreev(reinterpret_cast<gchar**>(ptr));
605 }
606};
607
adlr@google.com3defe6a2009-12-04 20:57:17 +0000608} // namespace chromeos_update_engine
609
610#define TEST_AND_RETURN_FALSE_ERRNO(_x) \
611 do { \
612 bool _success = (_x); \
613 if (!_success) { \
614 std::string _msg = \
615 chromeos_update_engine::utils::ErrnoNumberAsString(errno); \
616 LOG(ERROR) << #_x " failed: " << _msg; \
617 return false; \
618 } \
619 } while (0)
620
621#define TEST_AND_RETURN_FALSE(_x) \
622 do { \
623 bool _success = (_x); \
624 if (!_success) { \
625 LOG(ERROR) << #_x " failed."; \
626 return false; \
627 } \
628 } while (0)
629
630#define TEST_AND_RETURN_ERRNO(_x) \
631 do { \
632 bool _success = (_x); \
633 if (!_success) { \
634 std::string _msg = \
635 chromeos_update_engine::utils::ErrnoNumberAsString(errno); \
636 LOG(ERROR) << #_x " failed: " << _msg; \
637 return; \
638 } \
639 } while (0)
640
641#define TEST_AND_RETURN(_x) \
642 do { \
643 bool _success = (_x); \
644 if (!_success) { \
645 LOG(ERROR) << #_x " failed."; \
646 return; \
647 } \
648 } while (0)
649
Thieu Le5c7d9752010-12-15 16:09:28 -0800650#define TEST_AND_RETURN_FALSE_ERRCODE(_x) \
651 do { \
652 errcode_t _error = (_x); \
653 if (_error) { \
654 errno = _error; \
655 LOG(ERROR) << #_x " failed: " << _error; \
656 return false; \
657 } \
658 } while (0)
659
adlr@google.com3defe6a2009-12-04 20:57:17 +0000660
661
Alex Deymo759c2752014-03-17 21:09:36 -0700662#endif // CHROMEOS_PLATFORM_UPDATE_ENGINE_UTILS_H_