Lines Matching refs:e

54 static void _logger_log_text(logentry *e, const entry_details *d, const void *entry, va_list ap) {  in _logger_log_text()  argument
56 int total = vsnprintf((char *) e->data, reqlen, d->format, ap); in _logger_log_text()
60 e->size = total + 1; // null byte in _logger_log_text()
63 static void _logger_log_evictions(logentry *e, const entry_details *d, const void *entry, va_list a… in _logger_log_evictions() argument
65 struct logentry_eviction *le = (struct logentry_eviction *) e->data; in _logger_log_evictions()
74 e->size = sizeof(struct logentry_eviction) + le->nkey; in _logger_log_evictions()
77 static void _logger_log_ext_write(logentry *e, const entry_details *d, const void *entry, va_list a… in _logger_log_ext_write() argument
81 struct logentry_ext_write *le = (struct logentry_ext_write *) e->data; in _logger_log_ext_write()
89 e->size = sizeof(struct logentry_ext_write) + le->nkey; in _logger_log_ext_write()
96 static void _logger_log_item_get(logentry *e, const entry_details *d, const void *entry, va_list ap… in _logger_log_item_get() argument
104 struct logentry_item_get *le = (struct logentry_item_get *) e->data; in _logger_log_item_get()
111 e->size = sizeof(struct logentry_item_get) + nkey; in _logger_log_item_get()
114 static void _logger_log_item_store(logentry *e, const entry_details *d, const void *entry, va_list … in _logger_log_item_store() argument
124 struct logentry_item_store *le = (struct logentry_item_store *) e->data; in _logger_log_item_store()
137 e->size = sizeof(struct logentry_item_store) + nkey; in _logger_log_item_store()
140 static void _logger_log_item_deleted(logentry *e, const entry_details *d, const void *entry, va_lis… in _logger_log_item_deleted() argument
143 struct logentry_deletion *le = (struct logentry_deletion *) e->data; in _logger_log_item_deleted()
149 e->size = sizeof(struct logentry_deletion) + le->nkey; in _logger_log_item_deleted()
152 static void _logger_log_conn_event(logentry *e, const entry_details *d, const void *entry, va_list … in _logger_log_conn_event() argument
159 struct logentry_conn_event *le = (struct logentry_conn_event *) e->data; in _logger_log_conn_event()
165 e->size = sizeof(struct logentry_conn_event); in _logger_log_conn_event()
207 static int _logger_parse_text(logentry *e, char *scratch) { in _logger_parse_text() argument
209 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, in _logger_parse_text()
210 (unsigned long long) e->gid, (char *) e->data); in _logger_parse_text()
213 static int _logger_parse_ise(logentry *e, char *scratch) { in _logger_parse_ise() argument
217 struct logentry_item_store *le = (struct logentry_item_store *) e->data; in _logger_parse_ise()
229 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_ise()
235 static int _logger_parse_ige(logentry *e, char *scratch) { in _logger_parse_ige() argument
237 struct logentry_item_get *le = (struct logentry_item_get *) e->data; in _logger_parse_ige()
245 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_ige()
251 static int _logger_parse_ee(logentry *e, char *scratch) { in _logger_parse_ee() argument
254 struct logentry_eviction *le = (struct logentry_eviction *) e->data; in _logger_parse_ee()
258 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_ee()
266 static int _logger_parse_ide(logentry *e, char *scratch) { in _logger_parse_ide() argument
272 struct logentry_deletion *le = (struct logentry_deletion *) e->data; in _logger_parse_ide()
280 (int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_ide()
287 static int _logger_parse_extw(logentry *e, char *scratch) { in _logger_parse_extw() argument
290 struct logentry_ext_write *le = (struct logentry_ext_write *) e->data; in _logger_parse_extw()
294 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_extw()
302 static int _logger_parse_cne(logentry *e, char *scratch) { in _logger_parse_cne() argument
306 struct logentry_conn_event *le = (struct logentry_conn_event *) e->data; in _logger_parse_cne()
313 (long long int) e->tv.tv_sec, (int) e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_cne()
319 static int _logger_parse_cce(logentry *e, char *scratch) { in _logger_parse_cce() argument
323 struct logentry_conn_event *le = (struct logentry_conn_event *) e->data; in _logger_parse_cce()
331 (long long int) e->tv.tv_sec, (int) e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_cce()
343 static void _logger_log_proxy_req(logentry *e, const entry_details *d, const void *entry, va_list a… in _logger_log_proxy_req() argument
356 struct logentry_proxy_req *le = (void *)e->data; in _logger_log_proxy_req()
391 e->size = sizeof(struct logentry_proxy_req) + reqlen + dlen + le->be_namelen + le->be_portlen; in _logger_log_proxy_req()
394 static int _logger_parse_prx_req(logentry *e, char *scratch) { in _logger_parse_prx_req() argument
396 struct logentry_proxy_req *le = (void *)e->data; in _logger_parse_prx_req()
400 (long long int) e->tv.tv_sec, (int) e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_prx_req()
410 static void _logger_log_proxy_errbe(logentry *e, const entry_details *d, const void *entry, va_list… in _logger_log_proxy_errbe() argument
420 struct logentry_proxy_errbe *le = (void *)e->data; in _logger_log_proxy_errbe()
450 e->size = sizeof(struct logentry_proxy_errbe) + (data - le->data); in _logger_log_proxy_errbe()
453 static int _logger_parse_prx_errbe(logentry *e, char *scratch) { in _logger_parse_prx_errbe() argument
456 struct logentry_proxy_errbe *le = (void *)e->data; in _logger_parse_prx_errbe()
472 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_prx_errbe()
478 (long long int)e->tv.tv_sec, (int)e->tv.tv_usec, (unsigned long long) e->gid, in _logger_parse_prx_errbe()
642 static enum logger_parse_entry_ret logger_thread_parse_entry(logentry *e, struct logger_stats *ls, in logger_thread_parse_entry() argument
645 const entry_details *d = &default_entries[e->event]; in logger_thread_parse_entry()
647 total = d->parse_cb(e, scratch); in logger_thread_parse_entry()
660 static void logger_thread_write_entry(logentry *e, struct logger_stats *ls, in logger_thread_write_entry() argument
667 if (w == NULL || (e->eflags & w->eflags) == 0 || (e->gid < w->min_gid)) in logger_thread_write_entry()
728 logentry *e; in logger_thread_read() local
742 e = (logentry *) (data + pos); in logger_thread_read()
743 ret = logger_thread_parse_entry(e, ls, scratch, &scratch_len); in logger_thread_read()
748 logger_thread_write_entry(e, ls, scratch, scratch_len); in logger_thread_read()
750 pos += sizeof(logentry) + e->size + e->pad; in logger_thread_read()
1025 logentry *e; in logger_log() local
1032 e = (logentry *) bipbuf_request(buf, (sizeof(logentry) + reqlen)); in logger_log()
1033 if (e == NULL) { in logger_log()
1038 e->event = event; in logger_log()
1039 e->pad = 0; in logger_log()
1040 e->gid = logger_get_gid(); in logger_log()
1044 e->eflags = d->eflags; in logger_log()
1048 gettimeofday(&e->tv, NULL); in logger_log()
1051 d->log_cb(e, d, entry, ap); in logger_log()
1056 if (sizeof(logentry) + e->size % 8 != 0) { in logger_log()
1057 e->pad = 8 - (sizeof(logentry) + e->size % 8); in logger_log()
1062 if (bipbuf_push(buf, (sizeof(logentry) + e->size + e->pad)) == 0) { in logger_log()
1069 (sizeof(logentry) + e->size)); in logger_log()