Use libhdb.

git-svn-id: svn://svn.h5l.se/heimdal/trunk/heimdal@1392 ec53bebd-3082-4978-b11e-865c3cabbd6b

admin/load.c

@@ -2,30 +2,36 @@
 
 RCSID("$Id$");
 
+struct entry{
+    char *principal;
+    char *key;
+    char *kvno;
+    char *max_life;
+    char *max_renew;
+};
+
 int main(int argc, char **argv)
 {
     FILE *f;
-    DB *db;
+    HDB *db;
     krb5_context context;
     char s[1024];
     char *p;
     int line;
-    unsigned char key_buf[1024];
-    unsigned char *q;
-    unsigned char value_buf[1024];
-    krb5_keyblock keyblock;
-    DBT key, value;
     int err;
     int i;
-    krb5_storage *sp;
 
     struct entry e;
+    hdb_entry ent;
 
-    krb5_principal princ;
     
     krb5_init_context(&context);
     f = fopen(argv[1], "r");
-    db = dbopen(argv[2], O_RDWR | O_CREAT | O_TRUNC, 0600, DB_BTREE, NULL);
+    err = hdb_open(context, &db, argv[2], O_RDWR | O_CREAT | O_TRUNC, 0600);
+    if(err){
+	fprintf(stderr, "hdb_open: %s\n", krb5_get_err_text(context, err));
+	exit(1);
+    }
     line = 0;
     while(fgets(s, sizeof(s), f)){
 	line++;
@@ -61,7 +67,7 @@ int main(int argc, char **argv)
 	    *p++;
 	*p++ = 0;
 
-	err = krb5_parse_name(context, e.principal, &princ);
+	err = krb5_parse_name(context, e.principal, &ent.principal);
 	if(err){
 	    fprintf(stderr, "%s:%s:%s (%s)\n", 
 		    argv[1], 
@@ -71,29 +77,17 @@ int main(int argc, char **argv)
 	    continue;
 	}
 	
-	sp = krb5_storage_from_mem(key_buf, sizeof(key_buf));
+	ent.keyblock.keytype = KEYTYPE_DES;
-	princ->type = 0;
+	ent.keyblock.contents.data = malloc(strlen(e.key)/2+1);
-	krb5_store_principal(sp, princ);
-	key.data = key_buf;
-	key.size = sp->seek(sp, 0, SEEK_CUR);
-	krb5_storage_free(sp);
-
-	keyblock.keytype = KEYTYPE_DES;
-	keyblock.contents.data = malloc(strlen(e.key)/2+1);
 	for(i = 0; i < strlen(e.key); i += 2){
 	    sscanf(e.key + i, "%2x", 
-		   (unsigned char *)keyblock.contents.data + (i/2));
+		   (unsigned char *)ent.keyblock.contents.data + (i/2));
 	}
-	keyblock.contents.length = i / 2;
+	ent.keyblock.contents.length = i / 2;
-	sp = krb5_storage_from_mem(value_buf, sizeof(value_buf));
+	ent.kvno = atoi(e.kvno);
-	krb5_store_keyblock(sp, keyblock);
+	ent.max_life = atoi(e.max_life);
-	krb5_store_int32(sp, atoi(e.kvno));
+	ent.max_renew = atoi(e.max_renew);
-	krb5_store_int32(sp, atoi(e.max_life));
+	db->store(context, db, &ent);
-	krb5_store_int32(sp, atoi(e.max_renew));
-	value.data = value_buf;
-	value.size = sp->seek(sp, 0, SEEK_CUR);
-	db->put(db, &key, &value, 0);
-	krb5_storage_free(sp);
     }
-    db->close(db);
+    db->close(context, db);
 }

kadmin/load.c

@@ -2,30 +2,36 @@
 
 RCSID("$Id$");
 
