/* $OpenBSD: region.c,v 1.39 2021/03/01 10:51:14 lum Exp $ */ /* This file is in the public domain. */ /* * Region based commands. * The routines in this file deal with the region, that magic space between * "." and mark. Some functions are commands. Some functions are just for * internal use. */ #include #include #include #include #include #include #include #include #include #include #include #include #include "def.h" #define TIMEOUT 10000 static char leftover[BUFSIZ]; static int getregion(struct region *); static int iomux(int, char * const, int, struct buffer *); static int preadin(int, struct buffer *); static void pwriteout(int, char **, int *); static int setsize(struct region *, RSIZE); static int shellcmdoutput(char * const[], char * const, int); /* * Kill the region. Ask "getregion" to figure out the bounds of the region. * Move "." to the start, and kill the characters. Mark is cleared afterwards. */ /* ARGSUSED */ int killregion(int f, int n) { int s; struct region region; if ((s = getregion(®ion)) != TRUE) return (s); /* This is a kill-type command, so do magic kill buffer stuff. */ if ((lastflag & CFKILL) == 0) kdelete(); thisflag |= CFKILL; curwp->w_dotp = region.r_linep; curwp->w_doto = region.r_offset; curwp->w_dotline = region.r_lineno; s = ldelete(region.r_size, KFORW | KREG); clearmark(FFARG, 0); return (s); } /* * Copy all of the characters in the region to the kill buffer, * clearing the mark afterwards. * This is a bit like a kill region followed by a yank. */ /* ARGSUSED */ int copyregion(int f, int n) { struct line *linep; struct region region; int loffs; int s; if ((s = getregion(®ion)) != TRUE) return (s); /* kill type command */ if ((lastflag & CFKILL) == 0) kdelete(); thisflag |= CFKILL; /* current line */ linep = region.r_linep; /* current offset */ loffs = region.r_offset; while (region.r_size--) { if (loffs == llength(linep)) { /* End of line. */ if ((s = kinsert(*curbp->b_nlchr, KFORW)) != TRUE) return (s); linep = lforw(linep); loffs = 0; } else { /* Middle of line. */ if ((s = kinsert(lgetc(linep, loffs), KFORW)) != TRUE) return (s); ++loffs; } } clearmark(FFARG, 0); return (TRUE); } /* * Lower case region. Zap all of the upper case characters in the region to * lower case. Use the region code to set the limits. Scan the buffer, doing * the changes. Call "lchange" to ensure that redisplay is done in all * buffers. */ /* ARGSUSED */ int lowerregion(int f, int n) { struct line *linep; struct region region; int loffs, c, s; if ((s = checkdirty(curbp)) != TRUE) return (s); if (curbp->b_flag & BFREADONLY) { dobeep(); ewprintf("Buffer is read-only"); return (FALSE); } if ((s = getregion(®ion)) != TRUE) return (s); undo_add_change(region.r_linep, region.r_offset, region.r_size); lchange(WFFULL); linep = region.r_linep; loffs = region.r_offset; while (region.r_size--) { if (loffs == llength(linep)) { linep = lforw(linep); loffs = 0; } else { c = lgetc(linep, loffs); if (ISUPPER(c) != FALSE) lputc(linep, loffs, TOLOWER(c)); ++loffs; } } return (TRUE); } /* * Upper case region. Zap all of the lower case characters in the region to * upper case. Use the region code to set the limits. Scan the buffer, * doing the changes. Call "lchange" to ensure that redisplay is done in all * buffers. */ /* ARGSUSED */ int upperregion(int f, int n) { struct line *linep; struct region region; int loffs, c, s; if ((s = checkdirty(curbp)) != TRUE) return (s); if (curbp->b_flag & BFREADONLY) { dobeep(); ewprintf("Buffer is read-only"); return (FALSE); } if ((s = getregion(®ion)) != TRUE) return (s); undo_add_change(region.r_linep, region.r_offset, region.r_size); lchange(WFFULL); linep = region.r_linep; loffs = region.r_offset; while (region.r_size--) { if (loffs == llength(linep)) { linep = lforw(linep); loffs = 0; } else { c = lgetc(linep, loffs); if (ISLOWER(c) != FALSE) lputc(linep, loffs, TOUPPER(c)); ++loffs; } } return (TRUE); } /* * This routine figures out the bound of the region in the current window, * and stores the results into the fields of the REGION structure. Dot and * mark are usually close together, but I don't know the order, so I scan * outward from dot, in both directions, looking for mark. The size is kept * in a long. At the end, after the size is figured out, it is assigned to * the size field of the region structure. If this assignment loses any bits, * then we print an error. This is "type independent" overflow checking. All * of the callers of this routine should be ready to get an ABORT status, * because I might add a "if regions is big, ask before clobbering" flag. */ static int getregion(struct region *rp) { struct line *flp, *blp; long fsize, bsize; if (curwp->w_markp == NULL) { dobeep(); ewprintf("No mark set in this window"); return (FALSE); } /* "r_size" always ok */ if (curwp->w_dotp == curwp->w_markp) { rp->r_linep = curwp->w_dotp; rp->r_lineno = curwp->w_dotline; if (curwp->w_doto < curwp->w_marko) { rp->r_offset = curwp->w_doto; rp->r_size = (RSIZE)(curwp->w_marko - curwp->w_doto); } else { rp->r_offset = curwp->w_marko; rp->r_size = (RSIZE)(curwp->w_doto - curwp->w_marko); } return (TRUE); } /* get region size */ flp = blp = curwp->w_dotp; bsize = curwp->w_doto; fsize = llength(flp) - curwp->w_doto + 1; while (lforw(flp) != curbp->b_headp || lback(blp) != curbp->b_headp) { if (lforw(flp) != curbp->b_headp) { flp = lforw(flp); if (flp == curwp->w_markp) { rp->r_linep = curwp->w_dotp; rp->r_offset = curwp->w_doto; rp->r_lineno = curwp->w_dotline; return (setsize(rp, (RSIZE)(fsize + curwp->w_marko))); } fsize += llength(flp) + 1; } if (lback(blp) != curbp->b_headp) { blp = lback(blp); bsize += llength(blp) + 1; if (blp == curwp->w_markp) { rp->r_linep = blp; rp->r_offset = curwp->w_marko; rp->r_lineno = curwp->w_markline; return (setsize(rp, (RSIZE)(bsize - curwp->w_marko))); } } } dobeep(); ewprintf("Bug: lost mark"); return (FALSE); } /* * Set size, and check for overflow. */ static int setsize(struct region *rp, RSIZE size) { rp->r_size = size; if (rp->r_size != size) { dobeep(); ewprintf("Region is too large"); return (FALSE); } return (TRUE); } #define PREFIXLENGTH 40 static char prefix_string[PREFIXLENGTH] = {'>', '\0'}; /* * Prefix the region with whatever is in prefix_string. Leaves dot at the * beginning of the line after the end of the region. If an argument is * given, prompts for the line prefix string. */ /* ARGSUSED */ int prefixregion(int f, int n) { struct line *first, *last; struct region region; char *prefix = prefix_string; int nline; int s; if ((s = checkdirty(curbp)) != TRUE) return (s); if (curbp->b_flag & BFREADONLY) { dobeep(); ewprintf("Buffer is read-only"); return (FALSE); } if ((f == TRUE) && ((s = setprefix(FFRAND, 1)) != TRUE)) return (s); /* get # of lines to affect */ if ((s = getregion(®ion)) != TRUE) return (s); first = region.r_linep; last = (first == curwp->w_dotp) ? curwp->w_markp : curwp->w_dotp; for (nline = 1; first != last; nline++) first = lforw(first); /* move to beginning of region */ curwp->w_dotp = region.r_linep; curwp->w_doto = region.r_offset; curwp->w_dotline = region.r_lineno; /* for each line, go to beginning and insert the prefix string */ while (nline--) { (void)gotobol(FFRAND, 1); for (prefix = prefix_string; *prefix; prefix++) (void)linsert(1, *prefix); (void)forwline(FFRAND, 1); } (void)gotobol(FFRAND, 1); return (TRUE); } /* * Set line prefix string. Used by prefixregion. */ /* ARGSUSED */ int setprefix(int f, int n) { char buf[PREFIXLENGTH], *rep; int retval; if (prefix_string[0] == '\0') rep = eread("Prefix string: ", buf, sizeof(buf), EFNEW | EFCR); else rep = eread("Prefix string (default %s): ", buf, sizeof(buf), EFNUL | EFNEW | EFCR, prefix_string); if (rep == NULL) return (ABORT); if (rep[0] != '\0') { (void)strlcpy(prefix_string, rep, sizeof(prefix_string)); retval = TRUE; } else if (rep[0] == '\0' && prefix_string[0] != '\0') { /* CR -- use old one */ retval = TRUE; } else retval = FALSE; return (retval); } int region_get_data(struct region *reg, char *buf, int len) { int i, off; struct line *lp; off = reg->r_offset; lp = reg->r_linep; for (i = 0; i < len; i++) { if (off == llength(lp)) { lp = lforw(lp); if (lp == curbp->b_headp) break; off = 0; buf[i] = *curbp->b_nlchr; } else { buf[i] = lgetc(lp, off); off++; } } buf[i] = '\0'; return (i); } void region_put_data(const char *buf, int len) { int i; for (i = 0; buf[i] != '\0' && i < len; i++) { if (buf[i] == *curbp->b_nlchr) lnewline(); else linsert(1, buf[i]); } } /* * Mark whole buffer by first traversing to end-of-buffer * and then to beginning-of-buffer. Mark, dot are implicitly * set to eob, bob respectively during traversal. */ int markbuffer(int f, int n) { if (gotoeob(f,n) == FALSE) return (FALSE); (void) clearmark(f, n); if (gotobob(f,n) == FALSE) return (FALSE); return (TRUE); } /* * Pipe text from current region to external command. */ /*ARGSUSED */ int piperegion(int f, int n) { struct region region; int len; char *cmd, cmdbuf[NFILEN], *text; char *argv[] = {"sh", "-c", (char *) NULL, (char *) NULL}; /* C-u M-| is not supported yet */ if (n > 1) return (ABORT); if (curwp->w_markp == NULL) { dobeep(); ewprintf("The mark is not set now, so there is no region"); return (FALSE); } if ((cmd = eread("Shell command on region: ", cmdbuf, sizeof(cmdbuf), EFNEW | EFCR)) == NULL || (cmd[0] == '\0')) return (ABORT); argv[2] = cmd; if (getregion(®ion) != TRUE) return (FALSE); len = region.r_size; if ((text = malloc(len + 1)) == NULL) { dobeep(); ewprintf("Cannot allocate memory."); return (FALSE); } region_get_data(®ion, text, len); return shellcmdoutput(argv, text, len); } /* * Get command from mini-buffer and execute externally. */ /*ARGSUSED */ int shellcommand(int f, int n) { char *cmd, cmdbuf[NFILEN]; char *argv[] = {"sh", "-c", (char *) NULL, (char *) NULL}; if (n > 1) return (ABORT); if ((cmd = eread("Shell command: ", cmdbuf, sizeof(cmdbuf), EFNEW | EFCR)) == NULL || (cmd[0] == '\0')) return (ABORT); argv[2] = cmd; return shellcmdoutput(argv, NULL, 0); } int shellcmdoutput(char* const argv[], char* const text, int len) { struct buffer *bp; char *shellp; int ret; bp = bfind("*Shell Command Output*", TRUE); bp->b_flag |= BFREADONLY; if (bclear(bp) != TRUE) { free(text); return (FALSE); } shellp = getenv("SHELL"); ret = pipeio(shellp, argv, text, len, bp); if (ret == TRUE) { eerase(); if (lforw(bp->b_headp) == bp->b_headp) addline(bp, "(Shell command succeeded with no output)"); } free(text); return (ret); } /* * Create a socketpair, fork and execv path with argv. * STDIN, STDOUT and STDERR of child process are redirected to socket. * Parent writes len chars from text to socket. */ int pipeio(const char* const path, char* const argv[], char* const text, int len, struct buffer *outbp) { int s[2], ret; char *err; pid_t pid; if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, s) == -1) { dobeep(); ewprintf("socketpair error"); return (FALSE); } switch((pid = fork())) { case -1: dobeep(); ewprintf("Can't fork"); return (FALSE); case 0: /* Child process */ close(s[0]); if (dup2(s[1], STDIN_FILENO) == -1) _exit(1); if (dup2(s[1], STDOUT_FILENO) == -1) _exit(1); if (dup2(s[1], STDERR_FILENO) == -1) _exit(1); if (path == NULL) _exit(1); execv(path, argv); err = strerror(errno); write(s[1], err, strlen(err)); _exit(1); default: /* Parent process */ close(s[1]); ret = iomux(s[0], text, len, outbp); waitpid(pid, NULL, 0); /* Collect child to prevent zombies */ return (ret); } return (FALSE); } /* * Multiplex read, write on socket fd passed. Put output in outbp * Poll on the fd for both read and write readiness. */ int iomux(int fd, char* const text, int len, struct buffer *outbp) { struct pollfd pfd[1]; int nfds; char *textcopy; textcopy = text; fcntl(fd, F_SETFL, O_NONBLOCK); pfd[0].fd = fd; /* There is nothing to write if len is zero * but the cmd's output should be read so shutdown * the socket for writing only and don't wait for POLLOUT */ if (len == 0) { shutdown(fd, SHUT_WR); pfd[0].events = POLLIN; } else pfd[0].events = POLLIN | POLLOUT; while ((nfds = poll(pfd, 1, TIMEOUT)) != -1 || (pfd[0].revents & (POLLERR | POLLHUP | POLLNVAL))) { if (pfd[0].revents & POLLOUT && len > 0) pwriteout(fd, &textcopy, &len); else if (pfd[0].revents & POLLIN) if (preadin(fd, outbp) == FALSE) break; if (len == 0 && pfd[0].events & POLLOUT) pfd[0].events = POLLIN; } close(fd); /* In case if last line doesn't have a '\n' add the leftover * characters to buffer. */ if (leftover[0] != '\0') { addline(outbp, leftover); leftover[0] = '\0'; } if (nfds == 0) { dobeep(); ewprintf("poll timed out"); return (FALSE); } else if (nfds == -1) { dobeep(); ewprintf("poll error"); return (FALSE); } return (popbuftop(outbp, WNONE)); } /* * Write some text from region to fd. Once done shutdown the * write end. */ void pwriteout(int fd, char **text, int *len) { int w; if (((w = send(fd, *text, *len, MSG_NOSIGNAL)) == -1)) { switch(errno) { case EPIPE: *len = -1; break; case EAGAIN: return; } } else *len -= w; *text += w; if (*len <= 0) shutdown(fd, SHUT_WR); } /* * Read some data from socket fd, break on '\n' and add * to buffer. If couldn't break on newline hold leftover * characters and append in next iteration. */ int preadin(int fd, struct buffer *bp) { int len; char buf[BUFSIZ], *p, *q; if ((len = read(fd, buf, BUFSIZ - 1)) <= 0) return (FALSE); buf[len] = '\0'; p = q = buf; if (leftover[0] != '\0' && ((q = strchr(p, *bp->b_nlchr)) != NULL)) { *q++ = '\0'; if (strlcat(leftover, p, sizeof(leftover)) >= sizeof(leftover)) { dobeep(); ewprintf("line too long"); return (FALSE); } addline(bp, leftover); leftover[0] = '\0'; p = q; } while ((q = strchr(p, *bp->b_nlchr)) != NULL) { *q++ = '\0'; addline(bp, p); p = q; } if (strlcpy(leftover, p, sizeof(leftover)) >= sizeof(leftover)) { dobeep(); ewprintf("line too long"); return (FALSE); } return (TRUE); }