more

contrib/backends/srndv2/src/srnd/daemon.go

@@ -903,21 +903,21 @@ func (self *NNTPDaemon) processMessage(msgid string) {
 		if self.expire != nil {
 			// expire posts
 			log.Println("expire", group, "for", rollover, "threads")
-			self.expire.ExpireGroup(group, rollover)
+			go self.expire.ExpireGroup(group, rollover)
 		}
 		// send to mod panel
 		if group == "ctl" {
 			log.Println("process mod message", msgid)
-			self.mod.HandleMessage(msgid)
+			go self.mod.HandleMessage(msgid)
 		}
 		// inform callback hooks
 		go self.informHooks(group, msgid, ref)
 		// federate
-		self.sendAllFeeds(ArticleEntry{msgid, group})
+		go self.sendAllFeeds(ArticleEntry{msgid, group})
 		// send to frontend
 		if self.frontend != nil {
 			if self.frontend.AllowNewsgroup(group) {
-				self.frontend.HandleNewPost(frontendPost{msgid, ref, group})
+				go self.frontend.HandleNewPost(frontendPost{msgid, ref, group})
 			}
 		}
 	}

contrib/backends/srndv2/src/srnd/frontend_http.go

@@ -125,7 +125,7 @@ func (lc *liveChan) SendBanned() {
 	msg, _ := json.Marshal(map[string]string{
 		"Type": "ban",
 		// TODO: real ban message
-		"Reason": "your an faget, your IP was: " + lc.IP,
+		"Reason": "your an fagt, your IP was: " + lc.IP,
 	})
 	if lc.datachnl != nil {
 		lc.datachnl <- msg
@@ -324,10 +324,10 @@ func (self *httpFrontend) poll_liveui() {
 								th := threads[c-idx-1]
 								th.Update(self.daemon.database)
 								// send root post
-								live.Inform(th.OP())
+								go live.Inform(th.OP())
 								// send replies
 								for _, post := range th.Replies() {
-									live.Inform(post)
+									go live.Inform(post)
 								}
 							}
 						}
@@ -392,15 +392,17 @@ func (self *httpFrontend) HandleNewPost(nntp frontendPost) {
 	if len(ref) > 0 {
 		msgid = ref
 	}
-	entry := ArticleEntry{msgid, group}
-	// regnerate thread
-	self.Regen(entry)
-	// regenerate all board pages if not archiving
-	if !self.archive {
-		self.RegenerateBoard(group)
-	}
-	// regen front page
-	self.RegenFrontPage()
+	go func() {
+		entry := ArticleEntry{msgid, group}
+		// regnerate thread
+		self.Regen(entry)
+		// regenerate all board pages if not archiving
+		if !self.archive {
+			self.RegenerateBoard(group)
+		}
+		// regen front page
+		self.RegenFrontPage()
+	}()
 }
 
 // create a new captcha, return as json object