"\n%%% $Id$\n";
#endif
+#if defined(WIN32) && !defined (_CYGWIN_)
#include "win32.h"
-#include <stdio.h>
-#include <stdlib.h>
-#include <unistd.h>
-#include "log.h"
#include "port.h"
#include "mklink2.h"
+#endif
-#include "io_stream.h"
+#include "mkdir.h"
+
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <errno.h>
+#include <unistd.h>
+#if HAVE_SYS_STAT_H
+#include <sys/stat.h>
+#endif
+#include <stdexcept>
+
#include "io_stream_file.h"
+#include "IOStreamProvider.h"
+
+
+/* completely private iostream registration class */
+class FileProvider : public IOStreamProvider
+{
+public:
+ int exists (String const &path) const
+ {return io_stream_file::exists(path);}
+ int remove (String const &path) const
+ {return io_stream_file::remove(path);}
+ int mklink (String const &a , String const &b, io_stream_link_t c) const
+ {return io_stream_file::mklink(a,b,c);}
+ io_stream *open (String const &a,String const &b) const
+ {return new io_stream_file (a, b);}
+ ~FileProvider (){}
+ int move (String const &a,String const &b) const
+ {return io_stream_file::move (a, b);}
+ int mkdir_p (enum path_type_t isadir, String const &path) const
+ {
+ return ::mkdir_p (isadir == PATH_TO_DIR ? 1 : 0, path.cstr_oneuse());
+ }
+protected:
+ FileProvider() // no creating this
+ {
+ io_stream::registerProvider (theInstance, "file://");
+ }
+ FileProvider(FileProvider const &); // no copying
+ FileProvider &operator=(FileProvider const &); // no assignment
+private:
+ static FileProvider theInstance;
+};
+FileProvider FileProvider::theInstance = FileProvider();
+
/* for set_mtime */
#define FACTOR (0x19db1ded53ea710LL)
#define NSPERSEC 10000000LL
-io_stream_file::io_stream_file (const char *name, const char *mode)
+io_stream_file::io_stream_file (String const &name, String const &mode):
+fp(), fname(name),lmode (mode)
{
- fname = NULL;
- fp = NULL;
errno = 0;
- if (!name || IsBadStringPtr (name, MAX_PATH) || !name[0] ||
- !mode || IsBadStringPtr (mode, 5) || !mode[0])
+ if (!name.size() || !mode.size())
return;
- lmode = strdup (mode);
- fname = strdup (name);
- fp = fopen (name, mode);
+ fp = fopen (name.cstr_oneuse(), mode.cstr_oneuse());
if (!fp)
lasterr = errno;
}
io_stream_file::~io_stream_file ()
{
- if (fname)
- free (fname);
if (fp)
fclose (fp);
+ destroyed = 1;
}
int
-io_stream_file::exists (const char *path)
+io_stream_file::exists (String const &path)
{
- if (_access (path, 0) == 0)
+#if defined(WIN32) && !defined (_CYGWIN_)
+ if (_access (path.cstr_oneuse(), 0) == 0)
+#else
+ if (access (path.cstr_oneuse(), F_OK) == 0)
+#endif
return 1;
return 0;
}
int
-io_stream_file::remove (const char *path)
+io_stream_file::remove (String const &path)
{
- if (!path)
+ if (!path.size())
return 1;
-
- unsigned long w = GetFileAttributes (path);
+#if defined(WIN32) && !defined (_CYGWIN_)
+ unsigned long w = GetFileAttributes (path.cstr_oneuse());
if (w != 0xffffffff && w & FILE_ATTRIBUTE_DIRECTORY)
{
- char *tmp = (char *) malloc (strlen (path) + 10);
+ char *tmp = new char [path.size() + 10];
int i = 0;
do
{
i++;
- sprintf (tmp, "%s.old-%d", path, i);
+ sprintf (tmp, "%s.old-%d", path.cstr_oneuse(), i);
}
while (GetFileAttributes (tmp) != 0xffffffff);
fprintf (stderr, "warning: moving directory \"%s\" out of the way.\n",
- path);
- MoveFile (path, tmp);
- free (tmp);
+ path.cstr_oneuse());
+ MoveFile (path.cstr_oneuse(), tmp);
+ delete[] tmp;
}
- return !DeleteFileA (path);
-
+ SetFileAttributes (path.cstr_oneuse(), w & ~FILE_ATTRIBUTE_READONLY);
+ return !DeleteFileA (path.cstr_oneuse());
+#else
+ // FIXME: try rmdir if unlink fails - remove the dir
+ return unlink (path.cstr_oneuse());
+#endif
}
int
-io_stream_file::mklink (const char *from, const char *to,
+io_stream_file::mklink (String const &from, String const &to,
io_stream_link_t linktype)
{
- /* FIXME: badstring check */
- if (!from || !to)
+ if (!from.size() || !to.size())
return 1;
+#if defined(WIN32) && !defined (_CYGWIN_)
switch (linktype)
{
case IO_STREAM_SYMLINK:
- return mkcygsymlink (from, to);
+ return mkcygsymlink (from.cstr_oneuse(), to.cstr_oneuse());
case IO_STREAM_HARDLINK:
return 1;
}
+#else
+ switch (linktype)
+ {
+ case IO_STREAM_SYMLINK:
+ return symlink (to.cstr_oneuse(), from.cstr_oneuse());
+ case IO_STREAM_HARDLINK:
+ return link (to.cstr_oneuse(), from.cstr_oneuse());
+ }
+#endif
return 1;
}
/* virtuals */
-ssize_t io_stream_file::read (void *buffer, size_t len)
+ssize_t
+io_stream_file::read (void *buffer, size_t len)
{
if (fp)
return fread (buffer, 1, len, fp);
return 0;
}
-ssize_t io_stream_file::write (void *buffer, size_t len)
+ssize_t
+io_stream_file::write (const void *buffer, size_t len)
{
if (fp)
return fwrite (buffer, 1, len, fp);
return 0;
}
-ssize_t io_stream_file::peek (void *buffer, size_t len)
+ssize_t
+io_stream_file::peek (void *buffer, size_t len)
{
- log (LOG_TIMESTAMP, "io_stream_file::peek called");
if (fp)
{
- int
- pos = ftell (fp);
- ssize_t
- rv = fread (buffer, 1, len, fp);
+ int pos = ftell (fp);
+ ssize_t rv = fread (buffer, 1, len, fp);
fseek (fp, pos, SEEK_SET);
return rv;
}
return 0;
}
+int
+io_stream_file::seek (long where, io_stream_seek_t whence)
+{
+ if (fp)
+ {
+ return fseek (fp, where, (int) whence);
+ }
+ lasterr = EBADF;
+ return -1;
+}
+
int
io_stream_file::error ()
{
int
io_stream_file::set_mtime (int mtime)
{
- if (!fname)
+ if (!fname.size())
return 1;
if (fp)
fclose (fp);
+#if defined(WIN32) && !defined (_CYGWIN_)
long long ftimev = mtime * NSPERSEC + FACTOR;
FILETIME ftime;
ftime.dwHighDateTime = ftimev >> 32;
ftime.dwLowDateTime = ftimev;
HANDLE h =
- CreateFileA (fname, GENERIC_WRITE, FILE_SHARE_READ | FILE_SHARE_WRITE,
+ CreateFileA (fname.cstr_oneuse(), GENERIC_WRITE, FILE_SHARE_READ | FILE_SHARE_WRITE,
0, OPEN_EXISTING,
FILE_ATTRIBUTE_NORMAL | FILE_FLAG_BACKUP_SEMANTICS, 0);
if (h)
{
SetFileTime (h, 0, 0, &ftime);
CloseHandle (h);
- fp = fopen (fname, lmode);
- if (!fp)
- lasterr = errno;
return 0;
}
- fp = fopen (fname, lmode);
- if (!fp)
- lasterr = errno;
+#else
+ throw new runtime_error ("set_mtime not supported on posix yet.");
+#endif
return 1;
}
+
+int
+io_stream_file::move (String const &from, String const &to)
+{
+ if (!from.size()|| !to.size())
+ return 1;
+ return rename (from.cstr_oneuse(), to.cstr_oneuse());
+}
+
+size_t
+io_stream_file::get_size ()
+{
+ if (!fname.size())
+ return 0;
+#if defined(WIN32) && !defined (_CYGWIN_)
+ HANDLE h;
+ WIN32_FIND_DATA buf;
+ DWORD ret = 0;
+
+ h = FindFirstFileA (fname.cstr_oneuse(), &buf);
+ if (h != INVALID_HANDLE_VALUE)
+ {
+ if (buf.nFileSizeHigh == 0)
+ ret = buf.nFileSizeLow;
+ FindClose (h);
+ }
+ return ret;
+#else
+ struct stat buf;
+ if (stat(fname.cstr_oneuse(), &buf))
+ throw new runtime_error ("Failed to stat file - has it been deleted?");
+ return buf.st_size;
+#endif
+}
git://cygwin.com / cygwin-apps / setup.git / blobdiff