+#define _GNU_SOURCE
#include <stdio.h>
#include <stdint.h>
#include <signal.h>
#include "localerr.h"
#include "ustcomm.h"
#include "relay.h" /* FIXME: remove */
+#include "marker-control.h"
//#define USE_CLONE
}
}
-static int inform_consumer_daemon(void)
+static void inform_consumer_daemon(void)
{
ustcomm_request_consumer(getpid(), "metadata");
ustcomm_request_consumer(getpid(), "ust");
result = poll(fds, n_fds, 0);
if(result == -1) {
PERROR("poll");
- return -1;
+ return;
}
list_for_each_entry(bc, &blocked_consumers, list) {
close(bc->fd_producer);
- __list_del(bc->list.prev, bc->list.next);
+ list_del(&bc->list);
result = ustcomm_send_reply(&bc->server, "END", &bc->src);
if(result < 0) {
}
free(reply);
- __list_del(bc->list.prev, bc->list.next);
+ list_del(&bc->list);
}
}
}
-int listener_main(void *p)
+void *listener_main(void *p)
{
int result;
DBG("LISTENER");
for(;;) {
- uint32_t size;
- struct sockaddr_un addr;
- socklen_t addrlen = sizeof(addr);
char trace_name[] = "auto";
char trace_type[] = "ustrelay";
char *recvbuf;
result = ltt_trace_setup(trace_name);
if(result < 0) {
ERR("ltt_trace_setup failed");
- return;
+ return (void *)1;
}
result = ltt_trace_set_type(trace_name, trace_type);
if(result < 0) {
ERR("ltt_trace_set_type failed");
- return;
+ return (void *)1;
}
result = ltt_trace_alloc(trace_name);
if(result < 0) {
ERR("ltt_trace_alloc failed");
- return;
+ return (void *)1;
}
inform_consumer_daemon();
result = ltt_trace_setup(trace_name);
if(result < 0) {
ERR("ltt_trace_setup failed");
- return;
+ return (void *)1;
}
result = ltt_trace_set_type(trace_name, trace_type);
if(result < 0) {
ERR("ltt_trace_set_type failed");
- return;
+ return (void *)1;
}
}
else if(!strcmp(recvbuf, "trace_alloc")) {
result = ltt_trace_alloc(trace_name);
if(result < 0) {
ERR("ltt_trace_alloc failed");
- return;
+ return (void *)1;
}
}
else if(!strcmp(recvbuf, "trace_start")) {
result = ltt_trace_stop(trace_name);
if(result < 0) {
ERR("ltt_trace_stop failed");
- return;
+ return (void *)1;
}
}
else if(!strcmp(recvbuf, "trace_destroy")) {
result = ltt_trace_destroy(trace_name);
if(result < 0) {
ERR("ltt_trace_destroy failed");
- return;
+ return (void *)1;
}
}
else if(nth_token_is(recvbuf, "get_shmid", 0) == 1) {
ltt_unlock_traces();
if(trace == NULL) {
- CPRINTF("cannot find trace!");
- return 1;
+ ERR("cannot find trace!");
+ return (void *)1;
}
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 ltt_channel_buf_struct *ltt_buf = ltt_channel->buf;
if(!strcmp(trace->channels[i].channel_name, channel_name)) {
char *reply;
ltt_unlock_traces();
if(trace == NULL) {
- CPRINTF("cannot find trace!");
- return 1;
+ ERR("cannot find trace!");
+ return (void *)1;
}
for(i=0; i<trace->nr_channels; i++) {
if(!strcmp(trace->channels[i].channel_name, channel_name)) {
char *reply;
- DBG("the n_subbufs for the requested channel is %d", rchan->n_subbufs);
- asprintf(&reply, "%d", rchan->n_subbufs);
+ DBG("the n_subbufs for the requested channel is %zd", rchan->n_subbufs);
+ asprintf(&reply, "%zd", rchan->n_subbufs);
result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
if(result) {
ltt_unlock_traces();
if(trace == NULL) {
- CPRINTF("cannot find trace!");
- return 1;
+ ERR("cannot find trace!");
+ return (void *)1;
}
for(i=0; i<trace->nr_channels; i++) {
if(!strcmp(trace->channels[i].channel_name, channel_name)) {
char *reply;
- DBG("the subbuf_size for the requested channel is %d", rchan->subbuf_size);
- asprintf(&reply, "%d", rchan->subbuf_size);
+ DBG("the subbuf_size for the requested channel is %zd", rchan->subbuf_size);
+ asprintf(&reply, "%zd", rchan->subbuf_size);
result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
if(result) {
ltt_unlock_traces();
if(trace == NULL) {
- CPRINTF("cannot find trace!");
- return 1;
+ ERR("cannot find trace!");
+ return (void *)1;
}
for(i=0; i<trace->nr_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;
- char *reply;
- long consumed_old=0;
- int fd;
struct blocked_consumer *bc;
bc = (struct blocked_consumer *) malloc(sizeof(struct blocked_consumer));
ltt_unlock_traces();
if(trace == NULL) {
- CPRINTF("cannot find trace!");
- return 1;
+ ERR("cannot find trace!");
+ return (void *)1;
}
for(i=0; i<trace->nr_channels; i++) {
result = ltt_do_put_subbuf(rbuf, lttbuf, consumed_old);
if(result < 0) {
- WARN("ltt_do_put_subbuf: error");
+ WARN("ltt_do_put_subbuf: error (subbuf=%s)", channel_name);
+ asprintf(&reply, "%s", "ERROR");
}
else {
- DBG("ltt_do_put_subbuf: success");
+ DBG("ltt_do_put_subbuf: success (subbuf=%s)", channel_name);
+ asprintf(&reply, "%s", "OK");
}
- asprintf(&reply, "%s", "OK", consumed_old);
result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
if(result) {
char *channel_slash_name = nth_token(recvbuf, 1);
char channel_name[256]="";
char marker_name[256]="";
- struct marker_iter iter;
result = sscanf(channel_slash_name, "%255[^/]/%255s", channel_name, marker_name);
char *channel_slash_name = nth_token(recvbuf, 1);
char *marker_name;
char *channel_name;
- struct marker_iter iter;
result = sscanf(channel_slash_name, "%a[^/]/%as", &channel_name, &marker_name);
// ltt_unlock_traces();
//
// if(trace == NULL) {
-// CPRINTF("cannot find trace!");
-// return 1;
+// ERR("cannot find trace!");
+// return (void *)1;
// }
//
// for(i=0; i<trace->nr_channels; i++) {
}
}
-static char listener_stack[16384];
-
void create_listener(void)
{
- int result;
+#ifdef USE_CLONE
static char listener_stack[16384];
- //char *listener_stack = malloc(16384);
+#endif
#ifdef USE_CLONE
result = clone(listener_main, listener_stack+sizeof(listener_stack)-1, CLONE_FS | CLONE_FILES | CLONE_VM | CLONE_SIGHAND | CLONE_THREAD, NULL);
return ustcomm_init_app(getpid(), &ustcomm_app);
}
+/* FIXME: reenable this to delete socket file. */
+
+#if 0
static void destroy_socket(void)
{
-// int result;
-//
-// if(mysocketfile[0] == '\0')
-// return;
-//
-// result = unlink(mysocketfile);
-// if(result == -1) {
-// PERROR("unlink");
-// }
+ int result;
+
+ if(mysocketfile[0] == '\0')
+ return;
+
+ result = unlink(mysocketfile);
+ if(result == -1) {
+ PERROR("unlink");
+ }
}
+#endif
static int init_signal_handler(void)
{
}
}
-static void fini(void);
-
static void __attribute__((constructor(1000))) init()
{
int result;
/* This is only called if we terminate normally, not with an unhandled signal,
* so we cannot rely on it. */
+/* This destructor probably isn't needed, because ustd can do crash recovery. */
+#if 0
static void __attribute__((destructor)) fini()
{
int result;
ERR("ltt_trace_destroy error");
}
- /* FIXME: wait for the consumer to be done */
- //DBG("waiting 5 sec for consume");
- //sleep(5);
-
destroy_socket();
}
+#endif
projects / ust.git / blobdiff