Blame

Date:
Message:
libthread: add threadmaybackground Programs that want to background themselves now need to define threadmaybackground returning 1. This avoids a confusing (to people and debuggers) extra parent process for all the threaded programs that will never want to background themselves.
Actions:
History | Blob | Raw File
  1 b8c14089 2003-11-23 devnull #include <u.h>

  2 b8c14089 2003-11-23 devnull #include <libc.h>

  3 b8c14089 2003-11-23 devnull #include <regexp.h>

  4 b8c14089 2003-11-23 devnull #include <thread.h>

  5 b8c14089 2003-11-23 devnull #include <plumb.h>

  6 b8c14089 2003-11-23 devnull #include <fcall.h>

  7 b8c14089 2003-11-23 devnull #include "plumber.h"

  8 b8c14089 2003-11-23 devnull 

  9 32f69c36 2003-12-11 devnull int debug;

 10 b0aecb4b 2019-10-29 crossd int foreground=0;

 11 b8c14089 2003-11-23 devnull char	*plumbfile;

 12 b8c14089 2003-11-23 devnull char *user;

 13 b8c14089 2003-11-23 devnull char *home;

 14 b8c14089 2003-11-23 devnull char *progname;

 15 b8c14089 2003-11-23 devnull Ruleset **rules;

 16 b8c14089 2003-11-23 devnull int	printerrors=1;

 17 b8c14089 2003-11-23 devnull jmp_buf	parsejmp;

 18 b8c14089 2003-11-23 devnull char	*lasterror;

 19 b8c14089 2003-11-23 devnull 

 20 b8c14089 2003-11-23 devnull void

 21 b8c14089 2003-11-23 devnull makeports(Ruleset *rules[])

 22 b8c14089 2003-11-23 devnull {

 23 b8c14089 2003-11-23 devnull 	int i;

 24 b8c14089 2003-11-23 devnull 

 25 b8c14089 2003-11-23 devnull 	for(i=0; rules[i]; i++)

 26 b8c14089 2003-11-23 devnull 		addport(rules[i]->port);

 27 b8c14089 2003-11-23 devnull }

 28 b8c14089 2003-11-23 devnull 

 29 b3a20a96 2020-12-30 rsc int

 30 b3a20a96 2020-12-30 rsc threadmaybackground(void)

 31 b3a20a96 2020-12-30 rsc {

 32 b3a20a96 2020-12-30 rsc 	return 1;

 33 b3a20a96 2020-12-30 rsc }

 34 b3a20a96 2020-12-30 rsc 

 35 b8c14089 2003-11-23 devnull void

 36 b8c14089 2003-11-23 devnull threadmain(int argc, char *argv[])

 37 b8c14089 2003-11-23 devnull {

 38 b8c14089 2003-11-23 devnull 	char buf[512];

 39 f7b74c17 2004-12-28 devnull 	int fd;

 40 b8c14089 2003-11-23 devnull 

 41 b8c14089 2003-11-23 devnull 	progname = "plumber";

 42 b8c14089 2003-11-23 devnull 

 43 b8c14089 2003-11-23 devnull 	ARGBEGIN{

 44 32f69c36 2003-12-11 devnull 	case 'd':

 45 32f69c36 2003-12-11 devnull 		debug = 1;

 46 32f69c36 2003-12-11 devnull 		break;

 47 b0aecb4b 2019-10-29 crossd 	case 'f':

 48 b0aecb4b 2019-10-29 crossd 		foreground = 1;

 49 b0aecb4b 2019-10-29 crossd 		break;

 50 b8c14089 2003-11-23 devnull 	case 'p':

 51 b8c14089 2003-11-23 devnull 		plumbfile = ARGF();

 52 b8c14089 2003-11-23 devnull 		break;

 53 b8c14089 2003-11-23 devnull 	}ARGEND

 54 b8c14089 2003-11-23 devnull 

 55 32f69c36 2003-12-11 devnull 	user = getuser();

 56 c8b6342d 2005-01-13 devnull 	home = getenv("HOME");

 57 b8c14089 2003-11-23 devnull 	if(user==nil || home==nil)

 58 b8c14089 2003-11-23 devnull 		error("can't initialize $user or $home: %r");

 59 b8c14089 2003-11-23 devnull 	if(plumbfile == nil){

 60 b8c14089 2003-11-23 devnull 		sprint(buf, "%s/lib/plumbing", home);

 61 8ad51794 2004-03-25 devnull 		if(access(buf, 0) >= 0)

 62 8ad51794 2004-03-25 devnull 			plumbfile = estrdup(buf);

 63 8ad51794 2004-03-25 devnull 		else

 64 8ad51794 2004-03-25 devnull 			plumbfile = unsharp("#9/plumb/initial.plumbing");

 65 b8c14089 2003-11-23 devnull 	}

 66 b8c14089 2003-11-23 devnull 

 67 b8c14089 2003-11-23 devnull 	fd = open(plumbfile, OREAD);

 68 b8c14089 2003-11-23 devnull 	if(fd < 0)

 69 b8c14089 2003-11-23 devnull 		error("can't open rules file %s: %r", plumbfile);

 70 b8c14089 2003-11-23 devnull 	if(setjmp(parsejmp))

 71 b8c14089 2003-11-23 devnull 		error("parse error");

 72 b8c14089 2003-11-23 devnull 

 73 b8c14089 2003-11-23 devnull 	rules = readrules(plumbfile, fd);

 74 b8c14089 2003-11-23 devnull 	close(fd);

 75 b8c14089 2003-11-23 devnull 

 76 df49b303 2004-12-28 devnull 	/*

 77 df49b303 2004-12-28 devnull 	 * Start all processes and threads from other proc

 78 df49b303 2004-12-28 devnull 	 * so we (main pid) can return to user.

 79 df49b303 2004-12-28 devnull 	 */

 80 f4b26b64 2005-01-04 devnull 	printerrors = 0;

 81 f4b26b64 2005-01-04 devnull 	makeports(rules);

 82 b0aecb4b 2019-10-29 crossd 	startfsys(foreground);

 83 df49b303 2004-12-28 devnull 	threadexits(nil);

 84 b8c14089 2003-11-23 devnull }

 85 b8c14089 2003-11-23 devnull 

 86 b8c14089 2003-11-23 devnull void

 87 b8c14089 2003-11-23 devnull error(char *fmt, ...)

 88 b8c14089 2003-11-23 devnull {

 89 b8c14089 2003-11-23 devnull 	char buf[512];

 90 b8c14089 2003-11-23 devnull 	va_list args;

 91 b8c14089 2003-11-23 devnull 

 92 b8c14089 2003-11-23 devnull 	va_start(args, fmt);

 93 b8c14089 2003-11-23 devnull 	vseprint(buf, buf+sizeof buf, fmt, args);

 94 b8c14089 2003-11-23 devnull 	va_end(args);

 95 b8c14089 2003-11-23 devnull 

 96 b8c14089 2003-11-23 devnull 	fprint(2, "%s: %s\n", progname, buf);

 97 b8c14089 2003-11-23 devnull 	threadexitsall("error");

 98 b8c14089 2003-11-23 devnull }

 99 b8c14089 2003-11-23 devnull 

