Lines Matching refs:be
252 if (bew->be != NULL) { in mcplib_backend_wrap_gc()
253 mcp_backend_t *be = bew->be; in mcplib_backend_wrap_gc() local
259 assert(be->transferred); in mcplib_backend_wrap_gc()
262 proxy_event_thread_t *e = be->be[0].event_thread; in mcplib_backend_wrap_gc()
264 STAILQ_INSERT_TAIL(&e->beconn_head_in, be, beconn_next); in mcplib_backend_wrap_gc()
302 mcp_backend_label_t *be = lua_newuserdatauv(L, sizeof(mcp_backend_label_t), 0); in mcplib_backend() local
303 memset(be, 0, sizeof(*be)); in mcplib_backend()
308 memcpy(&be->tunables, &ctx->tunables, sizeof(be->tunables)); in mcplib_backend()
309 be->conncount = 1; // one connection per backend as default. in mcplib_backend()
338 be->tunables.tcp_keepalive = lua_toboolean(L, -1); in mcplib_backend()
343 be->tunables.use_tls = lua_toboolean(L, -1); in mcplib_backend()
354 be->tunables.backend_failure_limit = limit; in mcplib_backend()
365 be->tunables.backend_depth_limit = limit; in mcplib_backend()
374 be->tunables.connect.tv_sec = secondsi; in mcplib_backend()
375 be->tunables.connect.tv_usec = MICROSECONDS(subseconds); in mcplib_backend()
381 be->tunables.retry.tv_sec = in mcplib_backend()
387 be->tunables.retry.tv_sec = in mcplib_backend()
397 be->tunables.retry.tv_sec = secondsi; in mcplib_backend()
398 be->tunables.retry.tv_usec = MICROSECONDS(subseconds); in mcplib_backend()
407 be->tunables.read.tv_sec = secondsi; in mcplib_backend()
408 be->tunables.read.tv_usec = MICROSECONDS(subseconds); in mcplib_backend()
414 be->tunables.down = down; in mcplib_backend()
423 be->tunables.flap.tv_sec = secondsi; in mcplib_backend()
424 be->tunables.flap.tv_usec = MICROSECONDS(subseconds); in mcplib_backend()
433 be->tunables.flap_backoff_ramp = ramp; in mcplib_backend()
440 be->tunables.flap_backoff_max = max; in mcplib_backend()
454 be->conncount = c; in mcplib_backend()
479 memcpy(be->label, label, llen); in mcplib_backend()
480 be->label[llen] = '\0'; in mcplib_backend()
481 memcpy(be->name, name, nlen); in mcplib_backend()
482 be->name[nlen] = '\0'; in mcplib_backend()
483 memcpy(be->port, port, plen); in mcplib_backend()
484 be->port[plen] = '\0'; in mcplib_backend()
485 be->llen = llen; in mcplib_backend()
503 if (strncmp(be_orig->be->name, bel->name, MAX_NAMELEN) == 0 in _mcplib_backend_checkcache()
504 && strncmp(be_orig->be->port, bel->port, MAX_PORTLEN) == 0 in _mcplib_backend_checkcache()
505 && be_orig->be->conncount == bel->conncount in _mcplib_backend_checkcache()
506 && memcmp(&be_orig->be->tunables, &bel->tunables, sizeof(bel->tunables)) == 0) { in _mcplib_backend_checkcache()
528 …mcp_backend_t *be = calloc(1, sizeof(mcp_backend_t) + sizeof(struct mcp_backendconn_s) * bel->conn… in _mcplib_make_backendconn() local
529 if (be == NULL) { in _mcplib_make_backendconn()
533 bew->be = be; in _mcplib_make_backendconn()
535 strncpy(be->name, bel->name, MAX_NAMELEN+1); in _mcplib_make_backendconn()
536 strncpy(be->port, bel->port, MAX_PORTLEN+1); in _mcplib_make_backendconn()
537 strncpy(be->label, bel->label, MAX_LABELLEN+1); in _mcplib_make_backendconn()
538 memcpy(&be->tunables, &bel->tunables, sizeof(bel->tunables)); in _mcplib_make_backendconn()
539 be->conncount = bel->conncount; in _mcplib_make_backendconn()
540 STAILQ_INIT(&be->io_head); in _mcplib_make_backendconn()
543 struct mcp_backendconn_s *bec = &be->be[x]; in _mcplib_make_backendconn()
544 bec->be_parent = be; in _mcplib_make_backendconn()
581 if (be->tunables.use_tls && !ctx->tls_ctx) { in _mcplib_make_backendconn()
591 STAILQ_INSERT_TAIL(&e->beconn_head_in, be, beconn_next); in _mcplib_make_backendconn()
698 mcp_backend_t *be = p->pool[x-1].be; in _mcplib_pool_dist() local
707 lua_pushstring(L, be->name); in _mcplib_pool_dist()
709 lua_pushstring(L, be->port); in _mcplib_pool_dist()
779 s->be = bew->be; // unwrap the backend connection for direct ref. in _mcplib_pool_make_be_loop()
780 bew->be->use_io_thread = p->use_iothread; in _mcplib_pool_make_be_loop()
985 return pp->pool[lookup].be; in mcplib_pool_proxy_call_helper()