Lines Matching defs:tcp_set
172 setup_ssl(struct xfrd_tcp_pipeline* tp, struct xfrd_tcp_set* tcp_set,
175 if (!tcp_set->ssl_ctx) {
181 tp->ssl = SSL_new((SSL_CTX*)tcp_set->ssl_ctx);
260 struct xfrd_tcp_set* tcp_set = region_alloc(region,
262 memset(tcp_set, 0, sizeof(struct xfrd_tcp_set));
263 tcp_set->tcp_state = NULL;
264 tcp_set->tcp_max = tcp_max;
265 tcp_set->tcp_pipeline = tcp_pipeline;
266 tcp_set->tcp_count = 0;
267 tcp_set->tcp_waiting_first = 0;
268 tcp_set->tcp_waiting_last = 0;
271 tcp_set->ssl_ctx = create_ssl_context();
272 if (tcp_set->ssl_ctx == NULL)
276 tcp_set->ssl_ctx, tls_cert_bundle, NULL) != 1) {
284 tcp_set->tcp_state = region_alloc(region,
285 sizeof(*tcp_set->tcp_state)*tcp_set->tcp_max);
286 for(i=0; i<tcp_set->tcp_max; i++)
287 tcp_set->tcp_state[i] = xfrd_tcp_pipeline_create(region,
289 tcp_set->pipetree = rbtree_create(region, &xfrd_pipe_cmp);
290 return tcp_set;
708 (void)rbtree_delete(xfrd->tcp_set->pipetree, &tp->key.node);
710 (void)rbtree_insert(xfrd->tcp_set->pipetree, &tp->key.node);
738 xfrd_tcp_pipe_release(xfrd->tcp_set, tp, conn);
746 tv.tv_sec = xfrd->tcp_set->tcp_timeout;
1656 xfrd_tcp_release(xfrd->tcp_set, zone);
1660 xfrd_tcp_release(xfrd->tcp_set, zone);
1665 xfrd_tcp_release(xfrd->tcp_set, zone);
1675 xfrd_tcp_release(xfrd->tcp_set, zone);
1758 (void)rbtree_delete(xfrd->tcp_set->pipetree, &tp->key.node);