43c23d4b82
* sigproc.cc (wait_for_sigthread): Ditto. Don't synchronize with wait_sig after receiving an event that it is ready to go. (init_sig_pipe): New function. (wait_sig): Call init_sig_pipe to create pipes for communicating signals to this process. Don't send sigCONT signal when initializing. * fork.cc (frok::child): Accommodate wait_for_sigpipe parameter change. * fhandler.h (fhandler_*::write): Make ssize_t/__stdcall. (fhandler_*::write_overlapped): Ditto. (fhandler_*::raw_write): Ditto. (fhandler_*::readv): Ditto. (fhandler_*::writev): Ditto. (fhandler_*::raw_read): Make __stdcall. * fhandler: Accommodate changes to read/write functions throughout. * fhandler_clipboard.cc: Ditto. * fhandler_console.cc: Ditto. * fhandler_dsp.cc: Ditto. * fhandler_fifo.cc: Ditto. * fhandler_mailslot.cc: Ditto. * fhandler_mem.cc: Ditto. * fhandler_mem.cc: Ditto. * fhandler_random.cc: Ditto. * fhandler_tape.cc: Ditto. * fhandler_tty.cc: Ditto. * fhandler_virtual.cc: Ditto. * fhandler_windows.cc: Ditto. * fhandler_zero.cc: Ditto. * syscalls.cc (readv): Use ssize_t as temp variable. * fhandler.cc (fhandler_base::read): Coerce returned len to signed or it will never be treated as < 0. (fhandler_base::wait_overlapped): Minimize calls to GetLastError. Remove duplicate debugging test. Fix error return. * fhandler.h (fhandler_fifo::fifo_name): Declare new function. (fhandler_fifo::close): Ditto. (fhandler_fifo::dup): Ditto. (fhandler_fifo::close_on_exec): Ditto. * fhandler.cc (fhandler_fifo::fifo_name): Define new function. (FIFO_BUF_SIZE): New define. (cnp): Ditto. (fhandler_fifo::open): Rework. Use cnp to open named pipe. Always open write side as a client. Open dummy client when writing and can't connect. (wait): Rework. Implement fifo_wait_for_next_client. Handle signals during connect better. Add new fifo_wait_for_server code which polls (sigh) waiting for server. (fhandler_fifo::raw_read): Handle transition states when one client closes and another is available. (fhandler_fifo::close): Define. (fhandler_fifo::dup): Ditto. (fhandler_fifo::close_on_exec): Ditto.
278 lines
5.2 KiB
C++
278 lines
5.2 KiB
C++
/* fhandler_virtual.cc: base fhandler class for virtual filesystems
|
|
|
|
Copyright 2002, 2003, 2004, 2005, 2007, 2008, 2009 Red Hat, Inc.
|
|
|
|
This file is part of Cygwin.
|
|
|
|
This software is a copyrighted work licensed under the terms of the
|
|
Cygwin license. Please consult the file "CYGWIN_LICENSE" for
|
|
details. */
|
|
|
|
#include "winsup.h"
|
|
#include <sys/acl.h>
|
|
#include <sys/statvfs.h>
|
|
#include "cygerrno.h"
|
|
#include "path.h"
|
|
#include "fhandler.h"
|
|
#include "dtable.h"
|
|
#include "cygheap.h"
|
|
|
|
#include <dirent.h>
|
|
|
|
fhandler_virtual::fhandler_virtual ():
|
|
fhandler_base (), filebuf (NULL), fileid (-1)
|
|
{
|
|
}
|
|
|
|
fhandler_virtual::~fhandler_virtual ()
|
|
{
|
|
if (filebuf)
|
|
{
|
|
cfree (filebuf);
|
|
filebuf = NULL;
|
|
}
|
|
}
|
|
|
|
void
|
|
fhandler_virtual::fixup_after_exec ()
|
|
{
|
|
}
|
|
|
|
DIR *
|
|
fhandler_virtual::opendir (int fd)
|
|
{
|
|
DIR *dir;
|
|
DIR *res = NULL;
|
|
size_t len;
|
|
|
|
if (exists () <= 0)
|
|
set_errno (ENOTDIR);
|
|
else if ((len = strlen (get_name ())) > PATH_MAX - 3)
|
|
set_errno (ENAMETOOLONG);
|
|
else if ((dir = (DIR *) malloc (sizeof (DIR))) == NULL)
|
|
set_errno (ENOMEM);
|
|
else if ((dir->__d_dirname = (char *) malloc (len + 3)) == NULL)
|
|
{
|
|
free (dir);
|
|
set_errno (ENOMEM);
|
|
}
|
|
else if ((dir->__d_dirent =
|
|
(struct dirent *) malloc (sizeof (struct dirent))) == NULL)
|
|
{
|
|
free (dir);
|
|
set_errno (ENOMEM);
|
|
}
|
|
else
|
|
{
|
|
strcpy (dir->__d_dirname, get_name ());
|
|
dir->__d_dirent->__d_version = __DIRENT_VERSION;
|
|
dir->__d_cookie = __DIRENT_COOKIE;
|
|
dir->__handle = INVALID_HANDLE_VALUE;
|
|
dir->__d_position = 0;
|
|
dir->__flags = 0;
|
|
|
|
if (fd >= 0)
|
|
{
|
|
dir->__d_fd = fd;
|
|
res = dir;
|
|
dir->__fh = this;
|
|
res = dir;
|
|
}
|
|
else
|
|
{
|
|
cygheap_fdnew cfd;
|
|
if (cfd >= 0)
|
|
{
|
|
cfd = this;
|
|
cfd->nohandle (true);
|
|
dir->__d_fd = cfd;
|
|
dir->__fh = this;
|
|
res = dir;
|
|
}
|
|
}
|
|
close_on_exec (true);
|
|
}
|
|
|
|
syscall_printf ("%p = opendir (%s)", res, get_name ());
|
|
return res;
|
|
}
|
|
|
|
_off64_t fhandler_virtual::telldir (DIR * dir)
|
|
{
|
|
return dir->__d_position;
|
|
}
|
|
|
|
void
|
|
fhandler_virtual::seekdir (DIR * dir, _off64_t loc)
|
|
{
|
|
dir->__flags |= dirent_saw_dot | dirent_saw_dot_dot;
|
|
dir->__d_position = loc;
|
|
}
|
|
|
|
void
|
|
fhandler_virtual::rewinddir (DIR * dir)
|
|
{
|
|
dir->__d_position = 0;
|
|
dir->__flags |= dirent_saw_dot | dirent_saw_dot_dot;
|
|
}
|
|
|
|
int
|
|
fhandler_virtual::closedir (DIR * dir)
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
_off64_t
|
|
fhandler_virtual::lseek (_off64_t offset, int whence)
|
|
{
|
|
/*
|
|
* On Linux, when you lseek within a /proc file,
|
|
* the contents of the file are updated.
|
|
*/
|
|
if (!fill_filebuf ())
|
|
return (_off64_t) -1;
|
|
switch (whence)
|
|
{
|
|
case SEEK_SET:
|
|
position = offset;
|
|
break;
|
|
case SEEK_CUR:
|
|
position += offset;
|
|
break;
|
|
case SEEK_END:
|
|
position = filesize + offset;
|
|
break;
|
|
default:
|
|
set_errno (EINVAL);
|
|
return (_off64_t) -1;
|
|
}
|
|
return position;
|
|
}
|
|
|
|
int
|
|
fhandler_virtual::dup (fhandler_base * child)
|
|
{
|
|
int ret = fhandler_base::dup (child);
|
|
|
|
if (!ret)
|
|
{
|
|
fhandler_virtual *fhproc_child = (fhandler_virtual *) child;
|
|
fhproc_child->filebuf = (char *) cmalloc_abort (HEAP_BUF, filesize);
|
|
fhproc_child->filesize = filesize;
|
|
fhproc_child->position = position;
|
|
memcpy (fhproc_child->filebuf, filebuf, filesize);
|
|
fhproc_child->set_flags (get_flags ());
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
int
|
|
fhandler_virtual::close ()
|
|
{
|
|
if (!hExeced)
|
|
{
|
|
if (filebuf)
|
|
{
|
|
cfree (filebuf);
|
|
filebuf = NULL;
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
void __stdcall
|
|
fhandler_virtual::read (void *ptr, size_t& len)
|
|
{
|
|
if (len == 0)
|
|
return;
|
|
if (openflags & O_DIROPEN)
|
|
{
|
|
set_errno (EISDIR);
|
|
len = (size_t) -1;
|
|
return;
|
|
}
|
|
if (!filebuf)
|
|
{
|
|
len = (size_t) 0;
|
|
return;
|
|
}
|
|
if ((ssize_t) len > filesize - position)
|
|
len = (size_t) (filesize - position);
|
|
if ((ssize_t) len < 0)
|
|
len = 0;
|
|
else
|
|
memcpy (ptr, filebuf + position, len);
|
|
position += len;
|
|
}
|
|
|
|
ssize_t __stdcall
|
|
fhandler_virtual::write (const void *ptr, size_t len)
|
|
{
|
|
set_errno (EACCES);
|
|
return -1;
|
|
}
|
|
|
|
/* low-level open for all proc files */
|
|
int
|
|
fhandler_virtual::open (int flags, mode_t mode)
|
|
{
|
|
rbinary (true);
|
|
wbinary (true);
|
|
|
|
set_flags ((flags & ~O_TEXT) | O_BINARY);
|
|
|
|
return 1;
|
|
}
|
|
|
|
int
|
|
fhandler_virtual::exists ()
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
bool
|
|
fhandler_virtual::fill_filebuf ()
|
|
{
|
|
return true;
|
|
}
|
|
|
|
int
|
|
fhandler_virtual::fchmod (mode_t mode)
|
|
{
|
|
/* Same as on Linux. */
|
|
set_errno (EPERM);
|
|
return -1;
|
|
}
|
|
|
|
int
|
|
fhandler_virtual::fchown (__uid32_t uid, __gid32_t gid)
|
|
{
|
|
/* Same as on Linux. */
|
|
set_errno (EPERM);
|
|
return -1;
|
|
}
|
|
|
|
int
|
|
fhandler_virtual::facl (int cmd, int nentries, __aclent32_t *aclbufp)
|
|
{
|
|
int res = fhandler_base::facl (cmd, nentries, aclbufp);
|
|
if (res >= 0 && cmd == GETACL)
|
|
{
|
|
aclbufp[0].a_perm = (S_IRUSR | (pc.isdir () ? S_IXUSR : 0)) >> 6;
|
|
aclbufp[1].a_perm = (S_IRGRP | (pc.isdir () ? S_IXGRP : 0)) >> 3;
|
|
aclbufp[2].a_perm = S_IROTH | (pc.isdir () ? S_IXOTH : 0);
|
|
}
|
|
return res;
|
|
}
|
|
|
|
int __stdcall
|
|
fhandler_virtual::fstatvfs (struct statvfs *sfs)
|
|
{
|
|
/* Virtual file system. Just return an empty buffer with a few values
|
|
set to something useful. Just as on Linux. */
|
|
memset (sfs, 0, sizeof (*sfs));
|
|
sfs->f_bsize = sfs->f_frsize = 4096;
|
|
sfs->f_namemax = NAME_MAX;
|
|
return 0;
|
|
}
|