+struct entry{
+    char *principal;
+    char *key;
+    char *kvno;
+    char *max_life;
+    char *max_renew;
+};
+
 int main(int argc, char **argv)
 {
     FILE *f;
-    DB *db;
+    HDB *db;
     krb5_context context;
     char s[1024];
     char *p;
     int line;
-    unsigned char key_buf[1024];
-    unsigned char *q;
-    unsigned char value_buf[1024];
-    krb5_keyblock keyblock;
-    DBT key, value;
     int err;
     int i;
-    krb5_storage *sp;
 
     struct entry e;
+    hdb_entry ent;
 
-    krb5_principal princ;
     
     krb5_init_context(&context);
     f = fopen(argv[1], "r");
-    db = dbopen(argv[2], O_RDWR | O_CREAT | O_TRUNC, 0600, DB_BTREE, NULL);
+    err = hdb_open(context, &db, argv[2], O_RDWR | O_CREAT | O_TRUNC, 0600);
+    if(err){
+	fprintf(stderr, "hdb_open: %s\n", krb5_get_err_text(context, err));
+	exit(1);
+    }
     line = 0;
     while(fgets(s, sizeof(s), f)){
 	line++;
@@ -61,7 +67,7 @@ int main(int argc, char **argv)
 	    *p++;
 	*p++ = 0;
 
-	err = krb5_parse_name(context, e.principal, &princ);
+	err = krb5_parse_name(context, e.principal, &ent.principal);
 	if(err){
 	    fprintf(stderr, "%s:%s:%s (%s)\n", 
 		    argv[1], 
@@ -71,29 +77,17 @@ int main(int argc, char **argv)
 	    continue;
 	}
 	
-	sp = krb5_storage_from_mem(key_buf, sizeof(key_buf));
+	ent.keyblock.keytype = KEYTYPE_DES;
-	princ->type = 0;
+	ent.keyblock.contents.data = malloc(strlen(e.key)/2+1);
-	krb5_store_principal(sp, princ);
-	key.data = key_buf;
-	key.size = sp->seek(sp, 0, SEEK_CUR);
-	krb5_storage_free(sp);
-
-	keyblock.keytype = KEYTYPE_DES;
-	keyblock.contents.data = malloc(strlen(e.key)/2+1);
 	for(i = 0; i < strlen(e.key); i += 2){
 	    sscanf(e.key + i, "%2x", 
-		   (unsigned char *)keyblock.contents.data + (i/2));
+		   (unsigned char *)ent.keyblock.contents.data + (i/2));
 	}
-	keyblock.contents.length = i / 2;
+	ent.keyblock.contents.length = i / 2;
-	sp = krb5_storage_from_mem(value_buf, sizeof(value_buf));
+	ent.kvno = atoi(e.kvno);
-	krb5_store_keyblock(sp, keyblock);
+	ent.max_life = atoi(e.max_life);
-	krb5_store_int32(sp, atoi(e.kvno));
+	ent.max_renew = atoi(e.max_renew);
-	krb5_store_int32(sp, atoi(e.max_life));
+	db->store(context, db, &ent);
-	krb5_store_int32(sp, atoi(e.max_renew));
-	value.data = value_buf;
-	value.size = sp->seek(sp, 0, SEEK_CUR);
-	db->put(db, &key, &value, 0);
-	krb5_storage_free(sp);
     }
-    db->close(db);
+    db->close(context, db);
 }

kdc/kdc.c

@@ -5,44 +5,17 @@ RCSID("$Id$");
 struct timeval now;
 #define kdc_time now.tv_sec
 
-struct db_entry*
+hdb_entry*
 db_fetch(krb5_context context, PrincipalName *principal, char *realm)
 {
-    DB *db;
+    HDB *db;
-    DBT key, value;
+    hdb_entry *ent;
-    krb5_data data;
-    krb5_storage *sp;
-    struct db_entry *ent;
-    int32_t tmp;
-    int i;
 
-    ent = malloc(sizeof(struct db_entry));
+    ent = malloc(sizeof(*ent));
     principalname2krb5_principal(&ent->principal, *principal, realm);
-
+    hdb_open(context, &db, NULL, O_RDONLY, 0);
-    sp = krb5_storage_emem();
+    db->fetch(context, db, ent);
-    ent->principal->type = 0;
+    db->close(context, db);
-    krb5_store_principal(sp, ent->principal);
-    krb5_storage_to_data(sp, &data);
-    krb5_storage_free(sp);
-    key.data = data.data;
-    key.size = data.length;
-    
-    db = dbopen("foo.db", O_RDONLY, 0, DB_BTREE, NULL);
-    if(db->get(db, &key, &value, 0)){
-	db->close(db);
-	return NULL;
-    }
-    krb5_data_free(&data);
-    sp = krb5_storage_from_mem(value.data, value.size);
-    krb5_ret_keyblock(sp, &ent->keyblock);
-    krb5_ret_int32(sp, &tmp);
-    ent->kvno = tmp;
-    krb5_ret_int32(sp, &tmp);
-    ent->max_life = tmp;
-    krb5_ret_int32(sp, &tmp);
-    ent->max_renew = tmp;
-    krb5_storage_free(sp);
-    db->close(db);
     return ent;
 }
 
