Changeset 35d80a0f98b37605f57c21fbd5751fce4958910f

Show
Ignore:
Timestamp:
01/22/10 22:33:47 (8 years ago)
Author:
Theo Schlossnagle <jesus@omniti.com>
git-committer:
Theo Schlossnagle <jesus@omniti.com> 1264199627 +0000
git-parent:

[8883c4d669a4b6eb31dbf4743c3c76f8567a8c2f]

git-author:
Theo Schlossnagle <jesus@omniti.com> 1264199627 +0000
Message:

fixes #244

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • src/stratcon_datastore.c

    r58fc542 r35d80a0  
    7979static noit_log_stream_t ds_pool_deb = NULL; 
    8080static noit_log_stream_t ingest_err = NULL; 
     81 
     82static int ds_system_enabled = 1; 
     83int stratcon_datastore_get_enabled() { return ds_system_enabled; } 
     84void stratcon_datastore_set_enabled(int n) { ds_system_enabled = n; } 
    8185 
    8286static struct datastore_onlooker_list { 
  • src/stratcon_datastore.h

    r5360a1e r35d80a0  
    6666  stratcon_datastore_iep_check_preload(); 
    6767 
     68API_EXPORT(int) 
     69  stratcon_datastore_get_enabled(); 
     70 
     71API_EXPORT(void) 
     72  stratcon_datastore_set_enabled(int); 
     73 
    6874#endif 
  • src/stratcon_iep.c

    r9eeace2 r35d80a0  
    6565static mq_driver_t *mq_driver = NULL; 
    6666 
     67static int iep_system_enabled = 1; 
     68int stratcon_iep_get_enabled() { return iep_system_enabled; } 
     69void stratcon_iep_set_enabled(int n) { iep_system_enabled = n; } 
     70 
     71 
    6772struct iep_job_closure { 
    6873  char *line;       /* This is a copy and gets trashed during processing */ 
  • src/stratcon_iep.h

    r7afb4e3 r35d80a0  
    8181  stratcon_iep_mq_driver_register(const char *, mq_driver_t *); 
    8282 
     83API_EXPORT(int) 
     84  stratcon_iep_get_enabled(); 
     85 
     86API_EXPORT(void) 
     87  stratcon_iep_set_enabled(int); 
     88 
    8389#endif 
  • src/stratcon_jlog_streamer.c

    rc35ae3a r35d80a0  
    965965  xmlSetProp(newnoit, (xmlChar *)"port", (xmlChar *)port_str); 
    966966  xmlAddChild(parent, newnoit); 
    967   stratcon_streamer_connection(NULL, target, 
    968                                stratcon_jlog_recv_handler, 
    969                                (void *(*)())stratcon_jlog_streamer_datastore_ctx_alloc, 
    970                                NULL, 
    971                                jlog_streamer_ctx_free); 
    972   stratcon_streamer_connection(NULL, target, 
    973                                stratcon_jlog_recv_handler, 
    974                                (void *(*)())stratcon_jlog_streamer_iep_ctx_alloc, 
    975                                NULL, 
    976                                jlog_streamer_ctx_free); 
     967  if(stratcon_datastore_get_enabled()) 
     968    stratcon_streamer_connection(NULL, target, 
     969                                 stratcon_jlog_recv_handler, 
     970                                 (void *(*)())stratcon_jlog_streamer_datastore_ctx_alloc, 
     971                                 NULL, 
     972                                 jlog_streamer_ctx_free); 
     973  if(stratcon_iep_get_enabled()) 
     974    stratcon_streamer_connection(NULL, target, 
     975                                 stratcon_jlog_recv_handler, 
     976                                 (void *(*)())stratcon_jlog_streamer_iep_ctx_alloc, 
     977                                 NULL, 
     978                                 jlog_streamer_ctx_free); 
    977979  return 1; 
    978980} 
  • src/stratcond.c

    rd2d82a9 r35d80a0  
    6565static int debug = 0; 
    6666static int strict_module_load = 0; 
    67 static int no_store = 0; 
    6867static char **enable_logs; 
    6968static int enable_logs_cnt = 0; 
     
    108107  enable_logs = calloc(argc, sizeof(*enable_logs)); 
    109108  disable_logs = calloc(argc, sizeof(*disable_logs)); 
    110   while((c = getopt(argc, argv, "Mshc:dDu:g:t:l:L:")) != EOF) { 
     109  while((c = getopt(argc, argv, "Mrshc:dDu:g:t:l:L:")) != EOF) { 
    111110    switch(c) { 
    112111      case 'M': 
     
    119118        disable_logs[disable_logs_cnt++] = strdup(optarg); 
    120119        break; 
     120      case 'r': 
     121        stratcon_iep_set_enabled(0); 
     122        break; 
    121123      case 's': 
    122         no_store = 1
     124        stratcon_datastore_set_enabled(0)
    123125        break; 
    124126      case 'h': 
     
    237239  } 
    238240 
    239   stratcon_datastore_init(); 
     241  if(stratcon_datastore_get_enabled()) 
     242    stratcon_datastore_init(); 
    240243 
    241244  /* Drop privileges */ 
     
    249252  } 
    250253 
    251   stratcon_iep_init(); 
    252   if(!no_store) { 
     254  if(stratcon_iep_get_enabled()) 
     255    stratcon_iep_init(); 
     256  if(stratcon_datastore_get_enabled()) { 
    253257    stratcon_jlog_streamer_init(APPNAME); 
    254258    /* Write our log out, and setup a watchdog to write it out on change. */