Update these netgraph drivers in current so that these changes can be
MFC'ed i due time. I can't test it under current right now because netgraph seems to do unethical things with mutexes. musycc: Add status per channel. Reduce printf chattyness Keep error counters line if_mn does. Increase descriptor count. if_mn: Support experimental unframed E1 lines. These two drivers should share more code relating to framed channelized TDM media in general (T1/E1/E3/T3, Sonet). Anyone interested email me.
This commit is contained in:
parent
1fd7b93f3f
commit
18d5982009
@ -175,19 +175,22 @@ struct schan {
|
|||||||
int rx_last_md; /* index to next MD */
|
int rx_last_md; /* index to next MD */
|
||||||
int nmd; /* count of MD's. */
|
int nmd; /* count of MD's. */
|
||||||
|
|
||||||
#if 0
|
|
||||||
|
|
||||||
time_t last_recv;
|
time_t last_recv;
|
||||||
|
time_t last_rdrop;
|
||||||
time_t last_rxerr;
|
time_t last_rxerr;
|
||||||
time_t last_xmit;
|
|
||||||
|
|
||||||
u_long rx_error;
|
|
||||||
|
|
||||||
u_long short_error;
|
|
||||||
u_long crc_error;
|
u_long crc_error;
|
||||||
u_long dribble_error;
|
u_long dribble_error;
|
||||||
u_long long_error;
|
u_long long_error;
|
||||||
u_long abort_error;
|
u_long abort_error;
|
||||||
|
u_long short_error;
|
||||||
|
|
||||||
|
time_t last_xmit;
|
||||||
|
time_t last_txerr;
|
||||||
|
#if 0
|
||||||
|
|
||||||
|
|
||||||
|
u_long rx_error;
|
||||||
|
|
||||||
u_long overflow_error;
|
u_long overflow_error;
|
||||||
|
|
||||||
int last_error;
|
int last_error;
|
||||||
@ -419,6 +422,38 @@ init_ctrl(struct softc *sc)
|
|||||||
tsleep(&sc->last, PZERO + PCATCH, "con1", hz);
|
tsleep(&sc->last, PZERO + PCATCH, "con1", hz);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
static void
|
||||||
|
status_chans(struct softc *sc, char *s)
|
||||||
|
{
|
||||||
|
int i;
|
||||||
|
struct schan *scp;
|
||||||
|
|
||||||
|
s += strlen(s);
|
||||||
|
for (i = 0; i < NHDLC; i++) {
|
||||||
|
scp = sc->chan[i];
|
||||||
|
if (scp == NULL)
|
||||||
|
continue;
|
||||||
|
sprintf(s + strlen(s), "c%2d:", i);
|
||||||
|
sprintf(s + strlen(s), " ts %08x", scp->ts);
|
||||||
|
sprintf(s + strlen(s), " RX %lus/%lus",
|
||||||
|
time_second - scp->last_recv, time_second - scp->last_rxerr);
|
||||||
|
sprintf(s + strlen(s), " TX %lus/%lus",
|
||||||
|
time_second - scp->last_xmit, time_second - scp->last_txerr);
|
||||||
|
sprintf(s + strlen(s), " CRC %lu Dribble %lu Long %lu Short %lu Abort %lu",
|
||||||
|
scp->crc_error,
|
||||||
|
scp->dribble_error,
|
||||||
|
scp->long_error,
|
||||||
|
scp->short_error,
|
||||||
|
scp->abort_error);
|
||||||
|
sprintf(s + strlen(s), "\n");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
@ -651,10 +686,6 @@ musycc_intr0_rx_eom(struct softc *sc, int ch)
|
|||||||
m = md->m;
|
m = md->m;
|
||||||
m->m_len = m->m_pkthdr.len = status & 0x3fff;
|
m->m_len = m->m_pkthdr.len = status & 0x3fff;
|
||||||
error = (status >> 16) & 0xf;
|
error = (status >> 16) & 0xf;
|
||||||
#if 0
|
|
||||||
if (error == 8 && (sc->framing == E1U || sc->framing == T1U))
|
|
||||||
error = 0;
|
|
||||||
#endif
|
|
||||||
if (error == 0) {
|
if (error == 0) {
|
||||||
MGETHDR(m2, M_DONTWAIT, MT_DATA);
|
MGETHDR(m2, M_DONTWAIT, MT_DATA);
|
||||||
if (m2 != NULL) {
|
if (m2 != NULL) {
|
||||||
@ -664,6 +695,7 @@ musycc_intr0_rx_eom(struct softc *sc, int ch)
|
|||||||
md->m = m2;
|
md->m = m2;
|
||||||
md->data = vtophys(m2->m_data);
|
md->data = vtophys(m2->m_data);
|
||||||
/* Pass the received mbuf upwards. */
|
/* Pass the received mbuf upwards. */
|
||||||
|
sch->last_recv = time_second;
|
||||||
NG_SEND_DATA_ONLY(error, sch->hook, m);
|
NG_SEND_DATA_ONLY(error, sch->hook, m);
|
||||||
} else {
|
} else {
|
||||||
/*
|
/*
|
||||||
@ -673,6 +705,7 @@ musycc_intr0_rx_eom(struct softc *sc, int ch)
|
|||||||
* the mbuf+cluster we already had.
|
* the mbuf+cluster we already had.
|
||||||
*/
|
*/
|
||||||
m_freem(m2);
|
m_freem(m2);
|
||||||
|
sch->last_rdrop = time_second;
|
||||||
sch->rx_drop++;
|
sch->rx_drop++;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
@ -680,13 +713,23 @@ musycc_intr0_rx_eom(struct softc *sc, int ch)
|
|||||||
* We didn't get a mbuf, drop received packet
|
* We didn't get a mbuf, drop received packet
|
||||||
* and recycle the "old" mbuf+cluster.
|
* and recycle the "old" mbuf+cluster.
|
||||||
*/
|
*/
|
||||||
|
sch->last_rdrop = time_second;
|
||||||
sch->rx_drop++;
|
sch->rx_drop++;
|
||||||
}
|
}
|
||||||
} else if (error == 9) {
|
} else if (error == 9) {
|
||||||
printf("FCS\n");
|
sch->last_rxerr = time_second;
|
||||||
|
sch->crc_error++;
|
||||||
} else if (error == 10) {
|
} else if (error == 10) {
|
||||||
printf("ALIGN\n");
|
sch->last_rxerr = time_second;
|
||||||
|
sch->dribble_error++;
|
||||||
|
} else if (error == 11) {
|
||||||
|
sch->last_rxerr = time_second;
|
||||||
|
sch->abort_error++;
|
||||||
|
} else if (error == 12) {
|
||||||
|
sch->last_rxerr = time_second;
|
||||||
|
sch->long_error++;
|
||||||
} else {
|
} else {
|
||||||
|
sch->last_rxerr = time_second;
|
||||||
/* Receive error, print some useful info */
|
/* Receive error, print some useful info */
|
||||||
printf("%s %s: RX 0x%08x ", sch->sc->nodename,
|
printf("%s %s: RX 0x%08x ", sch->sc->nodename,
|
||||||
sch->hookname, status);
|
sch->hookname, status);
|
||||||
@ -740,9 +783,11 @@ musycc_intr0(void *arg)
|
|||||||
}
|
}
|
||||||
switch (ev) {
|
switch (ev) {
|
||||||
case 1: /* SACK Service Request Acknowledge */
|
case 1: /* SACK Service Request Acknowledge */
|
||||||
|
#if 0
|
||||||
printf("%s: SACK: %08x group=%d", sc->nodename, csc->iqd[j], g);
|
printf("%s: SACK: %08x group=%d", sc->nodename, csc->iqd[j], g);
|
||||||
printf("/%s", csc->iqd[j] & 0x80000000 ? "T" : "R");
|
printf("/%s", csc->iqd[j] & 0x80000000 ? "T" : "R");
|
||||||
printf(" cmd %08x (%08x) \n", sc->last, sc->reg->srd);
|
printf(" cmd %08x (%08x) \n", sc->last, sc->reg->srd);
|
||||||
|
#endif
|
||||||
sc->last = 0xffffffff;
|
sc->last = 0xffffffff;
|
||||||
wakeup(&sc->last);
|
wakeup(&sc->last);
|
||||||
break;
|
break;
|
||||||
@ -756,19 +801,14 @@ musycc_intr0(void *arg)
|
|||||||
musycc_intr0_rx_eom(sc, ch);
|
musycc_intr0_rx_eom(sc, ch);
|
||||||
break;
|
break;
|
||||||
case 0:
|
case 0:
|
||||||
#if 1
|
if (er == 13) { /* SHT */
|
||||||
if (er == 2) { /* COFA */
|
sc->chan[ch]->last_rxerr = time_second;
|
||||||
break;
|
sc->chan[i]->short_error++;
|
||||||
} else if (er == 3) { /* ONR */
|
|
||||||
musycc_intr0_tx_eom(sc, ch);
|
|
||||||
musycc_intr0_rx_eom(sc, ch);
|
|
||||||
} else if (er == 13) { /* SHT */
|
|
||||||
musycc_intr0_tx_eom(sc, ch);
|
|
||||||
musycc_intr0_rx_eom(sc, ch);
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
#endif
|
|
||||||
default:
|
default:
|
||||||
|
musycc_intr0_tx_eom(sc, ch);
|
||||||
|
musycc_intr0_rx_eom(sc, ch);
|
||||||
#if 1
|
#if 1
|
||||||
printf("huh ? %08x %d", u1, g);
|
printf("huh ? %08x %d", u1, g);
|
||||||
printf("/%s", u1 & 0x80000000 ? "T" : "R");
|
printf("/%s", u1 & 0x80000000 ? "T" : "R");
|
||||||
@ -954,6 +994,7 @@ musycc_rcvmsg(node_p node, item_p item, hook_p lasthook)
|
|||||||
}
|
}
|
||||||
s = (char *)resp->data;
|
s = (char *)resp->data;
|
||||||
status_8370(sc, s);
|
status_8370(sc, s);
|
||||||
|
status_chans(sc,s);
|
||||||
resp->header.arglen = strlen(s) + 1;
|
resp->header.arglen = strlen(s) + 1;
|
||||||
NG_FREE_MSG(msg);
|
NG_FREE_MSG(msg);
|
||||||
|
|
||||||
@ -1083,6 +1124,7 @@ musycc_rcvdata(hook_p hook, item_p item)
|
|||||||
md = &sc->mdt[ch][sch->tx_next_md];
|
md = &sc->mdt[ch][sch->tx_next_md];
|
||||||
if ((md->status & 0x80000000) != 0x00000000) {
|
if ((md->status & 0x80000000) != 0x00000000) {
|
||||||
printf("Out of tx md\n");
|
printf("Out of tx md\n");
|
||||||
|
sch->last_txerr = time_second;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -1101,6 +1143,7 @@ musycc_rcvdata(hook_p hook, item_p item)
|
|||||||
}
|
}
|
||||||
u |= m->m_len;
|
u |= m->m_len;
|
||||||
md->status = u;
|
md->status = u;
|
||||||
|
sch->last_xmit = time_second;
|
||||||
}
|
}
|
||||||
m = m->m_next;
|
m = m->m_next;
|
||||||
}
|
}
|
||||||
@ -1183,7 +1226,7 @@ musycc_connect(hook_p hook)
|
|||||||
* 1 timeslot, 50 bytes packets -> 68msec
|
* 1 timeslot, 50 bytes packets -> 68msec
|
||||||
* 31 timeslots, 50 bytes packets -> 14msec
|
* 31 timeslots, 50 bytes packets -> 14msec
|
||||||
*/
|
*/
|
||||||
sch->nmd = nmd = 10 + nts * 2;
|
sch->nmd = nmd = 40 + nts * 4;
|
||||||
sch->rx_last_md = 0;
|
sch->rx_last_md = 0;
|
||||||
sch->tx_next_md = 0;
|
sch->tx_next_md = 0;
|
||||||
sch->tx_last_md = 0;
|
sch->tx_last_md = 0;
|
||||||
|
183
sys/pci/if_mn.c
183
sys/pci/if_mn.c
@ -177,6 +177,7 @@ static void m32_dump(struct softc *sc);
|
|||||||
static void f54_dump(struct softc *sc);
|
static void f54_dump(struct softc *sc);
|
||||||
static void mn_fmt_ts(char *p, u_int32_t ts);
|
static void mn_fmt_ts(char *p, u_int32_t ts);
|
||||||
#endif /* notyet */
|
#endif /* notyet */
|
||||||
|
static void f54_init(struct softc *sc);
|
||||||
|
|
||||||
static ng_constructor_t ngmn_constructor;
|
static ng_constructor_t ngmn_constructor;
|
||||||
static ng_rcvmsg_t ngmn_rcvmsg;
|
static ng_rcvmsg_t ngmn_rcvmsg;
|
||||||
@ -235,11 +236,15 @@ struct schan {
|
|||||||
u_long tx_limit;
|
u_long tx_limit;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
enum framing {WHOKNOWS, E1, E1U, T1, T1U};
|
||||||
|
|
||||||
struct softc {
|
struct softc {
|
||||||
int unit;
|
int unit;
|
||||||
device_t dev;
|
device_t dev;
|
||||||
struct resource *irq;
|
struct resource *irq;
|
||||||
void *intrhand;
|
void *intrhand;
|
||||||
|
enum framing framing;
|
||||||
|
int nhooks;
|
||||||
void *m0v, *m1v;
|
void *m0v, *m1v;
|
||||||
vm_offset_t m0p, m1p;
|
vm_offset_t m0p, m1p;
|
||||||
struct m32xreg *m32x;
|
struct m32xreg *m32x;
|
||||||
@ -280,25 +285,72 @@ ngmn_shutdown(node_p nodep)
|
|||||||
return (EINVAL);
|
return (EINVAL);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
ngmn_config(node_p node, char *set, char *ret)
|
||||||
|
{
|
||||||
|
struct softc *sc;
|
||||||
|
enum framing wframing;
|
||||||
|
|
||||||
|
sc = NG_NODE_PRIVATE(node);
|
||||||
|
|
||||||
|
if (set != NULL) {
|
||||||
|
if (!strncmp(set, "line ", 5)) {
|
||||||
|
wframing = sc->framing;
|
||||||
|
if (!strcmp(set, "line e1")) {
|
||||||
|
wframing = E1;
|
||||||
|
} else if (!strcmp(set, "line e1u")) {
|
||||||
|
wframing = E1U;
|
||||||
|
} else {
|
||||||
|
strcat(ret, "ENOGROK\n");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
if (wframing == sc->framing)
|
||||||
|
return;
|
||||||
|
if (sc->nhooks > 0) {
|
||||||
|
sprintf(ret, "Cannot change line when %d hooks open\n", sc->nhooks);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
sc->framing = wframing;
|
||||||
|
#if 1
|
||||||
|
f54_init(sc);
|
||||||
|
#else
|
||||||
|
mn_reset(sc);
|
||||||
|
#endif
|
||||||
|
} else {
|
||||||
|
printf("%s CONFIG SET [%s]\n", sc->nodename, set);
|
||||||
|
strcat(ret, "ENOGROK\n");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
static int
|
static int
|
||||||
ngmn_rcvmsg(node_p node, item_p item, hook_p lasthook)
|
ngmn_rcvmsg(node_p node, item_p item, hook_p lasthook)
|
||||||
{
|
{
|
||||||
struct softc *sc;
|
struct softc *sc;
|
||||||
struct ng_mesg *resp = NULL;
|
struct ng_mesg *resp = NULL;
|
||||||
struct schan *sch;
|
struct schan *sch;
|
||||||
char *arg;
|
char *s, *r;
|
||||||
int pos, i;
|
int pos, i;
|
||||||
struct ng_mesg *msg;
|
struct ng_mesg *msg;
|
||||||
|
|
||||||
NGI_GET_MSG(item, msg);
|
NGI_GET_MSG(item, msg);
|
||||||
sc = NG_NODE_PRIVATE(node);
|
sc = NG_NODE_PRIVATE(node);
|
||||||
|
|
||||||
if (msg->header.typecookie != NGM_GENERIC_COOKIE ||
|
if (msg->header.typecookie != NGM_GENERIC_COOKIE) {
|
||||||
|
NG_FREE_ITEM(item);
|
||||||
|
NG_FREE_MSG(msg);
|
||||||
|
return (EINVAL);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (msg->header.cmd != NGM_TEXT_CONFIG &&
|
||||||
msg->header.cmd != NGM_TEXT_STATUS) {
|
msg->header.cmd != NGM_TEXT_STATUS) {
|
||||||
NG_FREE_ITEM(item);
|
NG_FREE_ITEM(item);
|
||||||
NG_FREE_MSG(msg);
|
NG_FREE_MSG(msg);
|
||||||
return (EINVAL);
|
return (EINVAL);
|
||||||
}
|
}
|
||||||
|
|
||||||
NG_MKRESPONSE(resp, msg, sizeof(struct ng_mesg) + NG_TEXTRESPONSE,
|
NG_MKRESPONSE(resp, msg, sizeof(struct ng_mesg) + NG_TEXTRESPONSE,
|
||||||
M_NOWAIT);
|
M_NOWAIT);
|
||||||
if (resp == NULL) {
|
if (resp == NULL) {
|
||||||
@ -306,21 +358,22 @@ ngmn_rcvmsg(node_p node, item_p item, hook_p lasthook)
|
|||||||
NG_FREE_MSG(msg);
|
NG_FREE_MSG(msg);
|
||||||
return (ENOMEM);
|
return (ENOMEM);
|
||||||
}
|
}
|
||||||
arg = (char *)resp->data;
|
|
||||||
pos = 0;
|
|
||||||
pos += sprintf(pos + arg,"Framer status %b;\n", sc->framer_state, "\20"
|
|
||||||
"\40LOS\37AIS\36LFA\35RRA"
|
|
||||||
"\34AUXP\33NMF\32LMFA\31frs0.0"
|
|
||||||
"\30frs1.7\27TS16RA\26TS16LOS\25TS16AIS"
|
|
||||||
"\24TS16LFA\23frs1.2\22XLS\21XLO"
|
|
||||||
"\20RS1\17rsw.6\16RRA\15RY0"
|
|
||||||
"\14RY1\13RY2\12RY3\11RY4"
|
|
||||||
"\10SI1\7SI2\6rsp.5\5rsp.4"
|
|
||||||
"\4rsp.3\3RSIF\2RS13\1RS15");
|
|
||||||
pos += sprintf(pos + arg," Framing errors: %lu", sc->cnt_fec);
|
|
||||||
pos += sprintf(pos + arg," Code Violations: %lu\n", sc->cnt_cvc);
|
|
||||||
|
|
||||||
pos += sprintf(pos + arg," Falc State %b;\n", sc->falc_state, "\20"
|
if (msg->header.arglen)
|
||||||
|
s = (char *)msg->data;
|
||||||
|
else
|
||||||
|
s = NULL;
|
||||||
|
r = (char *)resp->data;
|
||||||
|
*r = '\0';
|
||||||
|
|
||||||
|
if (msg->header.cmd == NGM_TEXT_CONFIG) {
|
||||||
|
ngmn_config(node, s, r);
|
||||||
|
resp->header.arglen = strlen(r) + 1;
|
||||||
|
FREE(msg, M_NETGRAPH);
|
||||||
|
return (0);
|
||||||
|
}
|
||||||
|
pos = 0;
|
||||||
|
pos += sprintf(pos + r,"Framer status %b;\n", sc->framer_state, "\20"
|
||||||
"\40LOS\37AIS\36LFA\35RRA"
|
"\40LOS\37AIS\36LFA\35RRA"
|
||||||
"\34AUXP\33NMF\32LMFA\31frs0.0"
|
"\34AUXP\33NMF\32LMFA\31frs0.0"
|
||||||
"\30frs1.7\27TS16RA\26TS16LOS\25TS16AIS"
|
"\30frs1.7\27TS16RA\26TS16LOS\25TS16AIS"
|
||||||
@ -329,7 +382,19 @@ ngmn_rcvmsg(node_p node, item_p item, hook_p lasthook)
|
|||||||
"\14RY1\13RY2\12RY3\11RY4"
|
"\14RY1\13RY2\12RY3\11RY4"
|
||||||
"\10SI1\7SI2\6rsp.5\5rsp.4"
|
"\10SI1\7SI2\6rsp.5\5rsp.4"
|
||||||
"\4rsp.3\3RSIF\2RS13\1RS15");
|
"\4rsp.3\3RSIF\2RS13\1RS15");
|
||||||
pos += sprintf(pos + arg, " Falc IRQ %b\n", sc->falc_irq, "\20"
|
pos += sprintf(pos + r," Framing errors: %lu", sc->cnt_fec);
|
||||||
|
pos += sprintf(pos + r," Code Violations: %lu\n", sc->cnt_cvc);
|
||||||
|
|
||||||
|
pos += sprintf(pos + r," Falc State %b;\n", sc->falc_state, "\20"
|
||||||
|
"\40LOS\37AIS\36LFA\35RRA"
|
||||||
|
"\34AUXP\33NMF\32LMFA\31frs0.0"
|
||||||
|
"\30frs1.7\27TS16RA\26TS16LOS\25TS16AIS"
|
||||||
|
"\24TS16LFA\23frs1.2\22XLS\21XLO"
|
||||||
|
"\20RS1\17rsw.6\16RRA\15RY0"
|
||||||
|
"\14RY1\13RY2\12RY3\11RY4"
|
||||||
|
"\10SI1\7SI2\6rsp.5\5rsp.4"
|
||||||
|
"\4rsp.3\3RSIF\2RS13\1RS15");
|
||||||
|
pos += sprintf(pos + r, " Falc IRQ %b\n", sc->falc_irq, "\20"
|
||||||
"\40RME\37RFS\36T8MS\35RMB\34CASC\33CRC4\32SA6SC\31RPF"
|
"\40RME\37RFS\36T8MS\35RMB\34CASC\33CRC4\32SA6SC\31RPF"
|
||||||
"\30b27\27RDO\26ALLS\25XDU\24XMB\23b22\22XLSC\21XPR"
|
"\30b27\27RDO\26ALLS\25XDU\24XMB\23b22\22XLSC\21XPR"
|
||||||
"\20FAR\17LFA\16MFAR\15T400MS\14AIS\13LOS\12RAR\11RA"
|
"\20FAR\17LFA\16MFAR\15T400MS\14AIS\13LOS\12RAR\11RA"
|
||||||
@ -339,39 +404,39 @@ ngmn_rcvmsg(node_p node, item_p item, hook_p lasthook)
|
|||||||
continue;
|
continue;
|
||||||
sch = sc->ch[i];
|
sch = sc->ch[i];
|
||||||
|
|
||||||
pos += sprintf(arg + pos, " Chan %d <%s> ",
|
pos += sprintf(r + pos, " Chan %d <%s> ",
|
||||||
i, NG_HOOK_NAME(sch->hook));
|
i, NG_HOOK_NAME(sch->hook));
|
||||||
|
|
||||||
pos += sprintf(arg + pos, " Last Rx: ");
|
pos += sprintf(r + pos, " Last Rx: ");
|
||||||
if (sch->last_recv)
|
if (sch->last_recv)
|
||||||
pos += sprintf(arg + pos, "%lu s", time_second - sch->last_recv);
|
pos += sprintf(r + pos, "%lu s", time_second - sch->last_recv);
|
||||||
else
|
else
|
||||||
pos += sprintf(arg + pos, "never");
|
pos += sprintf(r + pos, "never");
|
||||||
|
|
||||||
pos += sprintf(arg + pos, ", last RxErr: ");
|
pos += sprintf(r + pos, ", last RxErr: ");
|
||||||
if (sch->last_rxerr)
|
if (sch->last_rxerr)
|
||||||
pos += sprintf(arg + pos, "%lu s", time_second - sch->last_rxerr);
|
pos += sprintf(r + pos, "%lu s", time_second - sch->last_rxerr);
|
||||||
else
|
else
|
||||||
pos += sprintf(arg + pos, "never");
|
pos += sprintf(r + pos, "never");
|
||||||
|
|
||||||
pos += sprintf(arg + pos, ", last Tx: ");
|
pos += sprintf(r + pos, ", last Tx: ");
|
||||||
if (sch->last_xmit)
|
if (sch->last_xmit)
|
||||||
pos += sprintf(arg + pos, "%lu s\n", time_second - sch->last_xmit);
|
pos += sprintf(r + pos, "%lu s\n", time_second - sch->last_xmit);
|
||||||
else
|
else
|
||||||
pos += sprintf(arg + pos, "never\n");
|
pos += sprintf(r + pos, "never\n");
|
||||||
|
|
||||||
pos += sprintf(arg + pos, " RX error(s) %lu", sch->rx_error);
|
pos += sprintf(r + pos, " RX error(s) %lu", sch->rx_error);
|
||||||
pos += sprintf(arg + pos, " Short: %lu", sch->short_error);
|
pos += sprintf(r + pos, " Short: %lu", sch->short_error);
|
||||||
pos += sprintf(arg + pos, " CRC: %lu", sch->crc_error);
|
pos += sprintf(r + pos, " CRC: %lu", sch->crc_error);
|
||||||
pos += sprintf(arg + pos, " Mod8: %lu", sch->dribble_error);
|
pos += sprintf(r + pos, " Mod8: %lu", sch->dribble_error);
|
||||||
pos += sprintf(arg + pos, " Long: %lu", sch->long_error);
|
pos += sprintf(r + pos, " Long: %lu", sch->long_error);
|
||||||
pos += sprintf(arg + pos, " Abort: %lu", sch->abort_error);
|
pos += sprintf(r + pos, " Abort: %lu", sch->abort_error);
|
||||||
pos += sprintf(arg + pos, " Overflow: %lu\n", sch->overflow_error);
|
pos += sprintf(r + pos, " Overflow: %lu\n", sch->overflow_error);
|
||||||
|
|
||||||
pos += sprintf(arg + pos, " Last error: %b Prev error: %b\n",
|
pos += sprintf(r + pos, " Last error: %b Prev error: %b\n",
|
||||||
sch->last_error, "\20\7SHORT\5CRC\4MOD8\3LONG\2ABORT\1OVERRUN",
|
sch->last_error, "\20\7SHORT\5CRC\4MOD8\3LONG\2ABORT\1OVERRUN",
|
||||||
sch->prev_error, "\20\7SHORT\5CRC\4MOD8\3LONG\2ABORT\1OVERRUN");
|
sch->prev_error, "\20\7SHORT\5CRC\4MOD8\3LONG\2ABORT\1OVERRUN");
|
||||||
pos += sprintf(arg + pos, " Xmit bytes pending %ld\n",
|
pos += sprintf(r + pos, " Xmit bytes pending %ld\n",
|
||||||
sch->tx_pending);
|
sch->tx_pending);
|
||||||
}
|
}
|
||||||
resp->header.arglen = pos + 1;
|
resp->header.arglen = pos + 1;
|
||||||
@ -395,9 +460,17 @@ ngmn_newhook(node_p node, hook_p hook, const char *name)
|
|||||||
return (EINVAL);
|
return (EINVAL);
|
||||||
|
|
||||||
ts = mn_parse_ts(name + 2, &nbit);
|
ts = mn_parse_ts(name + 2, &nbit);
|
||||||
|
printf("%d bits %x\n", nbit, ts);
|
||||||
|
if (sc->framing == E1 && (ts & 1))
|
||||||
|
return (EINVAL);
|
||||||
|
if (sc->framing == E1U && nbit != 32)
|
||||||
|
return (EINVAL);
|
||||||
if (ts == 0)
|
if (ts == 0)
|
||||||
return (EINVAL);
|
return (EINVAL);
|
||||||
chan = ffs(ts) - 1;
|
if (sc->framing == E1)
|
||||||
|
chan = ffs(ts) - 1;
|
||||||
|
else
|
||||||
|
chan = 1;
|
||||||
if (!sc->ch[chan])
|
if (!sc->ch[chan])
|
||||||
mn_create_channel(sc, chan);
|
mn_create_channel(sc, chan);
|
||||||
else if (sc->ch[chan]->state == UP)
|
else if (sc->ch[chan]->state == UP)
|
||||||
@ -406,6 +479,7 @@ ngmn_newhook(node_p node, hook_p hook, const char *name)
|
|||||||
sc->ch[chan]->hook = hook;
|
sc->ch[chan]->hook = hook;
|
||||||
sc->ch[chan]->tx_limit = nbit * 8;
|
sc->ch[chan]->tx_limit = nbit * 8;
|
||||||
NG_HOOK_SET_PRIVATE(hook, sc->ch[chan]);
|
NG_HOOK_SET_PRIVATE(hook, sc->ch[chan]);
|
||||||
|
sc->nhooks++;
|
||||||
return(0);
|
return(0);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -440,24 +514,24 @@ mn_parse_ts(const char *s, int *nbit)
|
|||||||
char *p;
|
char *p;
|
||||||
|
|
||||||
r = 0;
|
r = 0;
|
||||||
j = 0;
|
j = -1;
|
||||||
*nbit = 0;
|
*nbit = 0;
|
||||||
while(*s) {
|
while(*s) {
|
||||||
i = strtol(s, &p, 0);
|
i = strtol(s, &p, 0);
|
||||||
if (i < 1 || i > 31)
|
if (i < 0 || i > 31)
|
||||||
return (0);
|
return (0);
|
||||||
while (j && j < i) {
|
while (j != -1 && j < i) {
|
||||||
r |= 1 << j++;
|
r |= 1 << j++;
|
||||||
(*nbit)++;
|
(*nbit)++;
|
||||||
}
|
}
|
||||||
j = 0;
|
j = -1;
|
||||||
r |= 1 << i;
|
r |= 1 << i;
|
||||||
(*nbit)++;
|
(*nbit)++;
|
||||||
if (*p == ',') {
|
if (*p == ',') {
|
||||||
s = p + 1;
|
s = p + 1;
|
||||||
continue;
|
continue;
|
||||||
} else if (*p == '-') {
|
} else if (*p == '-') {
|
||||||
j = i;
|
j = i + 1;
|
||||||
s = p + 1;
|
s = p + 1;
|
||||||
continue;
|
continue;
|
||||||
} else if (!*p) {
|
} else if (!*p) {
|
||||||
@ -477,8 +551,8 @@ mn_fmt_ts(char *p, u_int32_t ts)
|
|||||||
int j;
|
int j;
|
||||||
|
|
||||||
s = "";
|
s = "";
|
||||||
ts &= 0xfffffffe;
|
ts &= 0xffffffff;
|
||||||
for (j = 1; j < 32; j++) {
|
for (j = 0; j < 32; j++) {
|
||||||
if (!(ts & (1 << j)))
|
if (!(ts & (1 << j)))
|
||||||
continue;
|
continue;
|
||||||
sprintf(p, "%s%d", s, j);
|
sprintf(p, "%s%d", s, j);
|
||||||
@ -572,6 +646,7 @@ ngmn_rcvdata(hook_p hook, item_p item)
|
|||||||
sch->tx_pending , m->m_pkthdr.len, m);
|
sch->tx_pending , m->m_pkthdr.len, m);
|
||||||
#endif
|
#endif
|
||||||
sch->tx_pending += m->m_pkthdr.len;
|
sch->tx_pending += m->m_pkthdr.len;
|
||||||
|
sc->m32x->txpoll &= ~(1 << chan);
|
||||||
}
|
}
|
||||||
return (0);
|
return (0);
|
||||||
}
|
}
|
||||||
@ -608,7 +683,10 @@ ngmn_connect(hook_p hook)
|
|||||||
/* Init the receiver & xmitter to HDLC */
|
/* Init the receiver & xmitter to HDLC */
|
||||||
sc->m32_mem.cs[chan].flags = 0x80e90006;
|
sc->m32_mem.cs[chan].flags = 0x80e90006;
|
||||||
/* Allocate two buffers per timeslot */
|
/* Allocate two buffers per timeslot */
|
||||||
sc->m32_mem.cs[chan].itbs = nts * 2;
|
if (nts == 32)
|
||||||
|
sc->m32_mem.cs[chan].itbs = 63;
|
||||||
|
else
|
||||||
|
sc->m32_mem.cs[chan].itbs = nts * 2;
|
||||||
|
|
||||||
/* Setup a transmit chain with one descriptor */
|
/* Setup a transmit chain with one descriptor */
|
||||||
/* XXX: we actually send a 1 byte packet */
|
/* XXX: we actually send a 1 byte packet */
|
||||||
@ -744,6 +822,7 @@ ngmn_disconnect(hook_p hook)
|
|||||||
sc->ch[chan]->x1 = dp2 = dp->vnext;
|
sc->ch[chan]->x1 = dp2 = dp->vnext;
|
||||||
mn_free_desc(dp);
|
mn_free_desc(dp);
|
||||||
}
|
}
|
||||||
|
sc->nhooks--;
|
||||||
return(0);
|
return(0);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -829,6 +908,9 @@ m32_init(struct softc *sc)
|
|||||||
#if 1
|
#if 1
|
||||||
sc->m32x->mode2 = 0x00000081;
|
sc->m32x->mode2 = 0x00000081;
|
||||||
sc->m32x->txpoll = 0xffffffff;
|
sc->m32x->txpoll = 0xffffffff;
|
||||||
|
#elif 1
|
||||||
|
sc->m32x->mode2 = 0x00000081;
|
||||||
|
sc->m32x->txpoll = 0xffffffff;
|
||||||
#else
|
#else
|
||||||
sc->m32x->mode2 = 0x00000101;
|
sc->m32x->mode2 = 0x00000101;
|
||||||
#endif
|
#endif
|
||||||
@ -856,13 +938,19 @@ f54_init(struct softc *sc)
|
|||||||
|
|
||||||
sc->f54w->fmr0 = 0xf0; /* X: HDB3, R: HDB3 */
|
sc->f54w->fmr0 = 0xf0; /* X: HDB3, R: HDB3 */
|
||||||
sc->f54w->fmr1 = 0x0e; /* Send CRC4, 2Mbit, ECM */
|
sc->f54w->fmr1 = 0x0e; /* Send CRC4, 2Mbit, ECM */
|
||||||
sc->f54w->fmr2 = 0x03; /* Auto Rem-Alarm, Auto resync */
|
if (sc->framing == E1)
|
||||||
|
sc->f54w->fmr2 = 0x03; /* Auto Rem-Alarm, Auto resync */
|
||||||
|
else if (sc->framing == E1U)
|
||||||
|
sc->f54w->fmr2 = 0x33; /* dais, rtm, Auto Rem-Alarm, Auto resync */
|
||||||
|
|
||||||
sc->f54w->lim1 = 0xb0; /* XCLK=8kHz, .62V threshold */
|
sc->f54w->lim1 = 0xb0; /* XCLK=8kHz, .62V threshold */
|
||||||
sc->f54w->pcd = 0x0a;
|
sc->f54w->pcd = 0x0a;
|
||||||
sc->f54w->pcr = 0x15;
|
sc->f54w->pcr = 0x15;
|
||||||
sc->f54w->xsw = 0x9f; /* fmr4 */
|
sc->f54w->xsw = 0x9f; /* fmr4 */
|
||||||
sc->f54w->xsp = 0x1c; /* fmr5 */
|
if (sc->framing == E1)
|
||||||
|
sc->f54w->xsp = 0x1c; /* fmr5 */
|
||||||
|
else if (sc->framing == E1U)
|
||||||
|
sc->f54w->xsp = 0x3c; /* tt0, fmr5 */
|
||||||
sc->f54w->xc0 = 0x07;
|
sc->f54w->xc0 = 0x07;
|
||||||
sc->f54w->xc1 = 0x3d;
|
sc->f54w->xc1 = 0x3d;
|
||||||
sc->f54w->rc0 = 0x05;
|
sc->f54w->rc0 = 0x05;
|
||||||
@ -1253,6 +1341,7 @@ mn_attach (device_t self)
|
|||||||
|
|
||||||
sc->dev = self;
|
sc->dev = self;
|
||||||
sc->unit = device_get_unit(self);
|
sc->unit = device_get_unit(self);
|
||||||
|
sc->framing = E1;
|
||||||
sprintf(sc->name, "mn%d", sc->unit);
|
sprintf(sc->name, "mn%d", sc->unit);
|
||||||
|
|
||||||
rid = PCIR_MAPS;
|
rid = PCIR_MAPS;
|
||||||
|
Loading…
Reference in New Issue
Block a user