+/* Copyright (C) 2009 Pierre-Marc Fournier
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+ */
+
#define _GNU_SOURCE
#include <stdio.h>
#include <stdint.h>
#include "localerr.h"
#include "ustcomm.h"
#include "relay.h" /* FIXME: remove */
+#include "marker-control.h"
//#define USE_CLONE
idx++;
}
- result = poll(fds, n_fds, 0);
+ while((result = poll(fds, n_fds, 0)) == -1 && errno == EINTR)
+ /* nothing */;
if(result == -1) {
PERROR("poll");
return;
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;
ltt_unlock_traces();
if(trace == NULL) {
- CPRINTF("cannot find trace!");
+ ERR("cannot find trace!");
return (void *)1;
}
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!");
+ ERR("cannot find trace!");
return (void *)1;
}
ltt_unlock_traces();
if(trace == NULL) {
- CPRINTF("cannot find trace!");
+ ERR("cannot find trace!");
return (void *)1;
}
ltt_unlock_traces();
if(trace == NULL) {
- CPRINTF("cannot find trace!");
+ ERR("cannot find trace!");
return (void *)1;
}
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!");
+ ERR("cannot find trace!");
return (void *)1;
}
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!");
+// ERR("cannot find trace!");
// return (void *)1;
// }
//
}
}
-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)
{
int result;
result = ltt_marker_connect(m->channel, m->name, "default");
- if(result)
- ERR("ltt_marker_connect");
+ if(result && result != -EEXIST)
+ ERR("ltt_marker_connect (marker = %s/%s, errno = %d)", m->channel, m->name, -result);
DBG("just auto connected marker %s %s to probe default", m->channel, m->name);
}
}
}
-static void fini(void);
-
static void __attribute__((constructor(1000))) init()
{
int result;