#include "locator.h"
#include "config.h"
#include "porting.h"
#include "memory_alloc.h"
#include "oid.h"
#include "object_representation.h"
#include "error_manager.h"
#include "storage_common.h"
#include "thread_compat.hpp"
#include <stdio.h>
#include <string.h>
#include <assert.h>

Include dependency graph for locator.c:

Classes
struct	locator_global

struct	locator_global::locator_global_copyareas

struct	locator_global::locator_global_lockset_areas

struct	locator_global::locator_global_lockhint_areas

struct	locator_global::locator_global_packed_areas

Macros
#define	pthread_mutex_init(a, b)

#define	pthread_mutex_destroy(a)

#define	pthread_mutex_lock(a) 0

#define	pthread_mutex_unlock(a)

#define	LOCATOR_NKEEP_LIMIT (2)

#define	LOCATOR_CACHED_COPYAREA_SIZE_LIMIT (IO_MAX_PAGE_SIZE * 2 + sizeof (LC_COPYAREA))

Typedefs
typedef struct locator_global	LOCATOR_GLOBAL

Functions
static char *	locator_allocate_packed (int packed_size)

static char *	locator_reallocate_packed (char *packed, int packed_size)

static void	locator_free_packed (char *packed_area, int packed_size)

static int	locator_initialize_lockset (LC_LOCKSET *lockset, int length, int max_reqobjs, LOCK reqobj_inst_lock, LOCK reqobj_class_lock, int quit_on_errors)

static char *	locator_pack_lockset_header (char packed, LC_LOCKSET lockset)

static char *	locator_pack_lockset_classes (char packed, LC_LOCKSET lockset)

static char *	locator_pack_lockset_objects (char packed, LC_LOCKSET lockset)

static char *	locator_unpack_lockset_header (char unpacked, LC_LOCKSET lockset)

static char *	locator_unpack_lockset_classes (char unpacked, LC_LOCKSET lockset)

static char *	locator_unpack_lockset_objects (char unpacked, LC_LOCKSET lockset)

static int	locator_initialize_lockhint (LC_LOCKHINT *lockhint, int length, int max_classes, bool quit_on_errors)

static char *	locator_pack_lockhint_header (char packed, LC_LOCKHINT lockhint)

static char *	locator_pack_lockhint_classes (char packed, LC_LOCKHINT lockhint)

static char *	locator_unpack_lockhint_header (char unpacked, LC_LOCKHINT lockhint)

static char *	locator_unpack_lockhint_classes (char unpacked, LC_LOCKHINT lockhint)

static bool	locator_is_hfid_equal (HFID hfid1_p, HFID hfid2_p)

void	locator_initialize_areas (void)

void	locator_free_areas (void)

LC_COPYAREA *	locator_allocate_copy_area_by_length (int min_length)

LC_COPYAREA *	locator_reallocate_copy_area_by_length (LC_COPYAREA *old_area, int new_length)

void	locator_free_copy_area (LC_COPYAREA *copyarea)

char *	locator_pack_copy_area_descriptor (int num_objs, LC_COPYAREA copyarea, char desc, int desc_len)

char *	locator_unpack_copy_area_descriptor (int num_objs, LC_COPYAREA copyarea, char desc)

int	locator_send_copy_area (LC_COPYAREA copyarea, char contents_ptr, int contents_length, char *desc_ptr, int desc_length)

LC_COPYAREA *	locator_recv_allocate_copyarea (int num_objs, char packed_desc, int packed_desc_length, char contents_ptr, int contents_length)

LC_LOCKSET *	locator_allocate_lockset (int max_reqobjs, LOCK reqobj_inst_lock, LOCK reqobj_class_lock, int quit_on_errors)

LC_LOCKSET *	locator_reallocate_lockset (LC_LOCKSET *lockset, int max_reqobjs)

void	locator_free_lockset (LC_LOCKSET *lockset)

LC_LOCKSET *	locator_allocate_and_unpack_lockset (char *unpacked, int unpacked_size, bool unpack_classes, bool unpack_objects, bool reg_unpacked)

int	locator_pack_lockset (LC_LOCKSET *lockset, bool pack_classes, bool pack_objects)

int	locator_unpack_lockset (LC_LOCKSET *lockset, bool unpack_classes, bool unpack_objects)

