Lines Matching refs:tcp
187 } tcp; member
819 newconn->u.tcp.addrbuf, sizeof(newconn->u.tcp.addrbuf), in accept_tcp_connection()
822 strcpy(newconn->u.tcp.addrbuf, "???"); in accept_tcp_connection()
825 p = newconn->u.tcp.addrbuf; in accept_tcp_connection()
826 end = p + sizeof(newconn->u.tcp.addrbuf); in accept_tcp_connection()
835 s, newconn->u.tcp.addrbuf); in accept_tcp_connection()
838 newconn->u.tcp.addr_s = addr_s; in accept_tcp_connection()
839 newconn->u.tcp.addrlen = addrlen; in accept_tcp_connection()
840 newconn->u.tcp.bufsiz = 1024 * 1024; in accept_tcp_connection()
841 newconn->u.tcp.buffer = malloc(newconn->u.tcp.bufsiz); in accept_tcp_connection()
842 newconn->u.tcp.start_time = time(0); in accept_tcp_connection()
858 c->u.tcp.start_time); in accept_tcp_connection()
861 || oldest_tcp->u.tcp.start_time > c->u.tcp.start_time) in accept_tcp_connection()
866 oldest_tcp->fd, oldest_tcp->u.tcp.addrbuf); in accept_tcp_connection()
871 if (newconn->u.tcp.buffer == 0) { in accept_tcp_connection()
873 newconn->u.tcp.addrbuf); in accept_tcp_connection()
879 newconn->u.tcp.offset = 0; in accept_tcp_connection()
880 newconn->u.tcp.faddr.address = &newconn->u.tcp.kaddr; in accept_tcp_connection()
881 init_addr(&newconn->u.tcp.faddr, ss2sa(&newconn->u.tcp.addr_s)); in accept_tcp_connection()
882 SG_SET(&newconn->u.tcp.sgbuf[0], newconn->u.tcp.lenbuf, 4); in accept_tcp_connection()
883 SG_SET(&newconn->u.tcp.sgbuf[1], 0, 0); in accept_tcp_connection()
893 if (conn->u.tcp.response) in kill_tcp_connection()
894 krb5_free_data(kdc_context, conn->u.tcp.response); in kill_tcp_connection()
895 if (conn->u.tcp.buffer) in kill_tcp_connection()
896 free(conn->u.tcp.buffer); in kill_tcp_connection()
951 nwrote = SOCKET_WRITEV(conn->fd, conn->u.tcp.sgp, conn->u.tcp.sgnum, in process_tcp_connection()
960 sg_buf *sgp = conn->u.tcp.sgp; in process_tcp_connection()
966 conn->u.tcp.sgp++; in process_tcp_connection()
967 conn->u.tcp.sgnum--; in process_tcp_connection()
968 if (conn->u.tcp.sgnum == 0 && nwrote != 0) in process_tcp_connection()
972 if (conn->u.tcp.sgnum == 0) { in process_tcp_connection()
987 if (conn->u.tcp.offset < 4) { in process_tcp_connection()
992 len = 4 - conn->u.tcp.offset; in process_tcp_connection()
994 conn->u.tcp.buffer + conn->u.tcp.offset, len); in process_tcp_connection()
1001 conn->u.tcp.offset += nread; in process_tcp_connection()
1002 if (conn->u.tcp.offset == 4) { in process_tcp_connection()
1003 unsigned char *p = (unsigned char *)conn->u.tcp.buffer; in process_tcp_connection()
1004 conn->u.tcp.msglen = ((p[0] << 24) in process_tcp_connection()
1008 if (conn->u.tcp.msglen > conn->u.tcp.bufsiz - 4) { in process_tcp_connection()
1012 conn->u.tcp.addrbuf, (unsigned long) conn->u.tcp.msglen, in process_tcp_connection()
1013 (unsigned long) conn->u.tcp.bufsiz - 4); in process_tcp_connection()
1015 err = make_toolong_error (&conn->u.tcp.response); in process_tcp_connection()
1030 len = conn->u.tcp.msglen - (conn->u.tcp.offset - 4); in process_tcp_connection()
1032 conn->u.tcp.buffer + conn->u.tcp.offset, len); in process_tcp_connection()
1039 conn->u.tcp.offset += nread; in process_tcp_connection()
1040 if (conn->u.tcp.offset < conn->u.tcp.msglen + 4) in process_tcp_connection()
1043 request.length = conn->u.tcp.msglen; in process_tcp_connection()
1044 request.data = conn->u.tcp.buffer + 4; in process_tcp_connection()
1045 err = dispatch(&request, &conn->u.tcp.faddr, in process_tcp_connection()
1046 &conn->u.tcp.response); in process_tcp_connection()
1052 conn->u.tcp.lenbuf[0] = 0xff & (conn->u.tcp.response->length >> 24); in process_tcp_connection()
1053 conn->u.tcp.lenbuf[1] = 0xff & (conn->u.tcp.response->length >> 16); in process_tcp_connection()
1054 conn->u.tcp.lenbuf[2] = 0xff & (conn->u.tcp.response->length >> 8); in process_tcp_connection()
1055 conn->u.tcp.lenbuf[3] = 0xff & (conn->u.tcp.response->length >> 0); in process_tcp_connection()
1056 SG_SET(&conn->u.tcp.sgbuf[1], conn->u.tcp.response->data, in process_tcp_connection()
1057 conn->u.tcp.response->length); in process_tcp_connection()
1058 conn->u.tcp.sgp = conn->u.tcp.sgbuf; in process_tcp_connection()
1059 conn->u.tcp.sgnum = 2; in process_tcp_connection()