chiark / gitweb /
[PATCH] pass the whole event environment to udevd
[elogind.git] / udevdb.c
index e0bd39e84bb9a15529e3f945ab61e756fa0e5e54..fc579a94512155a514186347d20fed76d5a80e63 100644 (file)
--- a/udevdb.c
+++ b/udevdb.c
@@ -4,7 +4,7 @@
  * Userspace devfs
  *
  * Copyright (C) 2003 Greg Kroah-Hartman <greg@kroah.com>
- * Copyright (C) 2003 IBM Corp.
+ * Copyright (C) 2004 Kay Sievers <kay.sievers@vrfy.org>
  *
  *     This program is free software; you can redistribute it and/or modify it
  *     under the terms of the GNU General Public License as published by the
  *
  */
 
-/*
- * udev database library
- */
+
 #include <stdlib.h>
 #include <stdio.h>
+#include <string.h>
+#include <stddef.h>
 #include <fcntl.h>
 #include <string.h>
-#include <sys/stat.h>
 #include <errno.h>
-#include <signal.h>
+#include <dirent.h>
 
-#include "udev_version.h"
+#include "libsysfs/sysfs/libsysfs.h"
 #include "udev.h"
-#include "namedev.h"
+#include "udev_lib.h"
+#include "logging.h"
 #include "udevdb.h"
-#include "tdb/tdb.h"
-#include "libsysfs/libsysfs.h"
-
-static TDB_CONTEXT *udevdb;
 
+#define PATH_TO_NAME_CHAR              '@'
 
-int udevdb_add_dev(const char *path, const struct udevice *dev)
+static int get_db_filename(struct udevice *udev, char *filename, int len)
 {
-       TDB_DATA key, data;
-       char keystr[SYSFS_PATH_MAX];
-
-       if ((path == NULL) || (dev == NULL))
-               return -ENODEV;
-
-       memset(keystr, 0, NAME_SIZE);
-       strcpy(keystr, path);
-       key.dptr = keystr;
-       key.dsize = strlen(keystr) + 1;
+       char devpath[SYSFS_PATH_MAX];
+       char *pos;
+
+       /* replace '/' to transform path into a filename */
+       strfieldcpy(devpath, udev->devpath);
+       pos = strchr(&devpath[1], '/');
+       while (pos) {
+               pos[0] = PATH_TO_NAME_CHAR;
+               pos = strchr(&pos[1], '/');
+       }
+       snprintf(filename, len-1, "%s%s", udev_db_path, devpath);
+       filename[len-1] = '\0';
 
-       data.dptr = (void *)dev;
-       data.dsize = sizeof(*dev);
-       
-       return tdb_store(udevdb, key, data, TDB_REPLACE); 
+       return 0;
 }
 
-struct udevice *udevdb_get_dev(const char *path)
+int udevdb_add_dev(struct udevice *udev)
 {
-       TDB_DATA key, data;
-       struct udevice *dev;
+       char filename[SYSFS_PATH_MAX];
+       FILE *f;
+
+       if (udev->test_run)
+               return 0;
 
-       if (path == NULL)
-               return NULL;
+       get_db_filename(udev, filename, SYSFS_PATH_MAX);
 
-       key.dptr = (void *)path;
-       key.dsize = strlen(path) + 1;
+       create_path(filename);
 
-       data = tdb_fetch(udevdb, key);
-       if (data.dptr == NULL || data.dsize == 0)
-               return NULL;
+       f = fopen(filename, "w");
+       if (f == NULL) {
+               dbg("unable to create db file '%s'", filename);
+               return -1;
+       }
+       dbg("storing data for device '%s' in '%s'", udev->devpath, filename);
+
+       fprintf(f, "P:%s\n", udev->devpath);
+       fprintf(f, "N:%s\n", udev->name);
+       fprintf(f, "S:%s\n", udev->symlink);
+       fprintf(f, "A:%d\n", udev->partitions);
 
-       dev = malloc(sizeof(*dev));
-       if (dev == NULL)
-               goto exit;
+       fclose(f);
 
-       memcpy(dev, data.dptr, sizeof(*dev));
-exit:
-       free(data.dptr);
-       return dev;
+       return 0;
 }
 