LC_LOCKHINT *	locator_allocate_lockhint (int max_classes, bool quit_on_errors)

LC_LOCKHINT *	locator_reallocate_lockhint (LC_LOCKHINT *lockhint, int max_classes)

void	locator_free_lockhint (LC_LOCKHINT *lockhint)

LC_LOCKHINT *	locator_allocate_and_unpack_lockhint (char *unpacked, int unpacked_size, bool unpack_classes, bool reg_unpacked)

int	locator_pack_lockhint (LC_LOCKHINT *lockhint, bool pack_classes)

int	locator_unpack_lockhint (LC_LOCKHINT *lockhint, bool unpack_classes)

LC_OIDSET *	locator_make_oid_set (void)

void	locator_clear_oid_set (THREAD_ENTRY thread_p, LC_OIDSET oidset)

void	locator_free_oid_set (THREAD_ENTRY thread_p, LC_OIDSET oidset)

LC_OIDMAP *	locator_add_oid_set (THREAD_ENTRY thread_p, LC_OIDSET set, HFID heap, OID class_oid, OID *obj_oid)

int	locator_get_packed_oid_set_size (LC_OIDSET *oidset)

char *	locator_pack_oid_set (char buffer, LC_OIDSET oidset)

bool	locator_unpack_oid_set_to_exist (char buffer, LC_OIDSET use)

LC_OIDSET *	locator_unpack_oid_set_to_new (THREAD_ENTRY thread_p, char buffer)

bool	locator_manyobj_flag_is_set (LC_COPYAREA_MANYOBJS *copyarea, enum MULTI_UPDATE_FLAG muf)

void	locator_manyobj_flag_remove (LC_COPYAREA_MANYOBJS *copyarea, enum MULTI_UPDATE_FLAG muf)

void	locator_manyobj_flag_set (LC_COPYAREA_MANYOBJS *copyarea, enum MULTI_UPDATE_FLAG muf)

Variables
static int	rv

static LOCATOR_GLOBAL	locator_Keep

static LC_COPYAREA	packed_req_area_ptrs [LOCATOR_NKEEP_LIMIT]

static bool	locator_Is_initialized = false

Macro Definition Documentation

#define LOCATOR_CACHED_COPYAREA_SIZE_LIMIT (IO_MAX_PAGE_SIZE * 2 + sizeof (LC_COPYAREA))

Definition at line 60 of file locator.c.

Referenced by locator_free_copy_area().

#define LOCATOR_NKEEP_LIMIT (2)

Definition at line 57 of file locator.c.

Referenced by locator_free_copy_area(), locator_free_lockhint(), locator_free_lockset(), locator_free_packed(), and locator_initialize_areas().

#define pthread_mutex_destroy ( a )

Definition at line 48 of file locator.c.

Referenced by locator_free_areas().

#define pthread_mutex_init	(	a,
		b
	)

Definition at line 47 of file locator.c.

Referenced by locator_initialize_areas().

#define pthread_mutex_lock ( a ) 0

Definition at line 49 of file locator.c.

Referenced by locator_allocate_copy_area_by_length(), locator_allocate_lockhint(), locator_allocate_lockset(), locator_allocate_packed(), locator_free_copy_area(), locator_free_lockhint(), locator_free_lockset(), and locator_free_packed().

#define pthread_mutex_unlock ( a )

Definition at line 50 of file locator.c.

Referenced by locator_allocate_copy_area_by_length(), locator_allocate_lockhint(), locator_allocate_lockset(), locator_allocate_packed(), locator_free_copy_area(), locator_free_lockhint(), locator_free_lockset(), and locator_free_packed().

Typedef Documentation

typedef struct locator_global LOCATOR_GLOBAL

Definition at line 63 of file locator.c.

Function Documentation

LC_OIDMAP* locator_add_oid_set	(	THREAD_ENTRY *	thread_p,
		LC_OIDSET *	set,
		HFID *	heap,
		OID *	class_oid,
		OID *	obj_oid
	)

Definition at line 2255 of file locator.c.

