+// =============================================================================
+// bitrate
+
+
+// helper function to analyse bitrate speed specifications
+static int bitrate_analyse (int nb, const char **com, int *ports) {
+
+ int i=0, s;
+
+
+ while ( i<nb-1 ) {
+ s=parseBitrate(com[i+1]);
+ if ( strcmp(com[i], "inout")==0 ) {
+ ports[0]=s;
+ ports[1]=s;
+ } else if ( strcmp(com[i], "in")==0 ) {
+ ports[0]=s;
+ } else if ( strcmp(com[i], "out")==0 ) {
+ ports[1]=s;
+ } else {
+ break;
+ }
+ i+=2;
+ }
+
+
+ return i;
+
+}
+
+
+static bool do_bitrate_set (int nb, const char **com, struct ngadmin *nga) {
+
+ int i, k=0, defs[]={12, 12}, p, *ports=NULL;
+ const struct swi_attr *sa;
+ bool ret=true;
+
+
+ if ( nb<2 ) {
+ printf("Usage: bitrate set [all SPEEDSPEC] <port1> SPEEDSPEC [<port2> SPEEDSPEC ...]\n");
+ printf("SPEEDSPEC: [inout <speed>] [in <ispeed>] [out <ospeed>]\n");
+ ret=false;
+ goto end;
+ }
+
+ if ( (sa=ngadmin_getCurrentSwitch(nga))==NULL ) {
+ printf("must be logged\n");
+ ret=false;
+ goto end;
+ }
+
+ ports=malloc(2*sa->ports*sizeof(int));
+
+ // get defaults if present
+ if ( strcmp(com[k], "all")==0 ) {
+ ++k;
+ k+=bitrate_analyse(nb-k, &com[k], defs);
+ }
+
+ // apply defaults
+ for (i=0; i<sa->ports; ++i) {
+ memcpy(&ports[2*i], defs, sizeof(defs));
+ }
+
+ // get ports specifics
+ while ( k<nb ) {
+ p=strtol(com[k++], NULL, 0)-1;
+ if ( p>=0 && p<sa->ports ) {
+ k+=bitrate_analyse(nb-k, &com[k], &ports[2*p]);
+ }
+ }
+
+ // send it to the switch
+ i=ngadmin_setBitrateLimits(nga, ports);
+ printErrCode(i);
+
+
+ end:
+ free(ports);
+
+ return ret;
+
+}
+
+
+
+static bool do_bitrate_show (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
+
+ int i, ret=true, *ports=NULL;
+ const struct swi_attr *sa;
+
+
+ if ( (sa=ngadmin_getCurrentSwitch(nga))==NULL ) {
+ printf("must be logged\n");
+ ret=false;
+ goto end;
+ }
+
+
+ ports=malloc(2*sa->ports*sizeof(int));
+ if ( (i=ngadmin_getBitrateLimits(nga, ports))!=ERR_OK ) {
+ printErrCode(i);
+ ret=false;
+ goto end;
+ }
+
+ for (i=0; i<sa->ports; ++i) {
+ printf("port %i: in %s, out %s\n", i+1, bitrates[ports[2*i+0]], bitrates[ports[2*i+1]]);
+ }
+
+ end:
+ free(ports);
+
+ return ret;
+
+}
+
+
+
+// =============================================================================
+// defaults
+
+
+static bool do_defaults (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga UNUSED) {
+
+ int i, ret=true;
+ const struct swi_attr *sa;
+ char line[16];
+
+
+ if ( (sa=ngadmin_getCurrentSwitch(nga))==NULL ) {
+ printf("must be logged\n");
+ ret=false;
+ goto end;
+ }
+
+
+ printf("The switch settings will be CLEARED. Continue ? [y/N]: ");
+ fflush(stdout);
+
+ if ( fgets(line, sizeof(line), stdin)!=NULL && strcasecmp(line, "y\n")==0 ) {
+ i=ngadmin_defaults(nga);
+ printErrCode(i);
+ }
+
+
+ end:
+
+ return ret;
+
+}
+
+
+
// =============================================================================
// firmware
-static bool do_ports_stats_reset (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
+static bool do_ports_statistics_reset (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
int i;
-static bool do_ports_stats_show (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
+static bool do_ports_statistics_show (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
int i;
const struct swi_attr *sa;
ret=false;
goto end;
}
-
+
ps=calloc(sa->ports, sizeof(struct port_stats));
if ( (i=ngadmin_getPortsStatistics(nga, ps))<0 ) {
printErrCode(i);
goto end;
}
- printf("Port\tReceived\tSent\t\tCRC errors\n");
+ printf("Port\tReceived\tSent\tCRC errors\n");
for (i=0; i<sa->ports; ++i) {
- printf("%i\t%8llu\t%8llu\t%8llu\n", i+1, ps[i].recv, ps[i].sent, ps[i].crc);
+ printf("% 4i%12llu%12llu%14llu\n", i+1, ps[i].recv, ps[i].sent, ps[i].crc);
}
end:
+
+// =============================================================================
+// qos
+
+
+
+static bool do_qos_mode (int nb, const char **com, struct ngadmin *nga) {
+
+ int i, s, ret=true;
+ const struct swi_attr *sa;
+
+
+ if ( nb==0 ) {
+ printf("Usage: qos mode port|802.1p\n");
+ goto end;
+ }
+
+ if ( (sa=ngadmin_getCurrentSwitch(nga))==NULL ) {
+ printf("must be logged\n");
+ ret=false;
+ goto end;
+ }
+
+
+ if ( strcasecmp(com[0], "port")==0 ) {
+ s=QOS_PORT;
+ } else if ( strcasecmp(com[0], "802.1p")==0 ) {
+ s=QOS_DOT;
+ } else {
+ printf("Unknown QOS mode\n");
+ ret=false;
+ goto end;
+ }
+
+
+ i=ngadmin_setQOSMode(nga, s);
+ printErrCode(i);
+
+
+ end:
+
+ return ret;
+
+}
+
+
+
+static bool do_qos_set (int nb, const char **com, struct ngadmin *nga) {
+
+ int i, p;
+ const struct swi_attr *sa;
+ bool ret=true;
+ char d=PRIO_UNSPEC, *ports=NULL;
+
+
+ if ( nb<2 ) {
+ printf("Usage: qos set (all <prio0>)|(<port1> <prio1> [<port2> <prio2> ...])\n");
+ ret=false;
+ goto end;
+ }
+
+ if ( (sa=ngadmin_getCurrentSwitch(nga))==NULL ) {
+ printf("must be logged\n");
+ ret=false;
+ goto end;
+ }
+
+
+ ports=malloc(sa->ports*sizeof(char));
+
+ if ( strcmp(com[0], "all")==0 ) {
+ d=parsePrio(com[1]);
+ com+=2;
+ nb-=2;
+ }
+
+ for (i=0; i<sa->ports; ++i) {
+ ports[i]=d;
+ }
+
+ for (i=0; i<nb; i+=2) {
+ if ( (p=strtol(com[i], NULL, 0))<1 || p>sa->ports ) continue;
+ ports[p-1]=parsePrio(com[i+1]);
+ }
+
+
+ i=ngadmin_setQOSValues(nga, ports);
+ printErrCode(i);
+
+
+ end:
+ free(ports);
+
+ return ret;
+
+}
+
+
+
+static bool do_qos_show (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
+
+ int i, s=0, ret=true;
+ const struct swi_attr *sa;
+ char *ports=NULL;
+
+
+ if ( (sa=ngadmin_getCurrentSwitch(nga))==NULL ) {
+ printf("must be logged\n");
+ ret=false;
+ goto end;
+ }
+
+ if ( (i=ngadmin_getQOSMode(nga, &s))!=ERR_OK ) {
+ printErrCode(i);
+ ret=false;
+ goto end;
+ }
+
+
+ printf("QOS mode: ");
+
+ if ( s==QOS_DOT ) {
+ printf("802.1p\n");
+ goto end;
+ } else if ( s!=QOS_PORT ) {
+ printf("unknown (%i)\n", s);
+ goto end;
+ }
+
+ printf("port based\n");
+
+ ports=malloc(sa->ports*sizeof(char));
+
+ if ( (i=ngadmin_getQOSValues(nga, ports))!=ERR_OK ) {
+ printErrCode(i);
+ ret=false;
+ goto end;
+ }
+
+ for (i=0; i<sa->ports; ++i) {
+ printf("port %i: %s\n", i+1, prio[(int)ports[i]]);
+ }
+
+
+ end:
+ free(ports);
+
+ return ret;
+
+}
+
+
+
// =============================================================================
// quit
// =============================================================================
-// scan
+// restart
-static bool do_scan (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
+static bool do_restart (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga UNUSED) {
- int i;
+ int i, ret=true;
const struct swi_attr *sa;
+ char line[16];
- if ( (i=ngadmin_scan(nga))<0 ) {
+ if ( (sa=ngadmin_getCurrentSwitch(nga))==NULL ) {
+ printf("must be logged\n");
+ ret=false;
+ goto end;
+ }
+
+
+ printf("The switch will be restarted. Continue ? [y/N]: ");
+ fflush(stdout);
+
+ if ( fgets(line, sizeof(line), stdin)!=NULL && strcasecmp(line, "y\n")==0 ) {
+ i=ngadmin_restart(nga);
printErrCode(i);
- return false;
}
- sa=ngadmin_getSwitchTab(nga, &nb);
- displaySwitchTab(sa, nb);
+ end:
- return true;
+ return ret;
}
// =============================================================================
-// stormfilt
+// scan
-static bool do_stormfilt_enable (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
+static bool do_scan (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
int i;
const struct swi_attr *sa;
- if ( (sa=ngadmin_getCurrentSwitch(nga))==NULL ) {
- printf("must be logged\n");
+ if ( (i=ngadmin_scan(nga))<0 ) {
+ printErrCode(i);
return false;
}
- i=ngadmin_setStormFilterState(nga, 1);
- printErrCode(i);
+ sa=ngadmin_getSwitchTab(nga, &nb);
+ displaySwitchTab(sa, nb);
return true;
-static bool do_stormfilt_disable (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
+// =============================================================================
+// stormfilter
+
+
+static bool do_stormfilter_enable (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
int i;
const struct swi_attr *sa;
return false;
}
- i=ngadmin_setStormFilterState(nga, 0);
+ i=ngadmin_setStormFilterState(nga, 1);
printErrCode(i);
-static bool do_stormfilt_reset (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
+static bool do_stormfilter_disable (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
- int i, *ports=NULL;
+ int i;
const struct swi_attr *sa;
- bool ret=true;
if ( (sa=ngadmin_getCurrentSwitch(nga))==NULL ) {
printf("must be logged\n");
- ret=false;
- goto end;
- }
-
-
- ports=malloc(sa->ports*sizeof(int));
- for (i=0; i<sa->ports; ++i) {
- ports[i]=BITRATE_NOLIMIT;
+ return false;
}
- i=ngadmin_setStormFilterValues(nga, ports);
+ i=ngadmin_setStormFilterState(nga, 0);
printErrCode(i);
- end:
- free(ports);
-
- return ret;
+ return true;
}
-static bool do_stormfilt_set (int nb, const char **com, struct ngadmin *nga) {
+static bool do_stormfilter_set (int nb, const char **com, struct ngadmin *nga) {
- int i, p, *ports=NULL;
+ int i, d=BITRATE_UNSPEC, p, *ports=NULL;
const struct swi_attr *sa;
bool ret=true;
- if ( nb==0 ) {
- printf("Usage: stormfilt set <port1> <speed1> [<port2> <speed2> ...]\n");
+ if ( nb<2 ) {
+ printf("Usage: stormfilt set (all <speed0>)|(<port1> <speed1> [<port2> <speed2> ...])\n");
ret=false;
goto end;
}
-
if ( (sa=ngadmin_getCurrentSwitch(nga))==NULL ) {
printf("must be logged\n");
ret=false;
ports=malloc(sa->ports*sizeof(int));
+
+ if ( strcmp(com[0], "all")==0 ) {
+ d=parseBitrate(com[1]);
+ com+=2;
+ nb-=2;
+ }
+
for (i=0; i<sa->ports; ++i) {
- ports[i]=BITRATE_UNSPEC;
+ ports[i]=d;
}
for (i=0; i<nb; i+=2) {
-static bool do_stormfilt_show (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
+static bool do_stormfilter_show (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga) {
int i, s, ret=true, *ports=NULL;
const struct swi_attr *sa;
}
for (i=0; i<sa->ports; ++i) {
- printf("port %i: ", i+1);
- printBitrate(ports[i]);
+ printf("port %i: %s\n", i+1, bitrates[ports[i]]);
}
end:
+// =============================================================================
+// tree
+
+
+static void display_node (const struct TreeNode *tn, int depth) {
+
+ int i;
+ const struct TreeNode *s;
+
+
+ for (i=0; i<depth; ++i) {
+ putchar('\t');
+ }
+
+ puts(tn->name);
+
+ if ( tn->sub==NULL ) return;
+
+ for (s=tn->sub; s->name!=NULL; ++s) {
+ display_node(s, depth+1);
+ }
+
+
+}
+
+
+static bool do_tree (int nb UNUSED, const char **com UNUSED, struct ngadmin *nga UNUSED) {
+
+
+ display_node(&coms, 0);
+
+
+ return true;
+
+}
+
+
+
// =============================================================================
COM_ROOT_START(coms)
+ COM_START(bitrate)
+ COM_TERM(set, do_bitrate_set, true)
+ COM_TERM(show, do_bitrate_show, false)
+ COM_END
+
+ COM_TERM(cabletest, NULL, true)
+
+ COM_TERM(defaults, do_defaults, false)
+
COM_START(firmware)
COM_TERM(show, do_firmware_show, false)
COM_TERM(upgrade, do_firmware_upgrade, true)
COM_END
+ COM_START(igmp)
+ COM_TERM(set, NULL, false)
+ COM_TERM(show, NULL, false)
+ COM_END
+
COM_TERM(list, do_list, false)
COM_TERM(login, do_login, true)
+ COM_START(mirror)
+ COM_TERM(enable, NULL, false)
+ COM_TERM(disable, NULL, false)
+ COM_TERM(set, NULL, true)
+ COM_TERM(show, NULL, false)
+ COM_END
+
COM_START(name)
COM_TERM(show, do_name_show, false)
COM_TERM(set, do_name_set, true)
COM_TERM(clear, do_name_clear, false)
COM_END
+ COM_START(netconf)
+ COM_TERM(show, NULL, false)
+ COM_TERM(set, NULL, true)
+ COM_END
+
COM_START(password)
COM_TERM(change, do_password_change, true)
COM_TERM(set, do_password_set, true)
COM_START(ports)
COM_TERM(state, do_ports_state, false)
- COM_START(stats)
- COM_TERM(reset, do_ports_stats_reset, false)
- COM_TERM(show, do_ports_stats_show, false)
+ COM_START(statistics)
+ COM_TERM(reset, do_ports_statistics_reset, false)
+ COM_TERM(show, do_ports_statistics_show, false)
COM_END
COM_END
+ COM_START(qos)
+ COM_TERM(mode, do_qos_mode, true)
+ COM_TERM(set, do_qos_set, true)
+ COM_TERM(show, do_qos_show, false)
+ COM_END
+
COM_TERM(quit, do_quit, false)
+ COM_TERM(restart, do_restart, false)
+
COM_TERM(scan, do_scan, false)
- COM_START(stormfilt)
- COM_TERM(enable, do_stormfilt_enable, false)
- COM_TERM(disable, do_stormfilt_disable, false)
- COM_TERM(reset, do_stormfilt_reset, false)
- COM_TERM(set, do_stormfilt_set, true)
- COM_TERM(show, do_stormfilt_show, false)
+ COM_START(stormfilter)
+ COM_TERM(enable, do_stormfilter_enable, false)
+ COM_TERM(disable, do_stormfilter_disable, false)
+ COM_TERM(set, do_stormfilter_set, true)
+ COM_TERM(show, do_stormfilter_show, false)
+ COM_END
+
+ COM_TERM(tree, do_tree, false)
+
+ COM_START(vlan)
+ COM_TERM(show, NULL, false)
+ COM_TERM(mode, NULL, true)
COM_END
COM_ROOT_END
projects / ngadmin / blobdiff