Lines Matching refs:incoming
119 } incoming, outgoing;
185 uint16_t *p = (uint16_t *)incoming.buffer;
187 incoming.length = recv(the_socket, incoming.buffer, MAX_PACKET_LENGTH, 0);
188 if (incoming.length == -1) {
197 if ((incoming.length != ACK_SIZE && incoming.length < MESSAGE_HEADER_SIZE)
199 ntohs(p[1]) != incoming.length || p[2] != local_tunnel) {
203 if (incoming.length == ACK_SIZE) {
204 incoming.message = ACK;
206 incoming.message = ntohs(p[9]);
213 if (incoming.message != ACK) {
229 if (incoming.message != ACK) {
241 while (incoming.length >= offset + ATTRIBUTE_HEADER_SIZE) {
242 struct attribute *p = (struct attribute *)&incoming.buffer[offset];
248 if (length < 0 || offset > incoming.length) {
423 switch(incoming.message) {
486 "%d)", messages[incoming.message], local_session);
495 if (incoming.message == ACK) {
499 messages[incoming.message]);
516 "Sending CDN", messages[incoming.message], session);
530 if (incoming.message > MESSAGE_MAX || !messages[incoming.message]) {
532 incoming.message);
535 messages[incoming.message]);
