--- /dev/null
+/* This file is part of the Linux Trace Toolkit viewer
+ * Copyright (C) 2009 Benjamin Poirier <benjamin.poirier@polymtl.ca>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License Version 2 as
+ * published by the Free Software Foundation;
+ *
+ * This program 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston,
+ * MA 02111-1307, USA.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+
+#include "event_processing_lttng_common.h"
+
+
+#ifndef g_info
+#define g_info(format...) g_log (G_LOG_DOMAIN, G_LOG_LEVEL_INFO, format)
+#endif
+
+
+/*
+ * Initialize the GQuarks needed to register the event hooks for
+ * synchronization
+ */
+void createQuarks()
+{
+ LTT_CHANNEL_NET= g_quark_from_static_string("net");
+ LTT_CHANNEL_NETIF_STATE= g_quark_from_static_string("netif_state");
+
+ LTT_EVENT_DEV_XMIT= g_quark_from_static_string("dev_xmit");
+ LTT_EVENT_DEV_RECEIVE= g_quark_from_static_string("dev_receive");
+ LTT_EVENT_TCPV4_RCV= g_quark_from_static_string("tcpv4_rcv");
+ LTT_EVENT_NETWORK_IPV4_INTERFACE=
+ g_quark_from_static_string("network_ipv4_interface");
+
+ LTT_FIELD_SKB= g_quark_from_static_string("skb");
+ LTT_FIELD_PROTOCOL= g_quark_from_static_string("protocol");
+ LTT_FIELD_NETWORK_PROTOCOL=
+ g_quark_from_static_string("network_protocol");
+ LTT_FIELD_TRANSPORT_PROTOCOL=
+ g_quark_from_static_string("transport_protocol");
+ LTT_FIELD_SADDR= g_quark_from_static_string("saddr");
+ LTT_FIELD_DADDR= g_quark_from_static_string("daddr");
+ LTT_FIELD_TOT_LEN= g_quark_from_static_string("tot_len");
+ LTT_FIELD_IHL= g_quark_from_static_string("ihl");
+ LTT_FIELD_SOURCE= g_quark_from_static_string("source");
+ LTT_FIELD_DEST= g_quark_from_static_string("dest");
+ LTT_FIELD_SEQ= g_quark_from_static_string("seq");
+ LTT_FIELD_ACK_SEQ= g_quark_from_static_string("ack_seq");
+ LTT_FIELD_DOFF= g_quark_from_static_string("doff");
+ LTT_FIELD_ACK= g_quark_from_static_string("ack");
+ LTT_FIELD_RST= g_quark_from_static_string("rst");
+ LTT_FIELD_SYN= g_quark_from_static_string("syn");
+ LTT_FIELD_FIN= g_quark_from_static_string("fin");
+ LTT_FIELD_NAME= g_quark_from_static_string("name");
+ LTT_FIELD_ADDRESS= g_quark_from_static_string("address");
+ LTT_FIELD_UP= g_quark_from_static_string("up");
+}
+
+
+/* Fill hookListList and add event hooks
+ *
+ * Note: possibilité de remettre le code avec lttv_trace_find_marker_ids (voir
+ * r328)
+ *
+ * Args:
+ * hookListList: LttvTraceHook hookListList[traceNum][hookNum]
+ * traceSetContext: LTTV traceset
+ * hookFunction: call back function when event is encountered
+ * hookData: data that will be made accessible to hookFunction in
+ * arg0->hook_data
+ */
+void registerHooks(GArray* hookListList, LttvTracesetContext* const
+ traceSetContext, LttvHook hookFunction, gpointer hookData)
+{
+ unsigned int i, j, k;
+ unsigned int traceNb= lttv_traceset_number(traceSetContext->ts);
+ struct {
+ GQuark channelName;
+ GQuark eventName;
+ GQuark* fields;
+ } eventHookInfoList[] = {
+ {
+ .channelName= LTT_CHANNEL_NET,
+ .eventName= LTT_EVENT_DEV_XMIT,
+ .fields= FIELD_ARRAY(LTT_FIELD_SKB, LTT_FIELD_NETWORK_PROTOCOL,
+ LTT_FIELD_TRANSPORT_PROTOCOL, LTT_FIELD_SADDR,
+ LTT_FIELD_DADDR, LTT_FIELD_TOT_LEN, LTT_FIELD_IHL,
+ LTT_FIELD_SOURCE, LTT_FIELD_DEST, LTT_FIELD_SEQ,
+ LTT_FIELD_ACK_SEQ, LTT_FIELD_DOFF, LTT_FIELD_ACK,
+ LTT_FIELD_RST, LTT_FIELD_SYN, LTT_FIELD_FIN),
+ }, {
+ .channelName= LTT_CHANNEL_NET,
+ .eventName= LTT_EVENT_DEV_RECEIVE,
+ .fields= FIELD_ARRAY(LTT_FIELD_SKB, LTT_FIELD_PROTOCOL),
+ }, {
+ .channelName= LTT_CHANNEL_NET,
+ .eventName= LTT_EVENT_TCPV4_RCV,
+ .fields= FIELD_ARRAY(LTT_FIELD_SKB, LTT_FIELD_SADDR,
+ LTT_FIELD_DADDR, LTT_FIELD_TOT_LEN, LTT_FIELD_IHL,
+ LTT_FIELD_SOURCE, LTT_FIELD_DEST, LTT_FIELD_SEQ,
+ LTT_FIELD_ACK_SEQ, LTT_FIELD_DOFF, LTT_FIELD_ACK,
+ LTT_FIELD_RST, LTT_FIELD_SYN, LTT_FIELD_FIN),
+ }, {
+ .channelName= LTT_CHANNEL_NETIF_STATE,
+ .eventName= LTT_EVENT_NETWORK_IPV4_INTERFACE,
+ .fields= FIELD_ARRAY(LTT_FIELD_NAME, LTT_FIELD_ADDRESS,
+ LTT_FIELD_UP),
+ }
+ }; // This is called a compound literal
+ unsigned int hookNb= sizeof(eventHookInfoList) / sizeof(*eventHookInfoList);
+
+ for(i= 0; i < traceNb; i++)
+ {
+ LttvTraceContext* tc;
+ GArray* hookList;
+ int retval;
+
+ tc= traceSetContext->traces[i];
+ hookList= g_array_new(FALSE, FALSE, sizeof(LttvTraceHook));
+ g_array_append_val(hookListList, hookList);
+
+ // Find the hooks
+ for (j= 0; j < hookNb; j++)
+ {
+ guint old_len;
+
+ old_len= hookList->len;
+ retval= lttv_trace_find_hook(tc->t,
+ eventHookInfoList[j].channelName,
+ eventHookInfoList[j].eventName, eventHookInfoList[j].fields,
+ hookFunction, hookData, &hookList);
+ if (retval != 0)
+ {
+ g_warning("Trace %d contains no %s.%s marker\n", i,
+ g_quark_to_string(eventHookInfoList[j].channelName),
+ g_quark_to_string(eventHookInfoList[j].eventName));
+ }
+ else
+ {
+ g_assert(hookList->len - old_len == 1);
+ }
+ }
+
+ // Add the hooks to each tracefile's event_by_id hook list
+ for(j= 0; j < tc->tracefiles->len; j++)
+ {
+ LttvTracefileContext* tfc;
+
+ tfc= g_array_index(tc->tracefiles, LttvTracefileContext*, j);
+
+ for(k= 0; k < hookList->len; k++)
+ {
+ LttvTraceHook* traceHook;
+
+ traceHook= &g_array_index(hookList, LttvTraceHook, k);
+ if (traceHook->hook_data != hookData)
+ {
+ g_assert_not_reached();
+ }
+ if (traceHook->mdata == tfc->tf->mdata)
+ {
+ lttv_hooks_add(lttv_hooks_by_id_find(tfc->event_by_id,
+ traceHook->id), traceHook->h, traceHook,
+ LTTV_PRIO_DEFAULT);
+ }
+ }
+ }
+ }
+}
+
+
+/* Remove event hooks and free hookListList
+ *
+ * Args:
+ * hookListList: LttvTraceHook hookListList[traceNum][hookNum]
+ * traceSetContext: LTTV traceset
+ */
+void unregisterHooks(GArray* hookListList, LttvTracesetContext* const
+ traceSetContext)
+{
+ unsigned int i, j, k;
+ unsigned int traceNb= lttv_traceset_number(traceSetContext->ts);
+
+ for(i= 0; i < traceNb; i++)
+ {
+ LttvTraceContext* tc;
+ GArray* hookList;
+
+ tc= traceSetContext->traces[i];
+ hookList= g_array_index(hookListList, GArray*, i);
+
+ // Remove the hooks from each tracefile's event_by_id hook list
+ for(j= 0; j < tc->tracefiles->len; j++)
+ {
+ LttvTracefileContext* tfc;
+
+ tfc= g_array_index(tc->tracefiles, LttvTracefileContext*, j);
+
+ for(k= 0; k < hookList->len; k++)
+ {
+ LttvTraceHook* traceHook;
+
+ traceHook= &g_array_index(hookList, LttvTraceHook, k);
+ if (traceHook->mdata == tfc->tf->mdata)
+ {
+ lttv_hooks_remove_data(lttv_hooks_by_id_find(tfc->event_by_id,
+ traceHook->id), traceHook->h, traceHook);
+ }
+ }
+ }
+
+ g_array_free(hookList, TRUE);
+ }
+ g_array_free(hookListList, TRUE);
+}
projects / lttv.git / blobdiff