Lines Matching defs:kdc_socket
66 struct kdc_socket {
94 static void kdc_send_handler(struct kdc_socket *kdc_socket)
96 while (kdc_socket->send_queue) {
97 struct kdc_reply *rep = kdc_socket->send_queue;
101 status = socket_sendto(kdc_socket->sock, &rep->packet, &sendlen,
110 DLIST_REMOVE(kdc_socket->send_queue, rep);
114 if (kdc_socket->send_queue == NULL) {
115 EVENT_FD_NOT_WRITEABLE(kdc_socket->fde);
123 static void kdc_recv_handler(struct kdc_socket *kdc_socket)
126 TALLOC_CTX *tmp_ctx = talloc_new(kdc_socket);
135 status = socket_pending(kdc_socket->sock, &dsize);
148 status = socket_recvfrom(kdc_socket->sock, blob.data, blob.length, &nread,
159 my_addr = socket_get_my_addr(kdc_socket->sock, tmp_ctx);
167 ret = kdc_socket->process(kdc_socket->kdc,
179 rep = talloc(kdc_socket, struct kdc_reply);
194 DLIST_ADD_END(kdc_socket->send_queue, rep, struct kdc_reply *);
195 EVENT_FD_WRITEABLE(kdc_socket->fde);
205 struct kdc_socket *kdc_socket = talloc_get_type(private_data, struct kdc_socket);
207 kdc_send_handler(kdc_socket);
210 kdc_recv_handler(kdc_socket);
419 struct kdc_socket *kdc_socket;
420 struct kdc_socket *kpasswd_socket;
424 kdc_socket = talloc(kdc, struct kdc_socket);
425 NT_STATUS_HAVE_NO_MEMORY(kdc_socket);
427 kpasswd_socket = talloc(kdc, struct kdc_socket);
430 status = socket_create("ip", SOCKET_TYPE_DGRAM, &kdc_socket->sock, 0);
432 talloc_free(kdc_socket);
442 kdc_socket->kdc = kdc;
443 kdc_socket->send_queue = NULL;
444 kdc_socket->process = kdc_process;
446 talloc_steal(kdc_socket, kdc_socket->sock);
448 kdc_socket->fde = event_add_fd(kdc->task->event_ctx, kdc,
449 socket_get_fd(kdc_socket->sock), EVENT_FD_READ,
450 kdc_socket_handler, kdc_socket);
452 kdc_address = socket_address_from_strings(kdc_socket, kdc_socket->sock->backend_name,
456 status = socket_listen(kdc_socket->sock, kdc_address, 0, 0);
460 talloc_free(kdc_socket);
492 talloc_free(kdc_socket);
506 talloc_free(kdc_socket);
520 talloc_free(kdc_socket);