From 9b554e3e2b5dbaab46f69874287c10f3f03ad5e3 Mon Sep 17 00:00:00 2001
From: Miles Bader <miles@gnu.org>
Date: Tue, 7 May 1996 20:53:39 +0000
Subject: (diskfs_S_file_get_storage_info): Rewrite for new interface.
---
ext2fs/storeinfo.c | 229 ++++++++++++++++++++++++++++++-----------------------
1 file changed, 129 insertions(+), 100 deletions(-)
(limited to 'ext2fs')
diff --git a/ext2fs/storeinfo.c b/ext2fs/storeinfo.c
index 7d6bdd23..419809c9 100644
--- a/ext2fs/storeinfo.c
+++ b/ext2fs/storeinfo.c
@@ -18,128 +18,157 @@
along with this program; if not, write to the Free Software
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */
-#include <netinet/in.h>
+#include <string.h>
+#include <netinet/in.h> /* htonl */
#include "ext2fs.h"
error_t
-diskfs_S_file_get_storage_info (struct protid *cred, int *class,
- off_t **runs, unsigned *runs_len,
- size_t *block_size,
- char *dev_name, mach_port_t *dev_port,
- mach_msg_type_name_t *dev_port_type,
- char **misc, unsigned *misc_len,
- int *flags)
+diskfs_S_file_get_storage_info (struct protid *cred,
+ mach_port_t **ports,
+ mach_msg_type_name_t *ports_type,
+ mach_msg_type_number_t *num_ports,
+ int **ints, mach_msg_type_number_t *num_ints,
+ off_t **offsets,
+ mach_msg_type_number_t *num_offsets,
+ char **data, mach_msg_type_number_t *data_len)
{
error_t err = 0;
- block_t index = 0;
- unsigned num_fs_blocks;
- unsigned runs_alloced = 0;
- off_t *run = 0;
- struct node *node = cred->po->np;
-
- *misc_len = sizeof (long) * 4;
- err = vm_allocate (mach_task_self (), (vm_address_t *)misc, *misc_len, 1);
- if (err)
- return err;
+ size_t name_len =
+ (diskfs_device_name && *diskfs_device_name)
+ ? strlen (diskfs_device_name) + 1 : 0;
+ /* True when we've allocated memory for the corresponding vector. */
+ int al_ports = 0, al_ints = 0, al_offsets = 0, al_data = 0;
+
+ if (! cred)
+ return EOPNOTSUPP;
+
+#define ENSURE_MEM(v, vl, alp, num) \
+ if (!err && *vl < num) \
+ { \
+ err = vm_allocate (mach_task_self (), \
+ (vm_address_t *)v, num * sizeof (**v), 1); \
+ if (! err) \
+ { \
+ *vl = num; \
+ alp = 1; \
+ } \
+ }
+
+ /* Two longs. */
+#define MISC_LEN (sizeof (long) * 2)
- mutex_lock (&node->lock);
+ ENSURE_MEM (ports, num_ports, al_ports, 1);
+ ENSURE_MEM (ints, num_ints, al_ints, 6);
+ ENSURE_MEM (data, data_len, al_data, name_len + MISC_LEN);
+ /* OFFSETS is more complex, and done below. */
- num_fs_blocks = node->dn_stat.st_blocks >> log2_stat_blocks_per_fs_block;
- while (num_fs_blocks > 0)
+ if (! err)
{
- block_t block;
+ block_t index = 0;
+ unsigned num_fs_blocks;
+ off_t *run = *num_offsets ? *offsets : 0;
+ struct node *node = cred->po->np;
- err = ext2_getblk (node, index++, 0, &block);
- if (err == EINVAL)
- /* Either a hole, or past the end of the file. */
- {
- block = 0;
- err = 0;
- }
- if (err)
- goto fail;
-
- block <<= log2_dev_blocks_per_fs_block;
- if (!run
- || ((block && run[0] >= 0) /* Neither is a hole and... */
- ? (block != run[0] + run[1]) /* ... BLOCK doesn't follow RUN */
- : (block || run[0] >= 0))) /* or ... one is, but not both */
- /* Add a new run. */
+ mutex_lock (&node->lock);
+
+ num_fs_blocks = node->dn_stat.st_blocks >> log2_stat_blocks_per_fs_block;
+ while (num_fs_blocks > 0)
{
- if (run)
- /* There are already some runs. */
+ block_t block;
+
+ err = ext2_getblk (node, index++, 0, &block);
+ if (err == EINVAL)
+ /* Either a hole, or past the end of the file. */
{
- run += 2;
- if (run >= *runs + runs_alloced)
- /* Add a new page to the end of the existing RUNS array. */
- {
- err = vm_allocate (mach_task_self (),
- (vm_address_t *)&run, vm_page_size, 0);
- if (err)
- goto fail;
- runs_alloced += vm_page_size / sizeof (off_t);
- }
+ block = 0;
+ err = 0;
}
- else
- /* Allocate the RUNS array for the first time. */
+ else if (err)
+ break;
+
+ block <<= log2_dev_blocks_per_fs_block;
+ if (!run
+ || ((block && run[0] >= 0) /* Neither is a hole and... */
+ ? (block != run[0] + run[1]) /* BLOCK doesn't follow RUN */
+ : (block || run[0] >= 0))) /* or one is, but not both */
+ /* Add a new run. */
{
- err = vm_allocate (mach_task_self (),
- (vm_address_t *)runs, vm_page_size, 1);
- if (err)
- goto fail;
- runs_alloced = vm_page_size / sizeof (off_t);
- run = *runs;
+ run += 2;
+ if (!run || run >= *offsets + *num_offsets)
+ if (al_offsets)
+ /* We've already allocated space for offsets; add a new
+ page to the end of it. */
+ {
+ err =
+ vm_allocate (mach_task_self (),
+ (vm_address_t *)&run, vm_page_size, 0);
+ if (err)
+ break;
+ *num_offsets += vm_page_size / sizeof (off_t);
+ }
+ else
+ /* We've run out the space passed for inline offsets by
+ the caller, so allocate our own memory and copy
+ anything we've already stored. */
+ {
+ off_t *old = *offsets;
+ size_t old_len = *num_offsets;
+ err =
+ vm_allocate (mach_task_self (),
+ (vm_address_t *)offsets,
+ old_len * sizeof (off_t) + vm_page_size, 1);
+ if (err)
+ break;
+ if (old_len)
+ bcopy (old, *offsets, old_len * sizeof (off_t));
+ *num_offsets = old_len + vm_page_size / sizeof (off_t);
+ run = *offsets;
+ al_offsets = 1;
+ }
+
+ run[0] = block ?: -1; /* -1 means a hole in OFFSETS */
+ run[1] = 0; /* will get extended just below */
}
- run[0] = block ?: -1; /* -1 means a hole in RUNS */
- run[1] = 0; /* will get extended just below */
- }
-
- /* Increase the size of the current run by one filesystem block. */
- run[1] += 1 << log2_dev_blocks_per_fs_block;
+ /* Increase the size of the current run by one filesystem block. */
+ run[1] += 1 << log2_dev_blocks_per_fs_block;
- num_fs_blocks--;
- }
+ num_fs_blocks--;
+ }
- if (run)
- {
- if (run[0] >= 0)
- /* Include the current run, as long as it's not a hole. */
- run += 2;
- else if ((off_t *)trunc_page (run) == run)
- /* We allocated just *one* too many pages -- the last run is a hole. */
- vm_deallocate (mach_task_self (), (vm_address_t)run, vm_page_size);
- *runs_len = run - *runs;
+ /* Fill in PORTS. Root gets device port, everyone else, nothing. */
+ (*ports)[0] = diskfs_isuid (0, cred) ? diskfs_device : MACH_PORT_NULL;
+ *ports_type = MACH_MSG_TYPE_COPY_SEND;
+
+ /* Fill in INTS. */
+ (*ints)[0] = STORAGE_DEVICE; /* type */
+ (*ints)[1] = 0; /* flags */
+ (*ints)[2] = diskfs_device_block_size; /* block size */
+ (*ints)[3] = (run - *offsets) / 2; /* num runs */
+ (*ints)[4] = name_len;
+ (*ints)[5] = MISC_LEN;
+
+ /* Fill in DATA. */
+ if (name_len)
+ strcpy (*data, diskfs_device_name);
+ /* The following must be kept in sync with MISC_LEN. */
+ ((long *)(*data + name_len))[0] = htonl (node->cache_id);
+ ((long *)(*data + name_len))[1] =
+ htonl (dino (node->cache_id)->i_translator);
+
+ mutex_unlock (&node->lock);
}
- else
- *runs_len = 0;
-
- ((long *)*misc)[0] = htonl (node->cache_id);
- ((long *)*misc)[1] = htonl (dino (node->cache_id)->i_translator);
-
- *class = STORAGE_DEVICE;
- *flags = 0;
-
- *block_size = diskfs_device_block_size;
-
- strcpy (dev_name, diskfs_device_name);
-
- if (diskfs_isuid (0, cred))
- *dev_port = diskfs_device;
- else
- *dev_port = MACH_PORT_NULL;
- *dev_port_type = MACH_MSG_TYPE_COPY_SEND;
-
- fail:
- mutex_unlock (&node->lock);
if (err)
{
- if (*runs_len > 0)
- vm_deallocate (mach_task_self (), (vm_address_t)*runs,
- runs_alloced * sizeof (off_t));
- vm_deallocate (mach_task_self (), (vm_address_t)*misc, *misc_len);
+#define DISCARD_MEM(v, vl, alp) \
+ if (alp) \
+ vm_deallocate (mach_task_self (), (vm_address_t)*v, *vl * sizeof **v);
+ DISCARD_MEM (ports, num_ports, al_ports);
+ DISCARD_MEM (ints, num_ints, al_ints);
+ DISCARD_MEM (offsets, num_offsets, al_offsets);
+ DISCARD_MEM (data, data_len, al_data);
}
return err;
--
cgit v1.2.3