Lines Matching refs:incoming
132 } incoming, outgoing;
154 /* We are going to read a new message if incoming.expect is 0. */
155 if (!incoming.expect) {
156 incoming.length = 0;
157 incoming.expect = HEADER_SIZE;
163 length = incoming.expect - incoming.length;
164 if (incoming.length >= MAX_PACKET_LENGTH) {
168 if (incoming.expect > MAX_PACKET_LENGTH) {
169 length = MAX_PACKET_LENGTH - incoming.length;
171 length = recv(the_socket, &incoming.buffer[incoming.length], length, 0);
185 incoming.length += length;
187 /* If incoming.header is valid, check cookie and update incoming.expect. */
188 if (incoming.length == HEADER_SIZE && incoming.expect == HEADER_SIZE) {
189 if (incoming.header.cookie != MAGIC_COOKIE) {
194 incoming.expect = ntohs(incoming.header.length);
195 if (incoming.expect < HEADER_SIZE) {
202 /* Now we have a complete message. Reset incoming.expect. */
203 if (incoming.length == incoming.expect) {
204 incoming.expect = 0;
207 if (incoming.header.type == CONTROL_MESSAGE) {
211 ntohs(incoming.header.type));
263 if (incoming.length < MIN_MESSAGE_SIZE) {
267 incoming.message = ntohs(incoming.message);
268 if (incoming.message > MESSAGE_MAX || !messages[incoming.message]) {
269 log_print(DEBUG, "Received UNKNOWN %d", incoming.message);
272 if (incoming.length < lengths[incoming.message]) {
274 messages[incoming.message], incoming.length);
278 switch(incoming.message) {
281 if (incoming.sccrp.protocol_version == PROTOCOL_VERSION &&
282 ESTABLISHED(incoming.sccrp.result)) {
302 incoming.sccrq.result);
309 if (state == OCRQ && incoming.ocrp.peer == local) {
310 if (ESTABLISHED(incoming.ocrp.result)) {
311 remote = incoming.ocrp.call;
319 incoming.ocrp.result);
335 if (state == OCRP && incoming.ccrq.call == remote) {
343 if (state == OCRP && incoming.cdn.call == remote) {
353 outgoing.echorp.identifier = incoming.echorq.identifier;
360 log_print(DEBUG, "Recevied %s", messages[incoming.message]);
365 "with error", incoming.icrq.call);
367 outgoing.icrp.peer = incoming.icrq.call;
374 "with error", incoming.ocrq.call);
376 outgoing.ocrp.peer = incoming.ocrq.call;
383 log_print(DEBUG, "Received UNEXPECTED %s", messages[incoming.message]);
