session 114 src/dps8/uvutil.c static void accessPromote (access_client * session); session 115 src/dps8/uvutil.c static void accessReject (access_client * session); session 256 src/dps8/uvutil.c access_client * session = (access_client *)client->data; session 257 src/dps8/uvutil.c return session->closing ? NULL : session->owner; session 330 src/dps8/uvutil.c access_client * session = (access_client *)stream->data; session 331 src/dps8/uvutil.c uv_access * access = session ? session->owner : NULL; session 334 src/dps8/uvutil.c if (session && !session->closing) session 337 src/dps8/uvutil.c else if (nread > 0 && session && !session->closing && access) session 339 src/dps8/uvutil.c if (session->telnetp) session 341 src/dps8/uvutil.c telnet_recv (session->telnetp, buf->base, (size_t) nread); session 349 src/dps8/uvutil.c session->promoted_in_read = false; session 374 src/dps8/uvutil.c access_client * session = (access_client *)client->data; session 375 src/dps8/uvutil.c if (session && !session->closing && session->state != access_active) session 428 src/dps8/uvutil.c access_client * session = (access_client *)client->data; session 429 src/dps8/uvutil.c if (!session || session->closing || !data || datalen <= 0 || session 432 src/dps8/uvutil.c if (session->telnetp) session 433 src/dps8/uvutil.c telnet_send (session->telnetp, data, (size_t) datalen); session 456 src/dps8/uvutil.c static void accessLogon (access_client * session, unsigned char * buf, session 459 src/dps8/uvutil.c uv_access * access = session->owner; session 460 src/dps8/uvutil.c uv_tcp_t * client = session->client; session 465 src/dps8/uvutil.c if (session->pwPos >= sizeof (session->pwBuffer) - 1) session 476 src/dps8/uvutil.c session->pwPos -= 1; session 477 src/dps8/uvutil.c session->pwBuffer[session->pwPos] = 0; session 484 src/dps8/uvutil.c session->pwBuffer[session->pwPos] = 0; session 497 src/dps8/uvutil.c session->pwBuffer[session->pwPos++] = (char) kar; session 498 src/dps8/uvutil.c session->pwBuffer[session->pwPos] = 0; session 510 src/dps8/uvutil.c if (session->pwPos > 0) session 511 src/dps8/uvutil.c session->pwPos -= 1; session 512 src/dps8/uvutil.c session->pwBuffer[session->pwPos] = 0; session 519 src/dps8/uvutil.c session->pwBuffer[session->pwPos] = 0; session 534 src/dps8/uvutil.c memcpy (cpy, session->pwBuffer, session->pwPos); session 535 src/dps8/uvutil.c cpy[session->pwPos] = 0; session 538 src/dps8/uvutil.c session->pwPos = 0; session 539 src/dps8/uvutil.c memset (session->pwBuffer, 0, sizeof (session->pwBuffer)); session 543 src/dps8/uvutil.c fname = (char *)accessPeerText (&session->peer, ip, sizeof (ip)); session 575 src/dps8/uvutil.c if (session->closing) session 577 src/dps8/uvutil.c accessPromote (session); session 578 src/dps8/uvutil.c session->promoted_in_read = true; session 579 src/dps8/uvutil.c if (access->connected && !session->closing) session 595 src/dps8/uvutil.c accessRateFailure (&session->peer); session 596 src/dps8/uvutil.c accessReject (session); session 601 src/dps8/uvutil.c static void accessRelease (access_client * session) session 603 src/dps8/uvutil.c if (--session->close_refs != 0) session 606 src/dps8/uvutil.c while (*link && *link != session) session 608 src/dps8/uvutil.c if (*link == session) session 609 src/dps8/uvutil.c *link = session->next; session 610 src/dps8/uvutil.c if (session->pending) session 613 src/dps8/uvutil.c session->pending = false; session 615 src/dps8/uvutil.c memset (session->pwBuffer, 0, sizeof (session->pwBuffer)); session 616 src/dps8/uvutil.c FREE (session); session 621 src/dps8/uvutil.c access_client * session = (access_client *)handle->data; session 622 src/dps8/uvutil.c accessRelease (session); session 627 src/dps8/uvutil.c access_client * session = (access_client *)stream->data; session 628 src/dps8/uvutil.c if (session) session 632 src/dps8/uvutil.c if (session->telnetp) session 633 src/dps8/uvutil.c telnet_free (session->telnetp); session 634 src/dps8/uvutil.c accessRelease (session); session 643 src/dps8/uvutil.c access_client * session = (access_client *)stream->data; session 644 src/dps8/uvutil.c if (!session || session->closing) session 646 src/dps8/uvutil.c uv_access * access = session->owner; session 649 src/dps8/uvutil.c pname = accessPeerText (&session->peer, ip, sizeof (ip)); session 654 src/dps8/uvutil.c if (session->admitted) session 661 src/dps8/uvutil.c session->closing = true; session 662 src/dps8/uvutil.c session->state = access_closing; session 663 src/dps8/uvutil.c if (session->telnetp) session 664 src/dps8/uvutil.c libtelnet_set_invalid (session->telnetp); session 673 src/dps8/uvutil.c if (session->timer_inited) session 675 src/dps8/uvutil.c uv_timer_stop (&session->timer); session 676 src/dps8/uvutil.c uv_close ((uv_handle_t *)&session->timer, accessTimerCloseCallback); session 683 src/dps8/uvutil.c access_client * session = (access_client *)timer->data; session 684 src/dps8/uvutil.c if (session && !session->closing) session 685 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)session->client); session 688 src/dps8/uvutil.c static void accessReject (access_client * session) session 690 src/dps8/uvutil.c if (session->closing) session 692 src/dps8/uvutil.c session->state = access_rejected; session 693 src/dps8/uvutil.c (void)uv_read_stop ((uv_stream_t *)session->client); session 695 src/dps8/uvutil.c uv_timer_stop (&session->timer); session 696 src/dps8/uvutil.c if (uv_timer_start (&session->timer, accessTimerCallback, session 698 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)session->client); session 760 src/dps8/uvutil.c static void accessPromote (access_client * session) session 762 src/dps8/uvutil.c uv_access * access = session->owner; session 764 src/dps8/uvutil.c uv_timer_stop (&session->timer); session 765 src/dps8/uvutil.c if (session->pending) session 767 src/dps8/uvutil.c session->pending = false; session 770 src/dps8/uvutil.c session->state = access_active; session 774 src/dps8/uvutil.c access->client = session->client; session 776 src/dps8/uvutil.c if (old && old != session->client) session 786 src/dps8/uvutil.c for (access_client * session = access_sessions; session; ) session 788 src/dps8/uvutil.c access_client * next = session->next; session 789 src/dps8/uvutil.c if (session->owner == access && !session->closing) session 790 src/dps8/uvutil.c accessCloseConnection ((uv_stream_t *)session->client); session 791 src/dps8/uvutil.c session = next; session 798 src/dps8/uvutil.c for (access_client * session = access_sessions; session; session 799 src/dps8/uvutil.c session = session->next) session 856 src/dps8/uvutil.c access_client * session = (access_client *)client->data; session 857 src/dps8/uvutil.c if (!session || session->closing || session->promoted_in_read) session 859 src/dps8/uvutil.c if (session->state == access_active && session 860 src/dps8/uvutil.c session->owner->client == client) session 861 src/dps8/uvutil.c accessProcessInput (session->owner, buf, nread); session 862 src/dps8/uvutil.c else if (session->state == access_authenticating) session 863 src/dps8/uvutil.c accessLogon (session, buf, nread); session 1045 src/dps8/uvutil.c access_client * session = (access_client *)calloc (1, sizeof (*session)); session 1046 src/dps8/uvutil.c if (!session) session 1051 src/dps8/uvutil.c session->owner = access; session 1052 src/dps8/uvutil.c session->client = client; session 1053 src/dps8/uvutil.c session->close_refs = 1; session 1054 src/dps8/uvutil.c session->state = access_authenticating; session 1055 src/dps8/uvutil.c client->data = session; session 1056 src/dps8/uvutil.c if (!accessGetPeer (client, &session->peer)) session 1065 src/dps8/uvutil.c accessPendingFor (NULL, &session->peer) >= session 1067 src/dps8/uvutil.c !accessRatePermits (&session->peer))) session 1073 src/dps8/uvutil.c int timer_rc = uv_timer_init (access->loop, &session->timer); session 1079 src/dps8/uvutil.c session->timer_inited = true; session 1080 src/dps8/uvutil.c session->timer.data = session; session 1081 src/dps8/uvutil.c session->close_refs ++; session 1082 src/dps8/uvutil.c session->admitted = true; session 1083 src/dps8/uvutil.c session->next = access_sessions; session 1084 src/dps8/uvutil.c access_sessions = session; session 1087 src/dps8/uvutil.c session->pending = true; session 1089 src/dps8/uvutil.c if (uv_timer_start (&session->timer, accessTimerCallback, session 1099 src/dps8/uvutil.c const char * pname = accessPeerText (&session->peer, ip, sizeof (ip)); session 1107 src/dps8/uvutil.c session->telnetp = accessTelnetConnect (client); session 1108 src/dps8/uvutil.c if (!session->telnetp) session 1115 src/dps8/uvutil.c if (session->closing) session 1119 src/dps8/uvutil.c accessPromote (session); session 1120 src/dps8/uvutil.c if (access->connected && !session->closing) session 1125 src/dps8/uvutil.c if (!session->closing)