chat.c revision 43919
1169689Skan/*- 2169689Skan * Copyright (c) 1998 Brian Somers <brian@Awfulhak.org> 3169689Skan * All rights reserved. 4169689Skan * 5169689Skan * Redistribution and use in source and binary forms, with or without 6169689Skan * modification, are permitted provided that the following conditions 7169689Skan * are met: 8169689Skan * 1. Redistributions of source code must retain the above copyright 9169689Skan * notice, this list of conditions and the following disclaimer. 10169689Skan * 2. Redistributions in binary form must reproduce the above copyright 11169689Skan * notice, this list of conditions and the following disclaimer in the 12169689Skan * documentation and/or other materials provided with the distribution. 13169689Skan * 14169689Skan * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 15169689Skan * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 16169689Skan * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 17169689Skan * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 18169689Skan * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 19169689Skan * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 20169689Skan * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 21169689Skan * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 22169689Skan * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 23169689Skan * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 24169689Skan * SUCH DAMAGE. 25169689Skan * 26169689Skan * $Id: chat.c,v 1.53 1999/01/28 01:56:31 brian Exp $ 27169689Skan */ 28169689Skan 29169689Skan#include <sys/param.h> 30169689Skan#include <netinet/in.h> 31169689Skan#include <netinet/in_systm.h> 32169689Skan#include <netinet/ip.h> 33169689Skan#include <sys/un.h> 34169689Skan 35169689Skan#include <errno.h> 36169689Skan#include <fcntl.h> 37169689Skan#include <paths.h> 38169689Skan#include <stdio.h> 39169689Skan#include <stdlib.h> 40169689Skan#include <string.h> 41169689Skan#include <sys/wait.h> 42169689Skan#include <termios.h> 43169689Skan#include <unistd.h> 44169689Skan 45169689Skan#include "mbuf.h" 46169689Skan#include "log.h" 47169689Skan#include "defs.h" 48169689Skan#include "timer.h" 49169689Skan#include "lqr.h" 50169689Skan#include "hdlc.h" 51169689Skan#include "throughput.h" 52169689Skan#include "fsm.h" 53169689Skan#include "lcp.h" 54169689Skan#include "ccp.h" 55169689Skan#include "link.h" 56169689Skan#include "async.h" 57169689Skan#include "descriptor.h" 58169689Skan#include "physical.h" 59169689Skan#include "chat.h" 60169689Skan#include "mp.h" 61169689Skan#include "auth.h" 62169689Skan#include "chap.h" 63169689Skan#include "slcompress.h" 64169689Skan#include "iplist.h" 65169689Skan#include "ipcp.h" 66169689Skan#include "filter.h" 67169689Skan#include "cbcp.h" 68169689Skan#include "command.h" 69169689Skan#include "datalink.h" 70169689Skan#ifndef NORADIUS 71169689Skan#include "radius.h" 72169689Skan#endif 73169689Skan#include "bundle.h" 74169689Skan 75169689Skan#define BUFLEFT(c) (sizeof (c)->buf - ((c)->bufend - (c)->buf)) 76169689Skan#define issep(c) ((c) == '\t' || (c) == ' ') 77169689Skan 78169689Skanstatic void ExecStr(struct physical *, char *, char *, int); 79169689Skanstatic char *ExpandString(struct chat *, const char *, char *, int, int); 80169689Skan 81169689Skanstatic void 82169689Skanchat_PauseTimer(void *v) 83169689Skan{ 84169689Skan struct chat *c = (struct chat *)v; 85169689Skan timer_Stop(&c->pause); 86169689Skan c->pause.load = 0; 87169689Skan} 88169689Skan 89169689Skanstatic void 90169689Skanchat_Pause(struct chat *c, u_long load) 91169689Skan{ 92169689Skan timer_Stop(&c->pause); 93169689Skan c->pause.load += load; 94169689Skan c->pause.func = chat_PauseTimer; 95169689Skan c->pause.name = "chat pause"; 96169689Skan c->pause.arg = c; 97169689Skan timer_Start(&c->pause); 98169689Skan} 99169689Skan 100169689Skanstatic void 101169689Skanchat_TimeoutTimer(void *v) 102169689Skan{ 103169689Skan struct chat *c = (struct chat *)v; 104169689Skan timer_Stop(&c->timeout); 105169689Skan c->TimedOut = 1; 106169689Skan} 107169689Skan 108169689Skanstatic void 109169689Skanchat_SetTimeout(struct chat *c) 110169689Skan{ 111169689Skan timer_Stop(&c->timeout); 112169689Skan if (c->TimeoutSec > 0) { 113169689Skan c->timeout.load = SECTICKS * c->TimeoutSec; 114169689Skan c->timeout.func = chat_TimeoutTimer; 115169689Skan c->timeout.name = "chat timeout"; 116169689Skan c->timeout.arg = c; 117169689Skan timer_Start(&c->timeout); 118169689Skan } 119169689Skan} 120169689Skan 121169689Skanstatic char * 122169689Skanchat_NextChar(char *ptr, char ch) 123169689Skan{ 124169689Skan for (; *ptr; ptr++) 125169689Skan if (*ptr == ch) 126169689Skan return ptr; 127169689Skan else if (*ptr == '\\') 128169689Skan if (*++ptr == '\0') 129169689Skan return NULL; 130169689Skan 131169689Skan return NULL; 132169689Skan} 133169689Skan 134169689Skanstatic int 135169689Skanchat_UpdateSet(struct descriptor *d, fd_set *r, fd_set *w, fd_set *e, int *n) 136169689Skan{ 137169689Skan struct chat *c = descriptor2chat(d); 138169689Skan int special, gotabort, gottimeout, needcr; 139169689Skan int TimedOut = c->TimedOut; 140169689Skan static char arg_term; /* An empty string */ 141169689Skan 142169689Skan if (c->pause.state == TIMER_RUNNING) 143169689Skan return 0; 144169689Skan 145169689Skan if (TimedOut) { 146169689Skan log_Printf(LogCHAT, "Expect timeout\n"); 147169689Skan if (c->nargptr == NULL) 148169689Skan c->state = CHAT_FAILED; 149169689Skan else { 150169689Skan /* c->state = CHAT_EXPECT; */ 151169689Skan c->argptr = &arg_term; 152169689Skan } 153169689Skan c->TimedOut = 0; 154169689Skan } 155169689Skan 156169689Skan if (c->state != CHAT_EXPECT && c->state != CHAT_SEND) 157169689Skan return 0; 158169689Skan 159169689Skan gottimeout = gotabort = 0; 160169689Skan 161169689Skan if (c->arg < c->argc && (c->arg < 0 || *c->argptr == '\0')) { 162169689Skan /* Go get the next string */ 163169689Skan if (c->arg < 0 || c->state == CHAT_SEND) 164169689Skan c->state = CHAT_EXPECT; 165169689Skan else 166169689Skan c->state = CHAT_SEND; 167169689Skan 168169689Skan special = 1; 169169689Skan while (special && (c->nargptr || c->arg < c->argc - 1)) { 170 if (c->arg < 0 || (!TimedOut && c->state == CHAT_SEND)) 171 c->nargptr = NULL; 172 173 if (c->nargptr != NULL) { 174 /* We're doing expect-send-expect.... */ 175 c->argptr = c->nargptr; 176 /* Put the '-' back in case we ever want to rerun our script */ 177 c->nargptr[-1] = '-'; 178 c->nargptr = chat_NextChar(c->nargptr, '-'); 179 if (c->nargptr != NULL) 180 *c->nargptr++ = '\0'; 181 } else { 182 int minus; 183 184 c->argptr = c->argv[++c->arg]; 185 186 if (c->state == CHAT_EXPECT) { 187 /* Look for expect-send-expect sequence */ 188 c->nargptr = c->argptr; 189 minus = 0; 190 while ((c->nargptr = chat_NextChar(c->nargptr, '-'))) { 191 c->nargptr++; 192 minus++; 193 } 194 195 if (minus % 2) 196 log_Printf(LogWARN, "chat_UpdateSet: \"%s\": Uneven number of" 197 " '-' chars, all ignored\n", c->argptr); 198 else if (minus) { 199 c->nargptr = chat_NextChar(c->argptr, '-'); 200 *c->nargptr++ = '\0'; 201 } 202 } 203 } 204 205 /* 206 * c->argptr now temporarily points into c->script (via c->argv) 207 * If it's an expect-send-expect sequence, we've just got the correct 208 * portion of that sequence. 209 */ 210 211 needcr = c->state == CHAT_SEND && *c->argptr != '!'; 212 213 /* We leave room for a potential HDLC header in the target string */ 214 ExpandString(c, c->argptr, c->exp + 2, sizeof c->exp - 2, needcr); 215 216 if (gotabort) { 217 if (c->abort.num < MAXABORTS) { 218 int len, i; 219 220 len = strlen(c->exp+2); 221 for (i = 0; i < c->abort.num; i++) 222 if (len > c->abort.string[i].len) { 223 int last; 224 225 for (last = c->abort.num; last > i; last--) { 226 c->abort.string[last].data = c->abort.string[last-1].data; 227 c->abort.string[last].len = c->abort.string[last-1].len; 228 } 229 break; 230 } 231 c->abort.string[i].len = len; 232 c->abort.string[i].data = (char *)malloc(len+1); 233 memcpy(c->abort.string[i].data, c->exp+2, len+1); 234 c->abort.num++; 235 } else 236 log_Printf(LogERROR, "chat_UpdateSet: too many abort strings\n"); 237 gotabort = 0; 238 } else if (gottimeout) { 239 c->TimeoutSec = atoi(c->exp + 2); 240 if (c->TimeoutSec <= 0) 241 c->TimeoutSec = 30; 242 gottimeout = 0; 243 } else if (c->nargptr == NULL && !strcmp(c->exp+2, "ABORT")) 244 gotabort = 1; 245 else if (c->nargptr == NULL && !strcmp(c->exp+2, "TIMEOUT")) 246 gottimeout = 1; 247 else { 248 if (c->exp[2] == '!') 249 ExecStr(c->physical, c->exp + 3, c->exp + 2, sizeof c->exp - 2); 250 251 if (c->exp[2] == '\0') { 252 /* Empty string, reparse (this may be better as a `goto start') */ 253 c->argptr = &arg_term; 254 return chat_UpdateSet(d, r, w, e, n); 255 } 256 257 special = 0; 258 } 259 } 260 261 if (special) { 262 if (gottimeout) 263 log_Printf(LogWARN, "chat_UpdateSet: TIMEOUT: Argument expected\n"); 264 else if (gotabort) 265 log_Printf(LogWARN, "chat_UpdateSet: ABORT: Argument expected\n"); 266 267 /* End of script - all ok */ 268 c->state = CHAT_DONE; 269 return 0; 270 } 271 272 /* set c->argptr to point in the right place */ 273 c->argptr = c->exp + 2; 274 c->arglen = strlen(c->argptr); 275 276 if (c->state == CHAT_EXPECT) { 277 /* We must check to see if the string's already been found ! */ 278 char *begin, *end; 279 280 end = c->bufend - c->arglen + 1; 281 if (end < c->bufstart) 282 end = c->bufstart; 283 for (begin = c->bufstart; begin < end; begin++) 284 if (!strncmp(begin, c->argptr, c->arglen)) { 285 c->bufstart = begin + c->arglen; 286 c->argptr += c->arglen; 287 c->arglen = 0; 288 /* Continue - we've already read our expect string */ 289 return chat_UpdateSet(d, r, w, e, n); 290 } 291 292 log_Printf(LogCHAT, "Expect(%d): %s\n", c->TimeoutSec, c->argptr); 293 chat_SetTimeout(c); 294 } 295 } 296 297 /* 298 * We now have c->argptr pointing at what we want to expect/send and 299 * c->state saying what we want to do... we now know what to put in 300 * the fd_set :-) 301 */ 302 303 if (c->state == CHAT_EXPECT) 304 return physical_UpdateSet(&c->physical->desc, r, NULL, e, n, 1); 305 else 306 return physical_UpdateSet(&c->physical->desc, NULL, w, e, n, 1); 307} 308 309static int 310chat_IsSet(struct descriptor *d, const fd_set *fdset) 311{ 312 struct chat *c = descriptor2chat(d); 313 return physical_IsSet(&c->physical->desc, fdset); 314} 315 316static void 317chat_UpdateLog(struct chat *c, int in) 318{ 319 if (log_IsKept(LogCHAT) || log_IsKept(LogCONNECT)) { 320 /* 321 * If a linefeed appears in the last `in' characters of `c's input 322 * buffer, output from there, all the way back to the last linefeed. 323 * This is called for every read of `in' bytes. 324 */ 325 char *ptr, *end, *stop, ch; 326 int level; 327 328 level = log_IsKept(LogCHAT) ? LogCHAT : LogCONNECT; 329 if (in == -1) 330 end = ptr = c->bufend; 331 else { 332 ptr = c->bufend - in; 333 for (end = c->bufend - 1; end >= ptr; end--) 334 if (*end == '\n') 335 break; 336 } 337 338 if (end >= ptr) { 339 for (ptr = c->bufend - (in == -1 ? 1 : in + 1); ptr >= c->bufstart; ptr--) 340 if (*ptr == '\n') 341 break; 342 ptr++; 343 stop = NULL; 344 while (stop < end) { 345 if ((stop = memchr(ptr, '\n', end - ptr)) == NULL) 346 stop = end; 347 ch = *stop; 348 *stop = '\0'; 349 if (level == LogCHAT || strstr(ptr, "CONNECT")) 350 log_Printf(level, "Received: %s\n", ptr); 351 *stop = ch; 352 ptr = stop + 1; 353 } 354 } 355 } 356} 357 358static void 359chat_Read(struct descriptor *d, struct bundle *bundle, const fd_set *fdset) 360{ 361 struct chat *c = descriptor2chat(d); 362 363 if (c->state == CHAT_EXPECT) { 364 ssize_t in; 365 char *abegin, *ebegin, *begin, *aend, *eend, *end; 366 int n; 367 368 /* 369 * XXX - should this read only 1 byte to guarantee that we don't 370 * swallow any ppp talk from the peer ? 371 */ 372 in = BUFLEFT(c); 373 if (in > sizeof c->buf / 2) 374 in = sizeof c->buf / 2; 375 376 in = physical_Read(c->physical, c->bufend, in); 377 if (in <= 0) 378 return; 379 380 /* `begin' and `end' delimit where we're going to strncmp() from */ 381 ebegin = c->bufend - c->arglen + 1; 382 eend = ebegin + in; 383 if (ebegin < c->bufstart) 384 ebegin = c->bufstart; 385 386 if (c->abort.num) { 387 abegin = c->bufend - c->abort.string[0].len + 1; 388 aend = c->bufend - c->abort.string[c->abort.num-1].len + in + 1; 389 if (abegin < c->bufstart) 390 abegin = c->bufstart; 391 } else { 392 abegin = ebegin; 393 aend = eend; 394 } 395 begin = abegin < ebegin ? abegin : ebegin; 396 end = aend < eend ? eend : aend; 397 398 c->bufend += in; 399 400 chat_UpdateLog(c, in); 401 402 if (c->bufend > c->buf + sizeof c->buf / 2) { 403 /* Shuffle our receive buffer back a bit */ 404 int chop; 405 406 for (chop = begin - c->buf; chop; chop--) 407 if (c->buf[chop] == '\n') 408 /* found some already-logged garbage to remove :-) */ 409 break; 410 411 if (!chop) 412 chop = begin - c->buf; 413 414 if (chop) { 415 char *from, *to; 416 417 to = c->buf; 418 from = to + chop; 419 while (from < c->bufend) 420 *to++ = *from++; 421 c->bufstart -= chop; 422 c->bufend -= chop; 423 begin -= chop; 424 end -= chop; 425 abegin -= chop; 426 aend -= chop; 427 ebegin -= chop; 428 eend -= chop; 429 } 430 } 431 432 for (; begin < end; begin++) 433 if (begin >= ebegin && begin < eend && 434 !strncmp(begin, c->argptr, c->arglen)) { 435 /* Got it ! */ 436 timer_Stop(&c->timeout); 437 if (memchr(begin + c->arglen - 1, '\n', 438 c->bufend - begin - c->arglen + 1) == NULL) { 439 /* force it into the log */ 440 end = c->bufend; 441 c->bufend = begin + c->arglen; 442 chat_UpdateLog(c, -1); 443 c->bufend = end; 444 } 445 c->bufstart = begin + c->arglen; 446 c->argptr += c->arglen; 447 c->arglen = 0; 448 break; 449 } else if (begin >= abegin && begin < aend) { 450 for (n = c->abort.num - 1; n >= 0; n--) { 451 if (begin + c->abort.string[n].len > c->bufend) 452 break; 453 if (!strncmp(begin, c->abort.string[n].data, 454 c->abort.string[n].len)) { 455 if (memchr(begin + c->abort.string[n].len - 1, '\n', 456 c->bufend - begin - c->abort.string[n].len + 1) == NULL) { 457 /* force it into the log */ 458 end = c->bufend; 459 c->bufend = begin + c->abort.string[n].len; 460 chat_UpdateLog(c, -1); 461 c->bufend = end; 462 } 463 c->bufstart = begin + c->abort.string[n].len; 464 c->state = CHAT_FAILED; 465 return; 466 } 467 } 468 } 469 } 470} 471 472static int 473chat_Write(struct descriptor *d, struct bundle *bundle, const fd_set *fdset) 474{ 475 struct chat *c = descriptor2chat(d); 476 int result = 0; 477 478 if (c->state == CHAT_SEND) { 479 int wrote; 480 481 if (strstr(c->argv[c->arg], "\\P")) /* Don't log the password */ 482 log_Printf(LogCHAT, "Send: %s\n", c->argv[c->arg]); 483 else { 484 int sz; 485 486 sz = c->arglen - 1; 487 while (sz >= 0 && c->argptr[sz] == '\n') 488 sz--; 489 log_Printf(LogCHAT, "Send: %.*s\n", sz + 1, c->argptr); 490 } 491 492 if (physical_IsSync(c->physical)) { 493 /* There's always room for the HDLC header */ 494 c->argptr -= 2; 495 c->arglen += 2; 496 memcpy(c->argptr, "\377\003", 2); /* Prepend HDLC header */ 497 } 498 499 wrote = physical_Write(c->physical, c->argptr, c->arglen); 500 result = wrote ? 1 : 0; 501 if (wrote == -1) { 502 if (errno != EINTR) 503 log_Printf(LogERROR, "chat_Write: %s\n", strerror(errno)); 504 if (physical_IsSync(c->physical)) { 505 c->argptr += 2; 506 c->arglen -= 2; 507 } 508 } else if (wrote < 2 && physical_IsSync(c->physical)) { 509 /* Oops - didn't even write our HDLC header ! */ 510 c->argptr += 2; 511 c->arglen -= 2; 512 } else { 513 c->argptr += wrote; 514 c->arglen -= wrote; 515 } 516 } 517 518 return result; 519} 520 521void 522chat_Init(struct chat *c, struct physical *p, const char *data, int emptybuf, 523 const char *phone) 524{ 525 c->desc.type = CHAT_DESCRIPTOR; 526 c->desc.UpdateSet = chat_UpdateSet; 527 c->desc.IsSet = chat_IsSet; 528 c->desc.Read = chat_Read; 529 c->desc.Write = chat_Write; 530 c->physical = p; 531 532 c->state = CHAT_EXPECT; 533 534 if (data == NULL) { 535 *c->script = '\0'; 536 c->argc = 0; 537 } else { 538 strncpy(c->script, data, sizeof c->script - 1); 539 c->script[sizeof c->script - 1] = '\0'; 540 c->argc = MakeArgs(c->script, c->argv, VECSIZE(c->argv)); 541 } 542 543 c->arg = -1; 544 c->argptr = NULL; 545 c->nargptr = NULL; 546 547 if (emptybuf) 548 c->bufstart = c->bufend = c->buf; 549 550 c->TimeoutSec = 30; 551 c->TimedOut = 0; 552 c->phone = phone; 553 c->abort.num = 0; 554 555 memset(&c->pause, '\0', sizeof c->pause); 556 memset(&c->timeout, '\0', sizeof c->timeout); 557} 558 559void 560chat_Destroy(struct chat *c) 561{ 562 timer_Stop(&c->pause); 563 timer_Stop(&c->timeout); 564 while (c->abort.num) 565 free(c->abort.string[--c->abort.num].data); 566 c->abort.num = 0; 567} 568 569static char * 570findblank(char *p, int instring) 571{ 572 if (instring) { 573 while (*p) { 574 if (*p == '\\') { 575 strcpy(p, p + 1); 576 if (!*p) 577 break; 578 } else if (*p == '"') 579 return (p); 580 p++; 581 } 582 } else { 583 while (*p) { 584 if (issep(*p)) 585 return (p); 586 p++; 587 } 588 } 589 return p; 590} 591 592int 593MakeArgs(char *script, char **pvect, int maxargs) 594{ 595 int nargs, nb; 596 int instring; 597 598 nargs = 0; 599 while (*script) { 600 nb = strspn(script, " \t"); 601 script += nb; 602 if (*script) { 603 if (*script == '"') { 604 instring = 1; 605 script++; 606 if (*script == '\0') 607 break; /* Shouldn't return here. Need to null 608 * terminate below */ 609 } else 610 instring = 0; 611 if (nargs >= maxargs - 1) 612 break; 613 *pvect++ = script; 614 nargs++; 615 script = findblank(script, instring); 616 if (*script) 617 *script++ = '\0'; 618 } 619 } 620 *pvect = NULL; 621 return nargs; 622} 623 624/* 625 * \c don't add a cr 626 * \d Sleep a little (delay 2 seconds 627 * \n Line feed character 628 * \P Auth Key password 629 * \p pause 0.25 sec 630 * \r Carrige return character 631 * \s Space character 632 * \T Telephone number(s) (defined via `set phone') 633 * \t Tab character 634 * \U Auth User 635 */ 636static char * 637ExpandString(struct chat *c, const char *str, char *result, int reslen, 638 int sendmode) 639{ 640 int addcr = 0; 641 642 result[--reslen] = '\0'; 643 if (sendmode) 644 addcr = 1; 645 while (*str && reslen > 0) { 646 switch (*str) { 647 case '\\': 648 str++; 649 switch (*str) { 650 case 'c': 651 if (sendmode) 652 addcr = 0; 653 break; 654 case 'd': /* Delay 2 seconds */ 655 chat_Pause(c, 2 * SECTICKS); 656 break; 657 case 'p': 658 chat_Pause(c, SECTICKS / 4); 659 break; /* Pause 0.25 sec */ 660 case 'n': 661 *result++ = '\n'; 662 reslen--; 663 break; 664 case 'r': 665 *result++ = '\r'; 666 reslen--; 667 break; 668 case 's': 669 *result++ = ' '; 670 reslen--; 671 break; 672 case 't': 673 *result++ = '\t'; 674 reslen--; 675 break; 676 case 'P': 677 strncpy(result, c->physical->dl->bundle->cfg.auth.key, reslen); 678 reslen -= strlen(result); 679 result += strlen(result); 680 break; 681 case 'T': 682 if (c->phone) { 683 strncpy(result, c->phone, reslen); 684 reslen -= strlen(result); 685 result += strlen(result); 686 } 687 break; 688 case 'U': 689 strncpy(result, c->physical->dl->bundle->cfg.auth.name, reslen); 690 reslen -= strlen(result); 691 result += strlen(result); 692 break; 693 default: 694 reslen--; 695 *result++ = *str; 696 break; 697 } 698 if (*str) 699 str++; 700 break; 701 case '^': 702 str++; 703 if (*str) { 704 *result++ = *str++ & 0x1f; 705 reslen--; 706 } 707 break; 708 default: 709 *result++ = *str++; 710 reslen--; 711 break; 712 } 713 } 714 if (--reslen > 0) { 715 if (addcr) 716 *result++ = '\r'; 717 } 718 if (--reslen > 0) 719 *result++ = '\0'; 720 return (result); 721} 722 723static void 724ExecStr(struct physical *physical, char *command, char *out, int olen) 725{ 726 pid_t pid; 727 int fids[2]; 728 char *argv[MAXARGS], *vector[MAXARGS], *startout, *endout; 729 int stat, nb, argc; 730 731 log_Printf(LogCHAT, "Exec: %s\n", command); 732 argc = MakeArgs(command, vector, VECSIZE(vector)); 733 command_Expand(argv, argc, (char const *const *)vector, 734 physical->dl->bundle, 0); 735 736 if (pipe(fids) < 0) { 737 log_Printf(LogCHAT, "Unable to create pipe in ExecStr: %s\n", 738 strerror(errno)); 739 *out = '\0'; 740 return; 741 } 742 if ((pid = fork()) == 0) { 743 close(fids[0]); 744 timer_TermService(); 745 fids[1] = fcntl(fids[1], F_DUPFD, 4); 746 dup2(physical_GetFD(physical), STDIN_FILENO); 747 dup2(STDIN_FILENO, STDOUT_FILENO); 748 dup2(fids[1], STDERR_FILENO); 749 close(3); 750 if (open(_PATH_TTY, O_RDWR) == 3) 751 fcntl(3, F_SETFD, 0); /* Clear close-on-exec flag */ 752 else 753 fcntl(3, F_SETFD, 1); /* Set close-on-exec flag */ 754 setuid(geteuid()); 755 execvp(argv[0], argv); 756 fprintf(stderr, "execvp: %s: %s\n", argv[0], strerror(errno)); 757 exit(127); 758 } else { 759 char *name = strdup(vector[0]); 760 761 close(fids[1]); 762 endout = out + olen - 1; 763 startout = out; 764 while (out < endout) { 765 nb = read(fids[0], out, 1); 766 if (nb <= 0) 767 break; 768 out++; 769 } 770 *out = '\0'; 771 close(fids[0]); 772 close(fids[1]); 773 waitpid(pid, &stat, WNOHANG); 774 if (WIFSIGNALED(stat)) { 775 log_Printf(LogWARN, "%s: signal %d\n", name, WTERMSIG(stat)); 776 free(name); 777 *out = '\0'; 778 return; 779 } else if (WIFEXITED(stat)) { 780 switch (WEXITSTATUS(stat)) { 781 case 0: 782 free(name); 783 break; 784 case 127: 785 log_Printf(LogWARN, "%s: %s\n", name, startout); 786 free(name); 787 *out = '\0'; 788 return; 789 break; 790 default: 791 log_Printf(LogWARN, "%s: exit %d\n", name, WEXITSTATUS(stat)); 792 free(name); 793 *out = '\0'; 794 return; 795 break; 796 } 797 } else { 798 log_Printf(LogWARN, "%s: Unexpected exit result\n", name); 799 free(name); 800 *out = '\0'; 801 return; 802 } 803 } 804} 805