Support/FileSystem: Add create_hard_link implementation.
[oota-llvm.git] / lib / Support / Unix / PathV2.inc
1 //===- llvm/Support/Unix/PathV2.cpp - Unix Path Implementation --*- C++ -*-===//
2 //
3 //                     The LLVM Compiler Infrastructure
4 //
5 // This file is distributed under the University of Illinois Open Source
6 // License. See LICENSE.TXT for details.
7 //
8 //===----------------------------------------------------------------------===//
9 //
10 // This file implements the Unix specific implementation of the PathV2 API.
11 //
12 //===----------------------------------------------------------------------===//
13
14 //===----------------------------------------------------------------------===//
15 //=== WARNING: Implementation here must contain only generic UNIX code that
16 //===          is guaranteed to work on *all* UNIX variants.
17 //===----------------------------------------------------------------------===//
18
19 #include "Unix.h"
20 #if HAVE_SYS_STAT_H
21 #include <sys/stat.h>
22 #endif
23 #if HAVE_FCNTL_H
24 #include <fcntl.h>
25 #endif
26 #if HAVE_STDIO_H
27 #include <stdio.h>
28 #endif
29
30 using namespace llvm;
31
32 namespace {
33   struct AutoFD {
34     int FileDescriptor;
35
36     AutoFD(int fd) : FileDescriptor(fd) {}
37     ~AutoFD() {
38       if (FileDescriptor >= 0)
39         ::close(FileDescriptor);
40     }
41
42     int take() {
43       int ret = FileDescriptor;
44       FileDescriptor = -1;
45       return ret;
46     }
47
48     operator int() const {return FileDescriptor;}
49   };
50
51   error_code TempDir(SmallVectorImpl<char> &result) {
52     // FIXME: Don't use TMPDIR if program is SUID or SGID enabled.
53     const char *dir = 0;
54     (dir = std::getenv("TMPDIR" )) ||
55     (dir = std::getenv("TMP"    )) ||
56     (dir = std::getenv("TEMP"   )) ||
57     (dir = std::getenv("TEMPDIR")) ||
58 #ifdef P_tmpdir
59     (dir = P_tmpdir) ||
60 #endif
61     (dir = "/tmp");
62
63     result.set_size(0);
64     StringRef d(dir);
65     result.append(d.begin(), d.end());
66     return make_error_code(errc::success);
67   }
68 }
69
70 namespace llvm {
71 namespace sys  {
72 namespace path {
73
74 error_code current_path(SmallVectorImpl<char> &result) {
75   long size = ::pathconf(".", _PC_PATH_MAX);
76   result.reserve(size + 1);
77   result.set_size(size + 1);
78
79   if (::getcwd(result.data(), result.size()) == 0)
80     return error_code(errno, system_category());
81
82   result.set_size(strlen(result.data()));
83   return make_error_code(errc::success);
84 }
85
86 } // end namespace path
87
88 namespace fs{
89
90 error_code copy_file(const Twine &from, const Twine &to, copy_option copt) {
91  // Get arguments.
92   SmallString<128> from_storage;
93   SmallString<128> to_storage;
94   StringRef f = from.toNullTerminatedStringRef(from_storage);
95   StringRef t = to.toNullTerminatedStringRef(to_storage);
96
97   const size_t buf_sz = 32768;
98   char buffer[buf_sz];
99   int from_file = -1, to_file = -1;
100
101   // Open from.
102   if ((from_file = ::open(f.begin(), O_RDONLY)) < 0)
103     return error_code(errno, system_category());
104   AutoFD from_fd(from_file);
105
106   // Stat from.
107   struct stat from_stat;
108   if (::stat(f.begin(), &from_stat) != 0)
109     return error_code(errno, system_category());
110
111   // Setup to flags.
112   int to_flags = O_CREAT | O_WRONLY;
113   if (copt == copy_option::fail_if_exists)
114     to_flags |= O_EXCL;
115
116   // Open to.
117   if ((to_file = ::open(t.begin(), to_flags, from_stat.st_mode)) < 0)
118     return error_code(errno, system_category());
119   AutoFD to_fd(to_file);
120
121   // Copy!
122   ssize_t sz, sz_read = 1, sz_write;
123   while (sz_read > 0 &&
124          (sz_read = ::read(from_fd, buffer, buf_sz)) > 0) {
125     // Allow for partial writes - see Advanced Unix Programming (2nd Ed.),
126     // Marc Rochkind, Addison-Wesley, 2004, page 94
127     sz_write = 0;
128     do {
129       if ((sz = ::write(to_fd, buffer + sz_write, sz_read - sz_write)) < 0) {
130         sz_read = sz;  // cause read loop termination.
131         break;         // error.
132       }
133       sz_write += sz;
134     } while (sz_write < sz_read);
135   }
136
137   // After all the file operations above the return value of close actually
138   // matters.
139   if (::close(from_fd.take()) < 0) sz_read = -1;
140   if (::close(to_fd.take()) < 0) sz_read = -1;
141
142   // Check for errors.
143   if (sz_read < 0)
144     return error_code(errno, system_category());
145
146   return make_error_code(errc::success);
147 }
148
149 error_code create_directory(const Twine &path, bool &existed) {
150   SmallString<128> path_storage;
151   StringRef p = path.toNullTerminatedStringRef(path_storage);
152
153   if (::mkdir(p.begin(), 0700) == -1) {
154     if (errno != EEXIST)
155       return error_code(errno, system_category());
156     existed = true;
157   } else
158     existed = false;
159
160   return make_error_code(errc::success);
161 }
162
163 error_code create_hard_link(const Twine &to, const Twine &from) {
164   // Get arguments.
165   SmallString<128> from_storage;
166   SmallString<128> to_storage;
167   StringRef f = from.toNullTerminatedStringRef(from_storage);
168   StringRef t = to.toNullTerminatedStringRef(to_storage);
169
170   if (::link(t.begin(), f.begin()) == -1)
171     return error_code(errno, system_category());
172
173   return make_error_code(errc::success);
174 }
175
176 error_code exists(const Twine &path, bool &result) {
177   SmallString<128> path_storage;
178   StringRef p = path.toNullTerminatedStringRef(path_storage);
179
180   struct stat status;
181   if (::stat(p.begin(), &status) == -1) {
182     if (errno != ENOENT)
183       return error_code(errno, system_category());
184     result = false;
185   } else
186     result = true;
187
188   return make_error_code(errc::success);
189 }
190
191 error_code unique_file(const Twine &model, int &result_fd,
192                              SmallVectorImpl<char> &result_path) {
193   SmallString<128> Model;
194   model.toVector(Model);
195   // Null terminate.
196   Model.c_str();
197
198   // Make model absolute by prepending a temp directory if it's not already.
199   bool absolute;
200   if (error_code ec = path::is_absolute(Twine(Model), absolute)) return ec;
201   if (!absolute) {
202     SmallString<128> TDir;
203     if (error_code ec = TempDir(TDir)) return ec;
204     if (error_code ec = path::append(TDir, Twine(Model))) return ec;
205     Model.swap(TDir);
206   }
207
208   // Replace '%' with random chars. From here on, DO NOT modify model. It may be
209   // needed if the randomly chosen path already exists.
210   SmallString<128> RandomPath;
211   RandomPath.reserve(Model.size() + 1);
212   ::srand(::time(NULL));
213
214 retry_random_path:
215   // This is opened here instead of above to make it easier to track when to
216   // close it. Collisions should be rare enough for the possible extra syscalls
217   // not to matter.
218   FILE *RandomSource = ::fopen("/dev/urandom", "r");
219   RandomPath.set_size(0);
220   for (SmallVectorImpl<char>::const_iterator i = Model.begin(),
221                                              e = Model.end(); i != e; ++i) {
222     if (*i == '%') {
223       char val = 0;
224       if (RandomSource)
225         val = fgetc(RandomSource);
226       else
227         val = ::rand();
228       RandomPath.push_back("0123456789abcdef"[val & 15]);
229     } else
230       RandomPath.push_back(*i);
231   }
232
233   if (RandomSource)
234     ::fclose(RandomSource);
235
236   // Try to open + create the file.
237 rety_open_create:
238   int RandomFD = ::open(RandomPath.c_str(), O_RDWR | O_CREAT | O_EXCL, 0600);
239   if (RandomFD == -1) {
240     // If the file existed, try again, otherwise, error.
241     if (errno == EEXIST)
242       goto retry_random_path;
243     // The path prefix doesn't exist.
244     if (errno == ENOENT) {
245       StringRef p(RandomPath.begin(), RandomPath.size());
246       SmallString<64> dir_to_create;
247       for (path::const_iterator i = path::begin(p),
248                                 e = --path::end(p); i != e; ++i) {
249         if (error_code ec = path::append(dir_to_create, *i)) return ec;
250         bool Exists;
251         if (error_code ec = exists(Twine(dir_to_create), Exists)) return ec;
252         if (!Exists) {
253           // Don't try to create network paths.
254           if (i->size() > 2 && (*i)[0] == '/' &&
255                                (*i)[1] == '/' &&
256                                (*i)[2] != '/')
257             return error_code(ENOENT, system_category());
258           if (::mkdir(dir_to_create.c_str(), 0700) == -1)
259             return error_code(errno, system_category());
260         }
261       }
262       goto rety_open_create;
263     }
264     return error_code(errno, system_category());
265   }
266
267     // Make the path absolute.
268   char real_path_buff[PATH_MAX + 1];
269   if (realpath(RandomPath.c_str(), real_path_buff) == NULL) {
270     ::close(RandomFD);
271     ::unlink(RandomPath.c_str());
272     return error_code(errno, system_category());
273   }
274
275   result_path.set_size(0);
276   StringRef d(real_path_buff);
277   result_path.append(d.begin(), d.end());
278
279   result_fd = RandomFD;
280   return make_error_code(errc::success);
281 }
282
283 } // end namespace fs
284 } // end namespace sys
285 } // end namespace llvm