References ARG_FILE_LINE, lc_class_oidset::class_oid, lc_oidmap::client_data, db_private_alloc, db_private_free_and_init, ER_ERROR_SEVERITY, ER_GENERIC_ERROR, er_set(), lc_oidmap::est_size, lc_class_oidset::hfid, lc_class_oidset::is_list, locator_is_hfid_equal(), lc_oidmap::mop, lc_oidmap::next, lc_class_oidset::next, NULL, lc_class_oidset::num_oids, lc_oidmap::oid, OID_EQ, lc_class_oidset::oids, and thread_get_thread_entry_info().

Referenced by locator_add_oidset_object().

Here is the caller graph for this function:

LC_LOCKHINT* locator_allocate_and_unpack_lockhint	(	char *	unpacked,
		int	unpacked_size,
		bool	unpack_classes,
		bool	reg_unpacked
	)

Definition at line 1876 of file locator.c.

References locator_allocate_lockhint(), locator_unpack_lockhint(), NULL, or_unpack_int(), lc_lock_hint::packed, and lc_lock_hint::packed_size.

Referenced by locator_find_lockhint_class_oids(), and slocator_fetch_lockhint_classes().

Here is the caller graph for this function:

LC_LOCKSET* locator_allocate_and_unpack_lockset	(	char *	unpacked,
		int	unpacked_size,
		bool	unpack_classes,
		bool	unpack_objects,
		bool	reg_unpacked
	)

Definition at line 1302 of file locator.c.

References locator_allocate_lockset(), locator_unpack_lockset(), NULL, NULL_LOCK, or_unpack_int(), lc_lock_set::packed, and lc_lock_set::packed_size.

Referenced by locator_fetch_all_reference_lockset(), and slocator_fetch_lockset().

Here is the caller graph for this function:

LC_COPYAREA* locator_allocate_copy_area_by_length ( int min_length )

Definition at line 407 of file locator.c.

References locator_global::locator_global_copyareas::areas, ARG_FILE_LINE, locator_global::copy_areas, DB_ALIGN, db_network_page_size(), ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), i, lc_copy_area::length, lc_copy_area::mem, MEM_REGION_SCRAMBLE, NULL, locator_global::locator_global_copyareas::number, pthread_mutex_lock, pthread_mutex_unlock, and rv.

Referenced by locator_allocate_copy_area_by_attr_info(), locator_force(), locator_free_packed(), locator_mflush_reallocate_copy_area(), locator_reallocate_copy_area_by_length(), locator_recv_allocate_copyarea(), xlocator_fetch(), xlocator_fetch_all(), xlocator_fetch_lockhint_classes(), xlocator_fetch_lockset(), xlocator_lock_and_fetch_all(), and xlocator_notify_isolation_incons().

Here is the caller graph for this function:

LC_LOCKHINT* locator_allocate_lockhint	(	int	max_classes,
		bool	quit_on_errors
	)

Definition at line 1629 of file locator.c.

References locator_global::locator_global_lockhint_areas::areas, lc_lock_hint::classes, i, lc_lock_hint::length, locator_initialize_lockhint(), locator_global::lockhint_areas, MEM_REGION_SCRAMBLE, NO_ERROR, NULL, locator_global::locator_global_lockhint_areas::number, pthread_mutex_lock, pthread_mutex_unlock, and rv.

Referenced by locator_allocate_and_unpack_lockhint(), and xlocator_find_lockhint_class_oids().

Here is the caller graph for this function:

LC_LOCKSET* locator_allocate_lockset	(	int	max_reqobjs,
		LOCK	reqobj_inst_lock,
		LOCK	reqobj_class_lock,
		int	quit_on_errors
	)

Definition at line 955 of file locator.c.

References locator_global::locator_global_lockset_areas::areas, lc_lock_set::classes, i, lc_lock_set::length, locator_initialize_lockset(), locator_global::lockset_areas, MEM_REGION_SCRAMBLE, NO_ERROR, NULL, locator_global::locator_global_lockset_areas::number, lc_lock_set::objects, pthread_mutex_lock, pthread_mutex_unlock, and rv.

Referenced by locator_all_reference_lockset(), locator_allocate_and_unpack_lockset(), locator_initialize_lockset(), and locator_lock_set().

Here is the caller graph for this function:

static char * locator_allocate_packed ( int packed_size )

static

Definition at line 276 of file locator.c.

References locator_global::locator_global_packed_areas::areas, i, lc_copy_area::length, lc_copy_area::mem, MEM_REGION_SCRAMBLE, NULL, locator_global::locator_global_packed_areas::number, locator_global::packed_areas, pthread_mutex_lock, pthread_mutex_unlock, and rv.

