CernVM-FS  2.10.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
posix.h
Go to the documentation of this file.
1 
5 #ifndef CVMFS_UTIL_POSIX_H_
6 #define CVMFS_UTIL_POSIX_H_
7 
8 #include <pthread.h>
9 #include <sys/stat.h>
10 #include <sys/types.h>
11 #include <sys/uio.h>
12 #include <unistd.h>
13 
14 #include <cassert>
15 #include <cerrno>
16 #include <cstddef>
17 #include <map>
18 #include <set>
19 #include <string>
20 #include <vector>
21 
22 #include "util/export.h"
23 #include "util/pointer.h"
24 #include "util/single_copy.h"
25 
26 #ifdef CVMFS_NAMESPACE_GUARD
27 namespace CVMFS_NAMESPACE_GUARD {
28 #endif
29 
30 const unsigned kPageSize = 4096;
31 const size_t kMaxPathLength = 256;
32 const int kDefaultFileMode = S_IWUSR | S_IRUSR | S_IRGRP | S_IROTH;
33 const int kDefaultDirMode = S_IXUSR | S_IWUSR | S_IRUSR |
34  S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH;
35 const int kPrivateFileMode = S_IWUSR | S_IRUSR;
36 const int kPrivateDirMode = S_IXUSR | S_IWUSR | S_IRUSR;
37 
44  kFsTypeAutofs = 0x0187,
45  kFsTypeNFS = 0x6969,
46  kFsTypeProc = 0x9fa0,
47  kFsTypeBeeGFS = 0x19830326
48 };
49 
51  FileSystemInfo() : type(kFsTypeUnknown), is_rdonly(false) {}
53  bool is_rdonly;
54 };
55 
57  pid_t pid;
58  uid_t owner;
59  bool read_only;
60  std::string executable;
61  std::string path;
62 
63  LsofEntry() : pid(0), owner(0), read_only(false) {}
64 };
65 
66 CVMFS_EXPORT std::string MakeCanonicalPath(const std::string &path);
67 CVMFS_EXPORT std::string GetParentPath(const std::string &path);
68 CVMFS_EXPORT std::string GetFileName(const std::string &path);
69 CVMFS_EXPORT void SplitPath(const std::string &path,
70  std::string *dirname,
71  std::string *filename);
72 CVMFS_EXPORT bool IsAbsolutePath(const std::string &path);
73 CVMFS_EXPORT std::string GetAbsolutePath(const std::string &path);
74 CVMFS_EXPORT bool IsHttpUrl(const std::string &path);
75 
76 CVMFS_EXPORT std::string ReadSymlink(const std::string &path);
77 CVMFS_EXPORT std::string ResolvePath(const std::string &path);
78 CVMFS_EXPORT bool IsMountPoint(const std::string &path);
79 CVMFS_EXPORT FileSystemInfo GetFileSystemInfo(const std::string &path);
80 
81 CVMFS_EXPORT void CreateFile(const std::string &path, const int mode,
82  const bool ignore_failure = false);
83 CVMFS_EXPORT int MakeSocket(const std::string &path, const int mode);
84 CVMFS_EXPORT int MakeTcpEndpoint(const std::string &ipv4_address, int portno);
85 CVMFS_EXPORT int ConnectSocket(const std::string &path);
86 CVMFS_EXPORT int ConnectTcpEndpoint(const std::string &ipv4_address,
87  int portno);
88 CVMFS_EXPORT void MakePipe(int pipe_fd[2]);
89 CVMFS_EXPORT void WritePipe(int fd, const void *buf, size_t nbyte);
90 CVMFS_EXPORT void ReadPipe(int fd, void *buf, size_t nbyte);
91 CVMFS_EXPORT void ReadHalfPipe(int fd, void *buf, size_t nbyte);
92 CVMFS_EXPORT void ClosePipe(int pipe_fd[2]);
93 CVMFS_EXPORT bool DiffTree(const std::string &path_a,
94  const std::string &path_b);
95 
96 CVMFS_EXPORT void Nonblock2Block(int filedes);
97 CVMFS_EXPORT void Block2Nonblock(int filedes);
98 CVMFS_EXPORT void SendMsg2Socket(const int fd, const std::string &msg);
99 CVMFS_EXPORT bool SendFd2Socket(int socket_fd, int passing_fd);
100 CVMFS_EXPORT int RecvFdFromSocket(int msg_fd);
101 
102 CVMFS_EXPORT bool SwitchCredentials(const uid_t uid, const gid_t gid,
103  const bool temporarily);
104 
105 CVMFS_EXPORT bool FileExists(const std::string &path);
106 CVMFS_EXPORT int64_t GetFileSize(const std::string &path);
107 CVMFS_EXPORT bool DirectoryExists(const std::string &path);
108 CVMFS_EXPORT bool SymlinkExists(const std::string &path);
109 CVMFS_EXPORT bool SymlinkForced(const std::string &src,
110  const std::string &dest);
111 CVMFS_EXPORT bool MkdirDeep(const std::string &path, const mode_t mode,
112  bool verify_writable = true);
113 CVMFS_EXPORT bool MakeCacheDirectories(const std::string &path,
114  const mode_t mode);
115 CVMFS_EXPORT FILE *CreateTempFile(const std::string &path_prefix,
116  const int mode,
117  const char *open_flags,
118  std::string *final_path);
119 CVMFS_EXPORT std::string CreateTempPath(const std::string &path_prefix,
120  const int mode);
121 CVMFS_EXPORT std::string CreateTempDir(const std::string &path_prefix);
123 CVMFS_EXPORT int TryLockFile(const std::string &path);
124 CVMFS_EXPORT int LockFile(const std::string &path);
125 CVMFS_EXPORT int WritePidFile(const std::string &path);
126 CVMFS_EXPORT void UnlockFile(const int filedes);
127 CVMFS_EXPORT bool RemoveTree(const std::string &path);
129 std::vector<std::string> FindFilesBySuffix(const std::string &dir,
130  const std::string &suffix);
132 std::vector<std::string> FindFilesByPrefix(const std::string &dir,
133  const std::string &prefix);
135 std::vector<std::string> FindDirectories(const std::string &parent_dir);
136 CVMFS_EXPORT std::string FindExecutable(const std::string &exe);
137 CVMFS_EXPORT bool ListDirectory(const std::string &directory,
138  std::vector<std::string> *names,
139  std::vector<mode_t> *modes);
140 
141 CVMFS_EXPORT std::string GetUserName();
142 CVMFS_EXPORT std::string GetShell();
143 CVMFS_EXPORT bool GetUserNameOf(uid_t uid, std::string *username);
144 CVMFS_EXPORT bool GetUidOf(const std::string &username,
145  uid_t *uid,
146  gid_t *main_gid);
147 CVMFS_EXPORT bool GetGidOf(const std::string &groupname, gid_t *gid);
148 CVMFS_EXPORT mode_t GetUmask();
149 CVMFS_EXPORT bool AddGroup2Persona(const gid_t gid);
150 CVMFS_EXPORT std::string GetHomeDirectory();
151 
152 CVMFS_EXPORT int SetLimitNoFile(unsigned limit_nofile);
153 CVMFS_EXPORT void GetLimitNoFile(unsigned *soft_limit, unsigned *hard_limit);
154 
159 CVMFS_EXPORT std::vector<LsofEntry> Lsof(const std::string &path);
160 
161 CVMFS_EXPORT bool ProcessExists(pid_t pid);
162 CVMFS_EXPORT void BlockSignal(int signum);
163 CVMFS_EXPORT void WaitForSignal(int signum);
165 int WaitForChild(pid_t pid,
166  const std::vector<int> &sig_ok = std::vector<int>());
167 CVMFS_EXPORT void Daemonize();
168 CVMFS_EXPORT bool Shell(int *pipe_stdin, int *pipe_stdout, int *pipe_stderr);
169 CVMFS_EXPORT bool ExecuteBinary(int *fd_stdin,
170  int *fd_stdout,
171  int *fd_stderr,
172  const std::string &binary_path,
173  const std::vector<std::string> &argv,
174  const bool double_fork = true,
175  pid_t *child_pid = NULL);
176 CVMFS_EXPORT bool ManagedExec(const std::vector<std::string> &command_line,
177  const std::set<int> &preserve_fildes,
178  const std::map<int, int> &map_fildes,
179  const bool drop_credentials,
180  const bool clear_env = false,
181  const bool double_fork = true,
182  pid_t *child_pid = NULL);
183 
184 CVMFS_EXPORT void SafeSleepMs(const unsigned ms);
185 // Note that SafeWrite cannot return partial results but
186 // SafeRead can (as we may have hit the EOF).
187 CVMFS_EXPORT ssize_t SafeRead(int fd, void *buf, size_t nbyte);
188 CVMFS_EXPORT bool SafeWrite(int fd, const void *buf, size_t nbyte);
189 CVMFS_EXPORT bool SafeWriteV(int fd, struct iovec *iov, unsigned iovcnt);
190 
191 // Read the contents of a file descriptor to a string.
192 CVMFS_EXPORT bool SafeReadToString(int fd, std::string *final_result);
193 CVMFS_EXPORT bool SafeWriteToFile(const std::string &content,
194  const std::string &path, int mode);
195 
196 struct CVMFS_EXPORT Pipe : public SingleCopy {
197  Pipe() {
198  int pipe_fd[2];
199  MakePipe(pipe_fd);
200  read_end = pipe_fd[0];
201  write_end = pipe_fd[1];
202  }
203 
204  Pipe(const int fd_read, const int fd_write) :
205  read_end(fd_read), write_end(fd_write) {}
206 
207  void Close() {
208  close(read_end);
209  close(write_end);
210  }
211 
212  template<typename T>
213  bool Write(const T &data) {
214  assert(!IsPointer<T>::value); // TODO(rmeusel): C++11 static_assert
215  const int num_bytes = write(write_end, &data, sizeof(T));
216  return (num_bytes >= 0) && (static_cast<size_t>(num_bytes) == sizeof(T));
217  }
218 
219  template<typename T>
220  bool TryRead(T *data) {
221  assert(!IsPointer<T>::value); // TODO(rmeusel): C++11 static_assert
222  ssize_t num_bytes;
223  do {
224  num_bytes = read(read_end, data, sizeof(T));
225  } while ((num_bytes < 0) && (errno == EINTR));
226  return (num_bytes >= 0) && (static_cast<size_t>(num_bytes) == sizeof(T));
227  }
228 
229  template<typename T>
230  void Read(T *data) {
231  assert(!IsPointer<T>::value); // TODO(rmeusel): C++11 static_assert
232  ReadPipe(read_end, data, sizeof(T));
233  }
234 
235  bool Write(const void *buf, size_t nbyte) {
236  WritePipe(write_end, buf, nbyte);
237  return true;
238  }
239 
240  bool Read(void *buf, size_t nbyte) {
241  ReadPipe(read_end, buf, nbyte);
242  return true;
243  }
244 
245  int read_end;
247 };
248 
249 
250 #ifdef CVMFS_NAMESPACE_GUARD
251 } // namespace CVMFS_NAMESPACE_GUARD
252 #endif
253 
254 #endif // CVMFS_UTIL_POSIX_H_
bool MakeCacheDirectories(const std::string &path, const mode_t mode)
Definition: posix.cc:869
mode_t GetUmask()
Definition: posix.cc:1377
uid_t owner
Definition: posix.h:58
int MakeSocket(const std::string &path, const int mode)
Definition: posix.cc:326
bool SymlinkForced(const std::string &src, const std::string &dest)
Definition: posix.cc:820
bool Write(const void *buf, size_t nbyte)
Definition: posix.h:235
NameString GetFileName(const PathString &path)
Definition: shortstring.cc:29
const int kPrivateDirMode
Definition: posix.h:36
int MakeTcpEndpoint(const std::string &ipv4_address, int portno)
Definition: posix.cc:384
std::string GetUserName()
Definition: posix.cc:1269
const int kDefaultFileMode
Definition: posix.h:32
void CreateFile(const std::string &path, const int mode, const bool ignore_failure)
Definition: posix.cc:275
bool GetUserNameOf(uid_t uid, std::string *username)
Definition: posix.cc:1308
FILE * CreateTempFile(const std::string &path_prefix, const int mode, const char *open_flags, std::string *final_path)
Definition: posix.cc:992
Pipe(const int fd_read, const int fd_write)
Definition: posix.h:204
int ConnectTcpEndpoint(const std::string &ipv4_address, int portno)
Definition: posix.cc:456
EFileSystemTypes type
Definition: posix.h:52
bool Shell(int *fd_stdin, int *fd_stdout, int *fd_stderr)
Definition: posix.cc:1691
int read_end
Definition: posix.h:245
bool IsHttpUrl(const std::string &path)
Definition: posix.cc:166
bool ManagedExec(const std::vector< std::string > &command_line, const std::set< int > &preserve_fildes, const std::map< int, int > &map_fildes, const bool drop_credentials, const bool clear_env, const bool double_fork, pid_t *child_pid)
Definition: posix.cc:1746
void Daemonize()
Definition: posix.cc:1604
std::string CreateTempPath(const std::string &path_prefix, const int mode)
Definition: posix.cc:1021
#define CVMFS_EXPORT
Definition: export.h:11
bool SafeWrite(int fd, const void *buf, size_t nbyte)
Definition: posix.cc:1890
void SendMsg2Socket(const int fd, const std::string &msg)
Definition: posix.cc:654
assert((mem||(size==0))&&"Out Of Memory")
bool SafeWriteToFile(const std::string &content, const std::string &path, int mode)
Definition: posix.cc:1988
std::string FindExecutable(const std::string &exe)
Definition: posix.cc:1231
bool SendFd2Socket(int socket_fd, int passing_fd)
Definition: posix.cc:663
bool TryRead(T *data)
Definition: posix.h:220
int WaitForChild(pid_t pid, const std::vector< int > &sig_ok)
Definition: posix.cc:1579
bool Write(const T &data)
Definition: posix.h:213
bool AddGroup2Persona(const gid_t gid)
Definition: posix.cc:1388
void Close()
Definition: posix.h:207
void MakePipe(int pipe_fd[2])
Definition: posix.cc:487
std::vector< std::string > FindDirectories(const std::string &parent_dir)
Definition: posix.cc:1166
FileSystemInfo()
Definition: posix.h:51
bool is_rdonly
Definition: posix.h:53
int SetLimitNoFile(unsigned limit_nofile)
Definition: posix.cc:1435
std::string path
Definition: posix.h:61
bool SymlinkExists(const std::string &path)
Definition: posix.cc:810
bool FileExists(const std::string &path)
Definition: posix.cc:778
const int kPrivateFileMode
Definition: posix.h:35
std::string GetAbsolutePath(const std::string &path)
Definition: posix.cc:158
void SplitPath(const std::string &path, std::string *dirname, std::string *filename)
Definition: posix.cc:111
void GetLimitNoFile(unsigned *soft_limit, unsigned *hard_limit)
Definition: posix.cc:1457
std::string executable
Definition: posix.h:60
int write_end
Definition: posix.h:246
void ReadHalfPipe(int fd, void *buf, size_t nbyte)
Definition: posix.cc:520
ssize_t SafeRead(int fd, void *buf, size_t nbyte)
Definition: posix.cc:1949
const int kDefaultDirMode
Definition: posix.h:33
FileSystemInfo GetFileSystemInfo(const std::string &path)
Definition: posix.cc:178
void Nonblock2Block(int filedes)
Definition: posix.cc:631
bool Read(void *buf, size_t nbyte)
Definition: posix.h:240
bool read_only
Definition: posix.h:59
int TryLockFile(const std::string &path)
Definition: posix.cc:900
bool MkdirDeep(const std::string &path, const mode_t mode, bool verify_writable)
Definition: posix.cc:833
int LockFile(const std::string &path)
Definition: posix.cc:958
string ResolvePath(const std::string &path)
std::string GetHomeDirectory()
Definition: posix.cc:1411
void Read(T *data)
Definition: posix.h:230
void WaitForSignal(int signum)
Definition: posix.cc:1565
std::string GetShell()
Definition: posix.cc:1287
LsofEntry()
Definition: posix.h:63
pid_t pid
Definition: posix.h:57
bool GetGidOf(const std::string &groupname, gid_t *gid)
Definition: posix.cc:1354
std::string CreateTempDir(const std::string &path_prefix)
Definition: posix.cc:1034
bool DirectoryExists(const std::string &path)
Definition: posix.cc:800
bool ExecuteBinary(int *fd_stdin, int *fd_stdout, int *fd_stderr, const std::string &binary_path, const std::vector< std::string > &argv, const bool double_fork, pid_t *child_pid)
Definition: posix.cc:1635
bool RemoveTree(const std::string &path)
Definition: posix.cc:1082
bool SafeReadToString(int fd, std::string *final_result)
Definition: posix.cc:1972
int WritePidFile(const std::string &path)
Definition: posix.cc:922
int ConnectSocket(const std::string &path)
Definition: posix.cc:422
Definition: posix.h:196
const unsigned kPageSize
Definition: posix.h:30
bool GetUidOf(const std::string &username, uid_t *uid, gid_t *main_gid)
Definition: posix.cc:1331
std::vector< std::string > FindFilesByPrefix(const std::string &dir, const std::string &prefix)
Definition: posix.cc:1138
bool SwitchCredentials(const uid_t uid, const gid_t gid, const bool temporarily)
Definition: posix.cc:748
std::string ReadSymlink(const std::string &path)
Definition: posix.cc:218
PathString GetParentPath(const PathString &path)
Definition: shortstring.cc:15
std::vector< LsofEntry > Lsof(const std::string &path)
Definition: posix.cc:1476
EFileSystemTypes
Definition: posix.h:42
bool ListDirectory(const std::string &directory, std::vector< std::string > *names, std::vector< mode_t > *modes)
Definition: posix.cc:1195
Definition: posix.h:56
int64_t GetFileSize(const std::string &path)
Definition: posix.cc:788
Pipe()
Definition: posix.h:197
void SafeSleepMs(const unsigned ms)
Definition: posix.cc:1879
bool DiffTree(const std::string &path_a, const std::string &path_b)
Definition: posix.cc:556
void Block2Nonblock(int filedes)
Definition: posix.cc:642
bool IsAbsolutePath(const std::string &path)
Definition: posix.cc:153
bool ProcessExists(pid_t pid)
Definition: posix.cc:1538
std::string MakeCanonicalPath(const std::string &path)
Definition: posix.cc:96
void WritePipe(int fd, const void *buf, size_t nbyte)
Definition: posix.cc:496
std::string GetCurrentWorkingDirectory()
Definition: posix.cc:1047
void ReadPipe(int fd, void *buf, size_t nbyte)
Definition: posix.cc:508
std::vector< std::string > FindFilesBySuffix(const std::string &dir, const std::string &suffix)
Definition: posix.cc:1111
void ClosePipe(int pipe_fd[2])
Definition: posix.cc:546
bool IsMountPoint(const std::string &path)
Definition: posix.cc:261
int RecvFdFromSocket(int msg_fd)
Definition: posix.cc:703
const size_t kMaxPathLength
Definition: posix.h:31
bool SafeWriteV(int fd, struct iovec *iov, unsigned iovcnt)
Definition: posix.cc:1908
void UnlockFile(const int filedes)
Definition: posix.cc:982
void BlockSignal(int signum)
Definition: posix.cc:1550