tm.c File Reference

#include "db_config.h"
#include <sys/types.h>
#include <sys/mman.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include "db_int.h"

Go to the source code of this file.

Defines
#define	MAP_FAILED   (void *)-1
#define	MAP_FILE   0
#define	MUTEX_WAKEME   0x80
Functions
void	exec_proc ()
int	main (int argc, argv)
void	run_proc ()
void *	run_thread ()
void *	run_thread_wake ()
void	tm_file_init ()
void	tm_mutex_destroy ()
void	tm_mutex_init ()
void	tm_mutex_stats ()
void	unmap_file ()
Variables
int	align
int	child
DB_ENV	dbenv
char *	file = "mutex.file"
size_t	len
int	maxlocks = 20
int	nlocks = 10000
int	nprocs = 20
int	nthreads = 1
int	quit
int	verbose

---

Define Documentation

#define MAP_FAILED   (void *)-1

Referenced by _mi_memmap_file(), history_do_write(), and read_history_range().

#define MAP_FILE   0

#define MUTEX_WAKEME   0x80

Definition at line 35 of file tm.c. Referenced by run_thread().

---

Function Documentation

void exec_proc (   )

Referenced by main().

int main (  int  argc, argv  )

Definition at line 51 of file tm.c. References ALIGN, align, atoi(), child, exec_proc(), getopt(), len, maxlocks, MUTEX_ALIGN, nlocks, nprocs, nthreads, optarg, optind, perror(), run_proc(), status, tm_file_init(), tm_mutex_destroy(), tm_mutex_init(), tm_mutex_stats(), verbose, and WEXITSTATUS. { extern int optind; extern char *optarg; pid_t pid; int ch, eval, i, status; char *tmpath; tmpath = argv[0]; while ((ch = getopt(argc, argv, "l:n:p:st:v")) != EOF) switch(ch) { case 'l': maxlocks = atoi(optarg); break; case 'n': nlocks = atoi(optarg); break; case 'p': nprocs = atoi(optarg); break; case 's': child = 1; break; case 't': nthreads = atoi(optarg); #if !defined(HAVE_MUTEX_PTHREADS) && !defined(BUILD_PTHREADS_ANYWAY) if (nthreads != 1) { (void)fprintf(stderr, "tm: pthreads not available or not compiled for this platform.\n"); return (EXIT_FAILURE); } #endif break; case 'v': verbose = 1; break; case '?': default: (void)fprintf(stderr, "usage: tm [-v] [-l maxlocks] [-n locks] [-p procs] [-t threads]\n"); return (EXIT_FAILURE); } argc -= optind; argv += optind; /* * The file layout: * DB_MUTEX[1] per-thread mutex array lock * DB_MUTEX[nthreads] per-thread mutex array * DB_MUTEX[maxlocks] per-lock mutex array * u_long[maxlocks][2] per-lock ID array */ align = ALIGN(sizeof(DB_MUTEX) * 2, MUTEX_ALIGN); len = align * (1 + nthreads + maxlocks) + sizeof(u_long) * maxlocks * 2; printf( "mutex alignment %d, structure alignment %d, backing file %lu bytes\n", MUTEX_ALIGN, align, (u_long)len); if (child) { run_proc(); return (EXIT_SUCCESS); } tm_file_init(); tm_mutex_init(); printf( "%d proc, %d threads/proc, %d lock requests from %d locks:\n", nprocs, nthreads, nlocks, maxlocks); for (i = 0; i < nprocs; ++i) switch (fork()) { case -1: perror("fork"); return (EXIT_FAILURE); case 0: exec_proc(tmpath); break; default: break; } eval = EXIT_SUCCESS; while ((pid = wait(&status)) != (pid_t)-1) { fprintf(stderr, "%lu: exited %d\n", (u_long)pid, WEXITSTATUS(status)); if (WEXITSTATUS(status) != 0) eval = EXIT_FAILURE; } tm_mutex_stats(); tm_mutex_destroy(); printf("tm: exit status: %s\n", eval == EXIT_SUCCESS ? "success" : "failed!"); return (eval); }

void run_proc (   )

Definition at line 177 of file tm.c. References __os_sleep(), errno, exit, free, nthreads, NULL, quit, run_thread(), run_thread_wake(), status, and strerror(). Referenced by main(). { #if defined(HAVE_MUTEX_PTHREADS) || defined(BUILD_PTHREADS_ANYWAY) pthread_t *kidsp, wakep; int i, status; void *retp; #endif __os_sleep(&dbenv, 3, 0); /* Let everyone catch up. */ srand((u_int)time(NULL) / getpid()); /* Initialize random numbers. */ if (nthreads == 1) /* Simple case. */ exit((int)run_thread((void *)0)); #if defined(HAVE_MUTEX_PTHREADS) || defined(BUILD_PTHREADS_ANYWAY) /* * Spawn off threads. We have nthreads all locking and going to * sleep, and one other thread cycling through and waking them up. */ if ((kidsp = (pthread_t *)calloc(sizeof(pthread_t), nthreads)) == NULL) { fprintf(stderr, "tm: %s\n", strerror(errno)); exit(EXIT_FAILURE); } for (i = 0; i < nthreads; i++) if ((errno = pthread_create( &kidsp[i], NULL, run_thread, (void *)i)) != 0) { fprintf(stderr, "tm: failed spawning thread %d: %s\n", i, strerror(errno)); exit(EXIT_FAILURE); } if ((errno = pthread_create( &wakep, NULL, run_thread_wake, (void *)0)) != 0) { fprintf(stderr, "tm: failed spawning wakeup thread: %s\n", strerror(errno)); exit(EXIT_FAILURE); } /* Wait for the threads to exit. */ status = 0; for (i = 0; i < nthreads; i++) { pthread_join(kidsp[i], &retp); if (retp != NULL) { fprintf(stderr, "tm: thread %d exited with error\n", i); status = EXIT_FAILURE; } } free(kidsp); /* Signal wakeup thread to stop. */ quit = 1; pthread_join(wakep, &retp); if (retp != NULL) { fprintf(stderr, "tm: wakeup thread exited with error\n"); status = EXIT_FAILURE; } exit(status); #endif }

void* run_thread (   )

Referenced by run_proc().

void* run_thread_wake (   )

Referenced by run_proc().

void tm_file_init (   )

Definition at line 419 of file tm.c. References close(), errno, exit, file, len, lseek, off_t, open(), S_IRGRP, S_IROTH, S_IRUSR, S_IWGRP, S_IWOTH, S_IWUSR, SEEK_SET, strerror(), and write(). Referenced by main(). { int fd; /* Initialize the backing file. */ printf("Create the backing file...\n"); #ifdef HAVE_QNX (void)shm_unlink(file); if ((fd = shm_open(file, O_CREAT | O_RDWR | O_TRUNC, #else (void)remove(file); if ((fd = open(file, O_CREAT | O_RDWR | O_TRUNC, #endif S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH | S_IWOTH)) == -1) { (void)fprintf(stderr, "%s: open: %s\n", file, strerror(errno)); exit(EXIT_FAILURE); } if (lseek(fd, (off_t)len, SEEK_SET) != len || write(fd, &fd, 1) != 1) { (void)fprintf(stderr, "%s: seek/write: %s\n", file, strerror(errno)); exit(EXIT_FAILURE); } (void)close(fd); }

void tm_mutex_destroy (   )

Definition at line 498 of file tm.c. Referenced by main(). { DB_MUTEX *gm_addr, *lm_addr, *mp, *tm_addr; int fd, i; map_file(&gm_addr, &tm_addr, &lm_addr, NULL, &fd); printf("Destroy the global mutex...\n"); if (__db_mutex_destroy(gm_addr)) { fprintf(stderr, "__db_mutex_destroy (global): %s\n", strerror(errno)); exit(EXIT_FAILURE); } printf("Destroy the per-thread mutexes...\n"); for (i = 1, mp = tm_addr; i <= nthreads; ++i, mp = (DB_MUTEX *)((u_int8_t *)mp + align)) { if (__db_mutex_destroy(mp)) { fprintf(stderr, "__db_mutex_destroy (per-thread %d): %s\n", i, strerror(errno)); exit(EXIT_FAILURE); } } printf("Destroy the per-lock mutexes...\n"); for (i = 1, mp = lm_addr; i <= maxlocks; ++i, mp = (DB_MUTEX *)((u_int8_t *)mp + align)) if (__db_mutex_destroy(mp)) { fprintf(stderr, "__db_mutex_destroy (per-lock: %d): %s\n", i, strerror(errno)); exit(EXIT_FAILURE); } unmap_file((void *)gm_addr, fd); #ifdef HAVE_QNX (void)shm_unlink(file); #endif }

void tm_mutex_init (   )

Definition at line 451 of file tm.c. Referenced by main(). { DB_MUTEX *gm_addr, *lm_addr, *mp, *tm_addr; int fd, i; map_file(&gm_addr, &tm_addr, &lm_addr, NULL, &fd); printf("Initialize the global mutex...\n"); if (__db_mutex_init_int(&dbenv, gm_addr, 0, 0)) { fprintf(stderr, "__db_mutex_init (global): %s\n", strerror(errno)); exit(EXIT_FAILURE); } printf("Initialize the per-thread mutexes...\n"); for (i = 1, mp = tm_addr; i <= nthreads; ++i, mp = (DB_MUTEX *)((u_int8_t *)mp + align)) { if (__db_mutex_init_int(&dbenv, mp, 0, MUTEX_SELF_BLOCK)) { fprintf(stderr, "__db_mutex_init (per-thread %d): %s\n", i, strerror(errno)); exit(EXIT_FAILURE); } if (__db_mutex_lock(&dbenv, mp)) { fprintf(stderr, "__db_mutex_init (per-thread %d) lock: %s\n", i, strerror(errno)); exit(EXIT_FAILURE); } } printf("Initialize the per-lock mutexes...\n"); for (i = 1, mp = lm_addr; i <= maxlocks; ++i, mp = (DB_MUTEX *)((u_int8_t *)mp + align)) if (__db_mutex_init_int(&dbenv, mp, 0, 0)) { fprintf(stderr, "__db_mutex_init (per-lock: %d): %s\n", i, strerror(errno)); exit(EXIT_FAILURE); } unmap_file((void *)gm_addr, fd); }

void tm_mutex_stats (   )

Definition at line 544 of file tm.c. Referenced by main(). { DB_MUTEX *gm_addr, *lm_addr, *mp; int fd, i; map_file(&gm_addr, NULL, &lm_addr, NULL, &fd); printf("Per-lock mutex statistics...\n"); for (i = 1, mp = lm_addr; i <= maxlocks; ++i, mp = (DB_MUTEX *)((u_int8_t *)mp + align)) printf("mutex %2d: wait: %lu; no wait %lu\n", i, (u_long)mp->mutex_set_wait, (u_long)mp->mutex_set_nowait); unmap_file((void *)gm_addr, fd); }

void unmap_file (   )

Referenced by run_thread(), and mapped_file::~mapped_file().

---

Variable Documentation

int align

Definition at line 39 of file tm.c. Referenced by NdbOperation::equal_impl(), Dbdih::execDIADDTABREQ(), main(), run_thread(), NdbIndexScanOperation::setBound(), and FsBuffer::setup().

int child

Definition at line 46 of file tm.c. Referenced by __bam_dpages(), __bam_vrfy_inp(), __bam_vrfy_subtree(), __dd_build(), __ham_vrfy_bucket(), __ham_vrfy_item(), __ram_vrfy_inp(), sp_pcontext::destroy(), handle_child(), main(), sp_pcontext::push_context(), spawn_init(), and uses_only_table_name_fields().

DB_ENV dbenv

Definition at line 37 of file tm.c.

char* file = "mutex.file"

Definition at line 41 of file tm.c.

size_t len

Definition at line 38 of file tm.c.

int maxlocks = 20

Definition at line 43 of file tm.c. Referenced by exec_proc(), main(), and run_thread().

int nlocks = 10000

Definition at line 44 of file tm.c. Referenced by exec_proc(), main(), and run_thread().

int nprocs = 20

Definition at line 45 of file tm.c. Referenced by main().

int nthreads = 1

Definition at line 47 of file tm.c. Referenced by exec_proc(), main(), and run_proc().

int quit

Definition at line 40 of file tm.c. Referenced by run_proc().

int verbose

Definition at line 48 of file tm.c. Referenced by check_counts(), check_if_ignore_table(), com_go(), compress(), compress_isam_file(), convert_file(), db_connect(), db_disconnect(), dbConnect(), dbDisconnect(), dump_table(), examine_log(), exec_proc(), get_one_option(), get_options(), get_statistic(), get_table_structure(), get_view_structure(), join_same_trees(), lock_table(), main(), mysql_end(), open_isam_file(), out_header(), out_item(), out_trailer(), printf_log(), put_info(), run_test(), run_thread(), static_get_options(), term_echotc(), testMicros(), write_field_info(), write_huff_tree(), and write_to_table().

---