Referenced by locator_pack_lockhint(), and locator_pack_lockset().

Here is the caller graph for this function:

void locator_clear_oid_set	(	THREAD_ENTRY *	thread_p,
		LC_OIDSET *	oidset
	)

Definition at line 2153 of file locator.c.

References lc_oidset::classes, lc_oidmap::client_data, db_private_free_and_init, lc_class_oidset::is_list, lc_oidset::is_list, lc_oidmap::mop, lc_oidmap::next, lc_class_oidset::next, NULL, lc_oidset::num_classes, lc_lockhint_class::oid, lc_class_oidset::oids, thread_get_thread_entry_info(), and lc_oidset::total_oids.

Referenced by ldr_assign_all_perm_oids(), locator_add_to_oidset_when_temp_oid(), and locator_free_oid_set().

Here is the caller graph for this function:

void locator_free_areas ( void )

Definition at line 206 of file locator.c.

Referenced by boot_client_all_finalize(), boot_initialize_client(), boot_restart_client(), and boot_server_all_finalize().

Here is the caller graph for this function:

void locator_free_copy_area ( LC_COPYAREA * copyarea )

Definition at line 534 of file locator.c.

References locator_global::locator_global_copyareas::areas, locator_global::copy_areas, free_and_init, lc_copy_area::length, LOCATOR_CACHED_COPYAREA_SIZE_LIMIT, LOCATOR_NKEEP_LIMIT, lc_copy_area::mem, MEM_REGION_SCRAMBLE, locator_global::locator_global_copyareas::number, pthread_mutex_lock, pthread_mutex_unlock, and rv.

Referenced by locator_allocate_copy_area_by_attr_info(), locator_attribute_info_force(), locator_force(), locator_fun_get_all_mops(), locator_get_rest_objects_classes(), locator_insert_force(), locator_lock(), locator_lock_and_doesexist(), locator_lock_class_of_instance(), locator_lock_nested(), locator_lockhint_classes(), locator_mflush_end(), locator_mflush_reallocate_copy_area(), locator_mvcc_reev_cond_assigns(), locator_reallocate_copy_area_by_length(), locator_recv_allocate_copyarea(), locator_repl_mflush_force(), locator_synch_isolation_incons(), locator_update_force(), net_client_request_recv_copyarea(), process_class(), qexec_execute_delete(), qexec_execute_update(), qexec_oid_of_duplicate_key_update(), qexec_remove_duplicates_for_replace(), slocator_does_exist(), slocator_fetch(), slocator_fetch_all(), slocator_fetch_all_reference_lockset(), slocator_fetch_lockhint_classes(), slocator_fetch_lockset(), slocator_find_lockhint_class_oids(), slocator_force(), slocator_get_class(), slocator_notify_isolation_incons(), slocator_repl_force(), xlocator_fetch(), xlocator_fetch_all(), xlocator_fetch_lockhint_classes(), xlocator_fetch_lockset(), xlocator_lock_and_fetch_all(), xlocator_notify_isolation_incons(), and xlocator_upgrade_instances_domain().

void locator_free_lockhint ( LC_LOCKHINT * lockhint )

Definition at line 1765 of file locator.c.

References locator_global::locator_global_lockhint_areas::areas, lc_lockhint_class::chn, lc_lock_hint::classes, free_and_init, i, lc_lock_hint::length, locator_free_packed(), LOCATOR_NKEEP_LIMIT, lc_lockhint_class::lock, LOCK_TO_LOCKMODE_STRING, locator_global::lockhint_areas, lc_lock_hint::max_classes, lc_lock_hint::mem, MEM_REGION_SCRAMBLE, lc_lockhint_class::need_subclasses, NULL, lc_lock_hint::num_classes, lc_lock_hint::num_classes_processed, locator_global::locator_global_lockhint_areas::number, lc_lockhint_class::oid, lc_lock_hint::packed, lc_lock_hint::packed_size, db_identifier::pageid, pthread_mutex_lock, pthread_mutex_unlock, rv, db_identifier::slotid, and db_identifier::volid.

