summaryrefslogtreecommitdiffstats
path: root/winsup/cygwin/fhandler_procsysvipc.cc
diff options
context:
space:
mode:
Diffstat (limited to 'winsup/cygwin/fhandler_procsysvipc.cc')
-rw-r--r--winsup/cygwin/fhandler_procsysvipc.cc347
1 files changed, 347 insertions, 0 deletions
diff --git a/winsup/cygwin/fhandler_procsysvipc.cc b/winsup/cygwin/fhandler_procsysvipc.cc
new file mode 100644
index 000000000..a486a2944
--- /dev/null
+++ b/winsup/cygwin/fhandler_procsysvipc.cc
@@ -0,0 +1,347 @@
+/* fhandler_procsysvipc.cc: fhandler for /proc/sysvipc virtual filesystem
+
+ Copyright 2011 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 <stdlib.h>
+#include <stdio.h>
+#include <sys/cygwin.h>
+#include "cygerrno.h"
+#include "cygserver.h"
+#include "security.h"
+#include "path.h"
+#include "fhandler.h"
+#include "fhandler_virtual.h"
+#include "pinfo.h"
+#include "shared_info.h"
+#include "dtable.h"
+#include "cygheap.h"
+#include "ntdll.h"
+#include "cygtls.h"
+#include "pwdgrp.h"
+#include "tls_pbuf.h"
+#include <sys/param.h>
+#include <ctype.h>
+
+#define _COMPILING_NEWLIB
+#include <dirent.h>
+
+#define _KERNEL
+#include <sys/ipc.h>
+#include <sys/msg.h>
+#include <sys/sem.h>
+#include <sys/shm.h>
+
+static _off64_t format_procsysvipc_msg (void *, char *&);
+static _off64_t format_procsysvipc_sem (void *, char *&);
+static _off64_t format_procsysvipc_shm (void *, char *&);
+
+static const virt_tab_t procsysvipc_tab[] =
+{
+ { _VN ("."), FH_PROCSYSVIPC, virt_directory, NULL },
+ { _VN (".."), FH_PROCSYSVIPC, virt_directory, NULL },
+ { _VN ("msg"), FH_PROCSYSVIPC, virt_file, format_procsysvipc_msg },
+ { _VN ("sem"), FH_PROCSYSVIPC, virt_file, format_procsysvipc_sem },
+ { _VN ("shm"), FH_PROCSYSVIPC, virt_file, format_procsysvipc_shm },
+ { NULL, 0, 0, virt_none, NULL }
+};
+
+static const int PROCSYSVIPC_LINK_COUNT =
+ (sizeof (procsysvipc_tab) / sizeof (virt_tab_t)) - 1;
+
+/* Returns 0 if path doesn't exist, >0 if path is a directory,
+ * -1 if path is a file.
+ */
+virtual_ftype_t
+fhandler_procsysvipc::exists ()
+{
+ const char *path = get_name ();
+ debug_printf ("exists (%s)", path);
+ path += proc_len + 1;
+ while (*path != 0 && !isdirsep (*path))
+ path++;
+ if (*path == 0)
+ return virt_rootdir;
+
+ virt_tab_t *entry = virt_tab_search (path + 1, true, procsysvipc_tab,
+ PROCSYSVIPC_LINK_COUNT);
+
+ cygserver_init();
+
+ if (entry)
+ {
+ if (entry->type == virt_file)
+ {
+ if (cygserver_running != CYGSERVER_OK)
+ return virt_none;
+ }
+ fileid = entry - procsysvipc_tab;
+ return entry->type;
+ }
+ return virt_none;
+}
+
+fhandler_procsysvipc::fhandler_procsysvipc ():
+ fhandler_proc ()
+{
+}
+
+int
+fhandler_procsysvipc::fstat (struct __stat64 *buf)
+{
+ fhandler_base::fstat (buf);
+ buf->st_mode &= ~_IFMT & NO_W;
+ int file_type = exists ();
+ switch (file_type)
+ {
+ case virt_none:
+ set_errno (ENOENT);
+ return -1;
+ case virt_directory:
+ case virt_rootdir:
+ buf->st_mode |= S_IFDIR | S_IXUSR | S_IXGRP | S_IXOTH;
+ buf->st_nlink = 2;
+ return 0;
+ case virt_file:
+ default:
+ buf->st_mode |= S_IFREG | S_IRUSR | S_IRGRP | S_IROTH;
+ return 0;
+ }
+}
+
+int
+fhandler_procsysvipc::readdir (DIR *dir, dirent *de)
+{
+ int res = ENMFILE;
+ if (dir->__d_position >= PROCSYSVIPC_LINK_COUNT)
+ goto out;
+ {
+ cygserver_init();
+ if (cygserver_running != CYGSERVER_OK)
+ goto out;
+ }
+ strcpy (de->d_name, procsysvipc_tab[dir->__d_position++].name);
+ dir->__flags |= dirent_saw_dot | dirent_saw_dot_dot;
+ res = 0;
+out:
+ syscall_printf ("%d = readdir (%p, %p) (%s)", res, dir, de, de->d_name);
+ return res;
+}
+
+int
+fhandler_procsysvipc::open (int flags, mode_t mode)
+{
+ int res = fhandler_virtual::open (flags, mode);
+ if (!res)
+ goto out;
+
+ nohandle (true);
+
+ const char *path;
+ path = get_name () + proc_len + 1;
+ pid = atoi (path);
+ while (*path != 0 && !isdirsep (*path))
+ path++;
+
+ if (*path == 0)
+ {
+ if ((flags & (O_CREAT | O_EXCL)) == (O_CREAT | O_EXCL))
+ {
+ set_errno (EEXIST);
+ res = 0;
+ goto out;
+ }
+ else if (flags & O_WRONLY)
+ {
+ set_errno (EISDIR);
+ res = 0;
+ goto out;
+ }
+ else
+ {
+ flags |= O_DIROPEN;
+ goto success;
+ }
+ }
+
+ virt_tab_t *entry;
+ entry = virt_tab_search (path + 1, true, procsysvipc_tab, PROCSYSVIPC_LINK_COUNT);
+ if (!entry)
+ {
+ set_errno ((flags & O_CREAT) ? EROFS : ENOENT);
+ res = 0;
+ goto out;
+ }
+ if (flags & O_WRONLY)
+ {
+ set_errno (EROFS);
+ res = 0;
+ goto out;
+ }
+
+ fileid = entry - procsysvipc_tab;
+ if (!fill_filebuf ())
+ {
+ res = 0;
+ goto out;
+ }
+
+ if (flags & O_APPEND)
+ position = filesize;
+ else
+ position = 0;
+
+success:
+ res = 1;
+ set_flags ((flags & ~O_TEXT) | O_BINARY);
+ set_open_status ();
+out:
+ syscall_printf ("%d = fhandler_proc::open (%p, %d)", res, flags, mode);
+ return res;
+}
+
+bool
+fhandler_procsysvipc::fill_filebuf ()
+{
+ if (procsysvipc_tab[fileid].format_func)
+ {
+ filesize = procsysvipc_tab[fileid].format_func (NULL, filebuf);
+ return true;
+ }
+ return false;
+}
+
+static _off64_t
+format_procsysvipc_msg (void *, char *&destbuf)
+{
+ tmp_pathbuf tp;
+ char *buf = tp.c_get ();
+ char *bufptr = buf;
+ struct msginfo msginfo;
+ struct msqid_ds *xmsqids;
+ size_t xmsqids_len;
+
+ msgctl (0, IPC_INFO, (struct msqid_ds *) &msginfo);
+ xmsqids_len = sizeof (struct msqid_ds) * msginfo.msgmni;
+ xmsqids = (struct msqid_ds *) malloc (xmsqids_len);
+ msgctl (msginfo.msgmni, IPC_INFO, (struct msqid_ds *) xmsqids);
+
+ bufptr += __small_sprintf (bufptr,
+ " key msqid perms cbytes qnum lspid lrpid uid gid cuid cgid stime rtime ctime\n");
+
+ for (int i = 0; i < msginfo.msgmni; i++) {
+ if (xmsqids[i].msg_qbytes != 0) {
+ bufptr += sprintf (bufptr,
+ "%10llu %10u %5o %11lu %10lu %5d %5d %5lu %5lu %5lu %5lu %10ld %10ld %10ld\n",
+ xmsqids[i].msg_perm.key,
+ IXSEQ_TO_IPCID(i, xmsqids[i].msg_perm),
+ xmsqids[i].msg_perm.mode,
+ xmsqids[i].msg_cbytes,
+ xmsqids[i].msg_qnum,
+ xmsqids[i].msg_lspid,
+ xmsqids[i].msg_lrpid,
+ xmsqids[i].msg_perm.uid,
+ xmsqids[i].msg_perm.gid,
+ xmsqids[i].msg_perm.cuid,
+ xmsqids[i].msg_perm.cgid,
+ xmsqids[i].msg_stime,
+ xmsqids[i].msg_rtime,
+ xmsqids[i].msg_ctime);
+ }
+ }
+
+ destbuf = (char *) crealloc_abort (destbuf, bufptr - buf);
+ memcpy (destbuf, buf, bufptr - buf);
+ return bufptr - buf;
+}
+
+static _off64_t
+format_procsysvipc_sem (void *, char *&destbuf)
+{
+ tmp_pathbuf tp;
+ char *buf = tp.c_get ();
+ char *bufptr = buf;
+ union semun semun;
+ struct seminfo seminfo;
+ struct semid_ds *xsemids;
+ size_t xsemids_len;
+
+ semun.buf = (struct semid_ds *) &seminfo;
+ semctl (0, 0, IPC_INFO, semun);
+ xsemids_len = sizeof (struct semid_ds) * seminfo.semmni;
+ xsemids = (struct semid_ds *) malloc (xsemids_len);
+ semun.buf = xsemids;
+ semctl (seminfo.semmni, 0, IPC_INFO, semun);
+
+ bufptr += __small_sprintf (bufptr,
+ " key semid perms nsems uid gid cuid cgid otime ctime\n");
+ for (int i = 0; i < seminfo.semmni; i++) {
+ if ((xsemids[i].sem_perm.mode & SEM_ALLOC) != 0) {
+ bufptr += sprintf (bufptr,
+ "%10llu %10u %5o %10d %5lu %5lu %5lu %5lu %10ld %10ld\n",
+ xsemids[i].sem_perm.key,
+ IXSEQ_TO_IPCID(i, xsemids[i].sem_perm),
+ xsemids[i].sem_perm.mode,
+ xsemids[i].sem_nsems,
+ xsemids[i].sem_perm.uid,
+ xsemids[i].sem_perm.gid,
+ xsemids[i].sem_perm.cuid,
+ xsemids[i].sem_perm.cgid,
+ xsemids[i].sem_otime,
+ xsemids[i].sem_ctime);
+ }
+ }
+
+ destbuf = (char *) crealloc_abort (destbuf, bufptr - buf);
+ memcpy (destbuf, buf, bufptr - buf);
+ return bufptr - buf;
+}
+
+static _off64_t
+format_procsysvipc_shm (void *, char *&destbuf)
+{
+ tmp_pathbuf tp;
+ char *buf = tp.c_get ();
+ char *bufptr = buf;
+ struct shminfo shminfo;
+ struct shmid_ds *xshmids;
+ size_t xshmids_len;
+
+ shmctl (0, IPC_INFO, (struct shmid_ds *) &shminfo);
+ xshmids_len = sizeof (struct shmid_ds) * shminfo.shmmni;
+ xshmids = (struct shmid_ds *) malloc (xshmids_len);
+ shmctl (shminfo.shmmni, IPC_INFO, (struct shmid_ds *) xshmids);
+
+ bufptr += __small_sprintf (bufptr,
+ " key shmid perms size cpid lpid nattch uid gid cuid cgid atime dtime ctime\n");
+ for (int i = 0; i < shminfo.shmmni; i++) {
+ if (xshmids[i].shm_perm.mode & 0x0800) {
+ bufptr += sprintf (bufptr,
+ "%10llu %10u %5o %10u %5d %5d %6u %5lu %5lu %5lu %5lu %10ld %10ld %10ld\n",
+ xshmids[i].shm_perm.key,
+ IXSEQ_TO_IPCID(i, xshmids[i].shm_perm),
+ xshmids[i].shm_perm.mode,
+ xshmids[i].shm_segsz,
+ xshmids[i].shm_cpid,
+ xshmids[i].shm_lpid,
+ xshmids[i].shm_nattch,
+ xshmids[i].shm_perm.uid,
+ xshmids[i].shm_perm.gid,
+ xshmids[i].shm_perm.cuid,
+ xshmids[i].shm_perm.cgid,
+ xshmids[i].shm_atime,
+ xshmids[i].shm_dtime,
+ xshmids[i].shm_ctime);
+ }
+ }
+
+ destbuf = (char *) crealloc_abort (destbuf, bufptr - buf);
+ memcpy (destbuf, buf, bufptr - buf);
+ return bufptr - buf;
+}
generated by cgit v1.2.3 (git 2.25.1) at 2025-04-23 20:55:52 +0000