refactor: rearrange link

named-data · Dec 10, 2024 · 952e599 · 952e599
1 parent 9a6be34
commit 952e599
Showing 1 changed file with 19 additions and 17 deletions.
diff --git a/face/ndnlp-link-service.go b/face/ndnlp-link-service.go
@@ -143,6 +143,25 @@ func (l *NDNLPLinkService) Run(optNewFrame []byte) {
 	<-l.hasImplQuit
 	l.HasQuit <- true
 }
+
+func (l *NDNLPLinkService) runSend() {
+	core.LogTrace(l, "Starting send thread")
+
+	if lockThreadsToCores {
+		runtime.LockOSThread()
+	}
+
+	for {
+		select {
+		case pkt := <-l.sendQueue:
+			sendPacket(l, pkt)
+		case <-l.hasTransportQuit:
+			l.hasImplQuit <- true
+			return
+		}
+	}
+}
+
 func sendPacket(l *NDNLPLinkService, pkt *defn.Pkt) {
 	wire := pkt.Raw
 
@@ -269,23 +288,6 @@ func sendPacket(l *NDNLPLinkService, pkt *defn.Pkt) {
 		l.transport.sendFrame(l.outFrame)
 	}
 }
-func (l *NDNLPLinkService) runSend() {
-	core.LogTrace(l, "Starting send thread")
-
-	if lockThreadsToCores {
-		runtime.LockOSThread()
-	}
-
-	for {
-		select {
-		case pkt := <-l.sendQueue:
-			sendPacket(l, pkt)
-		case <-l.hasTransportQuit:
-			l.hasImplQuit <- true
-			return
-		}
-	}
-}
 
 func (l *NDNLPLinkService) handleIncomingFrame(frame []byte) {
 	// We have to copy so receive transport buffer can be reused