Lines Matching full:incoming
120 } incoming, outgoing;
186 uint16_t *p = (uint16_t *)incoming.buffer;
188 incoming.length = recv(the_socket, incoming.buffer, MAX_PACKET_LENGTH, 0);
189 if (incoming.length == -1) {
198 if ((incoming.length != ACK_SIZE && incoming.length < MESSAGE_HEADER_SIZE)
200 ntohs(p[1]) != incoming.length || p[2] != local_tunnel) {
204 if (incoming.length == ACK_SIZE) {
205 incoming.message = ACK;
207 incoming.message = ntohs(p[9]);
214 if (incoming.message != ACK) {
230 if (incoming.message != ACK) {
242 while (incoming.length >= offset + ATTRIBUTE_HEADER_SIZE) {
243 struct attribute *p = (struct attribute *)&incoming.buffer[offset];
249 if (length < 0 || offset > incoming.length) {
424 switch(incoming.message) {
487 "%d)", messages[incoming.message], local_session);
496 if (incoming.message == ACK) {
500 messages[incoming.message]);
517 "Sending CDN", messages[incoming.message], session);
531 if (incoming.message > MESSAGE_MAX || !messages[incoming.message]) {
533 incoming.message);
536 messages[incoming.message]);
