lttv/lttv/sync/event_processing_lttv_common.c

   1 /* This file is part of the Linux Trace Toolkit viewer
   2  * Copyright (C) 2009 Benjamin Poirier <benjamin.poirier@polymtl.ca>
   3  *
   4  * This program is free software; you can redistribute it and/or modify
   5  * it under the terms of the GNU General Public License Version 2 as
   6  * published by the Free Software Foundation;
   7  *
   8  * This program is distributed in the hope that it will be useful,
   9  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  10  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11  * GNU General Public License for more details.
  12  *
  13  * You should have received a copy of the GNU General Public License
  14  * along with this program; if not, write to the Free Software
  15  * Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  16  * MA 02111-1307, USA.
  17  */
  18
  19 #ifdef HAVE_CONFIG_H
  20 #include <config.h>
  21 #endif
  22
  23 #include "event_processing_lttv_common.h"
  24
  25
  26 /* This compound literal is #define'd in order to be able to "assign" it and
  27  * 'sizeof()' it
  28  */
  29 #define EVENT_HOOK_INFO_LIST ((EventHookInfo[]) {\
  30         {\
  31                 .channelName= LTT_CHANNEL_NET,\
  32                 .eventName= LTT_EVENT_DEV_XMIT,\
  33                 .fields= FIELD_ARRAY(LTT_FIELD_SKB, LTT_FIELD_NETWORK_PROTOCOL,\
  34                         LTT_FIELD_TRANSPORT_PROTOCOL, LTT_FIELD_SADDR,\
  35                         LTT_FIELD_DADDR, LTT_FIELD_TOT_LEN, LTT_FIELD_IHL,\
  36                         LTT_FIELD_SOURCE, LTT_FIELD_DEST, LTT_FIELD_SEQ,\
  37                         LTT_FIELD_ACK_SEQ, LTT_FIELD_DOFF, LTT_FIELD_ACK,\
  38                         LTT_FIELD_RST, LTT_FIELD_SYN, LTT_FIELD_FIN),\
  39         }, {\
  40                 .channelName= LTT_CHANNEL_NET,\
  41                 .eventName= LTT_EVENT_DEV_RECEIVE,\
  42                 .fields= FIELD_ARRAY(LTT_FIELD_SKB, LTT_FIELD_PROTOCOL),\
  43         }, {\
  44                 .channelName= LTT_CHANNEL_NET,\
  45                 .eventName= LTT_EVENT_TCPV4_RCV,\
  46                 .fields= FIELD_ARRAY(LTT_FIELD_SKB, LTT_FIELD_SADDR,\
  47                         LTT_FIELD_DADDR, LTT_FIELD_TOT_LEN, LTT_FIELD_IHL,\
  48                         LTT_FIELD_SOURCE, LTT_FIELD_DEST, LTT_FIELD_SEQ,\
  49                         LTT_FIELD_ACK_SEQ, LTT_FIELD_DOFF, LTT_FIELD_ACK,\
  50                         LTT_FIELD_RST, LTT_FIELD_SYN, LTT_FIELD_FIN),\
  51         }, {\
  52                 .channelName= LTT_CHANNEL_NETIF_STATE,\
  53                 .eventName= LTT_EVENT_NETWORK_IPV4_INTERFACE,\
  54                 .fields= FIELD_ARRAY(LTT_FIELD_NAME, LTT_FIELD_ADDRESS,\
  55                         LTT_FIELD_UP),\
  56         }\
  57 })
  58
  59 #ifndef g_info
  60 #define g_info(format...) g_log (G_LOG_DOMAIN, G_LOG_LEVEL_INFO, format)
  61 #endif
  62
  63
  64 typedef struct
  65 {
  66         GQuark channelName;
  67         GQuark eventName;
  68         GQuark* fields;
  69 } EventHookInfo;
  70
  71
  72 /*
  73  * Initialize the GQuarks needed to register the event hooks for
  74  * synchronization
  75  */
  76 void createQuarks()
  77 {
  78         LTT_CHANNEL_NET= g_quark_from_static_string("net");
  79         LTT_CHANNEL_NETIF_STATE= g_quark_from_static_string("netif_state");
  80
  81         LTT_EVENT_DEV_XMIT= g_quark_from_static_string("dev_xmit");
  82         LTT_EVENT_DEV_RECEIVE= g_quark_from_static_string("dev_receive");
  83         LTT_EVENT_TCPV4_RCV= g_quark_from_static_string("tcpv4_rcv");
  84         LTT_EVENT_NETWORK_IPV4_INTERFACE=
  85                 g_quark_from_static_string("network_ipv4_interface");
  86
  87         LTT_FIELD_SKB= g_quark_from_static_string("skb");
  88         LTT_FIELD_PROTOCOL= g_quark_from_static_string("protocol");
  89         LTT_FIELD_NETWORK_PROTOCOL=
  90                 g_quark_from_static_string("network_protocol");
  91         LTT_FIELD_TRANSPORT_PROTOCOL=
  92                 g_quark_from_static_string("transport_protocol");
  93         LTT_FIELD_SADDR= g_quark_from_static_string("saddr");
  94         LTT_FIELD_DADDR= g_quark_from_static_string("daddr");
  95         LTT_FIELD_TOT_LEN= g_quark_from_static_string("tot_len");
  96         LTT_FIELD_IHL= g_quark_from_static_string("ihl");
  97         LTT_FIELD_SOURCE= g_quark_from_static_string("source");
  98         LTT_FIELD_DEST= g_quark_from_static_string("dest");
  99         LTT_FIELD_SEQ= g_quark_from_static_string("seq");
 100         LTT_FIELD_ACK_SEQ= g_quark_from_static_string("ack_seq");
 101         LTT_FIELD_DOFF= g_quark_from_static_string("doff");
 102         LTT_FIELD_ACK= g_quark_from_static_string("ack");
 103         LTT_FIELD_RST= g_quark_from_static_string("rst");
 104         LTT_FIELD_SYN= g_quark_from_static_string("syn");
 105         LTT_FIELD_FIN= g_quark_from_static_string("fin");
 106         LTT_FIELD_NAME= g_quark_from_static_string("name");
 107         LTT_FIELD_ADDRESS= g_quark_from_static_string("address");
 108         LTT_FIELD_UP= g_quark_from_static_string("up");
 109 }
 110
 111
 112 /* Fill hookListList and add event hooks
 113  *
 114  * Note: possibilité de remettre le code avec lttv_trace_find_marker_ids (voir
 115  * r328)
 116  *
 117  * Args:
 118  */
 119 void registerHooks(GArray* hookListList, LttvTracesetContext* const
 120         traceSetContext, unsigned int traceNb, LttvHook hookFunction, gpointer
 121         hookData)
 122 {
 123         unsigned int i, j, k;
 124         unsigned int hookNb;
 125         EventHookInfo* eventHookInfoList;
 126
 127         eventHookInfoList= EVENT_HOOK_INFO_LIST;
 128         hookNb= sizeof(EVENT_HOOK_INFO_LIST) / sizeof(EventHookInfo);
 129
 130         for(i= 0; i < traceNb; i++)
 131         {
 132                 LttvTraceContext* tc;
 133                 GArray* hookList;
 134                 int retval;
 135
 136                 tc= traceSetContext->traces[i];
 137                 hookList= g_array_new(FALSE, FALSE, sizeof(LttvTraceHook));
 138                 g_array_append_val(hookListList, hookList);
 139
 140                 // Find the hooks
 141                 for (j= 0; j < hookNb; j++)
 142                 {
 143                         guint old_len;
 144
 145                         old_len= hookList->len;
 146                         retval= lttv_trace_find_hook(tc->t,
 147                                 eventHookInfoList[j].channelName,
 148                                 eventHookInfoList[j].eventName, eventHookInfoList[j].fields,
 149                                 hookFunction, hookData, &hookList);
 150                         if (retval != 0)
 151                         {
 152                                 g_warning("Trace %d contains no %s.%s marker\n", i,
 153                                         g_quark_to_string(eventHookInfoList[j].channelName),
 154                                         g_quark_to_string(eventHookInfoList[j].eventName));
 155                         }
 156                         else
 157                         {
 158                                 g_assert(hookList->len - old_len == 1);
 159                         }
 160                 }
 161
 162                 // Add the hooks to each tracefile's event_by_id hook list
 163                 for(j= 0; j < tc->tracefiles->len; j++)
 164                 {
 165                         LttvTracefileContext* tfc;
 166
 167                         tfc= g_array_index(tc->tracefiles, LttvTracefileContext*, j);
 168
 169                         for(k= 0; k < hookList->len; k++)
 170                         {
 171                                 LttvTraceHook* traceHook;
 172
 173                                 traceHook= &g_array_index(hookList, LttvTraceHook, k);
 174                                 if (traceHook->hook_data != hookData)
 175                                 {
 176                                         g_assert_not_reached();
 177                                 }
 178                                 if (traceHook->mdata == tfc->tf->mdata)
 179                                 {
 180                                         lttv_hooks_add(lttv_hooks_by_id_find( tfc->event_by_id,
 181                                                         traceHook->id), traceHook->h, traceHook,
 182                                                 LTTV_PRIO_DEFAULT);
 183                                 }
 184                         }
 185                 }
 186         }
 187 }
 188
 189
 190 /* Remove event hooks and free hookListList
 191  *
 192  * Args:
 193  *   hookListList: LttvTraceHook hookListList[traceNum][hookNum]
 194  *   traceSetContext: LTTV traceset
 195  *   traceNb:      number of traces in the traceset
 196  */
 197 void unregisterHooks(GArray* hookListList, LttvTracesetContext* const
 198         traceSetContext, unsigned int traceNb)
 199 {
 200         unsigned int i, j, k;
 201
 202         for(i= 0; i < traceNb; i++)
 203         {
 204                 LttvTraceContext* tc;
 205                 GArray* hookList;
 206
 207                 tc= traceSetContext->traces[i];
 208                 hookList= g_array_index(hookListList, GArray*, i);
 209
 210                 // Remove the hooks from each tracefile's event_by_id hook list
 211                 for(j= 0; j < tc->tracefiles->len; j++)
 212                 {
 213                         LttvTracefileContext* tfc;
 214
 215                         tfc= g_array_index(tc->tracefiles, LttvTracefileContext*, j);
 216
 217                         for(k= 0; k < hookList->len; k++)
 218                         {
 219                                 LttvTraceHook* traceHook;
 220
 221                                 traceHook= &g_array_index(hookList, LttvTraceHook, k);
 222                                 if (traceHook->mdata == tfc->tf->mdata)
 223                                 {
 224                                         lttv_hooks_remove_data(lttv_hooks_by_id_find(tfc->event_by_id,
 225                                                         traceHook->id), traceHook->h, traceHook);
 226                                 }
 227                         }
 228                 }
 229
 230                 g_array_free(hookList, TRUE);
 231         }
 232         g_array_free(hookListList, TRUE);
 233 }