Searched refs:dt_col (Results 1 – 2 of 2) sorted by relevance
44 sizeof(*dt_col)); in dt_collector_create()48 dt_col->send_buffer = buffer_create(dt_col->region, in dt_collector_create()113 return dt_col; in dt_collector_create()118 if(!dt_col) return; in dt_collector_destroy()128 free(dt_col); in dt_collector_destroy()134 if(!dt_col) return; in dt_collector_close()350 event_set(dt_col->cmd_event, dt_col->cmd_socket_dt, in dt_attach_events()352 if(event_base_set(dt_col->event_base, dt_col->cmd_event) != 0) in dt_attach_events()358 dt_col->inputs = xalloc_array_zero(dt_col->count, in dt_attach_events()361 dt_col->inputs[i].dt_collector = dt_col; in dt_attach_events()[all …]
61 void dt_collector_destroy(struct dt_collector* dt_col, struct nsd* nsd);63 void dt_collector_close(struct dt_collector* dt_col, struct nsd* nsd);65 void dt_collector_start(struct dt_collector* dt_col, struct nsd* nsd);