Lines Matching refs:le

65     struct logentry_eviction *le = (struct logentry_eviction *) e->data;  in _logger_log_evictions()  local
67 …le->exptime = (it->exptime > 0) ? (long long int)(it->exptime - current_time) : (long long int) -1; in _logger_log_evictions()
68 le->latime = current_time - it->time; in _logger_log_evictions()
69 le->it_flags = it->it_flags; in _logger_log_evictions()
70 le->nkey = it->nkey; in _logger_log_evictions()
71 le->nbytes = it->nbytes; in _logger_log_evictions()
72 le->clsid = ITEM_clsid(it); in _logger_log_evictions()
73 memcpy(le->key, ITEM_key(it), it->nkey); in _logger_log_evictions()
74 e->size = sizeof(struct logentry_eviction) + le->nkey; in _logger_log_evictions()
81 struct logentry_ext_write *le = (struct logentry_ext_write *) e->data; in _logger_log_ext_write() local
82 …le->exptime = (it->exptime > 0) ? (long long int)(it->exptime - current_time) : (long long int) -1; in _logger_log_ext_write()
83 le->latime = current_time - it->time; in _logger_log_ext_write()
84 le->it_flags = it->it_flags; in _logger_log_ext_write()
85 le->nkey = it->nkey; in _logger_log_ext_write()
86 le->clsid = ITEM_clsid(it); in _logger_log_ext_write()
87 le->bucket = (uint8_t)ew_bucket; in _logger_log_ext_write()
88 memcpy(le->key, ITEM_key(it), it->nkey); in _logger_log_ext_write()
89 e->size = sizeof(struct logentry_ext_write) + le->nkey; in _logger_log_ext_write()
104 struct logentry_item_get *le = (struct logentry_item_get *) e->data; in _logger_log_item_get() local
105 le->was_found = was_found; in _logger_log_item_get()
106 le->nkey = nkey; in _logger_log_item_get()
107 le->nbytes = nbytes; in _logger_log_item_get()
108 le->clsid = clsid; in _logger_log_item_get()
109 memcpy(le->key, key, nkey); in _logger_log_item_get()
110 le->sfd = sfd; in _logger_log_item_get()
124 struct logentry_item_store *le = (struct logentry_item_store *) e->data; in _logger_log_item_store() local
125 le->status = status; in _logger_log_item_store()
126 le->cmd = comm; in _logger_log_item_store()
127 le->nkey = nkey; in _logger_log_item_store()
128 le->nbytes = nbytes; in _logger_log_item_store()
129 le->clsid = clsid; in _logger_log_item_store()
131 le->ttl = ttl - current_time; in _logger_log_item_store()
133 le->ttl = 0; in _logger_log_item_store()
135 memcpy(le->key, key, nkey); in _logger_log_item_store()
136 le->sfd = sfd; in _logger_log_item_store()
143 struct logentry_deletion *le = (struct logentry_deletion *) e->data; in _logger_log_item_deleted() local
144 le->nkey = it->nkey; in _logger_log_item_deleted()
145 le->cmd = comm; in _logger_log_item_deleted()
146 le->nbytes = it->nbytes; in _logger_log_item_deleted()
147 le->clsid = ITEM_clsid(it); in _logger_log_item_deleted()
148 memcpy(le->key, ITEM_key(it), it->nkey); in _logger_log_item_deleted()
149 e->size = sizeof(struct logentry_deletion) + le->nkey; in _logger_log_item_deleted()
159 struct logentry_conn_event *le = (struct logentry_conn_event *) e->data; in _logger_log_conn_event() local
161 memcpy(&le->addr, addr, addrlen); in _logger_log_conn_event()
162 le->sfd = sfd; in _logger_log_conn_event()
163 le->transport = transport; in _logger_log_conn_event()
164 le->reason = reason; in _logger_log_conn_event()
217 struct logentry_item_store *le = (struct logentry_item_store *) e->data; in _logger_parse_ise() local
223 if (le->cmd <= 8) in _logger_parse_ise()
224 cmd = cmd_map[le->cmd]; in _logger_parse_ise()
226 uriencode(le->key, keybuf, le->nkey, KEY_MAX_URI_ENCODED_LENGTH); in _logger_parse_ise()
230 keybuf, status_map[le->status], cmd, le->ttl, le->clsid, le->sfd, in _logger_parse_ise()
231 le->nbytes > 0 ? le->nbytes - 2 : 0); // CLRF in _logger_parse_ise()
237 struct logentry_item_get *le = (struct logentry_item_get *) e->data; in _logger_parse_ige() local
242 uriencode(le->key, keybuf, le->nkey, KEY_MAX_URI_ENCODED_LENGTH); in _logger_parse_ige()
246 keybuf, was_found_map[le->was_found], le->clsid, le->sfd, in _logger_parse_ige()
247 le->nbytes > 0 ? le->nbytes - 2 : 0); // CLRF in _logger_parse_ige()
254 struct logentry_eviction *le = (struct logentry_eviction *) e->data; in _logger_parse_ee() local
255 uriencode(le->key, keybuf, le->nkey, KEY_MAX_URI_ENCODED_LENGTH); in _logger_parse_ee()
259 keybuf, (le->it_flags & ITEM_FETCHED) ? "yes" : "no", in _logger_parse_ee()
260 (long long int)le->exptime, le->latime, le->clsid, in _logger_parse_ee()
261 le->nbytes > 0 ? le->nbytes - 2 : 0); // CLRF in _logger_parse_ee()
272 struct logentry_deletion *le = (struct logentry_deletion *) e->data; in _logger_parse_ide() local
273 uriencode(le->key, keybuf, le->nkey, KEY_MAX_URI_ENCODED_LENGTH); in _logger_parse_ide()
275 if (le->cmd <= 2) in _logger_parse_ide()
276 cmd = cmd_map[le->cmd]; in _logger_parse_ide()
281 keybuf, cmd, le->clsid, in _logger_parse_ide()
282 le->nbytes > 0 ? le->nbytes - 2 : 0); // CLRF in _logger_parse_ide()
290 struct logentry_ext_write *le = (struct logentry_ext_write *) e->data; in _logger_parse_extw() local
291 uriencode(le->key, keybuf, le->nkey, KEY_MAX_URI_ENCODED_LENGTH); in _logger_parse_extw()
295 keybuf, (le->it_flags & ITEM_FETCHED) ? "yes" : "no", in _logger_parse_extw()
296 (long long int)le->exptime, le->latime, le->clsid, le->bucket); in _logger_parse_extw()
306 struct logentry_conn_event *le = (struct logentry_conn_event *) e->data; in _logger_parse_cne() local
309 _logger_util_addr_endpoint(&le->addr, rip, sizeof(rip), &rport); in _logger_parse_cne()
314 rip, rport, transport_map[le->transport], le->sfd); in _logger_parse_cne()
323 struct logentry_conn_event *le = (struct logentry_conn_event *) e->data; in _logger_parse_cce() local
327 _logger_util_addr_endpoint(&le->addr, rip, sizeof(rip), &rport); in _logger_parse_cce()
332 rip, rport, transport_map[le->transport], in _logger_parse_cce()
333 reason_map[le->reason], le->sfd); in _logger_parse_cce()
356 struct logentry_proxy_req *le = (void *)e->data; in _logger_log_proxy_req() local
357 le->type = type; in _logger_log_proxy_req()
358 le->code = code; in _logger_log_proxy_req()
359 le->status = status; in _logger_log_proxy_req()
360 le->conn_fd = conn_fd; in _logger_log_proxy_req()
361 le->dlen = dlen; in _logger_log_proxy_req()
362 le->elapsed = elapsed; in _logger_log_proxy_req()
364 le->be_namelen = strlen(be_name); in _logger_log_proxy_req()
365 le->be_portlen = strlen(be_port); in _logger_log_proxy_req()
367 le->be_namelen = 0; in _logger_log_proxy_req()
368 le->be_portlen = 0; in _logger_log_proxy_req()
370 char *data = le->data; in _logger_log_proxy_req()
383 le->reqlen = reqlen; in _logger_log_proxy_req()
388 memcpy(data, be_name, le->be_namelen); in _logger_log_proxy_req()
389 data += le->be_namelen; in _logger_log_proxy_req()
390 memcpy(data, be_port, le->be_portlen); 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()
396 struct logentry_proxy_req *le = (void *)e->data; in _logger_parse_prx_req() local
401 le->elapsed, le->type, le->code, le->status, le->conn_fd, in _logger_parse_prx_req()
402 (int)le->be_namelen, le->data+le->reqlen+le->dlen, in _logger_parse_prx_req()
403 (int)le->be_portlen, le->data+le->reqlen+le->dlen+le->be_namelen, // fml. in _logger_parse_prx_req()
404 (int)le->dlen, le->data+le->reqlen, (int)le->reqlen, le->data in _logger_parse_prx_req()
420 struct logentry_proxy_errbe *le = (void *)e->data; in _logger_log_proxy_errbe() local
421 le->be_depth = be_depth; in _logger_log_proxy_errbe()
422 le->retry = be_retry; in _logger_log_proxy_errbe()
423 le->errlen = strlen(errmsg); in _logger_log_proxy_errbe()
425 le->be_namelen = strlen(be_name); in _logger_log_proxy_errbe()
426 le->be_portlen = strlen(be_port); in _logger_log_proxy_errbe()
430 le->be_labellen = strlen(be_label); in _logger_log_proxy_errbe()
433 le->be_rbuflen = be_rbuflen; in _logger_log_proxy_errbe()
435 le->be_rbuflen = MAX_RBUF_READ; in _logger_log_proxy_errbe()
438 char *data = le->data; in _logger_log_proxy_errbe()
439 memcpy(data, errmsg, le->errlen); in _logger_log_proxy_errbe()
440 data += le->errlen; in _logger_log_proxy_errbe()
441 memcpy(data, be_name, le->be_namelen); in _logger_log_proxy_errbe()
442 data += le->be_namelen; in _logger_log_proxy_errbe()
443 memcpy(data, be_port, le->be_portlen); in _logger_log_proxy_errbe()
444 data += le->be_portlen; in _logger_log_proxy_errbe()
445 memcpy(data, be_label, le->be_labellen); in _logger_log_proxy_errbe()
446 data += le->be_labellen; in _logger_log_proxy_errbe()
447 memcpy(data, be_rbuf, le->be_rbuflen); in _logger_log_proxy_errbe()
448 data += le->be_rbuflen; in _logger_log_proxy_errbe()
450 e->size = sizeof(struct logentry_proxy_errbe) + (data - le->data); in _logger_log_proxy_errbe()
456 struct logentry_proxy_errbe *le = (void *)e->data; in _logger_parse_prx_errbe() local
457 char *data = le->data; in _logger_parse_prx_errbe()
459 data += le->errlen; in _logger_parse_prx_errbe()
461 data += le->be_namelen; in _logger_parse_prx_errbe()
463 data += le->be_portlen; in _logger_parse_prx_errbe()
465 data += le->be_labellen; in _logger_parse_prx_errbe()
468 uriencode(be_rbuf, rbuf, le->be_rbuflen, MAX_RBUF_READ * 3); in _logger_parse_prx_errbe()
469 if (le->retry) { in _logger_parse_prx_errbe()
473 (int)le->errlen, errmsg, (int)le->be_namelen, be_name, in _logger_parse_prx_errbe()
474 (int)le->be_portlen, be_port, (int)le->be_labellen, be_label, le->retry); in _logger_parse_prx_errbe()
479 (int)le->errlen, errmsg, (int)le->be_namelen, be_name, in _logger_parse_prx_errbe()
480 (int)le->be_portlen, be_port, (int)le->be_labellen, be_label, le->be_depth, rbuf); in _logger_parse_prx_errbe()