shithub: lola

Download patch

ref: ee60859199f151377a32b6932bde88cc6fe6007a
parent: 1c5f593c22a22f0cc35d5c8c0476e4d7007d208a
author: aap <aap@papnet.eu>
date: Sat Jan 28 16:37:24 EST 2023

stuff

--- a/fs.c
+++ b/fs.c
@@ -103,6 +103,7 @@
 	Xreq *xr = a;
 	XreqMsg xm;
 
+	threadsetname("xreg.%p", xr);
 	for(;;){
 		recv(xr->xc, &xm);
 		xr->req = xm.r;
@@ -875,9 +876,26 @@
 	return BIT32SZ+m;
 }
 
+/*
+ * Build pipe with OCEXEC set on second fd.
+ * Can't put it on both because we want to post one in /srv.
+ */
+int
+cexecpipe(int *p0, int *p1)
+{
+	/* pipe the hard way to get close on exec */
+	if(bind("#|", "/mnt/temp", MREPL) == -1)
+		return -1;
+	*p0 = open("/mnt/temp/data", ORDWR);
+	*p1 = open("/mnt/temp/data1", ORDWR|OCEXEC);
+	unmount(nil, "/mnt/temp");
+	if(*p0<0 || *p1<0)
+		return -1;
+	return 0;
+}
+
 int fsysfd;
-char	srvpipe[64];
-//char	srvwctl[64];
+char srvpipe[64];
 
 void
 fs(void)
@@ -884,13 +902,11 @@
 {
 	io9p = ioproc();
 
-	int fd[2];
-	if(pipe(fd) < 0)
+	if(cexecpipe(&fsysfd, &fsys.infd) < 0)
 		panic("pipe");
-	fsysfd = fd[0];		/* don't close for children */
-	fsys.infd = fsys.outfd = fd[1];
+	fsys.outfd = fsys.infd;
 	snprint(srvpipe, sizeof(srvpipe), "lola.%s.%lud", getuser(), (ulong)getpid());
-	post(srvpipe, fd[0]);
+	post(srvpipe, fsysfd);
 //	chatty9p++;
 	srv(&fsys);
 }
--- a/main.c
+++ b/main.c
@@ -544,6 +544,7 @@
 	Window *w;
 	int inside;
 
+	threadsetname("mousethread");
 	while(readmouse(mctl) != -1){
 		w = wpointto(mctl->xy);
 again:
@@ -597,6 +598,7 @@
 	Rectangle or, nr;
 	Point delta;
 
+	threadsetname("resizethread");
 	for(;;){
 		recvul(mctl->resizec);
 		or = screen->clipr;
@@ -774,6 +776,7 @@
 	return nil;
 }
 
+/* BUG: there's a deadlock somewhere sometimes when you delete a ktrans window */
 void
 keyboardtap(void*)
 {
@@ -854,17 +857,17 @@
 		case Ato:
 			recv(fschan, &pair);
 			n = strlen(s)+1;
-			memmove(pair.s, s, min(n, pair.ns));
+			pair.ns = min(n, pair.ns);
+			memmove(pair.s, s, pair.ns);
 			free(s);
-			pair.ns = n;
 			send(fschan, &pair);
 			goto Reset;
 		case Awatch:
 			recv(fschan, &pair);
 			n = strlen(watched)+1;
-			memmove(pair.s, watched, min(n, pair.ns));
+			pair.ns = min(n, pair.ns);
+			memmove(pair.s, watched, pair.ns);
 			free(watched);
-			pair.ns = n;
 			send(fschan, &pair);
 			alts[Awatch].op = CHANNOP;
 			break;
--- a/wind.c
+++ b/wind.c
@@ -736,6 +736,7 @@
 	Completion *comp;
 
 	w = arg;
+	threadsetname("winthread-%d", w->id);
 	x = &w->text;
 	nr = 0;
 	memset(&cnv, 0, sizeof(cnv));