*
*/
-#include <linux/config.h>
-#include <linux/kernel.h>
-#include <linux/mm.h>
-#include <linux/string.h>
-#include <linux/stat.h>
-#include <linux/errno.h>
-#include <linux/locks.h>
-#include <linux/unistd.h>
-
-#include <asm/system.h>
-#include <asm/uaccess.h>
+#include <linux/mm.h>
#include <linux/fs.h>
-#include <linux/stat.h>
+#include <linux/sched.h>
#include <asm/uaccess.h>
-#include <linux/vmalloc.h>
-#include <asm/segment.h>
-#include <linux/mm.h>
-#include <linux/pagemap.h>
-#include <linux/smp_lock.h>
#include <linux/obd_support.h>
#include <linux/obd_class.h>
int obd_init_obdo_cache(void)
{
- ENTRY;
- if (obdo_cachep == NULL) {
- obdo_cachep = kmem_cache_create("obdo_cache",
- sizeof(struct obdo),
- 0, SLAB_HWCACHE_ALIGN,
- NULL, NULL);
- if (obdo_cachep == NULL) {
- EXIT;
- return -ENOMEM;
- }
- }
- EXIT;
- return 0;
+ ENTRY;
+ if (obdo_cachep == NULL) {
+ CDEBUG(D_CACHE, "allocating obdo_cache\n");
+ obdo_cachep = kmem_cache_create("obdo_cache",
+ sizeof(struct obdo),
+ 0, SLAB_HWCACHE_ALIGN,
+ NULL, NULL);
+ if (obdo_cachep == NULL) {
+ EXIT;
+ return -ENOMEM;
+ } else {
+ CDEBUG(D_CACHE, "allocated cache at %p\n", obdo_cachep);
+ }
+ } else {
+ CDEBUG(D_CACHE, "using existing cache at %p\n", obdo_cachep);
+ }
+ EXIT;
+ return 0;
}
void obd_cleanup_obdo_cache(void)
{
- ENTRY;
- if (obdo_cachep != NULL) {
- if (kmem_cache_shrink(obdo_cachep))
- printk(KERN_INFO "obd_cleanup_obdo_cache: unable to free all of cache\n");
- } else
- printk(KERN_INFO "obd_cleanup_obdo_cache: called with NULL cache pointer\n");
-
- EXIT;
+ ENTRY;
+ if (obdo_cachep != NULL) {
+ CDEBUG(D_CACHE, "destroying obdo_cache at %p\n", obdo_cachep);
+ if (kmem_cache_destroy(obdo_cachep))
+ printk(KERN_WARNING __FUNCTION__
+ ": unable to free cache\n");
+ } else
+ printk(KERN_INFO __FUNCTION__
+ ": called with NULL cache pointer\n");
+
+ obdo_cachep = NULL;
+ EXIT;
}
/* map connection to client */
-struct obd_client *gen_client(struct obd_conn *conn)
+struct obd_client *gen_client(const struct obd_conn *conn)
{
- struct obd_device * obddev = conn->oc_dev;
- struct list_head * lh, * next;
- struct obd_client * cli;
-
- lh = next = &obddev->obd_gen_clients;
- while ((lh = lh->next) != &obddev->obd_gen_clients) {
- cli = list_entry(lh, struct obd_client, cli_chain);
-
- if (cli->cli_id == conn->oc_id)
- return cli;
- }
-
- return NULL;
+ struct obd_device * obddev = conn->oc_dev;
+ struct list_head * lh, * next;
+ struct obd_client * cli;
+
+ lh = next = &obddev->obd_gen_clients;
+ while ((lh = lh->next) != &obddev->obd_gen_clients) {
+ cli = list_entry(lh, struct obd_client, cli_chain);
+
+ if (cli->cli_id == conn->oc_id)
+ return cli;
+ }
+
+ return NULL;
} /* obd_client */
/* a connection defines a context in which preallocation can be managed. */
int gen_connect (struct obd_conn *conn)
{
- struct obd_client * cli;
-
- OBD_ALLOC(cli, struct obd_client *, sizeof(struct obd_client));
- if ( !cli ) {
- printk("obd_connect (minor %d): no memory!\n",
- conn->oc_dev->obd_minor);
- return -ENOMEM;
- }
-
- INIT_LIST_HEAD(&cli->cli_prealloc_inodes);
- /* XXX this should probably spinlocked? */
- cli->cli_id = ++conn->oc_dev->obd_gen_last_id;
- cli->cli_prealloc_quota = 0;
- cli->cli_obd = conn->oc_dev;
- list_add(&(cli->cli_chain), conn->oc_dev->obd_gen_clients.prev);
-
- CDEBUG(D_IOCTL, "connect: new ID %u\n", cli->cli_id);
- conn->oc_id = cli->cli_id;
- return 0;
+ struct obd_client * cli;
+
+ OBD_ALLOC(cli, struct obd_client *, sizeof(struct obd_client));
+ if ( !cli ) {
+ printk(__FUNCTION__ ": no memory! (minor %d)\n",
+ conn->oc_dev->obd_minor);
+ return -ENOMEM;
+ }
+
+ INIT_LIST_HEAD(&cli->cli_prealloc_inodes);
+ /* XXX this should probably spinlocked? */
+ cli->cli_id = ++conn->oc_dev->obd_gen_last_id;
+ cli->cli_prealloc_quota = 0;
+ cli->cli_obd = conn->oc_dev;
+ list_add(&(cli->cli_chain), conn->oc_dev->obd_gen_clients.prev);
+
+ CDEBUG(D_INFO, "connect: new ID %u\n", cli->cli_id);
+ conn->oc_id = cli->cli_id;
+ return 0;
} /* gen_obd_connect */
int gen_disconnect(struct obd_conn *conn)
{
- struct obd_client * cli;
- ENTRY;
+ struct obd_client * cli;
+ ENTRY;
- if (!(cli = gen_client(conn))) {
- CDEBUG(D_IOCTL, "disconnect: attempting to free "
- "nonexistent client %u\n", conn->oc_id);
- return -EINVAL;
- }
+ if (!(cli = gen_client(conn))) {
+ CDEBUG(D_IOCTL, "disconnect: attempting to free "
+ "nonexistent client %u\n", conn->oc_id);
+ return -EINVAL;
+ }
- list_del(&(cli->cli_chain));
- OBD_FREE(cli, sizeof(struct obd_client));
+ list_del(&(cli->cli_chain));
+ OBD_FREE(cli, sizeof(struct obd_client));
- CDEBUG(D_IOCTL, "disconnect: ID %u\n", conn->oc_id);
+ CDEBUG(D_INFO, "disconnect: ID %u\n", conn->oc_id);
- EXIT;
- return 0;
+ EXIT;
+ return 0;
} /* gen_obd_disconnect */
*/
int gen_multi_setup(struct obd_device *obddev, uint32_t len, void *data)
{
- int i;
-
- for (i = 0 ; i < obddev->obd_multi_count ; i++ ) {
- int rc;
- struct obd_conn *ch_conn = &obddev->obd_multi_conn[i];
- rc = OBP(ch_conn->oc_dev, connect)(ch_conn);
-
- if ( rc != 0 ) {
- /* XXX disconnect others */
- return -EINVAL;
- }
- }
- return 0;
+ int i;
+
+ for (i = 0 ; i < obddev->obd_multi_count ; i++ ) {
+ int rc;
+ struct obd_conn *ch_conn = &obddev->obd_multi_conn[i];
+ rc = OBP(ch_conn->oc_dev, connect)(ch_conn);
+
+ if ( rc != 0 ) {
+ int j;
+
+ for (j = --i; j >= 0; --j) {
+ ch_conn = &obddev->obd_multi_conn[i];
+ OBP(ch_conn->oc_dev, disconnect)(ch_conn);
+ }
+ return -EINVAL;
+ }
+ }
+ return 0;
}
#if 0
int gen_multi_attach(struct obd_device *obddev, int len, void *data)
{
- int i;
- int count;
- struct obd_device *rdev = obddev->obd_multi_dev[0];
-
- count = len/sizeof(int);
- obddev->obd_multi_count = count;
- for (i=0 ; i<count ; i++) {
- rdev = &obd_dev[*((int *)data + i)];
- rdev = rdev + 1;
- CDEBUG(D_IOCTL, "OBD RAID1: replicator %d is of type %s\n", i,
- (rdev + i)->obd_type->typ_name);
- }
- return 0;
+ int i;
+ int count;
+ struct obd_device *rdev = obddev->obd_multi_dev[0];
+
+ count = len/sizeof(int);
+ obddev->obd_multi_count = count;
+ for (i=0 ; i<count ; i++) {
+ rdev = &obd_dev[*((int *)data + i)];
+ rdev = rdev + 1;
+ CDEBUG(D_INFO, "OBD RAID1: replicator %d is of type %s\n", i,
+ (rdev + i)->obd_type->typ_name);
+ }
+ return 0;
}
#endif
*/
int gen_multi_cleanup(struct obd_device *obddev)
{
- int i;
-
- for (i = 0 ; i < obddev->obd_multi_count ; i++ ) {
- struct obd_conn *ch_conn = &obddev->obd_multi_conn[i];
- int rc;
- rc = OBP(ch_conn->oc_dev, disconnect)(ch_conn);
-
- if ( rc != 0 ) {
- printk("OBD multi cleanup dev: disconnect failure %d\n", ch_conn->oc_dev->obd_minor);
- }
- }
- return 0;
+ int i;
+
+ for (i = 0 ; i < obddev->obd_multi_count ; i++ ) {
+ struct obd_conn *ch_conn = &obddev->obd_multi_conn[i];
+ int rc;
+ rc = OBP(ch_conn->oc_dev, disconnect)(ch_conn);
+
+ if ( rc != 0 ) {
+ printk(KERN_WARNING __FUNCTION__
+ ": disconnect failure %d\n",
+ ch_conn->oc_dev->obd_minor);
+ }
+ }
+ return 0;
} /* gen_multi_cleanup_device */
*/
int gen_cleanup(struct obd_device * obddev)
{
- struct list_head * lh, * tmp;
- struct obd_client * cli;
-
- ENTRY;
-
- lh = tmp = &obddev->obd_gen_clients;
- while ((tmp = tmp->next) != lh) {
- cli = list_entry(tmp, struct obd_client, cli_chain);
- CDEBUG(D_IOCTL, "Disconnecting obd_connection %d, at %p\n",
- cli->cli_id, cli);
- }
- return 0;
+ struct list_head * lh, * tmp;
+ struct obd_client * cli;
+
+ ENTRY;
+
+ lh = tmp = &obddev->obd_gen_clients;
+ while ((tmp = tmp->next) != lh) {
+ cli = list_entry(tmp, struct obd_client, cli_chain);
+ CDEBUG(D_INFO, "Disconnecting obd_connection %d, at %p\n",
+ cli->cli_id, cli);
+ }
+ return 0;
} /* sim_cleanup_device */
void ___wait_on_page(struct page *page)
___wait_on_page(page);
}
-/* XXX this should return errors correctly, so should migrate!!! */
int gen_copy_data(struct obd_conn *dst_conn, struct obdo *dst,
- struct obd_conn *src_conn, struct obdo *src,
- obd_size count, obd_off offset)
+ struct obd_conn *src_conn, struct obdo *src,
+ obd_size count, obd_off offset)
{
- struct page *page;
- unsigned long index = 0;
- int rc;
- ENTRY;
-
- CDEBUG(D_INODE, "src: ino %Ld blocks %Ld, size %Ld, dst: ino %Ld\n",
- src->o_id, src->o_blocks, src->o_size, dst->o_id);
- page = alloc_page(GFP_USER);
- if ( !page ) {
- EXIT;
- return -ENOMEM;
- }
-
- lck_page(page);
-
- while (index < ((src->o_size + PAGE_SIZE - 1) >> PAGE_SHIFT)) {
- obd_size count = PAGE_SIZE;
-
- page->index = index;
- rc = OBP(src_conn->oc_dev, brw)
- (READ, src_conn, src, (char *)page_address(page),
- &count, (page->index) << PAGE_SHIFT, 0);
-
- if ( rc != 0 )
- break;
- CDEBUG(D_INODE, "Read page %ld ...\n", page->index);
-
- rc = OBP(dst_conn->oc_dev, brw)
- (WRITE, dst_conn, dst, (char *)page_address(page),
- &count, (page->index) << PAGE_SHIFT, 1);
- if ( rc != 0)
- break;
-
- CDEBUG(D_INODE, "Wrote page %ld ...\n", page->index);
-
- index ++;
- }
- dst->o_size = src->o_size;
- dst->o_blocks = src->o_blocks;
- dst->o_valid |= (OBD_MD_FLSIZE | OBD_MD_FLBLOCKS);
- UnlockPage(page);
- __free_page(page);
-
- EXIT;
- return 0;
+ struct page *page;
+ unsigned long index = 0;
+ int err = 0;
+
+ ENTRY;
+ CDEBUG(D_INFO, "src: ino %Ld blocks %Ld, size %Ld, dst: ino %Ld\n",
+ src->o_id, src->o_blocks, src->o_size, dst->o_id);
+ page = alloc_page(GFP_USER);
+ if ( !page ) {
+ EXIT;
+ return -ENOMEM;
+ }
+
+ lck_page(page);
+
+ /* XXX with brw vector I/O, we could batch up reads and writes here,
+ * all we need to do is allocate multiple pages to handle the I/Os
+ * and arrays to handle the request parameters.
+ */
+ while (index < ((src->o_size + PAGE_SIZE - 1) >> PAGE_SHIFT)) {
+ obd_count num_oa = 1;
+ obd_count num_buf = 1;
+ char *buf;
+ obd_size brw_count = PAGE_SIZE;
+ obd_off brw_offset = (page->index) << PAGE_SHIFT;
+ obd_flag flagr = 0;
+ obd_flag flagw = OBD_BRW_CREATE;
+
+ page->index = index;
+ buf = (char *)page_address(page);
+ err = OBP(src_conn->oc_dev, brw)(READ, src_conn, num_oa, &src,
+ &num_buf, &buf, &brw_count,
+ &brw_offset, &flagr);
+
+ if ( err ) {
+ EXIT;
+ break;
+ }
+ CDEBUG(D_INFO, "Read page %ld ...\n", page->index);
+
+ err = OBP(dst_conn->oc_dev, brw)(WRITE, dst_conn, num_oa, &dst,
+ &num_buf, &buf, &brw_count,
+ &brw_offset, &flagw);
+
+ /* XXX should handle dst->o_size, dst->o_blocks here */
+ if ( err ) {
+ EXIT;
+ break;
+ }
+
+ CDEBUG(D_INFO, "Wrote page %ld ...\n", page->index);
+
+ index++;
+ }
+ dst->o_size = src->o_size;
+ dst->o_blocks = src->o_blocks;
+ dst->o_valid |= (OBD_MD_FLSIZE | OBD_MD_FLBLOCKS);
+ obd_unlock_page(page);
+ __free_page(page);
+
+ EXIT;
+ return err;
}