Referenced by locator_lockhint_classes(), slocator_fetch_lockhint_classes(), slocator_find_lockhint_class_oids(), and xlocator_find_lockhint_class_oids().

Here is the caller graph for this function:

void locator_free_lockset ( LC_LOCKSET * lockset )

Definition at line 1140 of file locator.c.

References locator_global::locator_global_lockset_areas::areas, lc_lockset_reqobj::chn, lc_lockset_classof::chn, lc_lockset_reqobj::class_index, lc_lock_set::classes, free_and_init, i, lc_lock_set::last_classof_reqobjs_cached, lc_lock_set::last_reqobj_cached, lc_lock_set::length, locator_free_packed(), LOCATOR_NKEEP_LIMIT, LOCK_TO_LOCKMODE_STRING, locator_global::lockset_areas, lc_lock_set::mem, MEM_REGION_SCRAMBLE, NULL, lc_lock_set::num_classes_of_reqobjs, lc_lock_set::num_classes_of_reqobjs_processed, lc_lock_set::num_reqobjs, lc_lock_set::num_reqobjs_processed, locator_global::locator_global_lockset_areas::number, lc_lock_set::objects, lc_lockset_reqobj::oid, lc_lockset_classof::oid, lc_lock_set::packed, lc_lock_set::packed_size, db_identifier::pageid, pthread_mutex_lock, pthread_mutex_unlock, lc_lock_set::quit_on_errors, lc_lock_set::reqobj_class_lock, lc_lock_set::reqobj_inst_lock, rv, db_identifier::slotid, and db_identifier::volid.

Referenced by locator_all_reference_lockset(), locator_lock_nested(), locator_lock_set(), slocator_fetch_all_reference_lockset(), and slocator_fetch_lockset().

Here is the caller graph for this function:

void locator_free_oid_set	(	THREAD_ENTRY *	thread_p,
		LC_OIDSET *	oidset
	)

Definition at line 2227 of file locator.c.

References db_private_free_and_init, locator_clear_oid_set(), and NULL.

Referenced by col_permanent_oids(), ldr_assign_all_perm_oids(), locator_assign_all_permanent_oids(), locator_unpack_oid_set_to_new(), slocator_assign_oid_batch(), and tf_free_fixup().

Here is the caller graph for this function:

static void locator_free_packed	(	char *	packed_area,
		int	packed_size
	)

static

Definition at line 348 of file locator.c.

References locator_global::locator_global_packed_areas::areas, free_and_init, IO_PAGESIZE, lc_copy_area::length, locator_allocate_copy_area_by_length(), LOCATOR_NKEEP_LIMIT, lc_copy_area::mem, MEM_REGION_SCRAMBLE, locator_global::locator_global_packed_areas::number, locator_global::packed_areas, pthread_mutex_lock, pthread_mutex_unlock, and rv.

Referenced by locator_free_lockhint(), and locator_free_lockset().

Here is the caller graph for this function:

int locator_get_packed_oid_set_size ( LC_OIDSET * oidset )

Definition at line 2363 of file locator.c.

References lc_oidset::classes, cubregex::count(), lc_class_oidset::next, NULL, lc_oidset::num_classes, lc_class_oidset::num_oids, OR_HFID_SIZE, OR_INT_SIZE, and OR_OID_SIZE.

Referenced by locator_assign_oid_batch().

Here is the caller graph for this function:

void locator_initialize_areas ( void )

static int locator_initialize_lockhint	(	LC_LOCKHINT *	lockhint,
		int	length,
		int	max_classes,
		bool	quit_on_errors
	)

static

Definition at line 1697 of file locator.c.

References lc_lock_hint::classes, ER_FAILED, lc_lock_hint::first_fetch_lockhint_call, lc_lock_hint::length, lc_lock_hint::max_classes, lc_lock_hint::mem, NO_ERROR, NULL, lc_lock_hint::num_classes, lc_lock_hint::num_classes_processed, lc_lock_hint::packed, lc_lock_hint::packed_size, and lc_lock_hint::quit_on_errors.

Referenced by locator_allocate_lockhint().

Here is the caller graph for this function:

static int locator_initialize_lockset	(	LC_LOCKSET *	lockset,
		int	length,
		int	max_reqobjs,
		LOCK	reqobj_inst_lock,
		LOCK	reqobj_class_lock,
		int	quit_on_errors
	)