Keep track of RFNM messages.

larsbrinkhoff · larsbrinkhoff · commit 6363ea13cc83 · 2024-12-29T13:12:48.000+01:00
diff --git a/src/ncp.c b/src/ncp.c
@@ -87,6 +87,7 @@ static struct
 #define HOST_ALIVE   0001
 
   client_t echo;
+  int outstanding_rfnm;
 } hosts[256];
 
 static const char *type_name[] =
@@ -188,6 +189,9 @@ static void send_imp (int flags, int type, int destination, int link, int id,
   }
 #endif
 
+  if (type == IMP_REGULAR)
+    hosts[destination].outstanding_rfnm++;
+
   imp_send_message (packet, words);
 }
 
@@ -833,8 +837,10 @@ static void process_imp_nop (uint8_t *packet, int length)
 
 static void process_rfnm (uint8_t *packet, int length)
 {
+  uint8_t host = packet[1];
   fprintf (stderr, "NCP: Ready for next message to host %03o link %u.\n",
-           packet[1], packet[2]);
+           host, packet[2]);
+  hosts[host].outstanding_rfnm--;
 }
 
 static void process_full (uint8_t *packet, int length)

Original file line number	Diff line number	Diff line change
`@@ -87,6 +87,7 @@ static struct`
`87`	`87`	`#define HOST_ALIVE 0001`
`88`	`88`
`89`	`89`	`client_t echo;`
	`90`	`+ int outstanding_rfnm;`
`90`	`91`	`} hosts[256];`
`91`	`92`
`92`	`93`	`static const char *type_name[] =`
`@@ -188,6 +189,9 @@ static void send_imp (int flags, int type, int destination, int link, int id,`
`188`	`189`	`}`
`189`	`190`	`#endif`
`190`	`191`
	`192`	`+ if (type == IMP_REGULAR)`
	`193`	`+ hosts[destination].outstanding_rfnm++;`
	`194`	`+`
`191`	`195`	`imp_send_message (packet, words);`
`192`	`196`	`}`
`193`	`197`
`@@ -833,8 +837,10 @@ static void process_imp_nop (uint8_t *packet, int length)`
`833`	`837`
`834`	`838`	`static void process_rfnm (uint8_t *packet, int length)`
`835`	`839`	`{`
	`840`	`+ uint8_t host = packet[1];`
`836`	`841`	`fprintf (stderr, "NCP: Ready for next message to host %03o link %u.\n",`
`837`		`- packet[1], packet[2]);`
	`842`	`+ host, packet[2]);`
	`843`	`+ hosts[host].outstanding_rfnm--;`
`838`	`844`	`}`
`839`	`845`
`840`	`846`	`static void process_full (uint8_t *packet, int length)`