#include <arpa/inet.h>
#include <errno.h>
#include <net/if.h>
#include <netdb.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <stdlib.h>
#include <sys/param.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <sys/time.h>
#include <sys/uio.h>
#include <sys/un.h>
#include <time.h>
#include <errmsg.h>
#include <mysql.h>
#include <mysqld_error.h>
#include <atalk/adouble.h>
#include <atalk/cnid_bdb_private.h>
#include <atalk/cnid_mysql_private.h>
#include <atalk/errchk.h>
#include <atalk/globals.h>
#include <atalk/logger.h>
#include <atalk/unix.h>
#include <atalk/util.h>
#include <atalk/volume.h>

Macros
#define	CNID_MYSQL_HINT_RESERVE (1u << 28)
#define	CNID_MYSQL_MAX_HINT (UINT32_MAX - CNID_MYSQL_HINT_RESERVE)
#define	CNID_MYSQL_ADD_ATTEMPTS 16
#define	CNID_MYSQL_RECONNECT_ATTEMPTS 2

Functions
static bool	cnid_mysql_hint_usable (cnid_t hint)
	Whether a CNID hint from AppleDouble/EA metadata is safe to bind.
static int	init_prepared_stmt_lookup (CNID_mysql_private *db)
static int	init_prepared_stmt_add (CNID_mysql_private *db)
static int	init_prepared_stmt_put (CNID_mysql_private *db)
static int	init_prepared_stmt_get (CNID_mysql_private *db)
static int	init_prepared_stmt_delete (CNID_mysql_private *db)
static int	init_prepared_stmt_resolve (CNID_mysql_private *db)
static int	init_prepared_stmt_purge (CNID_mysql_private *db)
static int	init_prepared_stmt (CNID_mysql_private *db)
static void	close_prepared_stmt (CNID_mysql_private *db)
static void	cnid_mysql_set_errno (unsigned int mysql_error_code)
static int	cnid_mysql_drain_results (MYSQL *con)
	Drain the remaining results of a multi-statement batch.
static int	cnid_mysql_stmt_execute (CNID_mysql_private db, MYSQL_STMT *stmtp)
static int	cnid_mysql_execute (MYSQL con, const char sql)
int	cnid_mysql_delete (struct _cnid_db *cdb, const cnid_t id)
void	cnid_mysql_close (struct _cnid_db *cdb)
int	cnid_mysql_update (struct _cnid_db cdb, cnid_t id, const struct stat st, cnid_t did, const char *name, size_t len)
cnid_t	cnid_mysql_lookup (struct _cnid_db cdb, const struct stat st, cnid_t did, const char *name, size_t len)
cnid_t	cnid_mysql_add (struct _cnid_db cdb, const struct stat st, cnid_t did, const char *name, size_t len, cnid_t hint)
cnid_t	cnid_mysql_get (struct _cnid_db cdb, cnid_t did, const char name, size_t len)
char *	cnid_mysql_resolve (struct _cnid_db cdb, cnid_t id, void *buffer, size_t len)
int	cnid_mysql_getstamp (struct _cnid_db cdb, void buffer, const size_t len)
int	cnid_mysql_find (struct _cnid_db cdb, const char name, size_t namelen, cnid_t scope_did, void buffer, size_t buflen, bool more_available)
	Backend implementation of cnid_find() for the mysql backend.
cnid_t	cnid_mysql_rebuild_add (struct _cnid_db cdb, const struct stat st, cnid_t did, const char *name, size_t len, cnid_t hint)
int	cnid_mysql_wipe (struct _cnid_db *cdb)
static struct _cnid_db *	cnid_mysql_new (struct vol *vol)
struct _cnid_db *	cnid_mysql_open (struct cnid_open_args *args)

Variables
static MYSQL_BIND	lookup_param [4]
static MYSQL_BIND	lookup_result [5]
static MYSQL_BIND	add_param [4]
static MYSQL_BIND	put_param [5]
static MYSQL_BIND	get_param [2]
static MYSQL_BIND	get_result [1]
static MYSQL_BIND	delete_param [1]
static MYSQL_BIND	resolve_param [1]
static MYSQL_BIND	resolve_result [2]
static MYSQL_BIND	purge_param [5]
static char	stmt_param_name [MAXPATHLEN]
static unsigned long	stmt_param_name_len
static unsigned long long	stmt_param_id
static unsigned long long	stmt_param_did
static unsigned long long	stmt_param_dev
static unsigned long long	stmt_param_ino
static unsigned long long	lookup_result_id
static unsigned long long	lookup_result_did
static char	lookup_result_name [MAXPATHLEN]
static unsigned long	lookup_result_name_len
static unsigned long long	lookup_result_dev
static unsigned long long	lookup_result_ino
static unsigned long long	get_result_id
static unsigned long long	resolve_result_did
static char	resolve_result_name [MAXPATHLEN]
static unsigned long	resolve_result_name_len
struct _cnid_module	cnid_mysql_module

Macro Definition Documentation

◆ CNID_MYSQL_ADD_ATTEMPTS

#define CNID_MYSQL_ADD_ATTEMPTS 16

