FM / dyninst

/usr/share/systemtap/runtime/dyninst

Name	Size	Mode	Actions
addr-map.c	565	0644	edit dl rm
alloc.c	1188	0644	edit dl rm
arith.c	2291	0644	edit dl rm
common_session_state.h	6921	0644	edit dl rm
copy.c	4095	0644	edit dl rm
debug.h	413	0644	edit dl rm
ilog2.h	2943	0644	edit dl rm
io.c	4541	0644	edit dl rm
linux_defs.h	5602	0644	edit dl rm
linux_hash.h	1877	0644	edit dl rm
linux_types.h	654	0644	edit dl rm
loc2c-runtime.h	2494	0644	edit dl rm
map_list.h	1059	0644	edit dl rm
map_runtime.h	5160	0644	edit dl rm
namespaces.h	0	0644	edit dl rm
offptr.h	4788	0644	edit dl rm
offset_list.h	4428	0644	edit dl rm
perf.c	0	0644	edit dl rm
print.c	2700	0644	edit dl rm
probe_lock.h	1849	0644	edit dl rm
regs.c	2557	0644	edit dl rm
runtime.h	10292	0644	edit dl rm
runtime_context.h	6556	0644	edit dl rm
runtime_defines.h	280	0644	edit dl rm
session_attributes.c	1717	0644	edit dl rm
session_attributes.h	772	0644	edit dl rm
shm.c	6171	0644	edit dl rm
stapdyn.h	4617	0644	edit dl rm
stat_runtime.h	1832	0644	edit dl rm
sym.c	1621	0644	edit dl rm
task_finder.c	0	0644	edit dl rm
timer.c	2770	0644	edit dl rm
transport.c	31128	0644	edit dl rm
transport.h	3968	0644	edit dl rm
unwind.c	0	0644	edit dl rm
uprobes-regs.c	3163	0644	edit dl rm
uprobes.c	1798	0644	edit dl rm
uprobes.h	953	0644	edit dl rm

Edit: /usr/share/systemtap/runtime/dyninst/transport.h (3968B)

// stapdyn transport functions
// Copyright (C) 2013 Red Hat Inc.
//
// This file is part of systemtap, and is free software.  You can
// redistribute it and/or modify it under the terms of the GNU General
// Public License (GPL); either version 2, or (at your option) any
// later version.

#ifndef TRANSPORT_H
#define TRANSPORT_H

#define STP_DYN_EXIT		0x0001
#define STP_DYN_NORMAL_DATA	0x0002
#define STP_DYN_OOB_DATA	0x0004
#define STP_DYN_SYSTEM		0x0008
#define STP_DYN_REQUEST_EXIT	0x0010

#define STP_DYN_OOB_DATA_MASK (STP_DYN_OOB_DATA | STP_DYN_SYSTEM)

// The size of print buffers. This limits the maximum amount of data a
// print can send. Note that it must be a power of 2 (which is why
// we're using a bit shift). For reference sake, here are the
// resulting sizes with various shifts: 13 (8kB), 14 (16kB), 15 (32kB),
// 16 (64kB), 17 (128kB), 18 (256kB), 19 (512kB), and 20 (1MB).
#ifndef STP_BUFFER_SIZE_SHIFT
#define STP_BUFFER_SIZE_SHIFT 20
#endif
#define _STP_DYNINST_BUFFER_SIZE (1 << STP_BUFFER_SIZE_SHIFT)

// The size of an individual log message.
#ifndef STP_LOG_BUF_LEN
#define STP_LOG_BUF_LEN 256
#endif
#if (STP_LOG_BUF_LEN < 10) /* sizeof(WARN_STRING) */
#error "STP_LOG_BUF_LEN is too short"
#endif

// The maximum number of log messages the buffer can hold. Note that
// it must be a power of 2 (which is why we're using a bit shift).
#ifndef STP_LOG_BUF_ENTRIES_SHIFT
#define STP_LOG_BUF_ENTRIES_SHIFT 4
#endif
#define _STP_LOG_BUF_ENTRIES (1 << STP_LOG_BUF_ENTRIES_SHIFT)

// The total size of the log buffer
#define _STP_DYNINST_LOG_BUF_LEN (STP_LOG_BUF_LEN * _STP_LOG_BUF_ENTRIES)

// The maximum number of queue items each transport queue can
// hold.
#ifndef STP_DYNINST_QUEUE_ITEMS
#define STP_DYNINST_QUEUE_ITEMS 64
#endif

struct _stp_transport_queue_item {
	// The type variable lets the thread know what it needs to do.
	unsigned type;

// 'data_index' indicates which context structure we're
	// working on. */
	int data_index;

// When 'type' indicates that normal or oob data needs to be
	// output, this is the data offset.
	size_t offset;

// When 'type' indicates that normal or oob data needs to be
	// output, this is the number of bytes to output.
	size_t bytes;
};

struct _stp_transport_queue {
	size_t items;
	struct _stp_transport_queue_item queue[STP_DYNINST_QUEUE_ITEMS];
};

// This structure is stored in the session data.
struct _stp_transport_session_data {
	unsigned write_queue;
	struct _stp_transport_queue queues[2];
	pthread_mutex_t queue_mutex;
	pthread_cond_t queue_space_avail;
	pthread_cond_t queue_data_avail;
};

// This structure is stored in every context structure.
struct _stp_transport_context_data {
	/* The buffer and variables used for print messages */
	size_t read_offset;
	size_t write_offset;
	size_t write_bytes;
	char print_buf[_STP_DYNINST_BUFFER_SIZE];
	/* The condition variable is used to signal our thread. */
	pthread_cond_t print_space_avail;
	/* The lock for this print state. */
	pthread_mutex_t print_mutex;

/*
	 * The buffer and variables used for log (warn/error)
	 * messages. Note that 'log_buf' is a true circular buffer
	 * (unlike print_buf). Also note that 'log_start' and
	 * 'log_end' are entry numbers (not offsets).
	 */
	size_t log_start;		/* index of oldest entry */
	size_t log_end;			/* where to write new entry */
	char log_buf[_STP_DYNINST_LOG_BUF_LEN];
	/* The condition variable is used to signal space available. */
	pthread_cond_t log_space_avail;
	/* The lock for 'log_space_avail'. */
	pthread_mutex_t log_mutex;
};

static int _stp_dyninst_transport_session_init(void);

static int _stp_dyninst_transport_session_start(void);

static int _stp_dyninst_transport_write_oob_data(char *buffer, size_t bytes);

static int _stp_dyninst_transport_write(void);

static char *_stp_dyninst_transport_log_buffer(void);

static void _stp_dyninst_transport_shutdown(void);

static void _stp_dyninst_transport_request_exit(void);

#endif // TRANSPORT_H

cmd: