+ if (conf->collect_ban) {
+ if (strcmp(name, "n_ban") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "total", val);
+ else if (strcmp(name, "n_ban_add") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "added", val);
+ else if (strcmp(name, "n_ban_retire") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "deleted", val);
+ else if (strcmp(name, "n_ban_obj_test") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "objects_tested", val);
+ else if (strcmp(name, "n_ban_re_test") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "regexps_tested", val);
+ else if (strcmp(name, "n_ban_dups") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "duplicate", val);
+ }
+#endif
+#if HAVE_VARNISH_V4 || HAVE_VARNISH_V5
+ if (conf->collect_ban) {
+ if (strcmp(name, "bans") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "total", val);
+ else if (strcmp(name, "bans_added") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "added", val);
+ else if (strcmp(name, "bans_obj") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "obj", val);
+ else if (strcmp(name, "bans_req") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "req", val);
+ else if (strcmp(name, "bans_completed") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "completed", val);
+ else if (strcmp(name, "bans_deleted") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "deleted", val);
+ else if (strcmp(name, "bans_tested") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "tested", val);
+ else if (strcmp(name, "bans_dups") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "duplicate", val);
+ else if (strcmp(name, "bans_tested") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "tested", val);
+ else if (strcmp(name, "bans_lurker_contention") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "lurker_contention", val);
+ else if (strcmp(name, "bans_lurker_obj_killed") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "lurker_obj_killed", val);
+ else if (strcmp(name, "bans_lurker_tested") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "lurker_tested", val);
+ else if (strcmp(name, "bans_lurker_tests_tested") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "lurker_tests_tested", val);
+ else if (strcmp(name, "bans_obj_killed") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "obj_killed", val);
+ else if (strcmp(name, "bans_persisted_bytes") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_bytes",
+ "persisted_bytes", val);
+ else if (strcmp(name, "bans_persisted_fragmentation") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_bytes",
+ "persisted_fragmentation", val);
+ else if (strcmp(name, "bans_tests_tested") == 0)
+ return varnish_submit_derive(conf->instance, "ban", "total_operations",
+ "tests_tested", val);
+ }
+#endif
+
+ if (conf->collect_session) {
+ if (strcmp(name, "sess_closed") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "total_operations", "closed", val);
+ else if (strcmp(name, "sess_pipeline") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "total_operations", "pipeline", val);
+ else if (strcmp(name, "sess_readahead") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "total_operations", "readahead", val);
+ else if (strcmp(name, "sess_conn") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "total_operations", "accepted", val);
+ else if (strcmp(name, "sess_drop") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "total_operations", "dropped", val);
+ else if (strcmp(name, "sess_fail") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "total_operations", "failed", val);
+ else if (strcmp(name, "sess_pipe_overflow") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "total_operations", "overflow", val);
+ else if (strcmp(name, "sess_queued") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "total_operations", "queued", val);
+ else if (strcmp(name, "sess_linger") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "total_operations", "linger", val);
+ else if (strcmp(name, "sess_herd") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "total_operations", "herd", val);
+#if HAVE_VARNISH_V4 || HAVE_VARNISH_V5
+ else if (strcmp(name, "sess_closed_err") == 0)
+ return varnish_submit_derive(conf->instance, "session",
+ "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);
+#endif
+ }
+
+ if (conf->collect_shm) {
+ if (strcmp(name, "shm_records") == 0)
+ return varnish_submit_derive(conf->instance, "shm", "total_operations",
+ "records", val);
+ else if (strcmp(name, "shm_writes") == 0)
+ return varnish_submit_derive(conf->instance, "shm", "total_operations",
+ "writes", val);
+ else if (strcmp(name, "shm_flushes") == 0)
+ return varnish_submit_derive(conf->instance, "shm", "total_operations",
+ "flushes", val);
+ else if (strcmp(name, "shm_cont") == 0)
+ return varnish_submit_derive(conf->instance, "shm", "total_operations",
+ "contention", val);
+ else if (strcmp(name, "shm_cycles") == 0)
+ return varnish_submit_derive(conf->instance, "shm", "total_operations",
+ "cycles", val);
+ }
+
+ if (conf->collect_sms) {
+ if (strcmp(name, "sms_nreq") == 0)
+ return varnish_submit_derive(conf->instance, "sms", "total_requests",
+ "allocator", val);
+ else if (strcmp(name, "sms_nobj") == 0)
+ return varnish_submit_gauge(conf->instance, "sms", "requests",
+ "outstanding", val);
+ else if (strcmp(name, "sms_nbytes") == 0)
+ return varnish_submit_gauge(conf->instance, "sms", "bytes", "outstanding",
+ val);
+ else if (strcmp(name, "sms_balloc") == 0)
+ return varnish_submit_derive(conf->instance, "sms", "total_bytes",
+ "allocated", val);
+ else if (strcmp(name, "sms_bfree") == 0)
+ return varnish_submit_derive(conf->instance, "sms", "total_bytes", "free",
+ val);
+ }
+
+ if (conf->collect_struct) {
+ if (strcmp(name, "n_sess_mem") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "current_sessions",
+ "sess_mem", val);
+ else if (strcmp(name, "n_sess") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "current_sessions",
+ "sess", val);
+ else if (strcmp(name, "n_object") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "objects", "object",
+ val);
+ else if (strcmp(name, "n_vampireobject") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "objects",
+ "vampireobject", val);
+ else if (strcmp(name, "n_objectcore") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "objects",
+ "objectcore", val);
+ else if (strcmp(name, "n_waitinglist") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "objects",
+ "waitinglist", val);
+ else if (strcmp(name, "n_objecthead") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "objects",
+ "objecthead", val);
+ else if (strcmp(name, "n_smf") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "objects", "smf",
+ val);
+ else if (strcmp(name, "n_smf_frag") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "objects",
+ "smf_frag", val);
+ else if (strcmp(name, "n_smf_large") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "objects",
+ "smf_large", val);
+ else if (strcmp(name, "n_vbe_conn") == 0)
+ return varnish_submit_gauge(conf->instance, "struct", "objects",
+ "vbe_conn", val);
+ }
+
+ if (conf->collect_totals) {
+ if (strcmp(name, "s_sess") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_sessions",
+ "sessions", val);
+ else if (strcmp(name, "s_req") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_requests",
+ "requests", val);
+ else if (strcmp(name, "s_pipe") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_operations",
+ "pipe", val);
+ else if (strcmp(name, "s_pass") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_operations",
+ "pass", val);
+ else if (strcmp(name, "s_fetch") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_operations",
+ "fetches", val);
+ else if (strcmp(name, "s_synth") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "synth", val);
+ else if (strcmp(name, "s_req_hdrbytes") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "req_header", val);
+ else if (strcmp(name, "s_req_bodybytes") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "req_body", val);
+ else if (strcmp(name, "s_req_protobytes") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "req_proto", val);
+ else if (strcmp(name, "s_resp_hdrbytes") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "resp_header", val);
+ else if (strcmp(name, "s_resp_bodybytes") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "resp_body", val);
+ else if (strcmp(name, "s_resp_protobytes") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "resp_proto", val);
+ else if (strcmp(name, "s_pipe_hdrbytes") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "pipe_header", val);
+ else if (strcmp(name, "s_pipe_in") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "pipe_in", val);
+ else if (strcmp(name, "s_pipe_out") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "pipe_out", val);
+ else if (strcmp(name, "n_purges") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_operations",
+ "purges", val);
+ else if (strcmp(name, "s_hdrbytes") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "header-bytes", val);
+ else if (strcmp(name, "s_bodybytes") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "body-bytes", val);
+ else if (strcmp(name, "n_gzip") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_operations",
+ "gzip", val);
+ else if (strcmp(name, "n_gunzip") == 0)
+ return varnish_submit_derive(conf->instance, "totals", "total_operations",
+ "gunzip", val);
+ }
+
+ if (conf->collect_uptime) {
+ if (strcmp(name, "uptime") == 0)
+ return varnish_submit_gauge(conf->instance, "uptime", "uptime",
+ "client_uptime", val);
+ }
+
+ if (conf->collect_vcl) {
+ if (strcmp(name, "n_vcl") == 0)
+ return varnish_submit_gauge(conf->instance, "vcl", "vcl", "total_vcl",
+ val);
+ else if (strcmp(name, "n_vcl_avail") == 0)
+ return varnish_submit_gauge(conf->instance, "vcl", "vcl", "avail_vcl",
+ val);
+ else if (strcmp(name, "n_vcl_discard") == 0)
+ return varnish_submit_gauge(conf->instance, "vcl", "vcl", "discarded_vcl",
+ val);
+ else if (strcmp(name, "vmods") == 0)
+ return varnish_submit_gauge(conf->instance, "vcl", "objects", "vmod",
+ val);
+ }
+
+ if (conf->collect_workers) {
+ if (strcmp(name, "threads") == 0)
+ return varnish_submit_gauge(conf->instance, "workers", "threads",
+ "worker", val);
+ else if (strcmp(name, "threads_created") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_threads",
+ "created", val);
+ else if (strcmp(name, "threads_failed") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_threads",
+ "failed", val);
+ else if (strcmp(name, "threads_limited") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_threads",
+ "limited", val);
+ else if (strcmp(name, "threads_destroyed") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_threads",
+ "dropped", val);
+ else if (strcmp(name, "thread_queue_len") == 0)
+ return varnish_submit_gauge(conf->instance, "workers", "queue_length",
+ "threads", val);
+ else if (strcmp(name, "n_wrk") == 0)
+ return varnish_submit_gauge(conf->instance, "workers", "threads",
+ "worker", val);
+ else if (strcmp(name, "n_wrk_create") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_threads",
+ "created", val);
+ else if (strcmp(name, "n_wrk_failed") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_threads",
+ "failed", val);
+ else if (strcmp(name, "n_wrk_max") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_threads",
+ "limited", val);
+ else if (strcmp(name, "n_wrk_drop") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_threads",
+ "dropped", val);
+ else if (strcmp(name, "n_wrk_queue") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_requests",
+ "queued", val);
+ else if (strcmp(name, "n_wrk_overflow") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_requests",
+ "overflowed", val);
+ else if (strcmp(name, "n_wrk_queued") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_requests",
+ "queued", val);
+ else if (strcmp(name, "n_wrk_lqueue") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "total_requests",
+ "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);
+ else if (strcmp(name, "busy_killed") == 0)
+ return varnish_submit_derive(conf->instance, "workers", "http_requests",
+ "busy_killed", val);
+#endif
+ }
+
+#if HAVE_VARNISH_V4 || HAVE_VARNISH_V5
+ if (conf->collect_vsm) {
+ if (strcmp(name, "vsm_free") == 0)
+ return varnish_submit_gauge(conf->instance, "vsm", "bytes", "free", val);
+ else if (strcmp(name, "vsm_used") == 0)
+ return varnish_submit_gauge(conf->instance, "vsm", "bytes", "used", val);
+ else if (strcmp(name, "vsm_cooling") == 0)
+ return varnish_submit_gauge(conf->instance, "vsm", "bytes", "cooling",
+ val);
+ else if (strcmp(name, "vsm_overflow") == 0)
+ return varnish_submit_gauge(conf->instance, "vsm", "bytes", "overflow",
+ val);
+ else if (strcmp(name, "vsm_overflowed") == 0)
+ return varnish_submit_derive(conf->instance, "vsm", "total_bytes",
+ "overflowed", val);
+ }
+
+ if (conf->collect_vbe) {
+ /* @TODO figure out the collectd type for bitmap
+ if (strcmp(name, "happy") == 0)
+ return varnish_submit_derive(conf->instance, "vbe",
+ "bitmap", "happy_hprobes", val);
+ */
+ if (strcmp(name, "bereq_hdrbytes") == 0)
+ 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);
+ else if (strcmp(name, "bereq_protobytes") == 0)
+ 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);
+ else if (strcmp(name, "beresp_bodybytes") == 0)
+ 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);
+ else if (strcmp(name, "pipe_hdrbytes") == 0)
+ 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);
+ else if (strcmp(name, "pipe_in") == 0)
+ 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);
+ else if (strcmp(name, "req") == 0)
+ return varnish_submit_derive(conf->instance, "vbe", "http_requests",
+ "b_reqs", val);
+ }
+
+ /* All Stevedores support these counters */
+ if (conf->collect_sma || conf->collect_smf || conf->collect_mse) {
+
+ char category[4];
+ if (conf->collect_sma)
+ strncpy(category, "sma", 4);
+ else if (conf->collect_smf)
+ strncpy(category, "smf", 4);
+ else
+ strncpy(category, "mse", 4);
+
+ if (strcmp(name, "c_req") == 0)
+ 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);
+ else if (strcmp(name, "c_bytes") == 0)
+ 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);
+ else if (strcmp(name, "g_alloc") == 0)
+ 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);
+ else if (strcmp(name, "g_space") == 0)
+ return varnish_submit_gauge(conf->instance, category, "bytes",
+ "bytes_available", val);
+ }
+
+ /* No SMA specific counters */
+
+ 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);
+ }
+
+ if (conf->collect_mgt) {
+ if (strcmp(name, "uptime") == 0)
+ 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);
+ else if (strcmp(name, "child_exit") == 0)
+ 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);
+ else if (strcmp(name, "child_died") == 0)
+ 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);
+ else if (strcmp(name, "child_panic") == 0)
+ 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);
+ else if (strcmp(name, "destroy") == 0)
+ 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);
+ }
+
+ if (conf->collect_mempool) {
+ if (strcmp(name, "live") == 0)
+ return varnish_submit_gauge(conf->instance, "mempool", "objects",
+ "in_use", val);
+ else if (strcmp(name, "pool") == 0)
+ return varnish_submit_gauge(conf->instance, "mempool", "objects",
+ "in_pool", val);
+ else if (strcmp(name, "sz_wanted") == 0)
+ return varnish_submit_gauge(conf->instance, "mempool", "bytes",
+ "size_requested", val);
+ else if (strcmp(name, "sz_actual") == 0)
+ return varnish_submit_gauge(conf->instance, "mempool", "bytes",
+ "size_allocated", val);
+ else if (strcmp(name, "allocs") == 0)
+ return varnish_submit_derive(conf->instance, "mempool",
+ "total_operations", "allocations", val);
+ else if (strcmp(name, "frees") == 0)
+ 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);
+ else if (strcmp(name, "timeout") == 0)
+ 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);
+ else if (strcmp(name, "surplus") == 0)
+ 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);
+ }
+
+ if (conf->collect_mse) {
+ if (strcmp(name, "c_full") == 0)
+ 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);
+ else if (strcmp(name, "c_expanded") == 0)
+ 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);
+ else if (strcmp(name, "c_bytes") == 0)
+ 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);
+ else if (strcmp(name, "g_fo_alloc") == 0)
+ 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);
+ else if (strcmp(name, "g_membuf_alloc") == 0)
+ 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);
+ else if (strcmp(name, "g_bans_bytes") == 0)
+ 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);
+ else if (strcmp(name, "g_bans_persisted") == 0)
+ 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);
+
+ /* mse seg */
+ else if (strcmp(name, "g_journal_bytes") == 0)
+ 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);
+
+ /* mse segagg */
+ else if (strcmp(name, "g_bigspace") == 0)
+ 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);
+ else if (strcmp(name, "g_sparenode") == 0)
+ 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);
+ else if (strcmp(name, "g_extnode") == 0)
+ 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);
+ else if (strcmp(name, "c_pruneloop") == 0)
+ return varnish_submit_derive(conf->instance, "mse_segagg",
+ "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);
+ else if (strcmp(name, "c_spared") == 0)
+ return varnish_submit_derive(conf->instance, "mse_segagg",
+ "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);
+ else if (strcmp(name, "c_nuked") == 0)
+ return varnish_submit_derive(conf->instance, "mse_segagg",
+ "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);
+ }
+
+#endif
+
+ return 0;
+
+} /* }}} static int varnish_monitor */
+#else /* if HAVE_VARNISH_V2 */
+static void varnish_monitor(const user_config_t *conf, /* {{{ */
+ const c_varnish_stats_t *stats) {
+ if (conf->collect_cache) {
+ /* Cache hits */
+ varnish_submit_derive(conf->instance, "cache", "cache_result", "hit",
+ stats->cache_hit);
+ /* Cache misses */
+ varnish_submit_derive(conf->instance, "cache", "cache_result", "miss",
+ stats->cache_miss);
+ /* Cache hits for pass */
+ varnish_submit_derive(conf->instance, "cache", "cache_result", "hitpass",
+ stats->cache_hitpass);
+ }
+
+ if (conf->collect_connections) {
+ /* Client connections accepted */
+ varnish_submit_derive(conf->instance, "connections", "connections",
+ "accepted", stats->client_conn);
+ /* Connection dropped, no sess */
+ varnish_submit_derive(conf->instance, "connections", "connections",
+ "dropped", stats->client_drop);
+ /* Client requests received */
+ varnish_submit_derive(conf->instance, "connections", "connections",
+ "received", stats->client_req);
+ }
+
+ if (conf->collect_esi) {
+ /* ESI parse errors (unlock) */
+ varnish_submit_derive(conf->instance, "esi", "total_operations", "error",
+ stats->esi_errors);
+ /* Objects ESI parsed (unlock) */
+ varnish_submit_derive(conf->instance, "esi", "total_operations", "parsed",
+ stats->esi_parse);
+ }
+
+ if (conf->collect_backend) {
+ /* Backend conn. success */
+ varnish_submit_derive(conf->instance, "backend", "connections", "success",
+ stats->backend_conn);
+ /* Backend conn. not attempted */
+ varnish_submit_derive(conf->instance, "backend", "connections",
+ "not-attempted", stats->backend_unhealthy);
+ /* Backend conn. too many */
+ varnish_submit_derive(conf->instance, "backend", "connections", "too-many",
+ stats->backend_busy);
+ /* Backend conn. failures */
+ varnish_submit_derive(conf->instance, "backend", "connections", "failures",
+ stats->backend_fail);
+ /* Backend conn. reuses */
+ varnish_submit_derive(conf->instance, "backend", "connections", "reuses",
+ stats->backend_reuse);
+ /* Backend conn. was closed */
+ varnish_submit_derive(conf->instance, "backend", "connections",
+ "was-closed", stats->backend_toolate);
+ /* Backend conn. recycles */
+ varnish_submit_derive(conf->instance, "backend", "connections", "recycled",
+ stats->backend_recycle);
+ /* Backend conn. unused */
+ varnish_submit_derive(conf->instance, "backend", "connections", "unused",
+ stats->backend_unused);
+ /* Backend requests mades */
+ varnish_submit_derive(conf->instance, "backend", "http_requests",
+ "requests", stats->backend_req);
+ /* N backends */
+ varnish_submit_gauge(conf->instance, "backend", "backends", "n_backends",
+ stats->n_backend);
+ }
+
+ if (conf->collect_fetch) {
+ /* Fetch head */
+ varnish_submit_derive(conf->instance, "fetch", "http_requests", "head",
+ stats->fetch_head);
+ /* Fetch with length */
+ varnish_submit_derive(conf->instance, "fetch", "http_requests", "length",
+ stats->fetch_length);
+ /* Fetch chunked */
+ varnish_submit_derive(conf->instance, "fetch", "http_requests", "chunked",
+ stats->fetch_chunked);
+ /* Fetch EOF */
+ varnish_submit_derive(conf->instance, "fetch", "http_requests", "eof",
+ stats->fetch_eof);
+ /* Fetch bad headers */
+ varnish_submit_derive(conf->instance, "fetch", "http_requests",
+ "bad_headers", stats->fetch_bad);
+ /* Fetch wanted close */
+ varnish_submit_derive(conf->instance, "fetch", "http_requests", "close",
+ stats->fetch_close);
+ /* Fetch pre HTTP/1.1 closed */
+ varnish_submit_derive(conf->instance, "fetch", "http_requests", "oldhttp",
+ stats->fetch_oldhttp);
+ /* Fetch zero len */
+ varnish_submit_derive(conf->instance, "fetch", "http_requests", "zero",
+ stats->fetch_zero);
+ /* Fetch failed */
+ varnish_submit_derive(conf->instance, "fetch", "http_requests", "failed",
+ stats->fetch_failed);
+ }
+
+ if (conf->collect_hcb) {
+ /* HCB Lookups without lock */
+ varnish_submit_derive(conf->instance, "hcb", "cache_operation",
+ "lookup_nolock", stats->hcb_nolock);
+ /* HCB Lookups with lock */
+ varnish_submit_derive(conf->instance, "hcb", "cache_operation",
+ "lookup_lock", stats->hcb_lock);
+ /* HCB Inserts */
+ varnish_submit_derive(conf->instance, "hcb", "cache_operation", "insert",
+ stats->hcb_insert);
+ }
+
+ if (conf->collect_objects) {
+ /* N expired objects */
+ varnish_submit_derive(conf->instance, "objects", "total_objects", "expired",
+ stats->n_expired);
+ /* N LRU nuked objects */
+ varnish_submit_derive(conf->instance, "objects", "total_objects",
+ "lru_nuked", stats->n_lru_nuked);
+ /* N LRU saved objects */
+ varnish_submit_derive(conf->instance, "objects", "total_objects",
+ "lru_saved", stats->n_lru_saved);
+ /* N LRU moved objects */
+ varnish_submit_derive(conf->instance, "objects", "total_objects",
+ "lru_moved", stats->n_lru_moved);
+ /* N objects on deathrow */
+ varnish_submit_derive(conf->instance, "objects", "total_objects",
+ "deathrow", stats->n_deathrow);
+ /* HTTP header overflows */
+ varnish_submit_derive(conf->instance, "objects", "total_objects",
+ "header_overflow", stats->losthdr);
+ /* Objects sent with sendfile */
+ varnish_submit_derive(conf->instance, "objects", "total_objects",
+ "sent_sendfile", stats->n_objsendfile);
+ /* Objects sent with write */
+ varnish_submit_derive(conf->instance, "objects", "total_objects",
+ "sent_write", stats->n_objwrite);
+ /* Objects overflowing workspace */
+ varnish_submit_derive(conf->instance, "objects", "total_objects",
+ "workspace_overflow", stats->n_objoverflow);
+ }
+
+ if (conf->collect_purge) {
+ /* N total active purges */
+ varnish_submit_derive(conf->instance, "purge", "total_operations", "total",
+ stats->n_purge);
+ /* N new purges added */
+ varnish_submit_derive(conf->instance, "purge", "total_operations", "added",
+ stats->n_purge_add);
+ /* N old purges deleted */
+ varnish_submit_derive(conf->instance, "purge", "total_operations",
+ "deleted", stats->n_purge_retire);
+ /* N objects tested */
+ varnish_submit_derive(conf->instance, "purge", "total_operations",
+ "objects_tested", stats->n_purge_obj_test);
+ /* N regexps tested against */
+ varnish_submit_derive(conf->instance, "purge", "total_operations",
+ "regexps_tested", stats->n_purge_re_test);
+ /* N duplicate purges removed */
+ varnish_submit_derive(conf->instance, "purge", "total_operations",
+ "duplicate", stats->n_purge_dups);
+ }
+
+ if (conf->collect_session) {
+ /* Session Closed */
+ varnish_submit_derive(conf->instance, "session", "total_operations",
+ "closed", stats->sess_closed);
+ /* Session Pipeline */
+ varnish_submit_derive(conf->instance, "session", "total_operations",
+ "pipeline", stats->sess_pipeline);
+ /* Session Read Ahead */
+ varnish_submit_derive(conf->instance, "session", "total_operations",
+ "readahead", stats->sess_readahead);
+ /* Session Linger */
+ varnish_submit_derive(conf->instance, "session", "total_operations",
+ "linger", stats->sess_linger);
+ /* Session herd */
+ varnish_submit_derive(conf->instance, "session", "total_operations", "herd",
+ stats->sess_herd);
+ }
+
+ if (conf->collect_shm) {
+ /* SHM records */
+ varnish_submit_derive(conf->instance, "shm", "total_operations", "records",
+ stats->shm_records);
+ /* SHM writes */
+ varnish_submit_derive(conf->instance, "shm", "total_operations", "writes",
+ stats->shm_writes);
+ /* SHM flushes due to overflow */
+ varnish_submit_derive(conf->instance, "shm", "total_operations", "flushes",
+ stats->shm_flushes);
+ /* SHM MTX contention */
+ varnish_submit_derive(conf->instance, "shm", "total_operations",
+ "contention", stats->shm_cont);
+ /* SHM cycles through buffer */
+ varnish_submit_derive(conf->instance, "shm", "total_operations", "cycles",
+ stats->shm_cycles);
+ }
+
+ if (conf->collect_sm) {
+ /* allocator requests */
+ varnish_submit_derive(conf->instance, "sm", "total_requests", "nreq",
+ stats->sm_nreq);
+ /* outstanding allocations */
+ varnish_submit_gauge(conf->instance, "sm", "requests", "outstanding",
+ stats->sm_nobj);
+ /* bytes allocated */
+ varnish_submit_derive(conf->instance, "sm", "total_bytes", "allocated",
+ stats->sm_balloc);
+ /* bytes free */
+ varnish_submit_derive(conf->instance, "sm", "total_bytes", "free",
+ stats->sm_bfree);
+ }
+
+ if (conf->collect_sma) {
+ /* SMA allocator requests */
+ varnish_submit_derive(conf->instance, "sma", "total_requests", "nreq",
+ stats->sma_nreq);
+ /* SMA outstanding allocations */
+ varnish_submit_gauge(conf->instance, "sma", "requests", "outstanding",
+ stats->sma_nobj);
+ /* SMA outstanding bytes */
+ varnish_submit_gauge(conf->instance, "sma", "bytes", "outstanding",
+ stats->sma_nbytes);
+ /* SMA bytes allocated */
+ varnish_submit_derive(conf->instance, "sma", "total_bytes", "allocated",
+ stats->sma_balloc);
+ /* SMA bytes free */
+ varnish_submit_derive(conf->instance, "sma", "total_bytes", "free",
+ stats->sma_bfree);
+ }
+
+ if (conf->collect_sms) {
+ /* SMS allocator requests */
+ varnish_submit_derive(conf->instance, "sms", "total_requests", "allocator",
+ stats->sms_nreq);
+ /* SMS outstanding allocations */
+ varnish_submit_gauge(conf->instance, "sms", "requests", "outstanding",
+ stats->sms_nobj);
+ /* SMS outstanding bytes */
+ varnish_submit_gauge(conf->instance, "sms", "bytes", "outstanding",
+ stats->sms_nbytes);
+ /* SMS bytes allocated */
+ varnish_submit_derive(conf->instance, "sms", "total_bytes", "allocated",
+ stats->sms_balloc);
+ /* SMS bytes freed */
+ varnish_submit_derive(conf->instance, "sms", "total_bytes", "free",
+ stats->sms_bfree);
+ }
+
+ if (conf->collect_struct) {
+ /* N struct sess_mem */
+ varnish_submit_gauge(conf->instance, "struct", "current_sessions",
+ "sess_mem", stats->n_sess_mem);
+ /* N struct sess */
+ varnish_submit_gauge(conf->instance, "struct", "current_sessions", "sess",
+ stats->n_sess);
+ /* N struct object */
+ varnish_submit_gauge(conf->instance, "struct", "objects", "object",
+ stats->n_object);
+ /* N struct objecthead */
+ varnish_submit_gauge(conf->instance, "struct", "objects", "objecthead",
+ stats->n_objecthead);
+ /* N struct smf */
+ varnish_submit_gauge(conf->instance, "struct", "objects", "smf",
+ stats->n_smf);
+ /* N small free smf */
+ varnish_submit_gauge(conf->instance, "struct", "objects", "smf_frag",
+ stats->n_smf_frag);
+ /* N large free smf */
+ varnish_submit_gauge(conf->instance, "struct", "objects", "smf_large",
+ stats->n_smf_large);
+ /* N struct vbe_conn */
+ varnish_submit_gauge(conf->instance, "struct", "objects", "vbe_conn",
+ stats->n_vbe_conn);
+ }
+
+ if (conf->collect_totals) {
+ /* Total Sessions */
+ varnish_submit_derive(conf->instance, "totals", "total_sessions",
+ "sessions", stats->s_sess);
+ /* Total Requests */
+ varnish_submit_derive(conf->instance, "totals", "total_requests",
+ "requests", stats->s_req);
+ /* Total pipe */
+ varnish_submit_derive(conf->instance, "totals", "total_operations", "pipe",
+ stats->s_pipe);
+ /* Total pass */
+ varnish_submit_derive(conf->instance, "totals", "total_operations", "pass",
+ stats->s_pass);
+ /* Total fetch */
+ varnish_submit_derive(conf->instance, "totals", "total_operations",
+ "fetches", stats->s_fetch);
+ /* Total header bytes */
+ varnish_submit_derive(conf->instance, "totals", "total_bytes",
+ "header-bytes", stats->s_hdrbytes);
+ /* Total body byte */
+ varnish_submit_derive(conf->instance, "totals", "total_bytes", "body-bytes",
+ stats->s_bodybytes);
+ }
+
+ if (conf->collect_vcl) {
+ /* N vcl total */
+ varnish_submit_gauge(conf->instance, "vcl", "vcl", "total_vcl",
+ stats->n_vcl);
+ /* N vcl available */
+ varnish_submit_gauge(conf->instance, "vcl", "vcl", "avail_vcl",
+ stats->n_vcl_avail);
+ /* N vcl discarded */
+ varnish_submit_gauge(conf->instance, "vcl", "vcl", "discarded_vcl",
+ stats->n_vcl_discard);
+ }
+
+ if (conf->collect_workers) {
+ /* worker threads */
+ varnish_submit_gauge(conf->instance, "workers", "threads", "worker",
+ stats->n_wrk);
+ /* worker threads created */
+ varnish_submit_derive(conf->instance, "workers", "total_threads", "created",
+ stats->n_wrk_create);
+ /* worker threads not created */
+ varnish_submit_derive(conf->instance, "workers", "total_threads", "failed",
+ stats->n_wrk_failed);
+ /* worker threads limited */
+ varnish_submit_derive(conf->instance, "workers", "total_threads", "limited",
+ stats->n_wrk_max);
+ /* dropped work requests */
+ varnish_submit_derive(conf->instance, "workers", "total_threads", "dropped",
+ stats->n_wrk_drop);
+ /* queued work requests */
+ varnish_submit_derive(conf->instance, "workers", "total_requests", "queued",
+ stats->n_wrk_queue);
+ /* overflowed work requests */
+ varnish_submit_derive(conf->instance, "workers", "total_requests",
+ "overflowed", stats->n_wrk_overflow);
+ }
+
+} /* }}} void varnish_monitor */
+#endif
+
+#if HAVE_VARNISH_V3 || HAVE_VARNISH_V4 || HAVE_VARNISH_V5
+static int varnish_read(user_data_t *ud) /* {{{ */