github.com/rcornwell.sims
1
0
Fork 0
mirror of https://github.com/rcornwell/sims.git synced 2026-05-05 15:35:19 +00:00
Code Releases Activity

KA10: Return RFNM message for each message sent.

Browse Source
This commit is contained in:
Richard Cornwell
2019-06-07 23:50:29 -04:00
parent eb73c07d7f
commit 05487845b1
1 changed files with 19 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
PDP10/ka10_imp.c
View File

@@ -375,6 +375,7 @@ struct imp_device {
ETH_QUE ReadQ; ETH_QUE ReadQ;
int imp_error; int imp_error;
int host_error; int host_error;
int rfnm_count; /* Number of pending RFNM packets */
} imp_data; } imp_data;
extern int32 tmxr_poll; extern int32 tmxr_poll;
@@ -401,6 +402,7 @@ t_stat imp_show_hostip (FILE *st, UNIT *uptr, int32 val, CONST void *des
t_stat imp_set_hostip (UNIT* uptr, int32 val, CONST char* cptr, void* desc); t_stat imp_set_hostip (UNIT* uptr, int32 val, CONST char* cptr, void* desc);
t_stat imp_show_dhcpip (FILE *st, UNIT *uptr, int32 val, CONST void *desc); t_stat imp_show_dhcpip (FILE *st, UNIT *uptr, int32 val, CONST void *desc);
void imp_timer_task(struct imp_device *imp); void imp_timer_task(struct imp_device *imp);
void imp_send_rfmn(struct imp_device *imp);
void imp_packet_in(struct imp_device *imp); void imp_packet_in(struct imp_device *imp);
void imp_send_packet (struct imp_device *imp_data, int len); void imp_send_packet (struct imp_device *imp_data, int len);
void imp_free_packet(struct imp_device *imp, struct imp_packet *p); void imp_free_packet(struct imp_device *imp, struct imp_packet *p);
@@ -752,8 +754,22 @@ imp_packet_in(struct imp_device *imp)
int n; int n;
int pad; int pad;
if (eth_read (&imp_data.etherface, &read_buffer, NULL) <= 0) if (eth_read (&imp_data.etherface, &read_buffer, NULL) <= 0) {
/* Any pending packet notifications? */
if (imp->rfnm_count != 0) {
/* Create RFNM packet */
memset(&imp->rbuffer[0], 0, 256);
imp->rbuffer[0] = 0xf;
imp->rbuffer[3] = 4;
imp_unit[0].STATUS |= IMPIB;
imp_unit[0].IPOS = 0;
imp_unit[0].ILEN = 12*8;
if (!sim_is_active(&imp_unit[0]))
sim_activate(&imp_unit[0], 100);
imp->rfnm_count--;
}
return; return;
}
hdr = (struct imp_eth_hdr *)(&read_buffer.msg[0]); hdr = (struct imp_eth_hdr *)(&read_buffer.msg[0]);
type = ntohs(hdr->type); type = ntohs(hdr->type);
if (type == ETHTYPE_ARP) { if (type == ETHTYPE_ARP) {
@@ -1155,6 +1171,7 @@ imp_packet_out(struct imp_device *imp, ETH_PACK *packet) {
memcpy(&pkt->ethhdr.src, &imp->mac, 6); memcpy(&pkt->ethhdr.src, &imp->mac, 6);
pkt->ethhdr.type = htons(ETHTYPE_IP); pkt->ethhdr.type = htons(ETHTYPE_IP);
eth_write(&imp->etherface, packet, NULL); eth_write(&imp->etherface, packet, NULL);
imp->rfnm_count++;
return; return;
} }
} }
@@ -1293,6 +1310,7 @@ imp_arp_arpin(struct imp_device *imp, ETH_PACK *packet)
memcpy(&pkt->ethhdr.src, &imp->mac, 6); memcpy(&pkt->ethhdr.src, &imp->mac, 6);
pkt->ethhdr.type = htons(ETHTYPE_IP); pkt->ethhdr.type = htons(ETHTYPE_IP);
eth_write(&imp->etherface, &temp->packet, NULL); eth_write(&imp->etherface, &temp->packet, NULL);
imp->rfnm_count++;
imp_free_packet(imp, temp); imp_free_packet(imp, temp);
} else { } else {
temp->next = nq; temp->next = nq;