-int udevdb_delete_dev(const char *path)
+static int parse_db_file(struct udevice *udev, const char *filename)
 {
-       TDB_DATA key;
-       char keystr[SYSFS_PATH_MAX];
+       char line[NAME_SIZE];
+       char *bufline;
+       char *buf;
+       size_t bufsize;
+       size_t cur;
+       size_t count;
+
+       if (file_map(filename, &buf, &bufsize) != 0) {
+               dbg("unable to read db file '%s'", filename);
+               return -1;
+       }
+
+       cur = 0;
+       while (cur < bufsize) {
+               count = buf_get_line(buf, bufsize, cur);
+               bufline = &buf[cur];
+               cur += count+1;
+
+               switch(bufline[0]) {
+               case 'P':
+                       if (count > DEVPATH_SIZE)
+                               count = DEVPATH_SIZE-1;
+                       strncpy(udev->devpath, &bufline[2], count-2);
+                       break;
+               case 'N':
+                       if (count > NAME_SIZE)
+                               count = NAME_SIZE-1;
+                       strncpy(udev->name, &bufline[2], count-2);
+                       break;
+               case 'S':
+                       if (count > NAME_SIZE)
+                               count = NAME_SIZE-1;
+                       strncpy(udev->symlink, &bufline[2], count-2);
+                       break;
+               case 'A':
+                       strfieldcpy(line, &bufline[2]);
+                       udev->partitions = atoi(line);
+                       break;
+               }
+       }
 
-       if (path == NULL)
-               return -EINVAL;
+       if (udev->name[0] == '\0')
+               return -1;
 
-       memset(keystr, 0, sizeof(keystr));
-       strcpy(keystr, path);
+       return 0;
+}
+
+int udevdb_get_dev(struct udevice *udev)
+{
+       char filename[SYSFS_PATH_MAX];
 
-       key.dptr = keystr;
-       key.dsize = strlen(keystr) + 1;
+       get_db_filename(udev, filename, SYSFS_PATH_MAX);
 
-       return tdb_delete(udevdb, key);
+       return parse_db_file(udev, filename);
 }
 
-/**
- * udevdb_exit: closes database
- */
-void udevdb_exit(void)
+int udevdb_delete_dev(struct udevice *udev)
 {
-       if (udevdb != NULL) {
-               tdb_close(udevdb);
-               udevdb = NULL;
-       }
+       char filename[SYSFS_PATH_MAX];
+
+       get_db_filename(udev, filename, SYSFS_PATH_MAX);
+       unlink(filename);
+
+       return 0;
 }
 
-/**
- * udevdb_init: initializes database
- * @init_flag: UDEVDB_INTERNAL - database stays in memory
- *            UDEVDB_DEFAULT - database is written to a file
- */
-int udevdb_init(int init_flag)
+int udevdb_get_dev_byname(struct udevice *udev, const char *name)
 {
-       if (init_flag != UDEVDB_DEFAULT && init_flag != UDEVDB_INTERNAL)
-               return -EINVAL;
-
-       udevdb = tdb_open(udev_db_filename, 0, init_flag, O_RDWR | O_CREAT, 0644);
-       if (udevdb == NULL) {
-               if (init_flag == UDEVDB_INTERNAL)
-                       dbg("unable to initialize in-memory database");
-               else
-                       dbg("unable to initialize database at '%s'", udev_db_filename);
-               return -EINVAL;
+       struct dirent *ent;
+       DIR *dir;
+       char filename[NAME_SIZE];
+       struct udevice db_udev;
+
+       dir = opendir(udev_db_path);
+       if (dir == NULL) {
+               dbg("unable to udev db '%s'", udev_db_path);
+               return -1;
+       }
+
+       while (1) {
+               ent = readdir(dir);
+               if (ent == NULL || ent->d_name[0] == '\0')
+                       break;
+
+               if (ent->d_name[0] == '.')
+                       continue;
+
+               snprintf(filename, NAME_SIZE-1, "%s/%s", udev_db_path, ent->d_name);
+               filename[NAME_SIZE-1] = '\0';
+
+               memset(&db_udev, 0x00, sizeof(struct udevice));
+               if (parse_db_file(&db_udev, filename) == 0) {
+                       char *pos;
+                       int len;
+
+                       if (strncmp(name, db_udev.name, NAME_SIZE) == 0) {
+                               goto found;
+                       }
+
+                       foreach_strpart(db_udev.symlink, " ", pos, len) {
+                               if (strncmp(name, pos, len) != 0)
+                                       continue;
+
+                               if (len == strlen(name))
+                                       goto found;
+                       }
+
+               }
        }
+
+       closedir(dir);
+
+       return -1;
+
+found:
+       closedir(dir);
+
+       strfieldcpy(udev->devpath, db_udev.devpath);
+       strfieldcpy(udev->name, db_udev.name);
+       strfieldcpy(udev->symlink, db_udev.symlink);
+       udev->partitions = db_udev.partitions;
+
        return 0;
 }