@@ -93,7 +66,7 @@ as_rep(krb5_context context,
 {
     KDCOptions f = req->req_body.kdc_options;
     KDC_REQ_BODY *b = &req->req_body;
-    struct db_entry *client, *server;
+    hdb_entry *client, *server;
     int use_etype;
     EncTicketPart *et = calloc(1, sizeof(*et));
     EncKDCRepPart *ek = calloc(1, sizeof(*ek));
@@ -235,7 +208,7 @@ tgs_rep(krb5_context context,
     KDC_REQ_BODY *b = &req->req_body;
     KDCOptions f = req->req_body.kdc_options;
     EncTicketPart *tgt;
-    struct db_entry *server, *krbtgt, *client;
+    hdb_entry *server, *krbtgt, *client;
     EncTicketPart *et = calloc(1, sizeof(*et));
     EncKDCRepPart *ek = calloc(1, sizeof(*ek));
     
@@ -250,7 +223,7 @@ tgs_rep(krb5_context context,
 	krb5_flags ap_req_options;
 	krb5_ticket *ticket;
 	krb5_error_code err;
-	struct db_entry *ent;
+	hdb_entry *ent;
 
 	err = krb5_build_principal(context,
 				   &princ,
@@ -479,14 +452,12 @@ process_request(krb5_context context,
     krb5_principal princ;
     unsigned char key_buf[1024];
     unsigned char *q;
-    DB *db;
-    DBT key, value;
 
     
     KDC_REP rep;
 
 
-    struct db_entry *cname, *sname;
+    hdb_entry *cname, *sname;
     
     gettimeofday(&now, NULL);
 

kdc/kerberos5.c

@@ -5,44 +5,17 @@ RCSID("$Id$");
 struct timeval now;
 #define kdc_time now.tv_sec
 
-struct db_entry*
+hdb_entry*
 db_fetch(krb5_context context, PrincipalName *principal, char *realm)
 {
-    DB *db;
+    HDB *db;
-    DBT key, value;
+    hdb_entry *ent;
-    krb5_data data;
-    krb5_storage *sp;
-    struct db_entry *ent;
-    int32_t tmp;
-    int i;
 
-    ent = malloc(sizeof(struct db_entry));
+    ent = malloc(sizeof(*ent));
     principalname2krb5_principal(&ent->principal, *principal, realm);
-
+    hdb_open(context, &db, NULL, O_RDONLY, 0);
-    sp = krb5_storage_emem();
+    db->fetch(context, db, ent);
-    ent->principal->type = 0;
+    db->close(context, db);
-    krb5_store_principal(sp, ent->principal);
-    krb5_storage_to_data(sp, &data);
-    krb5_storage_free(sp);
-    key.data = data.data;
-    key.size = data.length;
-    
-    db = dbopen("foo.db", O_RDONLY, 0, DB_BTREE, NULL);
-    if(db->get(db, &key, &value, 0)){
-	db->close(db);
-	return NULL;
-    }
-    krb5_data_free(&data);
-    sp = krb5_storage_from_mem(value.data, value.size);
-    krb5_ret_keyblock(sp, &ent->keyblock);
-    krb5_ret_int32(sp, &tmp);
-    ent->kvno = tmp;
-    krb5_ret_int32(sp, &tmp);
-    ent->max_life = tmp;
-    krb5_ret_int32(sp, &tmp);
-    ent->max_renew = tmp;
-    krb5_storage_free(sp);
-    db->close(db);
     return ent;
 }
 
@@ -93,7 +66,7 @@ as_rep(krb5_context context,
 {
     KDCOptions f = req->req_body.kdc_options;
     KDC_REQ_BODY *b = &req->req_body;
-    struct db_entry *client, *server;
+    hdb_entry *client, *server;
     int use_etype;
     EncTicketPart *et = calloc(1, sizeof(*et));
     EncKDCRepPart *ek = calloc(1, sizeof(*ek));
@@ -235,7 +208,7 @@ tgs_rep(krb5_context context,
     KDC_REQ_BODY *b = &req->req_body;
     KDCOptions f = req->req_body.kdc_options;
     EncTicketPart *tgt;
-    struct db_entry *server, *krbtgt, *client;
+    hdb_entry *server, *krbtgt, *client;
     EncTicketPart *et = calloc(1, sizeof(*et));
     EncKDCRepPart *ek = calloc(1, sizeof(*ek));
     
@@ -250,7 +223,7 @@ tgs_rep(krb5_context context,
 	krb5_flags ap_req_options;
 	krb5_ticket *ticket;
 	krb5_error_code err;
-	struct db_entry *ent;
+	hdb_entry *ent;
 
 	err = krb5_build_principal(context,
 				   &princ,
@@ -479,14 +452,12 @@ process_request(krb5_context context,
     krb5_principal princ;
     unsigned char key_buf[1024];
     unsigned char *q;
-    DB *db;
-    DBT key, value;
 
     
     KDC_REP rep;
 
 
-    struct db_entry *cname, *sname;
+    hdb_entry *cname, *sname;
     
     gettimeofday(&now, NULL);
 

kdc/load.c

@@ -2,30 +2,36 @@
 
 RCSID("$Id$");
 
+struct entry{
+    char *principal;
+    char *key;
+    char *kvno;
+    char *max_life;
+    char *max_renew;
+};
+
 int main(int argc, char **argv)
 {
     FILE *f;
-    DB *db;
+    HDB *db;
     krb5_context context;
     char s[1024];
     char *p;
     int line;
-    unsigned char key_buf[1024];
-    unsigned char *q;
-    unsigned char value_buf[1024];
-    krb5_keyblock keyblock;
-    DBT key, value;
     int err;
     int i;
-    krb5_storage *sp;
 
     struct entry e;
+    hdb_entry ent;
 
-    krb5_principal princ;
     
     krb5_init_context(&context);
     f = fopen(argv[1], "r");
-    db = dbopen(argv[2], O_RDWR | O_CREAT | O_TRUNC, 0600, DB_BTREE, NULL);
+    err = hdb_open(context, &db, argv[2], O_RDWR | O_CREAT | O_TRUNC, 0600);
+    if(err){
+	fprintf(stderr, "hdb_open: %s\n", krb5_get_err_text(context, err));
+	exit(1);
+    }
     line = 0;
     while(fgets(s, sizeof(s), f)){
 	line++;
@@ -61,7 +67,7 @@ int main(int argc, char **argv)
 	    *p++;
 	*p++ = 0;
 
-	err = krb5_parse_name(context, e.principal, &princ);
+	err = krb5_parse_name(context, e.principal, &ent.principal);
 	if(err){
 	    fprintf(stderr, "%s:%s:%s (%s)\n", 
 		    argv[1], 
@@ -71,29 +77,17 @@ int main(int argc, char **argv)
 	    continue;
 	}
 	
-	sp = krb5_storage_from_mem(key_buf, sizeof(key_buf));
+	ent.keyblock.keytype = KEYTYPE_DES;
-	princ->type = 0;
+	ent.keyblock.contents.data = malloc(strlen(e.key)/2+1);
-	krb5_store_principal(sp, princ);
-	key.data = key_buf;
-	key.size = sp->seek(sp, 0, SEEK_CUR);
-	krb5_storage_free(sp);
-
-	keyblock.keytype = KEYTYPE_DES;
-	keyblock.contents.data = malloc(strlen(e.key)/2+1);
 	for(i = 0; i < strlen(e.key); i += 2){
 	    sscanf(e.key + i, "%2x", 
-		   (unsigned char *)keyblock.contents.data + (i/2));
+		   (unsigned char *)ent.keyblock.contents.data + (i/2));
 	}
-	keyblock.contents.length = i / 2;
+	ent.keyblock.contents.length = i / 2;
-	sp = krb5_storage_from_mem(value_buf, sizeof(value_buf));
+	ent.kvno = atoi(e.kvno);
-	krb5_store_keyblock(sp, keyblock);
+	ent.max_life = atoi(e.max_life);
-	krb5_store_int32(sp, atoi(e.kvno));
+	ent.max_renew = atoi(e.max_renew);
-	krb5_store_int32(sp, atoi(e.max_life));
+	db->store(context, db, &ent);
-	krb5_store_int32(sp, atoi(e.max_renew));
-	value.data = value_buf;
-	value.size = sp->seek(sp, 0, SEEK_CUR);
-	db->put(db, &key, &value, 0);
-	krb5_storage_free(sp);
     }
-    db->close(db);
+    db->close(context, db);
 }