#include <poll.h>
#include <regex.h>
-#include <urcu.h>
+#include <urcu-bp.h>
-#include "marker.h"
+#include <ust/marker.h>
#include "tracer.h"
-#include "localerr.h"
+#include "usterr.h"
#include "ustcomm.h"
-#include "relay.h" /* FIXME: remove */
+#include "buffers.h" /* FIXME: remove */
#include "marker-control.h"
//#define USE_CLONE
/* volatile because shared between the listener and the main thread */
volatile sig_atomic_t buffers_to_export = 0;
-//struct listener_arg {
-// int pipe_fd;
-//};
-
struct trctl_msg {
/* size: the size of all the fields except size itself */
uint32_t size;
struct ustcomm_server server;
struct ustcomm_source src;
- /* args to ltt_do_get_subbuf */
- struct rchan_buf *rbuf;
- struct ltt_channel_buf_struct *lttbuf;
+ /* args to ust_buffers_do_get_subbuf */
+ struct ust_buffer *buf;
struct list_head list;
};
marker_iter_start(&iter);
while(iter.marker) {
- fprintf(fp, "marker: %s_%s %d \"%s\"\n", iter.marker->channel, iter.marker->name, (int)imv_read(iter.marker->state), iter.marker->format);
+ fprintf(fp, "marker: %s/%s %d \"%s\" %p\n", iter.marker->channel, iter.marker->name, (int)imv_read(iter.marker->state), iter.marker->format, iter.marker->location);
marker_iter_next(&iter);
}
unlock_markers();
continue;
}
- result = ltt_do_get_subbuf(bc->rbuf, bc->lttbuf, &consumed_old);
+ result = ust_buffers_do_get_subbuf(bc->buf, &consumed_old);
if(result == -EAGAIN) {
WARN("missed buffer?");
continue;
}
else if(result < 0) {
- DBG("ltt_do_get_subbuf: error: %s", strerror(-result));
+ DBG("ust_buffers_do_get_subbuf: error: %s", strerror(-result));
}
asprintf(&reply, "%s %ld", "OK", consumed_old);
result = ustcomm_send_reply(&bc->server, reply, &bc->src);
}
for(i=0; i<trace->nr_channels; i++) {
- struct rchan *rchan = trace->channels[i].trans_channel_data;
- struct rchan_buf *rbuf = rchan->buf;
- struct ltt_channel_struct *ltt_channel = (struct ltt_channel_struct *)rchan->private_data;
+ struct ust_channel *channel = &trace->channels[i];
+ struct ust_buffer *buf = channel->buf;
if(!strcmp(trace->channels[i].channel_name, channel_name)) {
char *reply;
- DBG("the shmid for the requested channel is %d", rbuf->shmid);
- DBG("the shmid for its buffer structure is %d", ltt_channel->buf_shmid);
- asprintf(&reply, "%d %d", rbuf->shmid, ltt_channel->buf_shmid);
+ DBG("the shmid for the requested channel is %d", buf->shmid);
+ DBG("the shmid for its buffer structure is %d", channel->buf_shmid);
+ asprintf(&reply, "%d %d", buf->shmid, channel->buf_shmid);
result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
if(result) {
}
for(i=0; i<trace->nr_channels; i++) {
- struct rchan *rchan = trace->channels[i].trans_channel_data;
+ struct ust_channel *channel = &trace->channels[i];
if(!strcmp(trace->channels[i].channel_name, channel_name)) {
char *reply;
- DBG("the n_subbufs for the requested channel is %zd", rchan->n_subbufs);
- asprintf(&reply, "%zd", rchan->n_subbufs);
+ DBG("the n_subbufs for the requested channel is %d", channel->subbuf_cnt);
+ asprintf(&reply, "%d", channel->subbuf_cnt);
result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
if(result) {
}
for(i=0; i<trace->nr_channels; i++) {
- struct rchan *rchan = trace->channels[i].trans_channel_data;
+ struct ust_channel *channel = &trace->channels[i];
if(!strcmp(trace->channels[i].channel_name, channel_name)) {
char *reply;
- DBG("the subbuf_size for the requested channel is %zd", rchan->subbuf_size);
- asprintf(&reply, "%zd", rchan->subbuf_size);
+ DBG("the subbuf_size for the requested channel is %zd", channel->subbuf_size);
+ asprintf(&reply, "%zd", channel->subbuf_size);
result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
if(result) {
}
for(i=0; i<trace->nr_channels; i++) {
- struct rchan *rchan = trace->channels[i].trans_channel_data;
+ struct ust_channel *channel = &trace->channels[i];
if(!strcmp(trace->channels[i].channel_name, channel_name)) {
- struct rchan_buf *rbuf = rchan->buf;
- struct ltt_channel_buf_struct *lttbuf = trace->channels[i].buf;
+ struct ust_buffer *buf = channel->buf;
struct blocked_consumer *bc;
bc = (struct blocked_consumer *) malloc(sizeof(struct blocked_consumer));
goto next_cmd;
}
bc->fd_consumer = src.fd;
- bc->fd_producer = lttbuf->data_ready_fd_read;
- bc->rbuf = rbuf;
- bc->lttbuf = lttbuf;
+ bc->fd_producer = buf->data_ready_fd_read;
+ bc->buf = buf;
bc->src = src;
bc->server = ustcomm_app.server;
}
for(i=0; i<trace->nr_channels; i++) {
- struct rchan *rchan = trace->channels[i].trans_channel_data;
+ struct ust_channel *channel = &trace->channels[i];
if(!strcmp(trace->channels[i].channel_name, channel_name)) {
- struct rchan_buf *rbuf = rchan->buf;
- struct ltt_channel_buf_struct *lttbuf = trace->channels[i].buf;
+ struct ust_buffer *buf = channel->buf;
char *reply;
long consumed_old=0;
- result = ltt_do_put_subbuf(rbuf, lttbuf, consumed_old);
+ result = ust_buffers_do_put_subbuf(buf, consumed_old);
if(result < 0) {
- WARN("ltt_do_put_subbuf: error (subbuf=%s)", channel_name);
+ WARN("ust_buffers_do_put_subbuf: error (subbuf=%s)", channel_name);
asprintf(&reply, "%s", "ERROR");
}
else {
- DBG("ltt_do_put_subbuf: success (subbuf=%s)", channel_name);
+ DBG("ust_buffers_do_put_subbuf: success (subbuf=%s)", channel_name);
asprintf(&reply, "%s", "OK");
}
}
}
-int have_listener = 0;
+volatile sig_atomic_t have_listener = 0;
void create_listener(void)
{
#ifdef USE_CLONE
static char listener_stack[16384];
+ int result;
#else
pthread_t thread;
#endif
- if(have_listener)
+ if(have_listener) {
+ WARN("not creating listener because we already had one");
return;
+ }
#ifdef USE_CLONE
- result = clone(listener_main, listener_stack+sizeof(listener_stack)-1, CLONE_FS | CLONE_FILES | CLONE_VM | CLONE_SIGHAND | CLONE_THREAD, NULL);
+ result = clone((int (*)(void *)) listener_main, listener_stack+sizeof(listener_stack)-1, CLONE_FS | CLONE_FILES | CLONE_VM | CLONE_SIGHAND | CLONE_THREAD, NULL);
if(result == -1) {
perror("clone");
return;
have_listener = 1;
}
-/* The signal handler itself. Signals must be setup so there cannot be
- nested signals. */
-
-void sighandler(int sig)
-{
- static char have_listener = 0;
- DBG("sighandler");
-
- if(!have_listener) {
- create_listener();
- have_listener = 1;
- }
-}
-
-/* Called by the app signal handler to chain it to us. */
-
-void chain_signal(void)
-{
- sighandler(USTSIGNAL);
-}
-
static int init_socket(void)
{
return ustcomm_init_app(getpid(), &ustcomm_app);
}
-static int init_signal_handler(void)
-{
- /* Attempt to handler SIGIO. If the main program wants to
- * handle it, fine, it'll override us. They it'll have to
- * use the chaining function.
- */
-
- int result;
- struct sigaction act;
-
- result = sigemptyset(&act.sa_mask);
- if(result == -1) {
- PERROR("sigemptyset");
- return -1;
- }
-
- act.sa_handler = sighandler;
- act.sa_flags = SA_RESTART;
-
- /* Only defer ourselves. Also, try to restart interrupted
- * syscalls to disturb the traced program as little as possible.
- */
- result = sigaction(SIGIO, &act, NULL);
- if(result == -1) {
- PERROR("sigaction");
- return -1;
- }
-
- return 0;
-}
-
#define AUTOPROBE_DISABLED 0
#define AUTOPROBE_ENABLE_ALL 1
#define AUTOPROBE_ENABLE_REGEX 2
if(result && result != -EEXIST)
ERR("ltt_marker_connect (marker = %s/%s, errno = %d)", m->channel, m->name, -result);
- DBG("auto connected marker %s %s to probe default", m->channel, m->name);
+ DBG("auto connected marker %s (addr: %p) %s to probe default", m->channel, m, m->name);
}
-static void __attribute__((constructor(1000))) init()
+static void __attribute__((constructor)) init()
{
int result;
char* autoprobe_val = NULL;
ERR("init_socket error");
return;
}
- result = init_signal_handler();
- if(result == -1) {
- ERR("init_signal_handler error");
- return;
- }
+
+ create_listener();
autoprobe_val = getenv("UST_AUTOPROBE");
if(autoprobe_val) {
return;
}
- inform_consumer_daemon(trace_name);
-
result = ltt_trace_start(trace_name);
if(result < 0) {
ERR("ltt_trace_start failed");
return;
}
+
+ /* Do this after the trace is started in order to avoid creating confusion
+ * if the trace fails to start. */
+ inform_consumer_daemon(trace_name);
}
{
trace_mark(ust, potential_exec, MARK_NOARGS);
+ DBG("test");
+
keepalive();
}
projects / ust.git / blobdiff