FM / runtime

/usr/share/systemtap/runtime

Name	Size	Mode	Actions
dyninst/	-	0755	rm
linux/	-	0755	rm
softfloat/	-	0755	rm
transport/	-	0755	rm
unwind/	-	0755	rm
addr-map.c	523	0644	edit dl rm
addr-map.h	1156	0644	edit dl rm
alloc.c	498	0644	edit dl rm
arith.c	483	0644	edit dl rm
common_probe_context.h	6576	0644	edit dl rm
common_session_state.h	415	0644	edit dl rm
compatdefs.h	3682	0644	edit dl rm
copy.c	585	0644	edit dl rm
debug.h	485	0644	edit dl rm
io.c	508	0644	edit dl rm
k_syms.h	182	0644	edit dl rm
loc2c-runtime.h	17937	0644	edit dl rm
map-gen.c	25977	0644	edit dl rm
map-stat.c	3589	0644	edit dl rm
map.c	14660	0644	edit dl rm
map.h	5918	0644	edit dl rm
mempool.c	2644	0644	edit dl rm
namespaces.h	487	0644	edit dl rm
pmap-gen.c	8710	0644	edit dl rm
print.c	486	0644	edit dl rm
print.h	872	0644	edit dl rm
print_flush.c	3073	0644	edit dl rm
probe_lock.h	498	0644	edit dl rm
procfs-probes.c	4673	0644	edit dl rm
procfs-probes.h	674	0644	edit dl rm
procfs.c	4021	0644	edit dl rm
proc_fs_compatibility.h	2316	0644	edit dl rm
ptrace_compatibility.h	1512	0644	edit dl rm
regs.c	4280	0644	edit dl rm
regs.h	2352	0644	edit dl rm
runtime.h	928	0644	edit dl rm
runtime_context.h	669	0644	edit dl rm
runtime_defines.h	3582	0644	edit dl rm
softfloat.c	77159	0644	edit dl rm
softfloat.h	5125	0644	edit dl rm
stack-arm.c	1688	0644	edit dl rm
stack-ia64.c	1083	0644	edit dl rm
stack-mips.c	125	0644	edit dl rm
stack-s390.c	2362	0644	edit dl rm
stack.c	21790	0644	edit dl rm
stat-common.c	8486	0644	edit dl rm
stat.c	7421	0644	edit dl rm
stat.h	1964	0644	edit dl rm
stp_helper_lock.h	3669	0644	edit dl rm
stp_string.c	8632	0644	edit dl rm
stp_string.h	598	0644	edit dl rm
stp_task_work.c	3511	0644	edit dl rm
stp_utrace.c	94735	0644	edit dl rm
stp_utrace.h	14010	0644	edit dl rm
sym.c	39757	0644	edit dl rm
sym.h	6539	0644	edit dl rm
syscall.h	17408	0644	edit dl rm
task_finder_vma.c	13290	0644	edit dl rm
time.c	14887	0644	edit dl rm
timer.c	481	0644	edit dl rm
timer.h	482	0644	edit dl rm
uidgid_compatibility.h	603	0644	edit dl rm
unwind.c	47890	0644	edit dl rm
utrace_compatibility.h	3148	0644	edit dl rm
vma.c	9545	0644	edit dl rm
vsprintf.c	24058	0644	edit dl rm
vsprintf.h	1502	0644	edit dl rm

Edit: /usr/share/systemtap/runtime/print_flush.c (3073B)

/* -*- linux-c -*- 
 * Print Flush Function
 * Copyright (C) 2007-2008 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.
 */

/** Send the print buffer to the transport now.
 * Output accumulates in the print buffer until it
 * is filled, or this is called. This MUST be called before returning
 * from a probe or accumulated output in the print buffer will be lost.
 *
 * @note Interrupts must be disabled to use this.
 */

static void __stp_print_flush(struct _stp_log *log)
{
	char *bufp = log->buf; /* next byte of log->buf left to write */
	size_t len = log->len; /* # bytes of log->buf left to write */
        const size_t hlen = sizeof(struct _stp_trace);
	void *entry = NULL; /* current output buf handle */
        size_t bytes_reserved; /* current output buf size available */
        
	/* check to see if there is anything in the buffer */
	if (likely(len == 0))
		return;
	log->len = 0; /* clear it for later reuse */
	dbug_trans(1, "len = %zu\n", len);

/* try to reserve header + len */
        bytes_reserved = _stp_data_write_reserve(hlen+len,
                                                 &entry);
        /* require at least header to fit in its entirety */
        if (likely(entry && bytes_reserved > hlen)) {
                /* copy new _stp_trace_ header */
                struct _stp_trace t = {
                        .magic = STAP_TRACE_MAGIC,
                        .sequence = _stp_seq_inc(),
                        .pdu_len = len
                };
                memcpy(_stp_data_entry_data(entry), &t, hlen);
                /* copy the first part of the message */
                memcpy(_stp_data_entry_data(entry)+hlen,
                       bufp, bytes_reserved-hlen);
                bufp += bytes_reserved-hlen;
                len -= bytes_reserved-hlen;
                /* send header + first part */
                _stp_data_write_commit(entry);
                
                /* loop to copy the rest of the message into subsequent bufs */
                while (len > 0) {
                        bytes_reserved = _stp_data_write_reserve(len, &entry);
                        if (likely(entry && bytes_reserved)) {
                                memcpy(_stp_data_entry_data(entry), bufp,
                                       bytes_reserved);
                                _stp_data_write_commit(entry);
                                bufp += bytes_reserved;
                                len -= bytes_reserved;
                        } else { /* rest of message cannot fit at this time */
                                /* NB: the receiver must somehow resynch the framing! */
                                atomic_inc(&_stp_transport_failures);
                                break;
                        }
                }
        } else {
                atomic_inc(&_stp_transport_failures);
        }
}

cmd: