mirror of
https://codeberg.org/scip/pcp.git
synced 2025-12-17 12:00:56 +01:00
moved to ../include/pcp/
This commit is contained in:
@@ -1,55 +0,0 @@
|
|||||||
/*
|
|
||||||
This file is part of Pretty Curved Privacy (pcp1).
|
|
||||||
|
|
||||||
Copyright (C) 2013 T.Linden.
|
|
||||||
|
|
||||||
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 Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
You can contact me by mail: <tlinden AT cpan DOT org>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#ifndef _HAVE_PCP_CRYPTO_H
|
|
||||||
#define _HAVE_PCP_CRYPTO_H
|
|
||||||
|
|
||||||
#include <sodium.h>
|
|
||||||
#include <string.h>
|
|
||||||
#include <stdio.h>
|
|
||||||
#include <sodium.h>
|
|
||||||
#include <stdlib.h>
|
|
||||||
|
|
||||||
#include "defines.h"
|
|
||||||
#include "mem.h"
|
|
||||||
#include "key.h"
|
|
||||||
|
|
||||||
size_t pcp_sodium_box(unsigned char **cipher,
|
|
||||||
unsigned char *cleartext,
|
|
||||||
size_t clearsize,
|
|
||||||
unsigned char *nonce,
|
|
||||||
unsigned char *secret,
|
|
||||||
unsigned char *public);
|
|
||||||
|
|
||||||
int pcp_sodium_verify_box(unsigned char **cleartext, unsigned char* message,
|
|
||||||
size_t messagesize, unsigned char *nonce,
|
|
||||||
unsigned char *secret, unsigned char *public);
|
|
||||||
|
|
||||||
unsigned char *pcp_box_encrypt(pcp_key_t *secret, pcp_pubkey_t *public,
|
|
||||||
unsigned char *message, size_t messagesize,
|
|
||||||
size_t *csize);
|
|
||||||
|
|
||||||
unsigned char *pcp_box_decrypt(pcp_key_t *secret, pcp_pubkey_t *public,
|
|
||||||
unsigned char *cipher, size_t ciphersize,
|
|
||||||
size_t *dsize);
|
|
||||||
|
|
||||||
#endif // _HAVE_PCP_CRYPTO_H
|
|
||||||
@@ -1,75 +0,0 @@
|
|||||||
/*
|
|
||||||
This file is part of Pretty Curved Privacy (pcp1).
|
|
||||||
|
|
||||||
Copyright (C) 2013 T.Linden.
|
|
||||||
|
|
||||||
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 Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
You can contact me by mail: <tlinden AT cpan DOT org>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#ifndef _DEFINES_H
|
|
||||||
#define _DEFINES_H
|
|
||||||
|
|
||||||
typedef unsigned char byte; // Single unsigned byte = 8 bits
|
|
||||||
typedef unsigned short dbyte; // Double byte = 16 bits
|
|
||||||
typedef unsigned int qbyte; // Quad byte = 32 bits
|
|
||||||
|
|
||||||
// key stuff
|
|
||||||
#define PCP_KEY_HEADER "----- BEGIN PCP SECRET KEY -----"
|
|
||||||
#define PCP_KEY_FOOTER "------ END PCP SECRET KEY ------"
|
|
||||||
|
|
||||||
#define PCP_PUBKEY_HEADER "----- BEGIN PCP PUBLIC KEY -----"
|
|
||||||
#define PCP_PUBKEY_FOOTER "------ END PCP PUBLICKEY ------"
|
|
||||||
|
|
||||||
#define PCP_ENFILE_HEADER "----- BEGIN PCP ENCRYPTED FILE -----"
|
|
||||||
#define PCP_ENFILE_FOOTER "------ END PCP ENCRYPTED FILE ------"
|
|
||||||
|
|
||||||
#define PCP_ZFILE_HEADER "----- BEGIN Z85 ENCODED FILE -----"
|
|
||||||
#define PCP_ZFILE_FOOTER "------ END Z85 ENCODED FILE ------"
|
|
||||||
|
|
||||||
#define PCP_ME "Pretty Curved Privacy"
|
|
||||||
|
|
||||||
#define PCP_KEY_VERSION 0x00000001U
|
|
||||||
#define PCP_KEY_PRIMITIVE "CURVE25519-ED25519-SALSA20-POLY1305"
|
|
||||||
|
|
||||||
#define PCP_KEY_TYPE_MAINSECRET 0x01
|
|
||||||
#define PCP_KEY_TYPE_SECRET 0x02
|
|
||||||
#define PCP_KEY_TYPE_PUBLIC 0x03
|
|
||||||
|
|
||||||
// how many times do we hash a passphrase
|
|
||||||
#define HCYCLES 128000
|
|
||||||
|
|
||||||
// save typing, dammit
|
|
||||||
#define PCP_ENCRYPT_PAD crypto_secretbox_ZEROBYTES + crypto_secretbox_NONCEBYTES
|
|
||||||
|
|
||||||
// vault id
|
|
||||||
#define PCP_VAULT_ID 0xC4
|
|
||||||
#define PCP_VAULT_VERSION 0x01
|
|
||||||
|
|
||||||
char *PCP_ERR;
|
|
||||||
byte PCP_ERRSET;
|
|
||||||
int PCP_EXIT;
|
|
||||||
|
|
||||||
//set error
|
|
||||||
void fatal(const char * fmt, ...);
|
|
||||||
|
|
||||||
// fetch error
|
|
||||||
void fatals_ifany();
|
|
||||||
|
|
||||||
// reset
|
|
||||||
void fatals_reset();
|
|
||||||
|
|
||||||
#endif // _DEFINES_H
|
|
||||||
@@ -1,43 +0,0 @@
|
|||||||
/* -*- c++ -*- */
|
|
||||||
/*
|
|
||||||
* Copyright 2005,2011 Free Software Foundation, Inc.
|
|
||||||
*
|
|
||||||
* This file is part of GNU Radio
|
|
||||||
*
|
|
||||||
* GNU Radio is free software; you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by
|
|
||||||
* the Free Software Foundation; either version 3, or (at your option)
|
|
||||||
* any later version.
|
|
||||||
*
|
|
||||||
* GNU Radio is distributed in the hope that it will be useful,
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
* GNU General Public License for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License
|
|
||||||
* along with GNU Radio; see the file COPYING. If not, write to
|
|
||||||
* the Free Software Foundation, Inc., 51 Franklin Street,
|
|
||||||
* Boston, MA 02110-1301, USA.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#ifndef INCLUDED_DIGITAL_CRC32_H
|
|
||||||
#define INCLUDED_DIGITAL_CRC32_H
|
|
||||||
|
|
||||||
#include <stdlib.h>
|
|
||||||
|
|
||||||
/*!
|
|
||||||
* \brief update running CRC-32
|
|
||||||
* \ingroup misc
|
|
||||||
*
|
|
||||||
* Update a running CRC with the bytes buf[0..len-1] The CRC should be
|
|
||||||
* initialized to all 1's, and the transmitted value is the 1's
|
|
||||||
* complement of the final running CRC. The resulting CRC should be
|
|
||||||
* transmitted in big endian order.
|
|
||||||
*/
|
|
||||||
unsigned int
|
|
||||||
digital_update_crc32(unsigned int crc, const unsigned char *buf, size_t len);
|
|
||||||
|
|
||||||
unsigned int
|
|
||||||
digital_crc32(const unsigned char *buf, size_t len);
|
|
||||||
|
|
||||||
#endif /* INCLUDED_CRC32_H */
|
|
||||||
@@ -1,22 +0,0 @@
|
|||||||
#ifndef _HAVE_PCP_GETPASS
|
|
||||||
#define _HAVE_PCP_GETPASS
|
|
||||||
|
|
||||||
/*
|
|
||||||
* (unportable) functions to turn on/off terminal echo
|
|
||||||
* using termios functions. might compile however on
|
|
||||||
* most unices, tested on FreeBSD only.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#include <unistd.h>
|
|
||||||
#include <stdio.h>
|
|
||||||
#include <stdlib.h>
|
|
||||||
#include <termios.h>
|
|
||||||
|
|
||||||
|
|
||||||
void pcp_echo_off();
|
|
||||||
void pcp_echo_on();
|
|
||||||
char *pcp_get_stdin();
|
|
||||||
char *pcp_get_passphrase(char *prompt);
|
|
||||||
|
|
||||||
#endif // _HAVE_PCP_GETPASS
|
|
||||||
@@ -1,25 +0,0 @@
|
|||||||
#ifndef _HAVE_JENHASH_H
|
|
||||||
#define _HAVE_JENHASH_H
|
|
||||||
|
|
||||||
// Bob Jenkins 32bit hash function
|
|
||||||
// via: http://eternallyconfuzzled.com/tuts/algorithms/jsw_tut_hashing.aspx
|
|
||||||
|
|
||||||
#define jen_mix(a,b,c) \
|
|
||||||
{ \
|
|
||||||
a -= b; a -= c; a ^= ( c >> 13 ); \
|
|
||||||
b -= c; b -= a; b ^= ( a << 8 ); \
|
|
||||||
c -= a; c -= b; c ^= ( b >> 13 ); \
|
|
||||||
a -= b; a -= c; a ^= ( c >> 12 ); \
|
|
||||||
b -= c; b -= a; b ^= ( a << 16 ); \
|
|
||||||
c -= a; c -= b; c ^= ( b >> 5 ); \
|
|
||||||
a -= b; a -= c; a ^= ( c >> 3 ); \
|
|
||||||
b -= c; b -= a; b ^= ( a << 10 ); \
|
|
||||||
c -= a; c -= b; c ^= ( b >> 15 ); \
|
|
||||||
}
|
|
||||||
|
|
||||||
#define JEN_PSALT 0xD9A03
|
|
||||||
#define JEN_SSALT 0xC503B
|
|
||||||
|
|
||||||
unsigned jen_hash ( unsigned char *k, unsigned length, unsigned initval );
|
|
||||||
|
|
||||||
#endif // _HAVE_JENHASH_H
|
|
||||||
159
libpcp/key.h
159
libpcp/key.h
@@ -1,159 +0,0 @@
|
|||||||
/*
|
|
||||||
This file is part of Pretty Curved Privacy (pcp1).
|
|
||||||
|
|
||||||
Copyright (C) 2013 T.Linden.
|
|
||||||
|
|
||||||
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 Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
You can contact me by mail: <tlinden AT cpan DOT org>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#ifndef _HAVE_PCP_KEYPAIR_H
|
|
||||||
#define _HAVE_PCP_KEYPAIR_H
|
|
||||||
|
|
||||||
#ifdef __cplusplus
|
|
||||||
extern "C" {
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#include <sodium.h>
|
|
||||||
#include <string.h>
|
|
||||||
#include <stdio.h>
|
|
||||||
#include <time.h>
|
|
||||||
|
|
||||||
#include "defines.h"
|
|
||||||
#include "platform.h"
|
|
||||||
#include "mem.h"
|
|
||||||
#include "mac.h"
|
|
||||||
#include "randomart.h"
|
|
||||||
#include "version.h"
|
|
||||||
#include "z85.h"
|
|
||||||
#include "uthash.h"
|
|
||||||
#include "jenhash.h"
|
|
||||||
|
|
||||||
/*
|
|
||||||
PCP private key structure. Most fields are self explanatory.
|
|
||||||
Some notes:
|
|
||||||
|
|
||||||
'encrypted' contains the encrypted secret key. If it's set,
|
|
||||||
the field 'secret' which contains the clear secret key will
|
|
||||||
be zeroed with random values, the first byte will be 0.
|
|
||||||
|
|
||||||
'nonce' contains the nonce required to decrypt the encrypted
|
|
||||||
secret, if set.
|
|
||||||
|
|
||||||
'serial' is a random number.
|
|
||||||
|
|
||||||
'id' is a string containing the hex values of the CRC32 checksum
|
|
||||||
of the public and secret key.
|
|
||||||
|
|
||||||
Upon creation everything will be filled with random bytes.
|
|
||||||
String fields will contain a string followed by 0 followed
|
|
||||||
by the rest of the pre-filled random bytes. To denote a string
|
|
||||||
field as empty, the first byte will be set to 0.
|
|
||||||
|
|
||||||
There are dynamically calculated attributes as well:
|
|
||||||
|
|
||||||
'checksum' is a 256 bit SHA hash of the public key returned
|
|
||||||
by pcpkey_getchecksum() or pcppubkey_getchecksum().
|
|
||||||
|
|
||||||
'random id' is a random art ascii image returned by
|
|
||||||
pcppubkey_get_art() or pcpkey_get_art(), calculated from
|
|
||||||
the public key.
|
|
||||||
|
|
||||||
If exported to a single file or printed, the structure will
|
|
||||||
be encoded using Z85 encoding.
|
|
||||||
|
|
||||||
*/
|
|
||||||
struct _pcp_key_t {
|
|
||||||
byte public[32];
|
|
||||||
byte secret[32];
|
|
||||||
byte nonce[24];
|
|
||||||
byte encrypted[48];
|
|
||||||
char owner[255];
|
|
||||||
char mail[255];
|
|
||||||
char id[17];
|
|
||||||
long ctime;
|
|
||||||
uint32_t version;
|
|
||||||
uint32_t serial;
|
|
||||||
uint8_t type;
|
|
||||||
UT_hash_handle hh;
|
|
||||||
};
|
|
||||||
|
|
||||||
struct _pcp_pubkey_t {
|
|
||||||
byte public[32];
|
|
||||||
char owner[255];
|
|
||||||
char mail[255];
|
|
||||||
char id[17];
|
|
||||||
long ctime;
|
|
||||||
uint32_t version;
|
|
||||||
uint32_t serial;
|
|
||||||
uint8_t type;
|
|
||||||
UT_hash_handle hh;
|
|
||||||
};
|
|
||||||
|
|
||||||
typedef struct _pcp_key_t pcp_key_t;
|
|
||||||
typedef struct _pcp_pubkey_t pcp_pubkey_t;
|
|
||||||
|
|
||||||
pcp_key_t *pcpkey_hash;
|
|
||||||
pcp_pubkey_t *pcppubkey_hash;
|
|
||||||
|
|
||||||
void pcp_cleanhashes();
|
|
||||||
pcp_key_t *pcpkey_new ();
|
|
||||||
|
|
||||||
char *pcppubkey_get_art(pcp_pubkey_t *k);
|
|
||||||
char *pcpkey_get_art(pcp_key_t *k);
|
|
||||||
|
|
||||||
pcp_key_t *pcpkey_encrypt(pcp_key_t *key, char *passphrase);
|
|
||||||
pcp_key_t *pcpkey_decrypt(pcp_key_t *key, char *passphrase);
|
|
||||||
pcp_pubkey_t *pcpkey_pub_from_secret(pcp_key_t *key);
|
|
||||||
char *pcp_getkeyid(pcp_key_t *k);
|
|
||||||
unsigned char *pcppubkey_getchecksum(pcp_pubkey_t *k);
|
|
||||||
unsigned char *pcpkey_getchecksum(pcp_key_t *k);
|
|
||||||
void pcp_inithashes();
|
|
||||||
|
|
||||||
pcp_key_t *pcpkey_exists(char *id);
|
|
||||||
pcp_pubkey_t *pcppubkey_exists(char *id);
|
|
||||||
|
|
||||||
pcp_key_t * key2be(pcp_key_t *k);
|
|
||||||
pcp_key_t *key2native(pcp_key_t *k);
|
|
||||||
pcp_pubkey_t * pubkey2be(pcp_pubkey_t *k);
|
|
||||||
pcp_pubkey_t *pubkey2native(pcp_pubkey_t *k);
|
|
||||||
|
|
||||||
unsigned char * pcp_gennonce();
|
|
||||||
|
|
||||||
void pcpedit_key(char *keyid);
|
|
||||||
|
|
||||||
// proprietary key derivation function. derives an
|
|
||||||
// secure encryption key from the given passphrase by
|
|
||||||
// calculating a SALSA20 hash from it HCYCLES times.
|
|
||||||
//
|
|
||||||
// turns the result into a proper CURVE25519 secret
|
|
||||||
// key. allocates memory for key and it is up to the
|
|
||||||
// user to free it after use.
|
|
||||||
//
|
|
||||||
// deprecation warning: maybe removed once the libsodium
|
|
||||||
// developers incorporated some key derivation function
|
|
||||||
// into libsodium. so far, there's none but word goes
|
|
||||||
// that perhaps something like scrypt() from the star
|
|
||||||
// distribution may be added in the future.
|
|
||||||
unsigned char *pcp_derivekey(char *passphrase);
|
|
||||||
|
|
||||||
pcp_key_t *pcp_derive_pcpkey (pcp_key_t *ours, char *theirs);
|
|
||||||
|
|
||||||
#ifdef __cplusplus
|
|
||||||
}
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#endif // _HAVE_PCP_KEYPAIR_H
|
|
||||||
75
libpcp/mac.h
75
libpcp/mac.h
@@ -1,75 +0,0 @@
|
|||||||
/*
|
|
||||||
This file is part of Pretty Curved Privacy (pcp1).
|
|
||||||
|
|
||||||
Copyright (C) 2013 T.Linden.
|
|
||||||
|
|
||||||
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 Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
You can contact me by mail: <tlinden AT cpan DOT org>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#ifndef _HAVE_PCP_MAC
|
|
||||||
#define _HAVE_PCP_MAC
|
|
||||||
|
|
||||||
#include <strings.h>
|
|
||||||
#include <stdlib.h>
|
|
||||||
#include <errno.h>
|
|
||||||
#include <sodium.h>
|
|
||||||
#include "pad.h"
|
|
||||||
#include "mem.h"
|
|
||||||
|
|
||||||
|
|
||||||
// how many times do we hash the passphrase
|
|
||||||
#define HCYCLES 128000
|
|
||||||
|
|
||||||
// encrypt some arbitrary cleartext using
|
|
||||||
// a curve25519 secret key and a given nonce.
|
|
||||||
//
|
|
||||||
// expects a pointer to the target binary
|
|
||||||
// stream containing the encrypted data,
|
|
||||||
// the cleartext string, its size, the nonce
|
|
||||||
// (24 bytes) and the secret key (32 bytes).
|
|
||||||
//
|
|
||||||
// allocates memory for the returned cipher
|
|
||||||
// and it is up to the user to free it after use.
|
|
||||||
//
|
|
||||||
// returns the size of the returned cipherstream.
|
|
||||||
// in case of an error, the cipher will be set
|
|
||||||
// to NULL.
|
|
||||||
size_t pcp_sodium_mac(unsigned char **cipher,
|
|
||||||
unsigned char *cleartext,
|
|
||||||
size_t clearsize,
|
|
||||||
unsigned char *nonce,
|
|
||||||
unsigned char *key);
|
|
||||||
|
|
||||||
// does the opposite of pcp_sodium_mac and decrypts
|
|
||||||
// a given encrypted binary stream using a nonce and
|
|
||||||
// a secret key (sizes: see above).
|
|
||||||
//
|
|
||||||
// allocates memory for the returned cleartext and
|
|
||||||
// it is up to the user to free it after use.
|
|
||||||
//
|
|
||||||
// returns 0 if decryption and verification were
|
|
||||||
// successful, otherwise -1.
|
|
||||||
int pcp_sodium_verify_mac(unsigned char **cleartext,
|
|
||||||
unsigned char* message,
|
|
||||||
size_t messagesize,
|
|
||||||
unsigned char *nonce,
|
|
||||||
unsigned char *key);
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
#endif // _HAVE_PCP_MAC
|
|
||||||
47
libpcp/mem.h
47
libpcp/mem.h
@@ -1,47 +0,0 @@
|
|||||||
/*
|
|
||||||
This file is part of Pretty Curved Privacy (pcp1).
|
|
||||||
|
|
||||||
Copyright (C) 2013 T.Linden.
|
|
||||||
|
|
||||||
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 Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
You can contact me by mail: <tlinden AT cpan DOT org>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#ifndef _HAVE_PCP_MEM
|
|
||||||
#define _HAVE_PCP_MEM
|
|
||||||
|
|
||||||
#include <string.h>
|
|
||||||
#include <stdlib.h>
|
|
||||||
#include <errno.h>
|
|
||||||
#include <err.h>
|
|
||||||
#include "platform.h"
|
|
||||||
|
|
||||||
// simple malloc() wrapper
|
|
||||||
// behaves like calloc(), which
|
|
||||||
// I don't have here.
|
|
||||||
//
|
|
||||||
// exits if there's no more memory
|
|
||||||
// available.
|
|
||||||
void *ucmalloc(size_t s);
|
|
||||||
|
|
||||||
// the same but it fills the pointer with random values
|
|
||||||
void *urmalloc(size_t s);
|
|
||||||
|
|
||||||
// dito.
|
|
||||||
void *ucfree(void *ptr);
|
|
||||||
|
|
||||||
|
|
||||||
#endif // _HAVE_PCP_MEM
|
|
||||||
98
libpcp/pad.h
98
libpcp/pad.h
@@ -1,98 +0,0 @@
|
|||||||
/*
|
|
||||||
This file is part of Pretty Curved Privacy (pcp1).
|
|
||||||
|
|
||||||
Copyright (C) 2013 T.Linden.
|
|
||||||
|
|
||||||
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 Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
You can contact me by mail: <tlinden AT cpan DOT org>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#ifndef _HAVE_PCP_ZPADDING
|
|
||||||
#define _HAVE_PCP_ZPADDING
|
|
||||||
|
|
||||||
#include <stdio.h>
|
|
||||||
#include <string.h>
|
|
||||||
#include <stdlib.h>
|
|
||||||
#include <stdlib.h>
|
|
||||||
#include <limits.h>
|
|
||||||
|
|
||||||
#include "mem.h"
|
|
||||||
|
|
||||||
#ifdef DEBUG
|
|
||||||
#define ZPADCHAR 48
|
|
||||||
#else
|
|
||||||
#define ZPADCHAR 0
|
|
||||||
#endif
|
|
||||||
|
|
||||||
// prepends a binary stream with a number of
|
|
||||||
// \0's as required by the secret_box and
|
|
||||||
// secret_box_open functions of libsodium.
|
|
||||||
//
|
|
||||||
// parameters:
|
|
||||||
//
|
|
||||||
// padded: destination array (ref)
|
|
||||||
// unpadded: source array without padding
|
|
||||||
// padlen: length of padding
|
|
||||||
// unpadlen: length of source array
|
|
||||||
//
|
|
||||||
// turns "efa5" into "00000000efa5" with padlen 8
|
|
||||||
//
|
|
||||||
// if DEBUG is set, destination will be padded with
|
|
||||||
// the character '0', NOT the integer 0.
|
|
||||||
//
|
|
||||||
// allocates memory for padded and it is up to the
|
|
||||||
// user to free it after use.
|
|
||||||
//
|
|
||||||
// sample call:
|
|
||||||
//
|
|
||||||
// char unpadded[] = {0xef, 0xa5};
|
|
||||||
// unsigned char *padded;
|
|
||||||
// pcp_pad_prepend(&padded, unpadded, 8, 2);
|
|
||||||
//
|
|
||||||
// the result, padded, would be 10 bytes long, 8
|
|
||||||
// bytes for the leading zeros and 2 for the content
|
|
||||||
// of the original unpadded.
|
|
||||||
void pcp_pad_prepend(unsigned char **padded, unsigned char *unpadded,
|
|
||||||
size_t padlen, size_t unpadlen);
|
|
||||||
|
|
||||||
// removes zero's of a binary stream, which is
|
|
||||||
// the reverse of pcp_pad_prepend().
|
|
||||||
//
|
|
||||||
// parameters:
|
|
||||||
//
|
|
||||||
// unpadded: destination array (ref), with padding removed
|
|
||||||
// padded: source array with padding
|
|
||||||
// padlen: length of padding
|
|
||||||
// unpadlen: length of source array
|
|
||||||
//
|
|
||||||
// turns "00000000efa5" into "efa5" with padlen 8
|
|
||||||
//
|
|
||||||
// allocates memory for unpadded and it is up to the
|
|
||||||
// user to free it after use.
|
|
||||||
//
|
|
||||||
// sample call:
|
|
||||||
//
|
|
||||||
// char padded[] = {0x0, 0x0, 0x0, 0x0, 0xef, 0xa5};
|
|
||||||
// unsigned char *unpadded;
|
|
||||||
// pcp_pad_remove(unpadded, padded, 4, 2);
|
|
||||||
//
|
|
||||||
// the result, unpadded would be 2 bytes long containing
|
|
||||||
// only the 2 bytes we want to have with zeros removed.
|
|
||||||
void pcp_pad_remove(unsigned char **unpadded, unsigned char *padded,
|
|
||||||
size_t padlen, size_t unpadlen);
|
|
||||||
|
|
||||||
|
|
||||||
#endif // _HAVE_PCP_ZPADDING
|
|
||||||
@@ -1,106 +0,0 @@
|
|||||||
/*
|
|
||||||
This file is part of Pretty Curved Privacy (pcp1).
|
|
||||||
|
|
||||||
Copyright (C) 2013 T.Linden.
|
|
||||||
|
|
||||||
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 Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
You can contact me by mail: <tlinden AT cpan DOT org>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#ifndef _HAVE_PCP_PLATFORM_H
|
|
||||||
#define _HAVE_PCP_PLATFORM_H
|
|
||||||
|
|
||||||
#if defined(CONFIG_H_FILE)
|
|
||||||
#include CONFIG_H_FILE
|
|
||||||
#elif defined(HAVE_CONFIG_H)
|
|
||||||
#include "config.h"
|
|
||||||
#else
|
|
||||||
#error Need either CONFIG_H_FILE or HAVE_CONFIG_H defined.
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#ifdef HAVE_ENDIAN_H
|
|
||||||
# include <endian.h>
|
|
||||||
#else // no endian.h
|
|
||||||
# ifdef HAVE_SYS_ENDIAN_H
|
|
||||||
# include <sys/endian.h>
|
|
||||||
# ifdef HAVE_BETOH32
|
|
||||||
// openbsd, use aliases
|
|
||||||
# define be32toh betoh32
|
|
||||||
# define htobe32 hto32be
|
|
||||||
# endif
|
|
||||||
# else // no sys/endian.h
|
|
||||||
# if __BYTE_ORDER == __BIG_ENDIAN
|
|
||||||
# define be32toh(x) ((void)0)
|
|
||||||
# define htobe32(x) ((void)0)
|
|
||||||
# else
|
|
||||||
# ifdef HAVE_ARPA_INET_H
|
|
||||||
# include <arpa/inet.h>
|
|
||||||
# else
|
|
||||||
# ifdef HAVE_NETINET_IN_H
|
|
||||||
# include <netinet/in.h>
|
|
||||||
# else
|
|
||||||
# error Need either netinet/in.h or arpa/inet.h for ntohl() and htonl()
|
|
||||||
# endif
|
|
||||||
# endif
|
|
||||||
# define be32toh(x) ((u_int32_t)ntohl((u_int32_t)(x)))
|
|
||||||
# define htobe32(x) ((u_int32_t)htonl((u_int32_t)(x)))
|
|
||||||
# endif
|
|
||||||
# endif // HAVE_SYS_ENDIAN_H
|
|
||||||
#endif // HAVE_ENDIAN_H
|
|
||||||
|
|
||||||
|
|
||||||
#ifndef HAVE_ARC4RANDOM_BUF
|
|
||||||
// shitty OS. we've got to use other stuff
|
|
||||||
|
|
||||||
#include <stdlib.h>
|
|
||||||
#include <stdio.h>
|
|
||||||
#include <unistd.h>
|
|
||||||
#include <stdint.h>
|
|
||||||
|
|
||||||
static inline FILE *__getranddev() {
|
|
||||||
FILE *R;
|
|
||||||
if((R = fopen("/dev/urandom", "rb")) == NULL) {
|
|
||||||
// not even this is here! what a shame
|
|
||||||
if((R = fopen("/dev/random", "rb")) == NULL) {
|
|
||||||
// not available or depleted. that's too bad
|
|
||||||
fprintf(stderr, "ERROR: /dev/urandom not available, /dev/random is depleted.\n");
|
|
||||||
fprintf(stderr, "That's horrible for you but a nightmare for me. I die. Bye.\n");
|
|
||||||
exit(2);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return R;
|
|
||||||
}
|
|
||||||
|
|
||||||
static inline u_int32_t arc4random() {
|
|
||||||
uint32_t x;
|
|
||||||
FILE *R = __getranddev();
|
|
||||||
fread(&x, sizeof(uint32_t), 1, R);
|
|
||||||
fclose(R);
|
|
||||||
return x;
|
|
||||||
}
|
|
||||||
|
|
||||||
static inline void arc4random_buf(void *buf, size_t nbytes) {
|
|
||||||
FILE *R = __getranddev();
|
|
||||||
fread(buf, nbytes, 1, R);
|
|
||||||
fclose(R);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
#endif
|
|
||||||
|
|
||||||
|
|
||||||
#endif /* !_HAVE_PCP_PLATFORM_H */
|
|
||||||
|
|
||||||
@@ -1,54 +0,0 @@
|
|||||||
/* $OpenBSD: key.c,v 1.70 2008/06/11 21:01:35 grunk Exp $ */
|
|
||||||
/*
|
|
||||||
* read_bignum():
|
|
||||||
* Copyright (c) 1995 Tatu Ylonen <ylo@cs.hut.fi>, Espoo, Finland
|
|
||||||
*
|
|
||||||
* As far as I am concerned, the code I have written for this software
|
|
||||||
* can be used freely for any purpose. Any derived versions of this
|
|
||||||
* software must be clearly marked as such, and if the derived work is
|
|
||||||
* incompatible with the protocol description in the RFC file, it must be
|
|
||||||
* called by a name other than "ssh" or "Secure Shell".
|
|
||||||
*
|
|
||||||
*
|
|
||||||
* Copyright (c) 2000, 2001 Markus Friedl. All rights reserved.
|
|
||||||
*
|
|
||||||
* Redistribution and use in source and binary forms, with or without
|
|
||||||
* modification, are permitted provided that the following conditions
|
|
||||||
* are met:
|
|
||||||
* 1. Redistributions of source code must retain the above copyright
|
|
||||||
* notice, this list of conditions and the following disclaimer.
|
|
||||||
* 2. Redistributions in binary form must reproduce the above copyright
|
|
||||||
* notice, this list of conditions and the following disclaimer in the
|
|
||||||
* documentation and/or other materials provided with the distribution.
|
|
||||||
*
|
|
||||||
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
|
|
||||||
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
|
||||||
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
|
|
||||||
* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
|
|
||||||
* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
|
|
||||||
* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
||||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
||||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
||||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
|
|
||||||
* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
||||||
*/
|
|
||||||
|
|
||||||
// key_fingerprint_randomart comitted by Alexander von Gernler in rev 1.70
|
|
||||||
|
|
||||||
#ifndef _HAVE_PCP_RANDOMART_H
|
|
||||||
#define _HAVE_PCP_RANDOMART_H
|
|
||||||
|
|
||||||
#include "mem.h"
|
|
||||||
#include <string.h>
|
|
||||||
|
|
||||||
// from openssh key.c
|
|
||||||
|
|
||||||
#ifndef MAX
|
|
||||||
# define MAX(a,b) (((a)>(b))?(a):(b))
|
|
||||||
# define MIN(a,b) (((a)<(b))?(a):(b))
|
|
||||||
#endif
|
|
||||||
|
|
||||||
|
|
||||||
char *key_fingerprint_randomart(unsigned char *dgst_raw, unsigned int dgst_raw_len);
|
|
||||||
|
|
||||||
#endif // _HAVE_PCP_RANDOMART_H
|
|
||||||
948
libpcp/uthash.h
948
libpcp/uthash.h
@@ -1,948 +0,0 @@
|
|||||||
/*
|
|
||||||
Copyright (c) 2003-2013, Troy D. Hanson http://troydhanson.github.com/uthash/
|
|
||||||
All rights reserved.
|
|
||||||
|
|
||||||
Redistribution and use in source and binary forms, with or without
|
|
||||||
modification, are permitted provided that the following conditions are met:
|
|
||||||
|
|
||||||
* Redistributions of source code must retain the above copyright
|
|
||||||
notice, this list of conditions and the following disclaimer.
|
|
||||||
|
|
||||||
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS
|
|
||||||
IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
|
|
||||||
TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
|
|
||||||
PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER
|
|
||||||
OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
|
|
||||||
EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
|
|
||||||
PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
|
|
||||||
PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
|
|
||||||
LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
|
|
||||||
NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
|
||||||
SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#ifndef UTHASH_H
|
|
||||||
#define UTHASH_H
|
|
||||||
|
|
||||||
#include <string.h> /* memcmp,strlen */
|
|
||||||
#include <stddef.h> /* ptrdiff_t */
|
|
||||||
#include <stdlib.h> /* exit() */
|
|
||||||
|
|
||||||
/* These macros use decltype or the earlier __typeof GNU extension.
|
|
||||||
As decltype is only available in newer compilers (VS2010 or gcc 4.3+
|
|
||||||
when compiling c++ source) this code uses whatever method is needed
|
|
||||||
or, for VS2008 where neither is available, uses casting workarounds. */
|
|
||||||
#ifdef _MSC_VER /* MS compiler */
|
|
||||||
#if _MSC_VER >= 1600 && defined(__cplusplus) /* VS2010 or newer in C++ mode */
|
|
||||||
#define DECLTYPE(x) (decltype(x))
|
|
||||||
#else /* VS2008 or older (or VS2010 in C mode) */
|
|
||||||
#define NO_DECLTYPE
|
|
||||||
#define DECLTYPE(x)
|
|
||||||
#endif
|
|
||||||
#else /* GNU, Sun and other compilers */
|
|
||||||
#define DECLTYPE(x) (__typeof(x))
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#ifdef NO_DECLTYPE
|
|
||||||
#define DECLTYPE_ASSIGN(dst,src) \
|
|
||||||
do { \
|
|
||||||
char **_da_dst = (char**)(&(dst)); \
|
|
||||||
*_da_dst = (char*)(src); \
|
|
||||||
} while(0)
|
|
||||||
#else
|
|
||||||
#define DECLTYPE_ASSIGN(dst,src) \
|
|
||||||
do { \
|
|
||||||
(dst) = DECLTYPE(dst)(src); \
|
|
||||||
} while(0)
|
|
||||||
#endif
|
|
||||||
|
|
||||||
/* a number of the hash function use uint32_t which isn't defined on win32 */
|
|
||||||
#ifdef _MSC_VER
|
|
||||||
typedef unsigned int uint32_t;
|
|
||||||
typedef unsigned char uint8_t;
|
|
||||||
#else
|
|
||||||
#include <inttypes.h> /* uint32_t */
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#define UTHASH_VERSION 1.9.8
|
|
||||||
|
|
||||||
#ifndef uthash_fatal
|
|
||||||
#define uthash_fatal(msg) exit(-1) /* fatal error (out of memory,etc) */
|
|
||||||
#endif
|
|
||||||
#ifndef uthash_malloc
|
|
||||||
#define uthash_malloc(sz) malloc(sz) /* malloc fcn */
|
|
||||||
#endif
|
|
||||||
#ifndef uthash_free
|
|
||||||
#define uthash_free(ptr,sz) free(ptr) /* free fcn */
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#ifndef uthash_noexpand_fyi
|
|
||||||
#define uthash_noexpand_fyi(tbl) /* can be defined to log noexpand */
|
|
||||||
#endif
|
|
||||||
#ifndef uthash_expand_fyi
|
|
||||||
#define uthash_expand_fyi(tbl) /* can be defined to log expands */
|
|
||||||
#endif
|
|
||||||
|
|
||||||
/* initial number of buckets */
|
|
||||||
#define HASH_INITIAL_NUM_BUCKETS 32 /* initial number of buckets */
|
|
||||||
#define HASH_INITIAL_NUM_BUCKETS_LOG2 5 /* lg2 of initial number of buckets */
|
|
||||||
#define HASH_BKT_CAPACITY_THRESH 10 /* expand when bucket count reaches */
|
|
||||||
|
|
||||||
/* calculate the element whose hash handle address is hhe */
|
|
||||||
#define ELMT_FROM_HH(tbl,hhp) ((void*)(((char*)(hhp)) - ((tbl)->hho)))
|
|
||||||
|
|
||||||
#define HASH_FIND(hh,head,keyptr,keylen,out) \
|
|
||||||
do { \
|
|
||||||
unsigned _hf_bkt,_hf_hashv; \
|
|
||||||
out=NULL; \
|
|
||||||
if (head) { \
|
|
||||||
HASH_FCN(keyptr,keylen, (head)->hh.tbl->num_buckets, _hf_hashv, _hf_bkt); \
|
|
||||||
if (HASH_BLOOM_TEST((head)->hh.tbl, _hf_hashv)) { \
|
|
||||||
HASH_FIND_IN_BKT((head)->hh.tbl, hh, (head)->hh.tbl->buckets[ _hf_bkt ], \
|
|
||||||
keyptr,keylen,out); \
|
|
||||||
} \
|
|
||||||
} \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
#ifdef HASH_BLOOM
|
|
||||||
#define HASH_BLOOM_BITLEN (1ULL << HASH_BLOOM)
|
|
||||||
#define HASH_BLOOM_BYTELEN (HASH_BLOOM_BITLEN/8) + ((HASH_BLOOM_BITLEN%8) ? 1:0)
|
|
||||||
#define HASH_BLOOM_MAKE(tbl) \
|
|
||||||
do { \
|
|
||||||
(tbl)->bloom_nbits = HASH_BLOOM; \
|
|
||||||
(tbl)->bloom_bv = (uint8_t*)uthash_malloc(HASH_BLOOM_BYTELEN); \
|
|
||||||
if (!((tbl)->bloom_bv)) { uthash_fatal( "out of memory"); } \
|
|
||||||
memset((tbl)->bloom_bv, 0, HASH_BLOOM_BYTELEN); \
|
|
||||||
(tbl)->bloom_sig = HASH_BLOOM_SIGNATURE; \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
#define HASH_BLOOM_FREE(tbl) \
|
|
||||||
do { \
|
|
||||||
uthash_free((tbl)->bloom_bv, HASH_BLOOM_BYTELEN); \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
#define HASH_BLOOM_BITSET(bv,idx) (bv[(idx)/8] |= (1U << ((idx)%8)))
|
|
||||||
#define HASH_BLOOM_BITTEST(bv,idx) (bv[(idx)/8] & (1U << ((idx)%8)))
|
|
||||||
|
|
||||||
#define HASH_BLOOM_ADD(tbl,hashv) \
|
|
||||||
HASH_BLOOM_BITSET((tbl)->bloom_bv, (hashv & (uint32_t)((1ULL << (tbl)->bloom_nbits) - 1)))
|
|
||||||
|
|
||||||
#define HASH_BLOOM_TEST(tbl,hashv) \
|
|
||||||
HASH_BLOOM_BITTEST((tbl)->bloom_bv, (hashv & (uint32_t)((1ULL << (tbl)->bloom_nbits) - 1)))
|
|
||||||
|
|
||||||
#else
|
|
||||||
#define HASH_BLOOM_MAKE(tbl)
|
|
||||||
#define HASH_BLOOM_FREE(tbl)
|
|
||||||
#define HASH_BLOOM_ADD(tbl,hashv)
|
|
||||||
#define HASH_BLOOM_TEST(tbl,hashv) (1)
|
|
||||||
#define HASH_BLOOM_BYTELEN 0
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#define HASH_MAKE_TABLE(hh,head) \
|
|
||||||
do { \
|
|
||||||
(head)->hh.tbl = (UT_hash_table*)uthash_malloc( \
|
|
||||||
sizeof(UT_hash_table)); \
|
|
||||||
if (!((head)->hh.tbl)) { uthash_fatal( "out of memory"); } \
|
|
||||||
memset((head)->hh.tbl, 0, sizeof(UT_hash_table)); \
|
|
||||||
(head)->hh.tbl->tail = &((head)->hh); \
|
|
||||||
(head)->hh.tbl->num_buckets = HASH_INITIAL_NUM_BUCKETS; \
|
|
||||||
(head)->hh.tbl->log2_num_buckets = HASH_INITIAL_NUM_BUCKETS_LOG2; \
|
|
||||||
(head)->hh.tbl->hho = (char*)(&(head)->hh) - (char*)(head); \
|
|
||||||
(head)->hh.tbl->buckets = (UT_hash_bucket*)uthash_malloc( \
|
|
||||||
HASH_INITIAL_NUM_BUCKETS*sizeof(struct UT_hash_bucket)); \
|
|
||||||
if (! (head)->hh.tbl->buckets) { uthash_fatal( "out of memory"); } \
|
|
||||||
memset((head)->hh.tbl->buckets, 0, \
|
|
||||||
HASH_INITIAL_NUM_BUCKETS*sizeof(struct UT_hash_bucket)); \
|
|
||||||
HASH_BLOOM_MAKE((head)->hh.tbl); \
|
|
||||||
(head)->hh.tbl->signature = HASH_SIGNATURE; \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
#define HASH_ADD(hh,head,fieldname,keylen_in,add) \
|
|
||||||
HASH_ADD_KEYPTR(hh,head,&((add)->fieldname),keylen_in,add)
|
|
||||||
|
|
||||||
#define HASH_REPLACE(hh,head,fieldname,keylen_in,add,replaced) \
|
|
||||||
do { \
|
|
||||||
replaced=NULL; \
|
|
||||||
HASH_FIND(hh,head,&((add)->fieldname),keylen_in,replaced); \
|
|
||||||
if (replaced!=NULL) { \
|
|
||||||
HASH_DELETE(hh,head,replaced); \
|
|
||||||
}; \
|
|
||||||
HASH_ADD(hh,head,fieldname,keylen_in,add); \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
#define HASH_ADD_KEYPTR(hh,head,keyptr,keylen_in,add) \
|
|
||||||
do { \
|
|
||||||
unsigned _ha_bkt; \
|
|
||||||
(add)->hh.next = NULL; \
|
|
||||||
(add)->hh.key = (char*)(keyptr); \
|
|
||||||
(add)->hh.keylen = (unsigned)(keylen_in); \
|
|
||||||
if (!(head)) { \
|
|
||||||
head = (add); \
|
|
||||||
(head)->hh.prev = NULL; \
|
|
||||||
HASH_MAKE_TABLE(hh,head); \
|
|
||||||
} else { \
|
|
||||||
(head)->hh.tbl->tail->next = (add); \
|
|
||||||
(add)->hh.prev = ELMT_FROM_HH((head)->hh.tbl, (head)->hh.tbl->tail); \
|
|
||||||
(head)->hh.tbl->tail = &((add)->hh); \
|
|
||||||
} \
|
|
||||||
(head)->hh.tbl->num_items++; \
|
|
||||||
(add)->hh.tbl = (head)->hh.tbl; \
|
|
||||||
HASH_FCN(keyptr,keylen_in, (head)->hh.tbl->num_buckets, \
|
|
||||||
(add)->hh.hashv, _ha_bkt); \
|
|
||||||
HASH_ADD_TO_BKT((head)->hh.tbl->buckets[_ha_bkt],&(add)->hh); \
|
|
||||||
HASH_BLOOM_ADD((head)->hh.tbl,(add)->hh.hashv); \
|
|
||||||
HASH_EMIT_KEY(hh,head,keyptr,keylen_in); \
|
|
||||||
HASH_FSCK(hh,head); \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
#define HASH_TO_BKT( hashv, num_bkts, bkt ) \
|
|
||||||
do { \
|
|
||||||
bkt = ((hashv) & ((num_bkts) - 1)); \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
/* delete "delptr" from the hash table.
|
|
||||||
* "the usual" patch-up process for the app-order doubly-linked-list.
|
|
||||||
* The use of _hd_hh_del below deserves special explanation.
|
|
||||||
* These used to be expressed using (delptr) but that led to a bug
|
|
||||||
* if someone used the same symbol for the head and deletee, like
|
|
||||||
* HASH_DELETE(hh,users,users);
|
|
||||||
* We want that to work, but by changing the head (users) below
|
|
||||||
* we were forfeiting our ability to further refer to the deletee (users)
|
|
||||||
* in the patch-up process. Solution: use scratch space to
|
|
||||||
* copy the deletee pointer, then the latter references are via that
|
|
||||||
* scratch pointer rather than through the repointed (users) symbol.
|
|
||||||
*/
|
|
||||||
#define HASH_DELETE(hh,head,delptr) \
|
|
||||||
do { \
|
|
||||||
unsigned _hd_bkt; \
|
|
||||||
struct UT_hash_handle *_hd_hh_del; \
|
|
||||||
if ( ((delptr)->hh.prev == NULL) && ((delptr)->hh.next == NULL) ) { \
|
|
||||||
uthash_free((head)->hh.tbl->buckets, \
|
|
||||||
(head)->hh.tbl->num_buckets*sizeof(struct UT_hash_bucket) ); \
|
|
||||||
HASH_BLOOM_FREE((head)->hh.tbl); \
|
|
||||||
uthash_free((head)->hh.tbl, sizeof(UT_hash_table)); \
|
|
||||||
head = NULL; \
|
|
||||||
} else { \
|
|
||||||
_hd_hh_del = &((delptr)->hh); \
|
|
||||||
if ((delptr) == ELMT_FROM_HH((head)->hh.tbl,(head)->hh.tbl->tail)) { \
|
|
||||||
(head)->hh.tbl->tail = \
|
|
||||||
(UT_hash_handle*)((ptrdiff_t)((delptr)->hh.prev) + \
|
|
||||||
(head)->hh.tbl->hho); \
|
|
||||||
} \
|
|
||||||
if ((delptr)->hh.prev) { \
|
|
||||||
((UT_hash_handle*)((ptrdiff_t)((delptr)->hh.prev) + \
|
|
||||||
(head)->hh.tbl->hho))->next = (delptr)->hh.next; \
|
|
||||||
} else { \
|
|
||||||
DECLTYPE_ASSIGN(head,(delptr)->hh.next); \
|
|
||||||
} \
|
|
||||||
if (_hd_hh_del->next) { \
|
|
||||||
((UT_hash_handle*)((ptrdiff_t)_hd_hh_del->next + \
|
|
||||||
(head)->hh.tbl->hho))->prev = \
|
|
||||||
_hd_hh_del->prev; \
|
|
||||||
} \
|
|
||||||
HASH_TO_BKT( _hd_hh_del->hashv, (head)->hh.tbl->num_buckets, _hd_bkt); \
|
|
||||||
HASH_DEL_IN_BKT(hh,(head)->hh.tbl->buckets[_hd_bkt], _hd_hh_del); \
|
|
||||||
(head)->hh.tbl->num_items--; \
|
|
||||||
} \
|
|
||||||
HASH_FSCK(hh,head); \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
|
|
||||||
/* convenience forms of HASH_FIND/HASH_ADD/HASH_DEL */
|
|
||||||
#define HASH_FIND_STR(head,findstr,out) \
|
|
||||||
HASH_FIND(hh,head,findstr,strlen(findstr),out)
|
|
||||||
#define HASH_ADD_STR(head,strfield,add) \
|
|
||||||
HASH_ADD(hh,head,strfield,strlen(add->strfield),add)
|
|
||||||
#define HASH_REPLACE_STR(head,strfield,add,replaced) \
|
|
||||||
HASH_REPLACE(hh,head,strfield,strlen(add->strfield),add,replaced)
|
|
||||||
#define HASH_FIND_INT(head,findint,out) \
|
|
||||||
HASH_FIND(hh,head,findint,sizeof(int),out)
|
|
||||||
#define HASH_ADD_INT(head,intfield,add) \
|
|
||||||
HASH_ADD(hh,head,intfield,sizeof(int),add)
|
|
||||||
#define HASH_REPLACE_INT(head,intfield,add,replaced) \
|
|
||||||
HASH_REPLACE(hh,head,intfield,sizeof(int),add,replaced)
|
|
||||||
#define HASH_FIND_PTR(head,findptr,out) \
|
|
||||||
HASH_FIND(hh,head,findptr,sizeof(void *),out)
|
|
||||||
#define HASH_ADD_PTR(head,ptrfield,add) \
|
|
||||||
HASH_ADD(hh,head,ptrfield,sizeof(void *),add)
|
|
||||||
#define HASH_REPLACE_PTR(head,ptrfield,add) \
|
|
||||||
HASH_REPLACE(hh,head,ptrfield,sizeof(void *),add,replaced)
|
|
||||||
#define HASH_DEL(head,delptr) \
|
|
||||||
HASH_DELETE(hh,head,delptr)
|
|
||||||
|
|
||||||
/* HASH_FSCK checks hash integrity on every add/delete when HASH_DEBUG is defined.
|
|
||||||
* This is for uthash developer only; it compiles away if HASH_DEBUG isn't defined.
|
|
||||||
*/
|
|
||||||
#ifdef HASH_DEBUG
|
|
||||||
#define HASH_OOPS(...) do { fprintf(stderr,__VA_ARGS__); exit(-1); } while (0)
|
|
||||||
#define HASH_FSCK(hh,head) \
|
|
||||||
do { \
|
|
||||||
unsigned _bkt_i; \
|
|
||||||
unsigned _count, _bkt_count; \
|
|
||||||
char *_prev; \
|
|
||||||
struct UT_hash_handle *_thh; \
|
|
||||||
if (head) { \
|
|
||||||
_count = 0; \
|
|
||||||
for( _bkt_i = 0; _bkt_i < (head)->hh.tbl->num_buckets; _bkt_i++) { \
|
|
||||||
_bkt_count = 0; \
|
|
||||||
_thh = (head)->hh.tbl->buckets[_bkt_i].hh_head; \
|
|
||||||
_prev = NULL; \
|
|
||||||
while (_thh) { \
|
|
||||||
if (_prev != (char*)(_thh->hh_prev)) { \
|
|
||||||
HASH_OOPS("invalid hh_prev %p, actual %p\n", \
|
|
||||||
_thh->hh_prev, _prev ); \
|
|
||||||
} \
|
|
||||||
_bkt_count++; \
|
|
||||||
_prev = (char*)(_thh); \
|
|
||||||
_thh = _thh->hh_next; \
|
|
||||||
} \
|
|
||||||
_count += _bkt_count; \
|
|
||||||
if ((head)->hh.tbl->buckets[_bkt_i].count != _bkt_count) { \
|
|
||||||
HASH_OOPS("invalid bucket count %d, actual %d\n", \
|
|
||||||
(head)->hh.tbl->buckets[_bkt_i].count, _bkt_count); \
|
|
||||||
} \
|
|
||||||
} \
|
|
||||||
if (_count != (head)->hh.tbl->num_items) { \
|
|
||||||
HASH_OOPS("invalid hh item count %d, actual %d\n", \
|
|
||||||
(head)->hh.tbl->num_items, _count ); \
|
|
||||||
} \
|
|
||||||
/* traverse hh in app order; check next/prev integrity, count */ \
|
|
||||||
_count = 0; \
|
|
||||||
_prev = NULL; \
|
|
||||||
_thh = &(head)->hh; \
|
|
||||||
while (_thh) { \
|
|
||||||
_count++; \
|
|
||||||
if (_prev !=(char*)(_thh->prev)) { \
|
|
||||||
HASH_OOPS("invalid prev %p, actual %p\n", \
|
|
||||||
_thh->prev, _prev ); \
|
|
||||||
} \
|
|
||||||
_prev = (char*)ELMT_FROM_HH((head)->hh.tbl, _thh); \
|
|
||||||
_thh = ( _thh->next ? (UT_hash_handle*)((char*)(_thh->next) + \
|
|
||||||
(head)->hh.tbl->hho) : NULL ); \
|
|
||||||
} \
|
|
||||||
if (_count != (head)->hh.tbl->num_items) { \
|
|
||||||
HASH_OOPS("invalid app item count %d, actual %d\n", \
|
|
||||||
(head)->hh.tbl->num_items, _count ); \
|
|
||||||
} \
|
|
||||||
} \
|
|
||||||
} while (0)
|
|
||||||
#else
|
|
||||||
#define HASH_FSCK(hh,head)
|
|
||||||
#endif
|
|
||||||
|
|
||||||
/* When compiled with -DHASH_EMIT_KEYS, length-prefixed keys are emitted to
|
|
||||||
* the descriptor to which this macro is defined for tuning the hash function.
|
|
||||||
* The app can #include <unistd.h> to get the prototype for write(2). */
|
|
||||||
#ifdef HASH_EMIT_KEYS
|
|
||||||
#define HASH_EMIT_KEY(hh,head,keyptr,fieldlen) \
|
|
||||||
do { \
|
|
||||||
unsigned _klen = fieldlen; \
|
|
||||||
write(HASH_EMIT_KEYS, &_klen, sizeof(_klen)); \
|
|
||||||
write(HASH_EMIT_KEYS, keyptr, fieldlen); \
|
|
||||||
} while (0)
|
|
||||||
#else
|
|
||||||
#define HASH_EMIT_KEY(hh,head,keyptr,fieldlen)
|
|
||||||
#endif
|
|
||||||
|
|
||||||
/* default to Jenkin's hash unless overridden e.g. DHASH_FUNCTION=HASH_SAX */
|
|
||||||
#ifdef HASH_FUNCTION
|
|
||||||
#define HASH_FCN HASH_FUNCTION
|
|
||||||
#else
|
|
||||||
#define HASH_FCN HASH_JEN
|
|
||||||
#endif
|
|
||||||
|
|
||||||
/* The Bernstein hash function, used in Perl prior to v5.6 */
|
|
||||||
#define HASH_BER(key,keylen,num_bkts,hashv,bkt) \
|
|
||||||
do { \
|
|
||||||
unsigned _hb_keylen=keylen; \
|
|
||||||
char *_hb_key=(char*)(key); \
|
|
||||||
(hashv) = 0; \
|
|
||||||
while (_hb_keylen--) { (hashv) = ((hashv) * 33) + *_hb_key++; } \
|
|
||||||
bkt = (hashv) & (num_bkts-1); \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
|
|
||||||
/* SAX/FNV/OAT/JEN hash functions are macro variants of those listed at
|
|
||||||
* http://eternallyconfuzzled.com/tuts/algorithms/jsw_tut_hashing.aspx */
|
|
||||||
#define HASH_SAX(key,keylen,num_bkts,hashv,bkt) \
|
|
||||||
do { \
|
|
||||||
unsigned _sx_i; \
|
|
||||||
char *_hs_key=(char*)(key); \
|
|
||||||
hashv = 0; \
|
|
||||||
for(_sx_i=0; _sx_i < keylen; _sx_i++) \
|
|
||||||
hashv ^= (hashv << 5) + (hashv >> 2) + _hs_key[_sx_i]; \
|
|
||||||
bkt = hashv & (num_bkts-1); \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
#define HASH_FNV(key,keylen,num_bkts,hashv,bkt) \
|
|
||||||
do { \
|
|
||||||
unsigned _fn_i; \
|
|
||||||
char *_hf_key=(char*)(key); \
|
|
||||||
hashv = 2166136261UL; \
|
|
||||||
for(_fn_i=0; _fn_i < keylen; _fn_i++) \
|
|
||||||
hashv = (hashv * 16777619) ^ _hf_key[_fn_i]; \
|
|
||||||
bkt = hashv & (num_bkts-1); \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
#define HASH_OAT(key,keylen,num_bkts,hashv,bkt) \
|
|
||||||
do { \
|
|
||||||
unsigned _ho_i; \
|
|
||||||
char *_ho_key=(char*)(key); \
|
|
||||||
hashv = 0; \
|
|
||||||
for(_ho_i=0; _ho_i < keylen; _ho_i++) { \
|
|
||||||
hashv += _ho_key[_ho_i]; \
|
|
||||||
hashv += (hashv << 10); \
|
|
||||||
hashv ^= (hashv >> 6); \
|
|
||||||
} \
|
|
||||||
hashv += (hashv << 3); \
|
|
||||||
hashv ^= (hashv >> 11); \
|
|
||||||
hashv += (hashv << 15); \
|
|
||||||
bkt = hashv & (num_bkts-1); \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
#define HASH_JEN_MIX(a,b,c) \
|
|
||||||
do { \
|
|
||||||
a -= b; a -= c; a ^= ( c >> 13 ); \
|
|
||||||
b -= c; b -= a; b ^= ( a << 8 ); \
|
|
||||||
c -= a; c -= b; c ^= ( b >> 13 ); \
|
|
||||||
a -= b; a -= c; a ^= ( c >> 12 ); \
|
|
||||||
b -= c; b -= a; b ^= ( a << 16 ); \
|
|
||||||
c -= a; c -= b; c ^= ( b >> 5 ); \
|
|
||||||
a -= b; a -= c; a ^= ( c >> 3 ); \
|
|
||||||
b -= c; b -= a; b ^= ( a << 10 ); \
|
|
||||||
c -= a; c -= b; c ^= ( b >> 15 ); \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
#define HASH_JEN(key,keylen,num_bkts,hashv,bkt) \
|
|
||||||
do { \
|
|
||||||
unsigned _hj_i,_hj_j,_hj_k; \
|
|
||||||
unsigned char *_hj_key=(unsigned char*)(key); \
|
|
||||||
hashv = 0xfeedbeef; \
|
|
||||||
_hj_i = _hj_j = 0x9e3779b9; \
|
|
||||||
_hj_k = (unsigned)(keylen); \
|
|
||||||
while (_hj_k >= 12) { \
|
|
||||||
_hj_i += (_hj_key[0] + ( (unsigned)_hj_key[1] << 8 ) \
|
|
||||||
+ ( (unsigned)_hj_key[2] << 16 ) \
|
|
||||||
+ ( (unsigned)_hj_key[3] << 24 ) ); \
|
|
||||||
_hj_j += (_hj_key[4] + ( (unsigned)_hj_key[5] << 8 ) \
|
|
||||||
+ ( (unsigned)_hj_key[6] << 16 ) \
|
|
||||||
+ ( (unsigned)_hj_key[7] << 24 ) ); \
|
|
||||||
hashv += (_hj_key[8] + ( (unsigned)_hj_key[9] << 8 ) \
|
|
||||||
+ ( (unsigned)_hj_key[10] << 16 ) \
|
|
||||||
+ ( (unsigned)_hj_key[11] << 24 ) ); \
|
|
||||||
\
|
|
||||||
HASH_JEN_MIX(_hj_i, _hj_j, hashv); \
|
|
||||||
\
|
|
||||||
_hj_key += 12; \
|
|
||||||
_hj_k -= 12; \
|
|
||||||
} \
|
|
||||||
hashv += keylen; \
|
|
||||||
switch ( _hj_k ) { \
|
|
||||||
case 11: hashv += ( (unsigned)_hj_key[10] << 24 ); \
|
|
||||||
case 10: hashv += ( (unsigned)_hj_key[9] << 16 ); \
|
|
||||||
case 9: hashv += ( (unsigned)_hj_key[8] << 8 ); \
|
|
||||||
case 8: _hj_j += ( (unsigned)_hj_key[7] << 24 ); \
|
|
||||||
case 7: _hj_j += ( (unsigned)_hj_key[6] << 16 ); \
|
|
||||||
case 6: _hj_j += ( (unsigned)_hj_key[5] << 8 ); \
|
|
||||||
case 5: _hj_j += _hj_key[4]; \
|
|
||||||
case 4: _hj_i += ( (unsigned)_hj_key[3] << 24 ); \
|
|
||||||
case 3: _hj_i += ( (unsigned)_hj_key[2] << 16 ); \
|
|
||||||
case 2: _hj_i += ( (unsigned)_hj_key[1] << 8 ); \
|
|
||||||
case 1: _hj_i += _hj_key[0]; \
|
|
||||||
} \
|
|
||||||
HASH_JEN_MIX(_hj_i, _hj_j, hashv); \
|
|
||||||
bkt = hashv & (num_bkts-1); \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
/* The Paul Hsieh hash function */
|
|
||||||
#undef get16bits
|
|
||||||
#if (defined(__GNUC__) && defined(__i386__)) || defined(__WATCOMC__) \
|
|
||||||
|| defined(_MSC_VER) || defined (__BORLANDC__) || defined (__TURBOC__)
|
|
||||||
#define get16bits(d) (*((const uint16_t *) (d)))
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#if !defined (get16bits)
|
|
||||||
#define get16bits(d) ((((uint32_t)(((const uint8_t *)(d))[1])) << 8) \
|
|
||||||
+(uint32_t)(((const uint8_t *)(d))[0]) )
|
|
||||||
#endif
|
|
||||||
#define HASH_SFH(key,keylen,num_bkts,hashv,bkt) \
|
|
||||||
do { \
|
|
||||||
unsigned char *_sfh_key=(unsigned char*)(key); \
|
|
||||||
uint32_t _sfh_tmp, _sfh_len = keylen; \
|
|
||||||
\
|
|
||||||
int _sfh_rem = _sfh_len & 3; \
|
|
||||||
_sfh_len >>= 2; \
|
|
||||||
hashv = 0xcafebabe; \
|
|
||||||
\
|
|
||||||
/* Main loop */ \
|
|
||||||
for (;_sfh_len > 0; _sfh_len--) { \
|
|
||||||
hashv += get16bits (_sfh_key); \
|
|
||||||
_sfh_tmp = (uint32_t)(get16bits (_sfh_key+2)) << 11 ^ hashv; \
|
|
||||||
hashv = (hashv << 16) ^ _sfh_tmp; \
|
|
||||||
_sfh_key += 2*sizeof (uint16_t); \
|
|
||||||
hashv += hashv >> 11; \
|
|
||||||
} \
|
|
||||||
\
|
|
||||||
/* Handle end cases */ \
|
|
||||||
switch (_sfh_rem) { \
|
|
||||||
case 3: hashv += get16bits (_sfh_key); \
|
|
||||||
hashv ^= hashv << 16; \
|
|
||||||
hashv ^= (uint32_t)(_sfh_key[sizeof (uint16_t)] << 18); \
|
|
||||||
hashv += hashv >> 11; \
|
|
||||||
break; \
|
|
||||||
case 2: hashv += get16bits (_sfh_key); \
|
|
||||||
hashv ^= hashv << 11; \
|
|
||||||
hashv += hashv >> 17; \
|
|
||||||
break; \
|
|
||||||
case 1: hashv += *_sfh_key; \
|
|
||||||
hashv ^= hashv << 10; \
|
|
||||||
hashv += hashv >> 1; \
|
|
||||||
} \
|
|
||||||
\
|
|
||||||
/* Force "avalanching" of final 127 bits */ \
|
|
||||||
hashv ^= hashv << 3; \
|
|
||||||
hashv += hashv >> 5; \
|
|
||||||
hashv ^= hashv << 4; \
|
|
||||||
hashv += hashv >> 17; \
|
|
||||||
hashv ^= hashv << 25; \
|
|
||||||
hashv += hashv >> 6; \
|
|
||||||
bkt = hashv & (num_bkts-1); \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
#ifdef HASH_USING_NO_STRICT_ALIASING
|
|
||||||
/* The MurmurHash exploits some CPU's (x86,x86_64) tolerance for unaligned reads.
|
|
||||||
* For other types of CPU's (e.g. Sparc) an unaligned read causes a bus error.
|
|
||||||
* MurmurHash uses the faster approach only on CPU's where we know it's safe.
|
|
||||||
*
|
|
||||||
* Note the preprocessor built-in defines can be emitted using:
|
|
||||||
*
|
|
||||||
* gcc -m64 -dM -E - < /dev/null (on gcc)
|
|
||||||
* cc -## a.c (where a.c is a simple test file) (Sun Studio)
|
|
||||||
*/
|
|
||||||
#if (defined(__i386__) || defined(__x86_64__) || defined(_M_IX86))
|
|
||||||
#define MUR_GETBLOCK(p,i) p[i]
|
|
||||||
#else /* non intel */
|
|
||||||
#define MUR_PLUS0_ALIGNED(p) (((unsigned long)p & 0x3) == 0)
|
|
||||||
#define MUR_PLUS1_ALIGNED(p) (((unsigned long)p & 0x3) == 1)
|
|
||||||
#define MUR_PLUS2_ALIGNED(p) (((unsigned long)p & 0x3) == 2)
|
|
||||||
#define MUR_PLUS3_ALIGNED(p) (((unsigned long)p & 0x3) == 3)
|
|
||||||
#define WP(p) ((uint32_t*)((unsigned long)(p) & ~3UL))
|
|
||||||
#if (defined(__BIG_ENDIAN__) || defined(SPARC) || defined(__ppc__) || defined(__ppc64__))
|
|
||||||
#define MUR_THREE_ONE(p) ((((*WP(p))&0x00ffffff) << 8) | (((*(WP(p)+1))&0xff000000) >> 24))
|
|
||||||
#define MUR_TWO_TWO(p) ((((*WP(p))&0x0000ffff) <<16) | (((*(WP(p)+1))&0xffff0000) >> 16))
|
|
||||||
#define MUR_ONE_THREE(p) ((((*WP(p))&0x000000ff) <<24) | (((*(WP(p)+1))&0xffffff00) >> 8))
|
|
||||||
#else /* assume little endian non-intel */
|
|
||||||
#define MUR_THREE_ONE(p) ((((*WP(p))&0xffffff00) >> 8) | (((*(WP(p)+1))&0x000000ff) << 24))
|
|
||||||
#define MUR_TWO_TWO(p) ((((*WP(p))&0xffff0000) >>16) | (((*(WP(p)+1))&0x0000ffff) << 16))
|
|
||||||
#define MUR_ONE_THREE(p) ((((*WP(p))&0xff000000) >>24) | (((*(WP(p)+1))&0x00ffffff) << 8))
|
|
||||||
#endif
|
|
||||||
#define MUR_GETBLOCK(p,i) (MUR_PLUS0_ALIGNED(p) ? ((p)[i]) : \
|
|
||||||
(MUR_PLUS1_ALIGNED(p) ? MUR_THREE_ONE(p) : \
|
|
||||||
(MUR_PLUS2_ALIGNED(p) ? MUR_TWO_TWO(p) : \
|
|
||||||
MUR_ONE_THREE(p))))
|
|
||||||
#endif
|
|
||||||
#define MUR_ROTL32(x,r) (((x) << (r)) | ((x) >> (32 - (r))))
|
|
||||||
#define MUR_FMIX(_h) \
|
|
||||||
do { \
|
|
||||||
_h ^= _h >> 16; \
|
|
||||||
_h *= 0x85ebca6b; \
|
|
||||||
_h ^= _h >> 13; \
|
|
||||||
_h *= 0xc2b2ae35l; \
|
|
||||||
_h ^= _h >> 16; \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
#define HASH_MUR(key,keylen,num_bkts,hashv,bkt) \
|
|
||||||
do { \
|
|
||||||
const uint8_t *_mur_data = (const uint8_t*)(key); \
|
|
||||||
const int _mur_nblocks = (keylen) / 4; \
|
|
||||||
uint32_t _mur_h1 = 0xf88D5353; \
|
|
||||||
uint32_t _mur_c1 = 0xcc9e2d51; \
|
|
||||||
uint32_t _mur_c2 = 0x1b873593; \
|
|
||||||
uint32_t _mur_k1 = 0; \
|
|
||||||
const uint8_t *_mur_tail; \
|
|
||||||
const uint32_t *_mur_blocks = (const uint32_t*)(_mur_data+_mur_nblocks*4); \
|
|
||||||
int _mur_i; \
|
|
||||||
for(_mur_i = -_mur_nblocks; _mur_i; _mur_i++) { \
|
|
||||||
_mur_k1 = MUR_GETBLOCK(_mur_blocks,_mur_i); \
|
|
||||||
_mur_k1 *= _mur_c1; \
|
|
||||||
_mur_k1 = MUR_ROTL32(_mur_k1,15); \
|
|
||||||
_mur_k1 *= _mur_c2; \
|
|
||||||
\
|
|
||||||
_mur_h1 ^= _mur_k1; \
|
|
||||||
_mur_h1 = MUR_ROTL32(_mur_h1,13); \
|
|
||||||
_mur_h1 = _mur_h1*5+0xe6546b64; \
|
|
||||||
} \
|
|
||||||
_mur_tail = (const uint8_t*)(_mur_data + _mur_nblocks*4); \
|
|
||||||
_mur_k1=0; \
|
|
||||||
switch((keylen) & 3) { \
|
|
||||||
case 3: _mur_k1 ^= _mur_tail[2] << 16; \
|
|
||||||
case 2: _mur_k1 ^= _mur_tail[1] << 8; \
|
|
||||||
case 1: _mur_k1 ^= _mur_tail[0]; \
|
|
||||||
_mur_k1 *= _mur_c1; \
|
|
||||||
_mur_k1 = MUR_ROTL32(_mur_k1,15); \
|
|
||||||
_mur_k1 *= _mur_c2; \
|
|
||||||
_mur_h1 ^= _mur_k1; \
|
|
||||||
} \
|
|
||||||
_mur_h1 ^= (keylen); \
|
|
||||||
MUR_FMIX(_mur_h1); \
|
|
||||||
hashv = _mur_h1; \
|
|
||||||
bkt = hashv & (num_bkts-1); \
|
|
||||||
} while(0)
|
|
||||||
#endif /* HASH_USING_NO_STRICT_ALIASING */
|
|
||||||
|
|
||||||
/* key comparison function; return 0 if keys equal */
|
|
||||||
#define HASH_KEYCMP(a,b,len) memcmp(a,b,len)
|
|
||||||
|
|
||||||
/* iterate over items in a known bucket to find desired item */
|
|
||||||
#define HASH_FIND_IN_BKT(tbl,hh,head,keyptr,keylen_in,out) \
|
|
||||||
do { \
|
|
||||||
if (head.hh_head) DECLTYPE_ASSIGN(out,ELMT_FROM_HH(tbl,head.hh_head)); \
|
|
||||||
else out=NULL; \
|
|
||||||
while (out) { \
|
|
||||||
if ((out)->hh.keylen == keylen_in) { \
|
|
||||||
if ((HASH_KEYCMP((out)->hh.key,keyptr,keylen_in)) == 0) break; \
|
|
||||||
} \
|
|
||||||
if ((out)->hh.hh_next) DECLTYPE_ASSIGN(out,ELMT_FROM_HH(tbl,(out)->hh.hh_next)); \
|
|
||||||
else out = NULL; \
|
|
||||||
} \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
/* add an item to a bucket */
|
|
||||||
#define HASH_ADD_TO_BKT(head,addhh) \
|
|
||||||
do { \
|
|
||||||
head.count++; \
|
|
||||||
(addhh)->hh_next = head.hh_head; \
|
|
||||||
(addhh)->hh_prev = NULL; \
|
|
||||||
if (head.hh_head) { (head).hh_head->hh_prev = (addhh); } \
|
|
||||||
(head).hh_head=addhh; \
|
|
||||||
if (head.count >= ((head.expand_mult+1) * HASH_BKT_CAPACITY_THRESH) \
|
|
||||||
&& (addhh)->tbl->noexpand != 1) { \
|
|
||||||
HASH_EXPAND_BUCKETS((addhh)->tbl); \
|
|
||||||
} \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
/* remove an item from a given bucket */
|
|
||||||
#define HASH_DEL_IN_BKT(hh,head,hh_del) \
|
|
||||||
(head).count--; \
|
|
||||||
if ((head).hh_head == hh_del) { \
|
|
||||||
(head).hh_head = hh_del->hh_next; \
|
|
||||||
} \
|
|
||||||
if (hh_del->hh_prev) { \
|
|
||||||
hh_del->hh_prev->hh_next = hh_del->hh_next; \
|
|
||||||
} \
|
|
||||||
if (hh_del->hh_next) { \
|
|
||||||
hh_del->hh_next->hh_prev = hh_del->hh_prev; \
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Bucket expansion has the effect of doubling the number of buckets
|
|
||||||
* and redistributing the items into the new buckets. Ideally the
|
|
||||||
* items will distribute more or less evenly into the new buckets
|
|
||||||
* (the extent to which this is true is a measure of the quality of
|
|
||||||
* the hash function as it applies to the key domain).
|
|
||||||
*
|
|
||||||
* With the items distributed into more buckets, the chain length
|
|
||||||
* (item count) in each bucket is reduced. Thus by expanding buckets
|
|
||||||
* the hash keeps a bound on the chain length. This bounded chain
|
|
||||||
* length is the essence of how a hash provides constant time lookup.
|
|
||||||
*
|
|
||||||
* The calculation of tbl->ideal_chain_maxlen below deserves some
|
|
||||||
* explanation. First, keep in mind that we're calculating the ideal
|
|
||||||
* maximum chain length based on the *new* (doubled) bucket count.
|
|
||||||
* In fractions this is just n/b (n=number of items,b=new num buckets).
|
|
||||||
* Since the ideal chain length is an integer, we want to calculate
|
|
||||||
* ceil(n/b). We don't depend on floating point arithmetic in this
|
|
||||||
* hash, so to calculate ceil(n/b) with integers we could write
|
|
||||||
*
|
|
||||||
* ceil(n/b) = (n/b) + ((n%b)?1:0)
|
|
||||||
*
|
|
||||||
* and in fact a previous version of this hash did just that.
|
|
||||||
* But now we have improved things a bit by recognizing that b is
|
|
||||||
* always a power of two. We keep its base 2 log handy (call it lb),
|
|
||||||
* so now we can write this with a bit shift and logical AND:
|
|
||||||
*
|
|
||||||
* ceil(n/b) = (n>>lb) + ( (n & (b-1)) ? 1:0)
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
#define HASH_EXPAND_BUCKETS(tbl) \
|
|
||||||
do { \
|
|
||||||
unsigned _he_bkt; \
|
|
||||||
unsigned _he_bkt_i; \
|
|
||||||
struct UT_hash_handle *_he_thh, *_he_hh_nxt; \
|
|
||||||
UT_hash_bucket *_he_new_buckets, *_he_newbkt; \
|
|
||||||
_he_new_buckets = (UT_hash_bucket*)uthash_malloc( \
|
|
||||||
2 * tbl->num_buckets * sizeof(struct UT_hash_bucket)); \
|
|
||||||
if (!_he_new_buckets) { uthash_fatal( "out of memory"); } \
|
|
||||||
memset(_he_new_buckets, 0, \
|
|
||||||
2 * tbl->num_buckets * sizeof(struct UT_hash_bucket)); \
|
|
||||||
tbl->ideal_chain_maxlen = \
|
|
||||||
(tbl->num_items >> (tbl->log2_num_buckets+1)) + \
|
|
||||||
((tbl->num_items & ((tbl->num_buckets*2)-1)) ? 1 : 0); \
|
|
||||||
tbl->nonideal_items = 0; \
|
|
||||||
for(_he_bkt_i = 0; _he_bkt_i < tbl->num_buckets; _he_bkt_i++) \
|
|
||||||
{ \
|
|
||||||
_he_thh = tbl->buckets[ _he_bkt_i ].hh_head; \
|
|
||||||
while (_he_thh) { \
|
|
||||||
_he_hh_nxt = _he_thh->hh_next; \
|
|
||||||
HASH_TO_BKT( _he_thh->hashv, tbl->num_buckets*2, _he_bkt); \
|
|
||||||
_he_newbkt = &(_he_new_buckets[ _he_bkt ]); \
|
|
||||||
if (++(_he_newbkt->count) > tbl->ideal_chain_maxlen) { \
|
|
||||||
tbl->nonideal_items++; \
|
|
||||||
_he_newbkt->expand_mult = _he_newbkt->count / \
|
|
||||||
tbl->ideal_chain_maxlen; \
|
|
||||||
} \
|
|
||||||
_he_thh->hh_prev = NULL; \
|
|
||||||
_he_thh->hh_next = _he_newbkt->hh_head; \
|
|
||||||
if (_he_newbkt->hh_head) _he_newbkt->hh_head->hh_prev = \
|
|
||||||
_he_thh; \
|
|
||||||
_he_newbkt->hh_head = _he_thh; \
|
|
||||||
_he_thh = _he_hh_nxt; \
|
|
||||||
} \
|
|
||||||
} \
|
|
||||||
uthash_free( tbl->buckets, tbl->num_buckets*sizeof(struct UT_hash_bucket) ); \
|
|
||||||
tbl->num_buckets *= 2; \
|
|
||||||
tbl->log2_num_buckets++; \
|
|
||||||
tbl->buckets = _he_new_buckets; \
|
|
||||||
tbl->ineff_expands = (tbl->nonideal_items > (tbl->num_items >> 1)) ? \
|
|
||||||
(tbl->ineff_expands+1) : 0; \
|
|
||||||
if (tbl->ineff_expands > 1) { \
|
|
||||||
tbl->noexpand=1; \
|
|
||||||
uthash_noexpand_fyi(tbl); \
|
|
||||||
} \
|
|
||||||
uthash_expand_fyi(tbl); \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
|
|
||||||
/* This is an adaptation of Simon Tatham's O(n log(n)) mergesort */
|
|
||||||
/* Note that HASH_SORT assumes the hash handle name to be hh.
|
|
||||||
* HASH_SRT was added to allow the hash handle name to be passed in. */
|
|
||||||
#define HASH_SORT(head,cmpfcn) HASH_SRT(hh,head,cmpfcn)
|
|
||||||
#define HASH_SRT(hh,head,cmpfcn) \
|
|
||||||
do { \
|
|
||||||
unsigned _hs_i; \
|
|
||||||
unsigned _hs_looping,_hs_nmerges,_hs_insize,_hs_psize,_hs_qsize; \
|
|
||||||
struct UT_hash_handle *_hs_p, *_hs_q, *_hs_e, *_hs_list, *_hs_tail; \
|
|
||||||
if (head) { \
|
|
||||||
_hs_insize = 1; \
|
|
||||||
_hs_looping = 1; \
|
|
||||||
_hs_list = &((head)->hh); \
|
|
||||||
while (_hs_looping) { \
|
|
||||||
_hs_p = _hs_list; \
|
|
||||||
_hs_list = NULL; \
|
|
||||||
_hs_tail = NULL; \
|
|
||||||
_hs_nmerges = 0; \
|
|
||||||
while (_hs_p) { \
|
|
||||||
_hs_nmerges++; \
|
|
||||||
_hs_q = _hs_p; \
|
|
||||||
_hs_psize = 0; \
|
|
||||||
for ( _hs_i = 0; _hs_i < _hs_insize; _hs_i++ ) { \
|
|
||||||
_hs_psize++; \
|
|
||||||
_hs_q = (UT_hash_handle*)((_hs_q->next) ? \
|
|
||||||
((void*)((char*)(_hs_q->next) + \
|
|
||||||
(head)->hh.tbl->hho)) : NULL); \
|
|
||||||
if (! (_hs_q) ) break; \
|
|
||||||
} \
|
|
||||||
_hs_qsize = _hs_insize; \
|
|
||||||
while ((_hs_psize > 0) || ((_hs_qsize > 0) && _hs_q )) { \
|
|
||||||
if (_hs_psize == 0) { \
|
|
||||||
_hs_e = _hs_q; \
|
|
||||||
_hs_q = (UT_hash_handle*)((_hs_q->next) ? \
|
|
||||||
((void*)((char*)(_hs_q->next) + \
|
|
||||||
(head)->hh.tbl->hho)) : NULL); \
|
|
||||||
_hs_qsize--; \
|
|
||||||
} else if ( (_hs_qsize == 0) || !(_hs_q) ) { \
|
|
||||||
_hs_e = _hs_p; \
|
|
||||||
if (_hs_p){ \
|
|
||||||
_hs_p = (UT_hash_handle*)((_hs_p->next) ? \
|
|
||||||
((void*)((char*)(_hs_p->next) + \
|
|
||||||
(head)->hh.tbl->hho)) : NULL); \
|
|
||||||
} \
|
|
||||||
_hs_psize--; \
|
|
||||||
} else if (( \
|
|
||||||
cmpfcn(DECLTYPE(head)(ELMT_FROM_HH((head)->hh.tbl,_hs_p)), \
|
|
||||||
DECLTYPE(head)(ELMT_FROM_HH((head)->hh.tbl,_hs_q))) \
|
|
||||||
) <= 0) { \
|
|
||||||
_hs_e = _hs_p; \
|
|
||||||
if (_hs_p){ \
|
|
||||||
_hs_p = (UT_hash_handle*)((_hs_p->next) ? \
|
|
||||||
((void*)((char*)(_hs_p->next) + \
|
|
||||||
(head)->hh.tbl->hho)) : NULL); \
|
|
||||||
} \
|
|
||||||
_hs_psize--; \
|
|
||||||
} else { \
|
|
||||||
_hs_e = _hs_q; \
|
|
||||||
_hs_q = (UT_hash_handle*)((_hs_q->next) ? \
|
|
||||||
((void*)((char*)(_hs_q->next) + \
|
|
||||||
(head)->hh.tbl->hho)) : NULL); \
|
|
||||||
_hs_qsize--; \
|
|
||||||
} \
|
|
||||||
if ( _hs_tail ) { \
|
|
||||||
_hs_tail->next = ((_hs_e) ? \
|
|
||||||
ELMT_FROM_HH((head)->hh.tbl,_hs_e) : NULL); \
|
|
||||||
} else { \
|
|
||||||
_hs_list = _hs_e; \
|
|
||||||
} \
|
|
||||||
if (_hs_e) { \
|
|
||||||
_hs_e->prev = ((_hs_tail) ? \
|
|
||||||
ELMT_FROM_HH((head)->hh.tbl,_hs_tail) : NULL); \
|
|
||||||
} \
|
|
||||||
_hs_tail = _hs_e; \
|
|
||||||
} \
|
|
||||||
_hs_p = _hs_q; \
|
|
||||||
} \
|
|
||||||
if (_hs_tail){ \
|
|
||||||
_hs_tail->next = NULL; \
|
|
||||||
} \
|
|
||||||
if ( _hs_nmerges <= 1 ) { \
|
|
||||||
_hs_looping=0; \
|
|
||||||
(head)->hh.tbl->tail = _hs_tail; \
|
|
||||||
DECLTYPE_ASSIGN(head,ELMT_FROM_HH((head)->hh.tbl, _hs_list)); \
|
|
||||||
} \
|
|
||||||
_hs_insize *= 2; \
|
|
||||||
} \
|
|
||||||
HASH_FSCK(hh,head); \
|
|
||||||
} \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
/* This function selects items from one hash into another hash.
|
|
||||||
* The end result is that the selected items have dual presence
|
|
||||||
* in both hashes. There is no copy of the items made; rather
|
|
||||||
* they are added into the new hash through a secondary hash
|
|
||||||
* hash handle that must be present in the structure. */
|
|
||||||
#define HASH_SELECT(hh_dst, dst, hh_src, src, cond) \
|
|
||||||
do { \
|
|
||||||
unsigned _src_bkt, _dst_bkt; \
|
|
||||||
void *_last_elt=NULL, *_elt; \
|
|
||||||
UT_hash_handle *_src_hh, *_dst_hh, *_last_elt_hh=NULL; \
|
|
||||||
ptrdiff_t _dst_hho = ((char*)(&(dst)->hh_dst) - (char*)(dst)); \
|
|
||||||
if (src) { \
|
|
||||||
for(_src_bkt=0; _src_bkt < (src)->hh_src.tbl->num_buckets; _src_bkt++) { \
|
|
||||||
for(_src_hh = (src)->hh_src.tbl->buckets[_src_bkt].hh_head; \
|
|
||||||
_src_hh; \
|
|
||||||
_src_hh = _src_hh->hh_next) { \
|
|
||||||
_elt = ELMT_FROM_HH((src)->hh_src.tbl, _src_hh); \
|
|
||||||
if (cond(_elt)) { \
|
|
||||||
_dst_hh = (UT_hash_handle*)(((char*)_elt) + _dst_hho); \
|
|
||||||
_dst_hh->key = _src_hh->key; \
|
|
||||||
_dst_hh->keylen = _src_hh->keylen; \
|
|
||||||
_dst_hh->hashv = _src_hh->hashv; \
|
|
||||||
_dst_hh->prev = _last_elt; \
|
|
||||||
_dst_hh->next = NULL; \
|
|
||||||
if (_last_elt_hh) { _last_elt_hh->next = _elt; } \
|
|
||||||
if (!dst) { \
|
|
||||||
DECLTYPE_ASSIGN(dst,_elt); \
|
|
||||||
HASH_MAKE_TABLE(hh_dst,dst); \
|
|
||||||
} else { \
|
|
||||||
_dst_hh->tbl = (dst)->hh_dst.tbl; \
|
|
||||||
} \
|
|
||||||
HASH_TO_BKT(_dst_hh->hashv, _dst_hh->tbl->num_buckets, _dst_bkt); \
|
|
||||||
HASH_ADD_TO_BKT(_dst_hh->tbl->buckets[_dst_bkt],_dst_hh); \
|
|
||||||
(dst)->hh_dst.tbl->num_items++; \
|
|
||||||
_last_elt = _elt; \
|
|
||||||
_last_elt_hh = _dst_hh; \
|
|
||||||
} \
|
|
||||||
} \
|
|
||||||
} \
|
|
||||||
} \
|
|
||||||
HASH_FSCK(hh_dst,dst); \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
#define HASH_CLEAR(hh,head) \
|
|
||||||
do { \
|
|
||||||
if (head) { \
|
|
||||||
uthash_free((head)->hh.tbl->buckets, \
|
|
||||||
(head)->hh.tbl->num_buckets*sizeof(struct UT_hash_bucket)); \
|
|
||||||
HASH_BLOOM_FREE((head)->hh.tbl); \
|
|
||||||
uthash_free((head)->hh.tbl, sizeof(UT_hash_table)); \
|
|
||||||
(head)=NULL; \
|
|
||||||
} \
|
|
||||||
} while(0)
|
|
||||||
|
|
||||||
#define HASH_OVERHEAD(hh,head) \
|
|
||||||
(size_t)((((head)->hh.tbl->num_items * sizeof(UT_hash_handle)) + \
|
|
||||||
((head)->hh.tbl->num_buckets * sizeof(UT_hash_bucket)) + \
|
|
||||||
(sizeof(UT_hash_table)) + \
|
|
||||||
(HASH_BLOOM_BYTELEN)))
|
|
||||||
|
|
||||||
#ifdef NO_DECLTYPE
|
|
||||||
#define HASH_ITER(hh,head,el,tmp) \
|
|
||||||
for((el)=(head), (*(char**)(&(tmp)))=(char*)((head)?(head)->hh.next:NULL); \
|
|
||||||
el; (el)=(tmp),(*(char**)(&(tmp)))=(char*)((tmp)?(tmp)->hh.next:NULL))
|
|
||||||
#else
|
|
||||||
#define HASH_ITER(hh,head,el,tmp) \
|
|
||||||
for((el)=(head),(tmp)=DECLTYPE(el)((head)?(head)->hh.next:NULL); \
|
|
||||||
el; (el)=(tmp),(tmp)=DECLTYPE(el)((tmp)?(tmp)->hh.next:NULL))
|
|
||||||
#endif
|
|
||||||
|
|
||||||
/* obtain a count of items in the hash */
|
|
||||||
#define HASH_COUNT(head) HASH_CNT(hh,head)
|
|
||||||
#define HASH_CNT(hh,head) ((head)?((head)->hh.tbl->num_items):0)
|
|
||||||
|
|
||||||
typedef struct UT_hash_bucket {
|
|
||||||
struct UT_hash_handle *hh_head;
|
|
||||||
unsigned count;
|
|
||||||
|
|
||||||
/* expand_mult is normally set to 0. In this situation, the max chain length
|
|
||||||
* threshold is enforced at its default value, HASH_BKT_CAPACITY_THRESH. (If
|
|
||||||
* the bucket's chain exceeds this length, bucket expansion is triggered).
|
|
||||||
* However, setting expand_mult to a non-zero value delays bucket expansion
|
|
||||||
* (that would be triggered by additions to this particular bucket)
|
|
||||||
* until its chain length reaches a *multiple* of HASH_BKT_CAPACITY_THRESH.
|
|
||||||
* (The multiplier is simply expand_mult+1). The whole idea of this
|
|
||||||
* multiplier is to reduce bucket expansions, since they are expensive, in
|
|
||||||
* situations where we know that a particular bucket tends to be overused.
|
|
||||||
* It is better to let its chain length grow to a longer yet-still-bounded
|
|
||||||
* value, than to do an O(n) bucket expansion too often.
|
|
||||||
*/
|
|
||||||
unsigned expand_mult;
|
|
||||||
|
|
||||||
} UT_hash_bucket;
|
|
||||||
|
|
||||||
/* random signature used only to find hash tables in external analysis */
|
|
||||||
#define HASH_SIGNATURE 0xa0111fe1
|
|
||||||
#define HASH_BLOOM_SIGNATURE 0xb12220f2
|
|
||||||
|
|
||||||
typedef struct UT_hash_table {
|
|
||||||
UT_hash_bucket *buckets;
|
|
||||||
unsigned num_buckets, log2_num_buckets;
|
|
||||||
unsigned num_items;
|
|
||||||
struct UT_hash_handle *tail; /* tail hh in app order, for fast append */
|
|
||||||
ptrdiff_t hho; /* hash handle offset (byte pos of hash handle in element */
|
|
||||||
|
|
||||||
/* in an ideal situation (all buckets used equally), no bucket would have
|
|
||||||
* more than ceil(#items/#buckets) items. that's the ideal chain length. */
|
|
||||||
unsigned ideal_chain_maxlen;
|
|
||||||
|
|
||||||
/* nonideal_items is the number of items in the hash whose chain position
|
|
||||||
* exceeds the ideal chain maxlen. these items pay the penalty for an uneven
|
|
||||||
* hash distribution; reaching them in a chain traversal takes >ideal steps */
|
|
||||||
unsigned nonideal_items;
|
|
||||||
|
|
||||||
/* ineffective expands occur when a bucket doubling was performed, but
|
|
||||||
* afterward, more than half the items in the hash had nonideal chain
|
|
||||||
* positions. If this happens on two consecutive expansions we inhibit any
|
|
||||||
* further expansion, as it's not helping; this happens when the hash
|
|
||||||
* function isn't a good fit for the key domain. When expansion is inhibited
|
|
||||||
* the hash will still work, albeit no longer in constant time. */
|
|
||||||
unsigned ineff_expands, noexpand;
|
|
||||||
|
|
||||||
uint32_t signature; /* used only to find hash tables in external analysis */
|
|
||||||
#ifdef HASH_BLOOM
|
|
||||||
uint32_t bloom_sig; /* used only to test bloom exists in external analysis */
|
|
||||||
uint8_t *bloom_bv;
|
|
||||||
char bloom_nbits;
|
|
||||||
#endif
|
|
||||||
|
|
||||||
} UT_hash_table;
|
|
||||||
|
|
||||||
typedef struct UT_hash_handle {
|
|
||||||
struct UT_hash_table *tbl;
|
|
||||||
void *prev; /* prev element in app order */
|
|
||||||
void *next; /* next element in app order */
|
|
||||||
struct UT_hash_handle *hh_prev; /* previous hh in bucket order */
|
|
||||||
struct UT_hash_handle *hh_next; /* next hh in bucket order */
|
|
||||||
void *key; /* ptr to enclosing struct's key */
|
|
||||||
unsigned keylen; /* enclosing struct's key len */
|
|
||||||
unsigned hashv; /* result of hash-fcn(key) */
|
|
||||||
} UT_hash_handle;
|
|
||||||
|
|
||||||
#endif /* UTHASH_H */
|
|
||||||
@@ -1,85 +0,0 @@
|
|||||||
/*
|
|
||||||
This file is part of Pretty Curved Privacy (pcp1).
|
|
||||||
|
|
||||||
Copyright (C) 2013 T.Linden.
|
|
||||||
|
|
||||||
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 Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
You can contact me by mail: <tlinden AT cpan DOT org>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#ifndef _HAVE_PCP_VAULT
|
|
||||||
#define _HAVE_PCP_VAULT
|
|
||||||
|
|
||||||
#include <sys/types.h>
|
|
||||||
#include <sys/stat.h>
|
|
||||||
#include <stdio.h>
|
|
||||||
#include <sodium.h>
|
|
||||||
#include <unistd.h>
|
|
||||||
|
|
||||||
#include "defines.h"
|
|
||||||
#include "platform.h"
|
|
||||||
#include "mem.h"
|
|
||||||
#include "key.h"
|
|
||||||
#include "uthash.h"
|
|
||||||
|
|
||||||
|
|
||||||
struct _vault_t {
|
|
||||||
char *filename;
|
|
||||||
FILE *fd;
|
|
||||||
uint8_t unsafed;
|
|
||||||
uint8_t isnew;
|
|
||||||
uint32_t size;
|
|
||||||
time_t modified;
|
|
||||||
mode_t mode;
|
|
||||||
uint32_t version;
|
|
||||||
byte checksum[32];
|
|
||||||
};
|
|
||||||
|
|
||||||
struct _vault_header_t {
|
|
||||||
byte fileid;
|
|
||||||
uint32_t version;
|
|
||||||
byte checksum[32];
|
|
||||||
};
|
|
||||||
|
|
||||||
struct _vault_item_header_t {
|
|
||||||
byte type;
|
|
||||||
uint32_t size;
|
|
||||||
uint32_t version;
|
|
||||||
byte checksum[32];
|
|
||||||
};
|
|
||||||
|
|
||||||
typedef struct _vault_t vault_t;
|
|
||||||
typedef struct _vault_header_t vault_header_t;
|
|
||||||
typedef struct _vault_item_header_t vault_item_header_t;
|
|
||||||
|
|
||||||
vault_t *pcpvault_init(char *filename);
|
|
||||||
vault_t *pcpvault_new(char *filename, int is_tmp);
|
|
||||||
int pcpvault_create(vault_t *vault);
|
|
||||||
int pcpvault_additem(vault_t *vault, void *item, size_t itemsize, uint8_t type, uint8_t do_hash);
|
|
||||||
int pcpvault_close(vault_t *vault);
|
|
||||||
int pcpvault_fetchall(vault_t *vault);
|
|
||||||
int pcpvault_writeall(vault_t *vault);
|
|
||||||
void pcpvault_copy(vault_t *tmp, vault_t *vault);
|
|
||||||
void pcpvault_unlink(vault_t *tmp);
|
|
||||||
unsigned char *pcpvault_create_checksum(vault_t *vault);
|
|
||||||
void pcpvault_update_checksum(vault_t *vault);
|
|
||||||
|
|
||||||
vault_header_t * vh2be(vault_header_t *h);
|
|
||||||
vault_header_t * vh2native(vault_header_t *h);
|
|
||||||
vault_item_header_t * ih2be(vault_item_header_t *h);
|
|
||||||
vault_item_header_t * ih2native(vault_item_header_t *h);
|
|
||||||
|
|
||||||
#endif // _HAVE_PCP_VAULT
|
|
||||||
@@ -1,37 +0,0 @@
|
|||||||
/*
|
|
||||||
This file is part of Pretty Curved Privacy (pcp1).
|
|
||||||
|
|
||||||
Copyright (C) 2013 T.Linden.
|
|
||||||
|
|
||||||
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 Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
You can contact me by mail: <tlinden AT cpan DOT org>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#ifndef _HAVE_PCP_VERSION
|
|
||||||
#define _HAVE_PCP_VERSION
|
|
||||||
|
|
||||||
#define PCP_VERSION_MAJOR 0
|
|
||||||
#define PCP_VERSION_MINOR 1
|
|
||||||
#define PCP_VERSION_PATCH 2
|
|
||||||
|
|
||||||
#define PCP_MAKE_VERSION(major, minor, patch) \
|
|
||||||
((major) * 10000 + (minor) * 100 + (patch))
|
|
||||||
#define PCP_VERSION \
|
|
||||||
PCP_MAKE_VERSION(PCP_VERSION_MAJOR, PCP_VERSION_MINOR, PCP_VERSION_PATCH)
|
|
||||||
|
|
||||||
int pcp_version();
|
|
||||||
|
|
||||||
#endif // _HAVE_PCP_VERSION
|
|
||||||
45
libpcp/z85.h
45
libpcp/z85.h
@@ -1,45 +0,0 @@
|
|||||||
/*
|
|
||||||
This file is part of Pretty Curved Privacy (pcp1).
|
|
||||||
|
|
||||||
Copyright (C) 2013 T.Linden.
|
|
||||||
|
|
||||||
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 Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
|
|
||||||
You can contact me by mail: <tlinden AT cpan DOT org>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
// from https://github.com/tlinden/curve-keygen/
|
|
||||||
#ifndef _HAVE_PCP_Z85_H
|
|
||||||
|
|
||||||
#include "defines.h"
|
|
||||||
#include "zmq_z85.h"
|
|
||||||
#include "mem.h"
|
|
||||||
|
|
||||||
// convert a binary stream to one which gets accepted by zmq_z85_encode
|
|
||||||
// we pad it with zeroes and put the number of zerores in front of it
|
|
||||||
unsigned char *pcp_unpadfour(unsigned char *src, size_t srclen, size_t *dstlen);
|
|
||||||
|
|
||||||
// the reverse of the above
|
|
||||||
unsigned char *pcp_unpadfour(unsigned char *src, size_t srclen, size_t *dstlen);
|
|
||||||
|
|
||||||
// wrapper around zmq Z85 encoding function
|
|
||||||
unsigned char *pcp_z85_decode(char *z85block, size_t *dstlen);
|
|
||||||
|
|
||||||
// the reverse of the above
|
|
||||||
char *pcp_z85_encode(unsigned char *raw, size_t srclen, size_t *dstlen);
|
|
||||||
|
|
||||||
char *pcp_readz85file(FILE *infile);
|
|
||||||
|
|
||||||
#endif // _HAVE_PCP_Z85_H
|
|
||||||
@@ -1,39 +0,0 @@
|
|||||||
/*
|
|
||||||
Copyright (c) 2007-2013 Contributors as noted in the AUTHORS file
|
|
||||||
|
|
||||||
This file is part of 0MQ.
|
|
||||||
|
|
||||||
0MQ is free software; you can redistribute it and/or modify it under
|
|
||||||
the terms of the GNU Lesser General Public License as published by
|
|
||||||
the Free Software Foundation; either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
0MQ is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU Lesser General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU Lesser General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#ifndef __ZMQ_Z85_H_INCLUDED__
|
|
||||||
#define __ZMQ_Z85_H_INCLUDED__
|
|
||||||
|
|
||||||
#include <stdio.h>
|
|
||||||
#include <string.h>
|
|
||||||
#include <stdint.h>
|
|
||||||
#include <stdlib.h>
|
|
||||||
|
|
||||||
#ifdef __cplusplus
|
|
||||||
extern "C" {
|
|
||||||
#endif
|
|
||||||
|
|
||||||
uint8_t *zmq_z85_decode (uint8_t *dest, char *string);
|
|
||||||
char *zmq_z85_encode (char *dest, uint8_t *data, size_t size);
|
|
||||||
|
|
||||||
#ifdef __cplusplus
|
|
||||||
}
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#endif
|
|
||||||
Reference in New Issue
Block a user