X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fvarnish.c;h=08260dc27fe5c28e2a7eb58c6b7350735aa9a827;hb=d4cc32c4dddb01081c49a67d13ab4a737cda0ed0;hp=acc9015d1a02708494e6019f62ffa478f29565c1;hpb=3c42182e912e3d634fe8c4f6a636053959fcde49;p=collectd.git diff --git a/src/varnish.c b/src/varnish.c index acc9015d..08260dc2 100644 --- a/src/varnish.c +++ b/src/varnish.c @@ -144,7 +144,6 @@ static int varnish_monitor(void *priv, { uint64_t val; const user_config_t *conf; - const char *class; const char *name; if (pt == NULL) @@ -153,28 +152,25 @@ static int varnish_monitor(void *priv, conf = priv; #if HAVE_VARNISH_V5 - char namebuff[100]; - char *c; + char namebuff[DATA_MAX_NAME_LEN]; - c = rindex(pt->name, '.'); - strcpy(namebuff, c+1); + char const *c = strrchr(pt->name, '.'); + if (c == NULL) { + return EINVAL; + } + sstrncpy(namebuff, c + 1, sizeof(namebuff)); name = namebuff; - (void)class; - #elif HAVE_VARNISH_V4 - class = pt->section->fantom->type; - name = pt->desc->name; - - if (strcmp(class, "MAIN") != 0) + if (strcmp(pt->section->fantom->type, "MAIN") != 0) return 0; + name = pt->desc->name; #elif HAVE_VARNISH_V3 - class = pt->class; - name = pt->name; - - if (strcmp(class, "") != 0) + if (strcmp(pt->class, "") != 0) return 0; + + name = pt->name; #endif val = *(const volatile uint64_t *)pt->ptr; @@ -460,7 +456,6 @@ static int varnish_monitor(void *priv, else if (strcmp(name, "bans_tests_tested") == 0) return varnish_submit_derive(conf->instance, "ban", "total_operations", "tests_tested", val); - } #endif @@ -501,7 +496,8 @@ static int varnish_monitor(void *priv, "total_operations", "closed_err", val); else if (strcmp(name, "sess_dropped") == 0) return varnish_submit_derive(conf->instance, "session", - "total_operations", "dropped_for_thread", val); + "total_operations", "dropped_for_thread", + val); #endif } @@ -679,7 +675,7 @@ static int varnish_monitor(void *priv, "dropped", val); else if (strcmp(name, "thread_queue_len") == 0) return varnish_submit_gauge(conf->instance, "workers", "queue_length", - "threads", val); + "threads", val); else if (strcmp(name, "n_wrk") == 0) return varnish_submit_gauge(conf->instance, "workers", "threads", "worker", val); @@ -709,8 +705,8 @@ static int varnish_monitor(void *priv, "queue_length", val); #if HAVE_VARNISH_V4 || HAVE_VARNISH_V5 else if (strcmp(name, "pools") == 0) - return varnish_submit_gauge(conf->instance, "workers", "pools", - "pools", val); + return varnish_submit_gauge(conf->instance, "workers", "pools", "pools", + val); else if (strcmp(name, "busy_killed") == 0) return varnish_submit_derive(conf->instance, "workers", "http_requests", "busy_killed", val); @@ -741,38 +737,38 @@ static int varnish_monitor(void *priv, "bitmap", "happy_hprobes", val); */ if (strcmp(name, "bereq_hdrbytes") == 0) - return varnish_submit_derive(conf->instance, "vbe", - "total_bytes", "bereq_hdrbytes", val); + return varnish_submit_derive(conf->instance, "vbe", "total_bytes", + "bereq_hdrbytes", val); else if (strcmp(name, "bereq_bodybytes") == 0) - return varnish_submit_derive(conf->instance, "vbe", - "total_bytes", "bereq_bodybytes", val); + return varnish_submit_derive(conf->instance, "vbe", "total_bytes", + "bereq_bodybytes", val); else if (strcmp(name, "bereq_protobytes") == 0) - return varnish_submit_derive(conf->instance, "vbe", - "total_bytes", "bereq_protobytes", val); + return varnish_submit_derive(conf->instance, "vbe", "total_bytes", + "bereq_protobytes", val); else if (strcmp(name, "beresp_hdrbytes") == 0) - return varnish_submit_derive(conf->instance, "vbe", - "total_bytes", "beresp_hdrbytes", val); + return varnish_submit_derive(conf->instance, "vbe", "total_bytes", + "beresp_hdrbytes", val); else if (strcmp(name, "beresp_bodybytes") == 0) - return varnish_submit_derive(conf->instance, "vbe", - "total_bytes", "beresp_bodybytes", val); + return varnish_submit_derive(conf->instance, "vbe", "total_bytes", + "beresp_bodybytes", val); else if (strcmp(name, "beresp_protobytes") == 0) - return varnish_submit_derive(conf->instance, "vbe", - "total_bytes", "beresp_protobytes", val); + return varnish_submit_derive(conf->instance, "vbe", "total_bytes", + "beresp_protobytes", val); else if (strcmp(name, "pipe_hdrbytes") == 0) - return varnish_submit_derive(conf->instance, "vbe", - "total_bytes", "pipe_hdrbytes", val); + return varnish_submit_derive(conf->instance, "vbe", "total_bytes", + "pipe_hdrbytes", val); else if (strcmp(name, "pipe_out") == 0) - return varnish_submit_derive(conf->instance, "vbe", - "total_bytes", "pipe_out", val); + return varnish_submit_derive(conf->instance, "vbe", "total_bytes", + "pipe_out", val); else if (strcmp(name, "pipe_in") == 0) - return varnish_submit_derive(conf->instance, "vbe", - "total_bytes", "pipe_in", val); + return varnish_submit_derive(conf->instance, "vbe", "total_bytes", + "pipe_in", val); else if (strcmp(name, "conn") == 0) return varnish_submit_derive(conf->instance, "vbe", "connections", - "c_conns", val); + "c_conns", val); else if (strcmp(name, "req") == 0) return varnish_submit_derive(conf->instance, "vbe", "http_requests", - "b_reqs", val); + "b_reqs", val); } /* All Stevedores support these counters */ @@ -787,20 +783,20 @@ static int varnish_monitor(void *priv, strncpy(category, "mse", 4); if (strcmp(name, "c_req") == 0) - return varnish_submit_derive(conf->instance, category, - "total_operations", "alloc_req", val); + return varnish_submit_derive(conf->instance, category, "total_operations", + "alloc_req", val); else if (strcmp(name, "c_fail") == 0) - return varnish_submit_derive(conf->instance, category, - "total_operations", "alloc_fail", val); + return varnish_submit_derive(conf->instance, category, "total_operations", + "alloc_fail", val); else if (strcmp(name, "c_bytes") == 0) - return varnish_submit_derive(conf->instance, category, - "total_bytes", "bytes_allocated", val); + return varnish_submit_derive(conf->instance, category, "total_bytes", + "bytes_allocated", val); else if (strcmp(name, "c_freed") == 0) - return varnish_submit_derive(conf->instance, category, - "total_bytes", "bytes_freed", val); + return varnish_submit_derive(conf->instance, category, "total_bytes", + "bytes_freed", val); else if (strcmp(name, "g_alloc") == 0) - return varnish_submit_derive(conf->instance, category, - "total_operations", "alloc_outstanding", val); + return varnish_submit_derive(conf->instance, category, "total_operations", + "alloc_outstanding", val); else if (strcmp(name, "g_bytes") == 0) return varnish_submit_gauge(conf->instance, category, "bytes", "bytes_outstanding", val); @@ -813,14 +809,14 @@ static int varnish_monitor(void *priv, if (conf->collect_smf) { if (strcmp(name, "g_smf") == 0) - return varnish_submit_gauge(conf->instance, "smf", "objects", - "n_struct_smf", val); - else if (strcmp(name, "g_smf_frag") == 0) - return varnish_submit_gauge(conf->instance, "smf", "objects", - "n_small_free_smf", val); - else if (strcmp(name, "g_smf_large") == 0) - return varnish_submit_gauge(conf->instance, "smf", "objects", - "n_large_free_smf", val); + return varnish_submit_gauge(conf->instance, "smf", "objects", + "n_struct_smf", val); + else if (strcmp(name, "g_smf_frag") == 0) + return varnish_submit_gauge(conf->instance, "smf", "objects", + "n_small_free_smf", val); + else if (strcmp(name, "g_smf_large") == 0) + return varnish_submit_gauge(conf->instance, "smf", "objects", + "n_large_free_smf", val); } if (conf->collect_mgt) { @@ -828,35 +824,35 @@ static int varnish_monitor(void *priv, return varnish_submit_gauge(conf->instance, "mgt", "uptime", "mgt_proc_uptime", val); else if (strcmp(name, "child_start") == 0) - return varnish_submit_derive(conf->instance, "mgt", - "total_operations", "child_start", val); + return varnish_submit_derive(conf->instance, "mgt", "total_operations", + "child_start", val); else if (strcmp(name, "child_exit") == 0) - return varnish_submit_derive(conf->instance, "mgt", - "total_operations", "child_exit", val); + return varnish_submit_derive(conf->instance, "mgt", "total_operations", + "child_exit", val); else if (strcmp(name, "child_stop") == 0) - return varnish_submit_derive(conf->instance, "mgt", - "total_operations", "child_stop", val); + return varnish_submit_derive(conf->instance, "mgt", "total_operations", + "child_stop", val); else if (strcmp(name, "child_died") == 0) - return varnish_submit_derive(conf->instance, "mgt", - "total_operations", "child_died", val); + return varnish_submit_derive(conf->instance, "mgt", "total_operations", + "child_died", val); else if (strcmp(name, "child_dump") == 0) - return varnish_submit_derive(conf->instance, "mgt", - "total_operations", "child_dump", val); + return varnish_submit_derive(conf->instance, "mgt", "total_operations", + "child_dump", val); else if (strcmp(name, "child_panic") == 0) - return varnish_submit_derive(conf->instance, "mgt", - "total_operations", "child_panic", val); + return varnish_submit_derive(conf->instance, "mgt", "total_operations", + "child_panic", val); } if (conf->collect_lck) { if (strcmp(name, "creat") == 0) - return varnish_submit_gauge(conf->instance, "lck", "objects", - "created", val); + return varnish_submit_gauge(conf->instance, "lck", "objects", "created", + val); else if (strcmp(name, "destroy") == 0) - return varnish_submit_gauge(conf->instance, "lck", "objects", - "destroyed", val); + return varnish_submit_gauge(conf->instance, "lck", "objects", "destroyed", + val); else if (strcmp(name, "locks") == 0) return varnish_submit_derive(conf->instance, "lck", "total_operations", - "lock_ops", val); + "lock_ops", val); } if (conf->collect_mempool) { @@ -879,112 +875,111 @@ static int varnish_monitor(void *priv, return varnish_submit_derive(conf->instance, "mempool", "total_operations", "frees", val); else if (strcmp(name, "recycle") == 0) - return varnish_submit_gauge(conf->instance, "mempool", - "objects", "recycled", val); + return varnish_submit_gauge(conf->instance, "mempool", "objects", + "recycled", val); else if (strcmp(name, "timeout") == 0) - return varnish_submit_gauge(conf->instance, "mempool", - "objects", "timed_out", val); + return varnish_submit_gauge(conf->instance, "mempool", "objects", + "timed_out", val); else if (strcmp(name, "toosmall") == 0) - return varnish_submit_gauge(conf->instance, "mempool", - "objects", "too_small", val); + return varnish_submit_gauge(conf->instance, "mempool", "objects", + "too_small", val); else if (strcmp(name, "surplus") == 0) - return varnish_submit_gauge(conf->instance, "mempool", - "objects", "surplus", val); + return varnish_submit_gauge(conf->instance, "mempool", "objects", + "surplus", val); else if (strcmp(name, "randry") == 0) - return varnish_submit_gauge(conf->instance, "mempool", - "objects", "ran_dry", val); + return varnish_submit_gauge(conf->instance, "mempool", "objects", + "ran_dry", val); } if (conf->collect_mse) { if (strcmp(name, "c_full") == 0) - return varnish_submit_derive(conf->instance, "mse", - "total_operations", "full_allocs", val); + return varnish_submit_derive(conf->instance, "mse", "total_operations", + "full_allocs", val); else if (strcmp(name, "c_truncated") == 0) - return varnish_submit_derive(conf->instance, "mse", - "total_operations", "truncated_allocs", val); + return varnish_submit_derive(conf->instance, "mse", "total_operations", + "truncated_allocs", val); else if (strcmp(name, "c_expanded") == 0) - return varnish_submit_derive(conf->instance, "mse", - "total_operations", "expanded_allocs", val); + return varnish_submit_derive(conf->instance, "mse", "total_operations", + "expanded_allocs", val); else if (strcmp(name, "c_failed") == 0) - return varnish_submit_derive(conf->instance, "mse", - "total_operations", "failed_allocs", val); + return varnish_submit_derive(conf->instance, "mse", "total_operations", + "failed_allocs", val); else if (strcmp(name, "c_bytes") == 0) - return varnish_submit_derive(conf->instance, "mse", - "total_bytes", "bytes_allocated", val); + return varnish_submit_derive(conf->instance, "mse", "total_bytes", + "bytes_allocated", val); else if (strcmp(name, "c_freed") == 0) - return varnish_submit_derive(conf->instance, "mse", - "total_bytes", "bytes_freed", val); + return varnish_submit_derive(conf->instance, "mse", "total_bytes", + "bytes_freed", val); else if (strcmp(name, "g_fo_alloc") == 0) - return varnish_submit_derive(conf->instance, "mse", - "total_operations", "fo_allocs_outstanding", val); + return varnish_submit_derive(conf->instance, "mse", "total_operations", + "fo_allocs_outstanding", val); else if (strcmp(name, "g_fo_bytes") == 0) - return varnish_submit_gauge(conf->instance, "mse", - "bytes", "fo_bytes_outstanding", val); + return varnish_submit_gauge(conf->instance, "mse", "bytes", + "fo_bytes_outstanding", val); else if (strcmp(name, "g_membuf_alloc") == 0) - return varnish_submit_gauge(conf->instance, "mse", - "objects", "membufs_allocated", val); + return varnish_submit_gauge(conf->instance, "mse", "objects", + "membufs_allocated", val); else if (strcmp(name, "g_membuf_inuse") == 0) - return varnish_submit_gauge(conf->instance, "mse", - "objects", "membufs_inuse", val); + return varnish_submit_gauge(conf->instance, "mse", "objects", + "membufs_inuse", val); else if (strcmp(name, "g_bans_bytes") == 0) - return varnish_submit_gauge(conf->instance, "mse", - "bytes", "persisted_banspace_used", val); + return varnish_submit_gauge(conf->instance, "mse", "bytes", + "persisted_banspace_used", val); else if (strcmp(name, "g_bans_space") == 0) - return varnish_submit_gauge(conf->instance, "mse", - "bytes", "persisted_banspace_available", val); + return varnish_submit_gauge(conf->instance, "mse", "bytes", + "persisted_banspace_available", val); else if (strcmp(name, "g_bans_persisted") == 0) - return varnish_submit_derive(conf->instance, "mse", - "total_operations", "bans_persisted", val); + return varnish_submit_derive(conf->instance, "mse", "total_operations", + "bans_persisted", val); else if (strcmp(name, "g_bans_lost") == 0) - return varnish_submit_derive(conf->instance, "mse", - "total_operations", "bans_lost", val); + return varnish_submit_derive(conf->instance, "mse", "total_operations", + "bans_lost", val); - /* mse seg */ + /* mse seg */ else if (strcmp(name, "g_journal_bytes") == 0) - return varnish_submit_gauge(conf->instance, "mse_reg", - "bytes", "journal_bytes_used", val); + return varnish_submit_gauge(conf->instance, "mse_reg", "bytes", + "journal_bytes_used", val); else if (strcmp(name, "g_journal_space") == 0) - return varnish_submit_gauge(conf->instance, "mse_reg", - "bytes", "journal_bytes_free", val); + return varnish_submit_gauge(conf->instance, "mse_reg", "bytes", + "journal_bytes_free", val); /* mse segagg */ else if (strcmp(name, "g_bigspace") == 0) - return varnish_submit_gauge(conf->instance, "mse_segagg", - "bytes", "big_extents_bytes_available", val); + return varnish_submit_gauge(conf->instance, "mse_segagg", "bytes", + "big_extents_bytes_available", val); else if (strcmp(name, "g_extfree") == 0) - return varnish_submit_gauge(conf->instance, "mse_segagg", - "objects", "free_extents", val); + return varnish_submit_gauge(conf->instance, "mse_segagg", "objects", + "free_extents", val); else if (strcmp(name, "g_sparenode") == 0) - return varnish_submit_gauge(conf->instance, "mse_segagg", - "objects", "spare_nodes_available", val); + return varnish_submit_gauge(conf->instance, "mse_segagg", "objects", + "spare_nodes_available", val); else if (strcmp(name, "g_objnode") == 0) - return varnish_submit_gauge(conf->instance, "mse_segagg", - "objects", "object_nodes_in_use", val); + return varnish_submit_gauge(conf->instance, "mse_segagg", "objects", + "object_nodes_in_use", val); else if (strcmp(name, "g_extnode") == 0) - return varnish_submit_gauge(conf->instance, "mse_segagg", - "objects", "extent_nodes_in_use", val); + return varnish_submit_gauge(conf->instance, "mse_segagg", "objects", + "extent_nodes_in_use", val); else if (strcmp(name, "g_bigextfree") == 0) - return varnish_submit_gauge(conf->instance, "mse_segagg", - "objects", "free_big_extents", val); + return varnish_submit_gauge(conf->instance, "mse_segagg", "objects", + "free_big_extents", val); else if (strcmp(name, "c_pruneloop") == 0) return varnish_submit_derive(conf->instance, "mse_segagg", - "total_operations", "prune_loops", val); + "total_operations", "prune_loops", val); else if (strcmp(name, "c_pruned") == 0) return varnish_submit_derive(conf->instance, "mse_segagg", - "total_objects", "pruned_objects", val); + "total_objects", "pruned_objects", val); else if (strcmp(name, "c_spared") == 0) return varnish_submit_derive(conf->instance, "mse_segagg", - "total_operations", "spared_objects", val); + "total_operations", "spared_objects", val); else if (strcmp(name, "c_skipped") == 0) return varnish_submit_derive(conf->instance, "mse_segagg", - "total_operations", "missed_objects", val); + "total_operations", "missed_objects", val); else if (strcmp(name, "c_nuked") == 0) return varnish_submit_derive(conf->instance, "mse_segagg", - "total_operations", "nuked_objects", val); + "total_operations", "nuked_objects", val); else if (strcmp(name, "c_sniped") == 0) return varnish_submit_derive(conf->instance, "mse_segagg", - "total_operations", "sniped_objects", val); - + "total_operations", "sniped_objects", val); } #endif @@ -1374,8 +1369,8 @@ static int varnish_read(user_data_t *ud) /* {{{ */ #if HAVE_VARNISH_V3 || HAVE_VARNISH_V4 VSM_Delete(vd); #elif HAVE_VARNISH_V5 - VSC_Destroy(&vsc, vd); - VSM_Destroy(&vd); + VSC_Destroy(&vsc, vd); + VSM_Destroy(&vd); #endif ERROR("varnish plugin: VSM_Arg (\"%s\") failed " "with status %i.", @@ -1391,7 +1386,7 @@ static int varnish_read(user_data_t *ud) /* {{{ */ #endif #if HAVE_VARNISH_V3 || HAVE_VARNISH_V4 if (!ok) { - VSM_Destroy(&vd); + VSM_Delete(vd); ERROR("varnish plugin: Unable to open connection."); return -1; } @@ -1404,27 +1399,27 @@ static int varnish_read(user_data_t *ud) /* {{{ */ #endif #if HAVE_VARNISH_V3 || HAVE_VARNISH_V4 if (!stats) { - VSM_Destroy(&vd); + VSM_Delete(vd); ERROR("varnish plugin: Unable to get statistics."); return -1; } #endif #if HAVE_VARNISH_V5 - if (VSM_Attach(vd, STDERR_FILENO)) { - ERROR("varnish plugin: Cannot attach to varnish. %s", VSM_Error(vd)); - VSC_Destroy(&vsc, vd); - VSM_Destroy(&vd); - return -1; - } + if (VSM_Attach(vd, STDERR_FILENO)) { + ERROR("varnish plugin: Cannot attach to varnish. %s", VSM_Error(vd)); + VSC_Destroy(&vsc, vd); + VSM_Destroy(&vd); + return -1; + } - vsm_status = VSM_Status(vd); - if (vsm_status & ~(VSM_MGT_RUNNING|VSM_WRK_RUNNING)) { - ERROR("varnish plugin: Unable to get statistics."); - VSC_Destroy(&vsc, vd); - VSM_Destroy(&vd); - return -1; - } + vsm_status = VSM_Status(vd); + if (vsm_status & ~(VSM_MGT_RUNNING | VSM_WRK_RUNNING)) { + ERROR("varnish plugin: Unable to get statistics."); + VSC_Destroy(&vsc, vd); + VSM_Destroy(&vd); + return -1; + } #endif #if HAVE_VARNISH_V3 @@ -1436,10 +1431,10 @@ static int varnish_read(user_data_t *ud) /* {{{ */ #endif #if HAVE_VARNISH_V3 || HAVE_VARNISH_V4 - VSM_Delete(vd); + VSM_Delete(vd); #elif HAVE_VARNISH_V5 - VSC_Destroy(&vsc, vd); - VSM_Destroy(&vd); + VSC_Destroy(&vsc, vd); + VSM_Destroy(&vd); #endif return 0; @@ -1752,9 +1747,9 @@ static int varnish_config_instance(const oconfig_item_t *ci) /* {{{ */ #endif && !conf->collect_vcl && !conf->collect_workers #if HAVE_VARNISH_V4 || HAVE_VARNISH_V5 - && !conf->collect_vsm && !conf->collect_vbe && !conf->collect_smf - && !conf->collect_mgt && !conf->collect_lck && !conf->collect_mempool - && !conf->collect_mse + && !conf->collect_vsm && !conf->collect_vbe && !conf->collect_smf && + !conf->collect_mgt && !conf->collect_lck && !conf->collect_mempool && + !conf->collect_mse #endif ) { WARNING("Varnish plugin: No metric has been configured for "