◆ CNID_MYSQL_HINT_RESERVE

#define CNID_MYSQL_HINT_RESERVE (1u << 28)

◆ CNID_MYSQL_MAX_HINT

#define CNID_MYSQL_MAX_HINT (UINT32_MAX - CNID_MYSQL_HINT_RESERVE)

◆ CNID_MYSQL_RECONNECT_ATTEMPTS

#define CNID_MYSQL_RECONNECT_ATTEMPTS 2

Function Documentation

◆ close_prepared_stmt()

void close_prepared_stmt ( CNID_mysql_private * db )

static

NULL-safe and NULLs each handle: a failed recovery leaves a mix of closed and live handles, and a later close or re-init must neither double-close nor leak the survivors.

◆ cnid_mysql_add()

cnid_t cnid_mysql_add	(	struct _cnid_db *	cdb,
		const struct stat *	st,
		cnid_t	did,
		const char *	name,
		size_t	len,
		cnid_t	hint )

◆ cnid_mysql_close()

void cnid_mysql_close ( struct _cnid_db * cdb )

◆ cnid_mysql_delete()

int cnid_mysql_delete	(	struct _cnid_db *	cdb,
		const cnid_t	id )

◆ cnid_mysql_drain_results()

int cnid_mysql_drain_results ( MYSQL * con )

static

Drain the remaining results of a multi-statement batch.

cnid_mysql_execute() reports only the batch's first statement. mysql_next_result() returns >0 when a later one failed, which a plain "== 0" loop reads as the end of the batch — so a wipe whose TRUNCATE or ALTER failed would be taken for a completed one.

Returns: 0 when every statement succeeded, -1 otherwise

◆ cnid_mysql_execute()

int cnid_mysql_execute	(	MYSQL *	con,
		const char *	sql )

static

◆ cnid_mysql_find()

int cnid_mysql_find	(	struct _cnid_db *	cdb,
		const char *	name,
		size_t	namelen,
		cnid_t	scope_did,
		void *	buffer,
		size_t	buflen,
		bool *	more_available )

Backend implementation of cnid_find() for the mysql backend.

Parameters are pre-validated by the libatalk/cnid/cnid.c wrapper, so cdb, name, namelen and buflen are all sane on entry. Detects truncation by building "LIMIT max_results + 1" into the SQL and observing whether the extra row was produced; reports it via more_available.

