Lines Matching defs:dae

101 	struct module_ipcp_dae		*dae;
285 	struct module_ipcp_dae	*dae;
308 	TAILQ_FOREACH(dae, &self->daes, next) {
309 		if ((sock = socket(dae->nas_addr.sin4.sin_family,
311 			log_warn("%s: could not start dae: socket()", __func__);
314 		if (connect(sock, (struct sockaddr *)&dae->nas_addr,
315 		    dae->nas_addr.sin4.sin_len) == -1) {
316 			log_warn("%s: could not start dae: connect()",
320 		dae->sock = sock;
321 		event_set(&dae->ev_sock, sock, EV_READ | EV_PERSIST,
322 		    ipcp_dae_on_event, dae);
323 		event_add(&dae->ev_sock, NULL);
324 		evtimer_set(&dae->ev_reqs, ipcp_dae_send_pending_requests, dae);
334 	struct module_ipcp_dae		*dae;
338 	TAILQ_FOREACH(dae, &self->daes, next) {
339 		if (dae->sock >= 0) {
340 			event_del(&dae->ev_sock);
341 			close(dae->sock);
342 			dae->sock = -1;
344 		if (evtimer_pending(&dae->ev_reqs, NULL))
345 			event_del(&dae->ev_reqs);
357 	struct module_ipcp_dae		*dae, *daet;
368 	TAILQ_FOREACH_SAFE(dae, &self->daes, next, daet) {
369 		if (dae->sock >= 0) {
370 			event_del(&dae->ev_sock);
371 			close(dae->sock);
373 		free(dae);
390 	struct module_ipcp_dae	 dae, *dae0;
506 	} else if (strcmp(name, "dae") == 0) {
507 		memset(&dae, 0, sizeof(dae));
508 		dae.sock = -1;
515 		SYNTAX_ASSERT(i < argc, "no address[:port] for dae server");
518 		    &dae.nas_addr, sizeof(dae.nas_addr)) == -1) {
520 			    "failed to parse dae server's address, %s",
524 		if (ntohs(dae.nas_addr.sin4.sin_port) == 0)
525 			dae.nas_addr.sin4.sin_port =
528 		SYNTAX_ASSERT(i < argc, "no secret for dae server");
529 		if (strlcpy(dae.secret, argv[i++], sizeof(dae.secret)) >=
530 		    sizeof(dae.secret)) {
532 			    "dae server's secret must be < %d bytes",
533 			    (int)sizeof(dae.secret) - 1);
537 			strlcpy(dae.nas_id, argv[i++], sizeof(dae.nas_id));
544 		*dae0 = dae;
669 			if (assign->dae == NULL)
1050 	struct module_ipcp_dae	*dae;
1180 		TAILQ_FOREACH(dae, &self->daes, next) {
1181 			if (dae->nas_id[0] == '\0' ||
1182 			    strcmp(dae->nas_id, assign->nas_id) == 0)
1185 		assign->dae = dae;
1402 	struct module_ipcp_dae	*dae;
1443 			TAILQ_FOREACH(dae, &self->daes, next) {
1444 				if (dae->nas_id[0] == '\0' ||
1445 				    strcmp(dae->nas_id, assigned->nas_id) == 0)
1448 			assigned->dae = dae;
1602 	if (assign->dae == NULL)
1631 		    assign->dae->secret);
1633 		TAILQ_INSERT_TAIL(&assign->dae->reqs, assign, dae_next);
1637 		if (assign->dae->ninflight >= RADIUSD_IPCP_DAE_MAX_INFLIGHT)
1641 		    &assign->dae->nas_addr, buf, sizeof(buf)));
1644 	if (radius_send(assign->dae->sock, assign->dae_reqpkt, 0) < 0)
1652 		assign->dae->ninflight++;
1666 		    &assign->dae->nas_addr, buf, sizeof(buf)));
1668 			module_imsg_compose(assign->dae->ipcp->base, IMSG_NG,
1678 	struct module_ipcp_dae	*dae = ctx;
1679 	struct module_ipcp	*self = dae->ipcp;
1693 	if ((radres = radius_recv(dae->sock, 0)) == NULL) {
1697 		    (struct sockaddr *)&dae->nas_addr, buf, sizeof(buf)));
1700 	TAILQ_FOREACH(assign, &dae->reqs, dae_next) {
1707 		    &dae->nas_addr, buf, sizeof(buf)), radius_get_id(radres));
1712 	if ((radius_check_response_authenticator(radres, dae->secret)) != 0) {
1715 			(struct sockaddr *)&dae->nas_addr, buf,
1735 		    &dae->nas_addr, buf, sizeof(buf)), cause);
1740 		    &dae->nas_addr, buf, sizeof(buf)), cause);
1745 		    &dae->nas_addr, buf, sizeof(buf)));
1773 	if (assign->dae != NULL) {
1775 			TAILQ_REMOVE(&assign->dae->reqs, assign, dae_next);
1777 			assign->dae->ninflight--;
1778 			if (!evtimer_pending(&assign->dae->ev_reqs, NULL))
1779 				evtimer_add(&assign->dae->ev_reqs, &zero);
1797 	struct module_ipcp_dae	*dae = ctx;
1798 	struct module_ipcp	*self = dae->ipcp;
1803 	TAILQ_FOREACH_SAFE(assign, &dae->reqs, dae_next, assignt) {
1804 		if (dae->ninflight >= RADIUSD_IPCP_DAE_MAX_INFLIGHT)