85 	struct connection *conn;  in tcpp_client_newconn()  local
125 	conn = malloc(sizeof(*conn));  in tcpp_client_newconn()
126 	if (conn == NULL)  in tcpp_client_newconn()
128 	bzero(conn, sizeof(*conn));  in tcpp_client_newconn()
129 	conn->conn_magic = CONNECTION_MAGIC;  in tcpp_client_newconn()
130 	conn->conn_fd = fd;  in tcpp_client_newconn()
131 	conn->conn_header.th_magic = TCPP_MAGIC;  in tcpp_client_newconn()
132 	conn->conn_header.th_len = payload_len;  in tcpp_client_newconn()
133 	tcpp_header_encode(&conn->conn_header);  in tcpp_client_newconn()
135 	EV_SET(&kev, fd, EVFILT_WRITE, EV_ADD, 0, 0, conn);  in tcpp_client_newconn()
140 	return (conn);  in tcpp_client_newconn()
144 tcpp_client_closeconn(struct connection *conn)  in tcpp_client_closeconn()  argument
147 	close(conn->conn_fd);  in tcpp_client_closeconn()
148 	bzero(conn, sizeof(*conn));  in tcpp_client_closeconn()
149 	free(conn);  in tcpp_client_closeconn()
156 	struct connection *conn;  in tcpp_client_handleconn()  local
160 	conn = kev->udata;  in tcpp_client_handleconn()
161 	if (conn->conn_magic != CONNECTION_MAGIC)  in tcpp_client_handleconn()
164 	if (conn->conn_header_sent < sizeof(conn->conn_header)) {  in tcpp_client_handleconn()
165 		header_left = sizeof(conn->conn_header) -  in tcpp_client_handleconn()
166 		    conn->conn_header_sent;  in tcpp_client_handleconn()
167 		iov[0].iov_base = ((u_char *)&conn->conn_header) +  in tcpp_client_handleconn()
168 		    conn->conn_header_sent;  in tcpp_client_handleconn()
172 		len = writev(conn->conn_fd, iov, 2);  in tcpp_client_handleconn()
174 			tcpp_client_closeconn(conn);  in tcpp_client_handleconn()
178 			tcpp_client_closeconn(conn);  in tcpp_client_handleconn()
183 			conn->conn_data_sent += (len - header_left);  in tcpp_client_handleconn()
184 			conn->conn_header_sent += header_left;  in tcpp_client_handleconn()
186 			conn->conn_header_sent += len;  in tcpp_client_handleconn()
188 		len = write(conn->conn_fd, buffer, min(sizeof(buffer),  in tcpp_client_handleconn()
189 		    payload_len - conn->conn_data_sent));  in tcpp_client_handleconn()
191 			tcpp_client_closeconn(conn);  in tcpp_client_handleconn()
195 			tcpp_client_closeconn(conn);  in tcpp_client_handleconn()
199 		conn->conn_data_sent += len;  in tcpp_client_handleconn()
201 	if (conn->conn_data_sent >= payload_len) {  in tcpp_client_handleconn()
205 		tcpp_client_closeconn(conn);  in tcpp_client_handleconn()