The Name LIKE parameter is bound via mysql_stmt_bind_param, never inlined into the SQL string, to prevent a filename SQL-injection vector. The LIMIT literal is not user-controlled (derived from caller's buflen) and is safely interpolated into the SQL string.

◆ cnid_mysql_get()

cnid_t cnid_mysql_get	(	struct _cnid_db *	cdb,
		cnid_t	did,
		const char *	name,
		size_t	len )

◆ cnid_mysql_getstamp()

int cnid_mysql_getstamp	(	struct _cnid_db *	cdb,
		void *	buffer,
		const size_t	len )

Caller passes buffer where we will store the db stamp

◆ cnid_mysql_hint_usable()

bool cnid_mysql_hint_usable ( cnid_t hint )

static

Whether a CNID hint from AppleDouble/EA metadata is safe to bind.

Rejects the reserved range below CNID_START and anything above CNID_MYSQL_MAX_HINT, which as an explicit Id would raise the AUTO_INCREMENT high-water mark towards the depletion reset.

◆ cnid_mysql_lookup()

cnid_t cnid_mysql_lookup	(	struct _cnid_db *	cdb,
		const struct stat *	st,
		cnid_t	did,
		const char *	name,
		size_t	len )

◆ cnid_mysql_new()

struct _cnid_db * cnid_mysql_new ( struct vol * vol )

static

◆ cnid_mysql_open()

struct _cnid_db * cnid_mysql_open ( struct cnid_open_args * args )

◆ cnid_mysql_rebuild_add()

cnid_t cnid_mysql_rebuild_add	(	struct _cnid_db *	cdb,
		const struct stat *	st,
		cnid_t	did,
		const char *	name,
		size_t	len,
		cnid_t	hint )

◆ cnid_mysql_resolve()

char * cnid_mysql_resolve	(	struct _cnid_db *	cdb,
		cnid_t *	id,
		void *	buffer,
		size_t	len )

◆ cnid_mysql_set_errno()

void cnid_mysql_set_errno ( unsigned int mysql_error_code )

static

◆ cnid_mysql_stmt_execute()

int cnid_mysql_stmt_execute	(	CNID_mysql_private *	db,
		MYSQL_STMT **	stmtp )

static

stmtp must point at the handle field in CNID_mysql_private: CR_SERVER_LOST recovery reallocates every handle, and the retry must execute the fresh one. Recovery also invalidates any other statement's in-flight stored result.

◆ cnid_mysql_update()

int cnid_mysql_update	(	struct _cnid_db *	cdb,
		cnid_t	id,
		const struct stat *	st,
		cnid_t	did,
		const char *	name,
		size_t	len )

◆ cnid_mysql_wipe()

int cnid_mysql_wipe ( struct _cnid_db * cdb )

◆ init_prepared_stmt()

int init_prepared_stmt ( CNID_mysql_private * db )

static

◆ init_prepared_stmt_add()

int init_prepared_stmt_add ( CNID_mysql_private * db )

static

◆ init_prepared_stmt_delete()

int init_prepared_stmt_delete ( CNID_mysql_private * db )

static

◆ init_prepared_stmt_get()

int init_prepared_stmt_get ( CNID_mysql_private * db )

static

◆ init_prepared_stmt_lookup()

int init_prepared_stmt_lookup ( CNID_mysql_private * db )

static

◆ init_prepared_stmt_purge()

int init_prepared_stmt_purge ( CNID_mysql_private * db )

static

◆ init_prepared_stmt_put()

int init_prepared_stmt_put ( CNID_mysql_private * db )

static

◆ init_prepared_stmt_resolve()

int init_prepared_stmt_resolve ( CNID_mysql_private * db )

static

Variable Documentation

◆ add_param

MYSQL_BIND add_param[4]

static

◆ cnid_mysql_module

struct _cnid_module cnid_mysql_module

Initial value:

                  = {
    "mysql",
    {NULL, NULL},
    cnid_mysql_open,
    0
}

◆ delete_param

MYSQL_BIND delete_param[1]

static

◆ get_param

MYSQL_BIND get_param[2]

static

◆ get_result

MYSQL_BIND get_result[1]

static

◆ get_result_id

unsigned long long get_result_id

static

◆ lookup_param

MYSQL_BIND lookup_param[4]

static

◆ lookup_result

MYSQL_BIND lookup_result[5]

static

◆ lookup_result_dev

unsigned long long lookup_result_dev

static

◆ lookup_result_did

unsigned long long lookup_result_did

static

◆ lookup_result_id

unsigned long long lookup_result_id

static

lookup result parameters

◆ lookup_result_ino

unsigned long long lookup_result_ino

static

◆ lookup_result_name

char lookup_result_name[MAXPATHLEN]

static

◆ lookup_result_name_len

unsigned long lookup_result_name_len

static

◆ purge_param

MYSQL_BIND purge_param[5]

static

◆ put_param

MYSQL_BIND put_param[5]

static

◆ resolve_param

MYSQL_BIND resolve_param[1]

static

◆ resolve_result

MYSQL_BIND resolve_result[2]

static

◆ resolve_result_did

unsigned long long resolve_result_did

static

◆ resolve_result_name

char resolve_result_name[MAXPATHLEN]

static

◆ resolve_result_name_len

unsigned long resolve_result_name_len

static

◆ stmt_param_dev

unsigned long long stmt_param_dev

static

◆ stmt_param_did

unsigned long long stmt_param_did

static

◆ stmt_param_id

unsigned long long stmt_param_id

static

◆ stmt_param_ino

unsigned long long stmt_param_ino

static

◆ stmt_param_name

char stmt_param_name[MAXPATHLEN]

static

Prepared statement parameters

◆ stmt_param_name_len

unsigned long stmt_param_name_len

static

Macros

Functions

Variables

Macro Definition Documentation

◆ CNID_MYSQL_ADD_ATTEMPTS

◆ CNID_MYSQL_HINT_RESERVE

◆ CNID_MYSQL_MAX_HINT

◆ CNID_MYSQL_RECONNECT_ATTEMPTS

Function Documentation

◆ close_prepared_stmt()

◆ cnid_mysql_add()

◆ cnid_mysql_close()

◆ cnid_mysql_delete()

◆ cnid_mysql_drain_results()

◆ cnid_mysql_execute()

◆ cnid_mysql_find()

◆ cnid_mysql_get()

◆ cnid_mysql_getstamp()

◆ cnid_mysql_hint_usable()

◆ cnid_mysql_lookup()

◆ cnid_mysql_new()

◆ cnid_mysql_open()

◆ cnid_mysql_rebuild_add()

◆ cnid_mysql_resolve()

◆ cnid_mysql_set_errno()

◆ cnid_mysql_stmt_execute()

◆ cnid_mysql_update()

◆ cnid_mysql_wipe()

◆ init_prepared_stmt()

◆ init_prepared_stmt_add()

◆ init_prepared_stmt_delete()

◆ init_prepared_stmt_get()

◆ init_prepared_stmt_lookup()

◆ init_prepared_stmt_purge()

◆ init_prepared_stmt_put()

◆ init_prepared_stmt_resolve()

Variable Documentation

◆ add_param

◆ cnid_mysql_module

◆ delete_param

◆ get_param

◆ get_result

◆ get_result_id

◆ lookup_param

◆ lookup_result

◆ lookup_result_dev

◆ lookup_result_did

◆ lookup_result_id

◆ lookup_result_ino

◆ lookup_result_name

◆ lookup_result_name_len

◆ purge_param

◆ put_param

◆ resolve_param

◆ resolve_result

◆ resolve_result_did

◆ resolve_result_name

◆ resolve_result_name_len

◆ stmt_param_dev

◆ stmt_param_did

◆ stmt_param_id

◆ stmt_param_ino

◆ stmt_param_name

◆ stmt_param_name_len