100 b8c14089 2003-11-23 devnull void

101 b8c14089 2003-11-23 devnull parseerror(char *fmt, ...)

102 b8c14089 2003-11-23 devnull {

103 b8c14089 2003-11-23 devnull 	char buf[512];

104 b8c14089 2003-11-23 devnull 	va_list args;

105 b8c14089 2003-11-23 devnull 

106 b8c14089 2003-11-23 devnull 	va_start(args, fmt);

107 b8c14089 2003-11-23 devnull 	vseprint(buf, buf+sizeof buf, fmt, args);

108 b8c14089 2003-11-23 devnull 	va_end(args);

109 b8c14089 2003-11-23 devnull 

110 b8c14089 2003-11-23 devnull 	if(printerrors){

111 b8c14089 2003-11-23 devnull 		printinputstack();

112 b8c14089 2003-11-23 devnull 		fprint(2, "%s\n", buf);

113 b8c14089 2003-11-23 devnull 	}

114 b8c14089 2003-11-23 devnull 	do; while(popinput());

115 b8c14089 2003-11-23 devnull 	lasterror = estrdup(buf);

116 b8c14089 2003-11-23 devnull 	longjmp(parsejmp, 1);

117 b8c14089 2003-11-23 devnull }

118 b8c14089 2003-11-23 devnull 

119 b8c14089 2003-11-23 devnull void*

120 b8c14089 2003-11-23 devnull emalloc(long n)

121 b8c14089 2003-11-23 devnull {

122 b8c14089 2003-11-23 devnull 	void *p;

123 b8c14089 2003-11-23 devnull 

124 b8c14089 2003-11-23 devnull 	p = malloc(n);

125 b8c14089 2003-11-23 devnull 	if(p == nil)

126 b8c14089 2003-11-23 devnull 		error("malloc failed: %r");

127 b8c14089 2003-11-23 devnull 	memset(p, 0, n);

128 b8c14089 2003-11-23 devnull 	return p;

129 b8c14089 2003-11-23 devnull }

130 b8c14089 2003-11-23 devnull 

131 b8c14089 2003-11-23 devnull void*

132 b8c14089 2003-11-23 devnull erealloc(void *p, long n)

133 b8c14089 2003-11-23 devnull {

134 b8c14089 2003-11-23 devnull 	p = realloc(p, n);

135 b8c14089 2003-11-23 devnull 	if(p == nil)

136 b8c14089 2003-11-23 devnull 		error("realloc failed: %r");

137 b8c14089 2003-11-23 devnull 	return p;

138 b8c14089 2003-11-23 devnull }

139 b8c14089 2003-11-23 devnull 

140 b8c14089 2003-11-23 devnull char*

141 b8c14089 2003-11-23 devnull estrdup(char *s)

142 b8c14089 2003-11-23 devnull {

143 b8c14089 2003-11-23 devnull 	char *t;

144 b8c14089 2003-11-23 devnull 

145 b8c14089 2003-11-23 devnull 	t = strdup(s);

146 b8c14089 2003-11-23 devnull 	if(t == nil)

147 b8c14089 2003-11-23 devnull 		error("estrdup failed: %r");

148 b8c14089 2003-11-23 devnull 	return t;

149 b8c14089 2003-11-23 devnull }