diff options
Diffstat (limited to 'xpp/mpptalk.c')
| -rw-r--r-- | xpp/mpptalk.c | 915 |
1 files changed, 915 insertions, 0 deletions
diff --git a/xpp/mpptalk.c b/xpp/mpptalk.c new file mode 100644 index 0000000..a8bf12a --- /dev/null +++ b/xpp/mpptalk.c @@ -0,0 +1,915 @@ +/* + * Written by Oron Peled <oron@actcom.co.il> + * Copyright (C) 2008, Xorcom + * + * All rights reserved. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + * + */ + +#include <stdio.h> +#include <string.h> +#include <assert.h> +#include <errno.h> +#include <arpa/inet.h> +#include "hexfile.h" +#include "astribank_usb.h" +#include "mpp.h" +#include "mpptalk.h" +#include <debug.h> +#include <xusb.h> +#include <xtalk.h> + +static const char rcsid[] = "$Id$"; + +#define DBG_MASK 0x02 + +const char *ack_status_msg(uint8_t status) +{ + const static char *msgs[] = { + [STAT_OK] = "Acknowledges previous command", + [STAT_FAIL] = "Last command failed", + [STAT_RESET_FAIL] = "Reset failed", + [STAT_NODEST] = "No destination is selected", + [STAT_MISMATCH] = "Data mismatch", + [STAT_NOACCESS] = "No access", + [STAT_BAD_CMD] = "Bad command", + [STAT_TOO_SHORT] = "Packet is too short", + [STAT_ERROFFS] = "Offset error", + [STAT_NOCODE] = "Source was not burned before", + [STAT_NO_LEEPROM] = "Large EEPROM was not found", + [STAT_NO_EEPROM] = "No EEPROM was found", + [STAT_WRITE_FAIL] = "Writing to device failed", + [STAT_FPGA_ERR] = "FPGA error", + [STAT_KEY_ERR] = "Bad Capabilities Key", + [STAT_NOCAPS_ERR] = "No matching capability", + [STAT_NOPWR_ERR] = "No power on USB connector", + [STAT_CAPS_FPGA_ERR] = "Setting of the capabilities while FPGA is loaded", + }; + if(status > sizeof(msgs)/sizeof(msgs[0])) + return "ERROR CODE TOO LARGE"; + if(!msgs[status]) + return "MISSING ERROR CODE"; + return msgs[status]; +} + +const char *eeprom_type2str(int et) +{ + const static char *msgs[] = { + [EEPROM_TYPE_NONE] = "NONE", + [EEPROM_TYPE_SMALL] = "SMALL", + [EEPROM_TYPE_LARGE] = "LARGE", + [EEPROM_TYPE_UNUSED] = "UNUSED", + }; + if(et > sizeof(msgs)/sizeof(msgs[0])) + return NULL; + return msgs[et]; +}; + +const char *dev_dest2str(int dest) +{ + const static char *msgs[] = { + [DEST_NONE] = "NONE", + [DEST_FPGA] = "FPGA", + [DEST_EEPROM] = "EEPROM", + }; + if(dest > sizeof(msgs)/sizeof(msgs[0])) + return NULL; + return msgs[dest]; +}; + +union XTALK_PDATA(MPP) { + MEMBER(MPP, STATUS_GET); + MEMBER(MPP, STATUS_GET_REPLY); + MEMBER(MPP, EEPROM_SET); + MEMBER(MPP, CAPS_GET); + MEMBER(MPP, CAPS_GET_REPLY); + MEMBER(MPP, CAPS_SET); + MEMBER(MPP, EXTRAINFO_GET); + MEMBER(MPP, EXTRAINFO_GET_REPLY); + MEMBER(MPP, EXTRAINFO_SET); + MEMBER(MPP, RENUM); + MEMBER(MPP, EEPROM_BLK_RD); + MEMBER(MPP, EEPROM_BLK_RD_REPLY); + MEMBER(MPP, DEV_SEND_SEG); + MEMBER(MPP, DEV_SEND_START); + MEMBER(MPP, DEV_SEND_END); + MEMBER(MPP, RESET); + MEMBER(MPP, HALF_RESET); + MEMBER(MPP, SER_SEND); + MEMBER(MPP, SER_RECV); + /* Twinstar */ + MEMBER(MPP, TWS_WD_MODE_SET); + MEMBER(MPP, TWS_WD_MODE_GET); + MEMBER(MPP, TWS_WD_MODE_GET_REPLY); + MEMBER(MPP, TWS_PORT_SET); + MEMBER(MPP, TWS_PORT_GET); + MEMBER(MPP, TWS_PORT_GET_REPLY); + MEMBER(MPP, TWS_PWR_GET); + MEMBER(MPP, TWS_PWR_GET_REPLY); +} PACKED members; + +struct xtalk_protocol astribank_proto = { + .name = "ABNK", + .proto_version = 0x14, + .commands = { + CMD_SEND(MPP, STATUS_GET), + CMD_RECV(MPP, STATUS_GET_REPLY, NULL), + CMD_SEND(MPP, EEPROM_SET), + CMD_SEND(MPP, CAPS_GET), + CMD_RECV(MPP, CAPS_GET_REPLY, NULL), + CMD_SEND(MPP, CAPS_SET), + CMD_SEND(MPP, EXTRAINFO_GET), + CMD_RECV(MPP, EXTRAINFO_GET_REPLY, NULL), + CMD_SEND(MPP, EXTRAINFO_SET), + CMD_SEND(MPP, RENUM), + CMD_SEND(MPP, EEPROM_BLK_RD), + CMD_RECV(MPP, EEPROM_BLK_RD_REPLY, NULL), + CMD_SEND(MPP, DEV_SEND_SEG), + CMD_SEND(MPP, DEV_SEND_START), + CMD_SEND(MPP, DEV_SEND_END), + CMD_SEND(MPP, RESET), + CMD_SEND(MPP, HALF_RESET), + CMD_SEND(MPP, SER_SEND), + CMD_SEND(MPP, SER_RECV), + /* Twinstar */ + CMD_SEND(MPP, TWS_WD_MODE_SET), + CMD_SEND(MPP, TWS_WD_MODE_GET), + CMD_RECV(MPP, TWS_WD_MODE_GET_REPLY, NULL), + CMD_SEND(MPP, TWS_PORT_SET), + CMD_SEND(MPP, TWS_PORT_GET), + CMD_RECV(MPP, TWS_PORT_GET_REPLY, NULL), + CMD_SEND(MPP, TWS_PWR_GET), + CMD_RECV(MPP, TWS_PWR_GET_REPLY, NULL), + }, + .ack_statuses = { + } +}; + +struct cmd_queue { + struct cmd_queue *next; + struct cmd_queue *prev; + struct xtalk_command *cmd; +}; + +static struct cmd_queue output_queue = { + .next = &output_queue, + .prev = &output_queue, + .cmd = NULL + }; + +void dump_command(struct xtalk_command *cmd) +{ + uint16_t len; + int i; + + len = cmd->header.len; + if(len < sizeof(struct mpp_header)) { + ERR("Command too short (%d)\n", len); + return; + } + INFO("DUMP: OP=0x%X len=%d seq=%d\n", + cmd->header.op, cmd->header.len, cmd->header.seq); + for(i = 0; i < len - sizeof(struct mpp_header); i++) { + INFO(" %2d. 0x%X\n", i, cmd->alt.raw_data[i]); + } +} + + +static int set_ihex_version(char *dst, const char *src) +{ + memcpy(dst, src, VERSION_LEN); + return 0; +} + +/* + * Protocol Commands + */ + +int mpp_status_query(struct astribank_device *astribank) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_STATUS_GET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + astribank->eeprom_type = 0x3 & (CMD_FIELD(reply, MPP, STATUS_GET_REPLY, i2cs_data) >> 3); + astribank->status = CMD_FIELD(reply, MPP, STATUS_GET_REPLY, status); + astribank->fw_versions = CMD_FIELD(reply, MPP, STATUS_GET_REPLY, fw_versions); + DBG("EEPROM TYPE: %02x\n", astribank->eeprom_type); + DBG("FPGA Firmware: %s\n", (astribank->status & 0x1) ? "Loaded" : "Empty"); + DBG("Firmware Versions: USB='%s' FPGA='%s' EEPROM='%s'\n", + astribank->fw_versions.usb, + astribank->fw_versions.fpga, + astribank->fw_versions.eeprom); + free_command(reply); + return ret; +} + +int mpp_eeprom_set(struct astribank_device *astribank, const struct eeprom_table *et) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_EEPROM_SET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + memcpy(&CMD_FIELD(cmd, MPP, EEPROM_SET, data), et, sizeof(*et)); + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + free_command(reply); + return 0; +} + +int mpp_renumerate(struct astribank_device *astribank) +{ + struct xtalk_command *cmd; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_RENUM, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + ret = process_command(xtalk_dev, cmd, NULL); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + return 0; +} + +int mpp_caps_get(struct astribank_device *astribank, + struct eeprom_table *eeprom_table, + struct capabilities *capabilities, + struct capkey *key) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_CAPS_GET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + assert(reply->header.op == MPP_CAPS_GET_REPLY); + if(eeprom_table) { + memcpy(eeprom_table, (void *)&CMD_FIELD(reply, MPP, CAPS_GET_REPLY, data), sizeof(*eeprom_table)); + } + if(capabilities) { + const struct capabilities *cap = &CMD_FIELD(reply, MPP, CAPS_GET_REPLY, capabilities); + + memcpy(capabilities, cap, sizeof(*capabilities)); + } + if(key) { + const struct capkey *k = &CMD_FIELD(reply, MPP, CAPS_GET_REPLY, key); + + memcpy(key, k, sizeof(*key)); + } + free_command(reply); + return 0; +} + +int mpp_caps_set(struct astribank_device *astribank, + const struct eeprom_table *eeprom_table, + const struct capabilities *capabilities, + const struct capkey *key) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_CAPS_SET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + memcpy(&CMD_FIELD(cmd, MPP, CAPS_SET, data), eeprom_table, sizeof(*eeprom_table)); + memcpy(&CMD_FIELD(cmd, MPP, CAPS_SET, capabilities), capabilities, sizeof(*capabilities)); + memcpy(&CMD_FIELD(cmd, MPP, CAPS_SET, key), key, sizeof(*key)); + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + free_command(reply); + return 0; +} + +int mpp_extrainfo_get(struct astribank_device *astribank, struct extrainfo *info) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_EXTRAINFO_GET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + assert(reply->header.op == MPP_EXTRAINFO_GET_REPLY); + if(info) { + memcpy(info, (void *)&CMD_FIELD(reply, MPP, EXTRAINFO_GET_REPLY, info), sizeof(*info)); + } + free_command(reply); + return 0; +} + +int mpp_extrainfo_set(struct astribank_device *astribank, const struct extrainfo *info) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_EXTRAINFO_SET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + memcpy(&CMD_FIELD(cmd, MPP, EXTRAINFO_SET, info), info, sizeof(*info)); + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + free_command(reply); + return 0; +} + +int mpp_eeprom_blk_rd(struct astribank_device *astribank, uint8_t *buf, uint16_t offset, uint16_t len) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + int size; + + DBG("len = %d, offset = %d\n", len, offset); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_EEPROM_BLK_RD, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + CMD_FIELD(cmd, MPP, EEPROM_BLK_RD, len) = len; + CMD_FIELD(cmd, MPP, EEPROM_BLK_RD, offset) = offset; + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + size = ret; + goto out; + } + size = reply->header.len - sizeof(struct mpp_header) - sizeof(XTALK_STRUCT(MPP, EEPROM_BLK_RD_REPLY)); + INFO("size=%d offset=0x%X\n", size, CMD_FIELD(reply, MPP, EEPROM_BLK_RD_REPLY, offset)); + dump_packet(LOG_DEBUG, DBG_MASK, "BLK_RD", (char *)reply, ret); + if(size > len) { + ERR("Truncating reply (was %d, now %d)\n", size, len); + size = len; + } + memcpy(buf, CMD_FIELD(reply, MPP, EEPROM_BLK_RD_REPLY, data), size); +out: + free_command(reply); + return size; +} + +int mpp_send_start(struct astribank_device *astribank, int dest, const char *ihex_version) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply = NULL; + struct xtalk_device *xtalk_dev; + int ret = 0; + + DBG("dest = %s ihex_version = '%s'\n", dev_dest2str(dest), ihex_version); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_DEV_SEND_START, 0)) == NULL) { + ERR("new_command failed\n"); + ret = -ENOMEM; + goto out; + } + CMD_FIELD(cmd, MPP, DEV_SEND_START, dest) = dest; + set_ihex_version(CMD_FIELD(cmd, MPP, DEV_SEND_START, ihex_version), ihex_version); + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + goto out; + } +out: + if(reply) + free_command(reply); + astribank->burn_state = (ret == 0) + ? BURN_STATE_STARTED + : BURN_STATE_FAILED; + return ret; +} + +int mpp_send_end(struct astribank_device *astribank) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply = NULL; + struct xtalk_device *xtalk_dev; + int ret = 0; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_DEV_SEND_END, 0)) == NULL) { + ERR("new_command failed\n"); + ret = -ENOMEM; + goto out; + } + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + goto out; + } +out: + if(reply) + free_command(reply); + astribank->burn_state = (ret == 0) + ? BURN_STATE_ENDED + : BURN_STATE_FAILED; + return ret; +} + +int mpp_send_seg(struct astribank_device *astribank, const uint8_t *data, uint16_t offset, uint16_t len) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if(!astribank->burn_state == BURN_STATE_STARTED) { + ERR("Tried to send a segment while burn_state=%d\n", + astribank->burn_state); + return -EINVAL; + } + DBG("len = %d, offset = %d (0x%02X, 0x%02X)\n", len, offset, *data, *(data + 1)); + if((cmd = new_command(xtalk_dev, MPP_DEV_SEND_SEG, len)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + CMD_FIELD(cmd, MPP, DEV_SEND_SEG, offset) = offset; + memcpy(CMD_FIELD(cmd, MPP, DEV_SEND_SEG, data), data, len); +#if 0 + { + FILE *fp; + if((fp = fopen("seg_data.bin", "a")) == NULL) { + perror("seg_data.bin"); + exit(1); + } + if(fwrite(CMD_FIELD(cmd, MPP, DEV_SEND_SEG, data), len, 1, fp) != 1) { + perror("fwrite"); + exit(1); + } + fclose(fp); + } +#endif + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + free_command(reply); + return 0; +} + +int mpp_reset(struct astribank_device *astribank, int full_reset) +{ + struct xtalk_command *cmd; + struct xtalk_device *xtalk_dev; + int ret; + int op = (full_reset) ? MPP_RESET: MPP_HALF_RESET; + + DBG("full = %s\n", (full_reset) ? "YES" : "NO"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, op, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + ret = process_command(xtalk_dev, cmd, NULL); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + return 0; +} + +int mpp_serial_cmd(struct astribank_device *astribank, const uint8_t *in, uint8_t *out, uint16_t len) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + uint8_t *data; + + DBG("len=%d\n", len); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_SER_SEND, len)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + data = CMD_FIELD(cmd, MPP, SER_SEND, data); + memcpy(data, in, len); + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + assert(reply->header.op == MPP_SER_RECV); + data = CMD_FIELD(reply, MPP, SER_RECV, data); + memcpy(out, data, len); + free_command(reply); + return 0; +} + +int mpps_card_info(struct astribank_device *astribank, int unit, uint8_t *card_type, uint8_t *card_status) +{ + struct card_info_send { + uint8_t ser_op; + uint8_t addr; + } *card_info_send; + struct card_info_recv { + uint8_t ser_op_undef; /* invalid data */ + uint8_t addr; + uint8_t card_full_type; /* (type << 4 | subtype) */ + uint8_t card_status; /* BIT(0) - PIC burned */ + } *card_info_recv; + uint8_t in[sizeof(struct card_info_recv)]; + uint8_t out[sizeof(struct card_info_recv)]; + int len; + int ret; + + len = sizeof(struct card_info_recv); + memset(in, 0, len); + memset(out, 0, len); + card_info_send = (struct card_info_send *)∈ + card_info_recv = (struct card_info_recv *)&out; + card_info_send->ser_op = SER_CARD_INFO_GET; + card_info_send->addr = (unit << 4); /* low nibble is subunit */ + ret = mpp_serial_cmd(astribank, in, out, len); + if(ret < 0) + return ret; + *card_type = card_info_recv->card_full_type; + *card_status = card_info_recv->card_status; + return 0; +} + +int mpp_tws_watchdog(struct astribank_device *astribank) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_TWS_WD_MODE_GET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + ret = CMD_FIELD(reply, MPP, TWS_WD_MODE_GET_REPLY, wd_active); + DBG("wd_active=0x%X\n", ret); + free_command(reply); + return ret == 1; +} + +int mpp_tws_setwatchdog(struct astribank_device *astribank, int yes) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("%s\n", (yes) ? "YES" : "NO"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_TWS_WD_MODE_SET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + CMD_FIELD(cmd, MPP, TWS_WD_MODE_SET, wd_active) = (yes) ? 1 : 0; + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + free_command(reply); + return 0; +} + +int mpp_tws_powerstate(struct astribank_device *astribank) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_TWS_PWR_GET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + ret = CMD_FIELD(reply, MPP, TWS_PWR_GET_REPLY, power); + DBG("power=0x%X\n", ret); + free_command(reply); + return ret; +} + +int mpp_tws_portnum(struct astribank_device *astribank) +{ + struct xtalk_command *cmd; + struct xtalk_command *reply; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if((cmd = new_command(xtalk_dev, MPP_TWS_PORT_GET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + ret = process_command(xtalk_dev, cmd, &reply); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + ret = CMD_FIELD(reply, MPP, TWS_PORT_GET_REPLY, portnum); + DBG("portnum=0x%X\n", ret); + free_command(reply); + return ret; +} + +int mpp_tws_setportnum(struct astribank_device *astribank, uint8_t portnum) +{ + struct xtalk_command *cmd; + struct xtalk_device *xtalk_dev; + int ret; + + DBG("\n"); + assert(astribank != NULL); + xtalk_dev = astribank->xtalk_dev; + if(portnum >= 2) { + ERR("Invalid portnum (%d)\n", portnum); + return -EINVAL; + } + if((cmd = new_command(xtalk_dev, MPP_TWS_PORT_SET, 0)) == NULL) { + ERR("new_command failed\n"); + return -ENOMEM; + } + CMD_FIELD(cmd, MPP, TWS_PORT_SET, portnum) = portnum; + ret = process_command(xtalk_dev, cmd, NULL); + if(ret < 0) { + ERR("process_command failed: %d\n", ret); + return ret; + } + return 0; +} + +/* Adapters for xusb ops */ +static inline int xusb_close_func(void *priv) +{ + return xusb_close((struct xusb *)priv); +} + +static inline int xusb_send_func(void *priv, void *data, size_t len, int timeout) +{ + return xusb_send((struct xusb *)priv, data, len, timeout); +} + +static inline int xusb_recv_func(void *priv, void *data, size_t maxlen, int timeout) +{ + return xusb_recv((struct xusb *)priv, data, maxlen, timeout); +} + + +static struct xtalk_ops xusb_ops = { + .send_func = xusb_send_func, + .recv_func = xusb_recv_func, + .close_func = xusb_close_func, +}; + +/* + * Wrappers + */ + +struct astribank_device *mpp_init(const char devpath[], int iface_num) +{ + struct astribank_device *astribank = NULL; + struct xtalk_device *xtalk_dev = NULL; + struct xusb *xusb = NULL; + int packet_size; + int ret; + + DBG("devpath='%s' iface_num=%d\n", devpath, iface_num); + if((astribank = astribank_open(devpath, iface_num)) == NULL) { + ERR("Opening astribank failed\n"); + goto err; + } + xusb = astribank->xusb; + packet_size = xusb_packet_size(xusb); + if((xtalk_dev = xtalk_new(&xusb_ops, packet_size, xusb)) == NULL) { + ERR("Allocating new XTALK device failed\n"); + goto err; + } + astribank->xtalk_dev = xtalk_dev; + ret = xtalk_set_protocol(xtalk_dev, &astribank_proto); + if(ret < 0) { + ERR("MPP Protocol registration failed: %d\n", ret); + goto err; + } + ret = xtalk_proto_query(xtalk_dev); + if(ret < 0) { + ERR("Protocol handshake failed: %d\n", ret); + goto err; + } + ret = mpp_status_query(astribank); + if(ret < 0) { + ERR("Status query failed: %d\n", ret); + goto err; + } + return astribank; + +err: + if (astribank) { + astribank_close(astribank, 0); + astribank = NULL; + } + if(xtalk_dev) { + xtalk_delete(xtalk_dev); + xtalk_dev = NULL; + } + return NULL; +} + +void mpp_exit(struct astribank_device *astribank) +{ + DBG("\n"); + astribank_close(astribank, 0); +} + +/* + * data structures + */ + +void show_eeprom(const struct eeprom_table *eprm, FILE *fp) +{ + int rmajor = (eprm->release >> 8) & 0xFF; + int rminor = eprm->release & 0xFF;; + char buf[BUFSIZ]; + + memset(buf, 0, LABEL_SIZE + 1); + memcpy(buf, eprm->label, LABEL_SIZE); + fprintf(fp, "EEPROM: %-15s: 0x%02X\n", "Source", eprm->source); + fprintf(fp, "EEPROM: %-15s: 0x%04X\n", "Vendor", eprm->vendor); + fprintf(fp, "EEPROM: %-15s: 0x%04X\n", "Product", eprm->product); + fprintf(fp, "EEPROM: %-15s: %d.%d\n", "Release", rmajor, rminor); + fprintf(fp, "EEPROM: %-15s: 0x%02X\n", "Config", eprm->config_byte); + fprintf(fp, "EEPROM: %-15s: '%s'\n", "Label", buf); +} + +void show_capabilities(const struct capabilities *capabilities, FILE *fp) +{ + fprintf(fp, "Capabilities: FXS ports: %2d\n", capabilities->ports_fxs); + fprintf(fp, "Capabilities: FXO ports: %2d\n", capabilities->ports_fxo); + fprintf(fp, "Capabilities: BRI ports: %2d\n", capabilities->ports_bri); + fprintf(fp, "Capabilities: PRI ports: %2d\n", capabilities->ports_pri); + fprintf(fp, "Capabilities: ECHO ports: %2d\n", capabilities->ports_echo); + fprintf(fp, "Capabilities: TwinStar : %s\n", + (CAP_EXTRA_TWINSTAR(capabilities)) ? "Yes" : "No"); +} + +void show_astribank_status(struct astribank_device *astribank, FILE *fp) +{ + char version_buf[BUFSIZ]; + int is_loaded = STATUS_FPGA_LOADED(astribank->status); + + fprintf(fp, "Astribank: EEPROM : %s\n", + eeprom_type2str(astribank->eeprom_type)); + fprintf(fp, "Astribank: FPGA status : %s\n", + is_loaded ? "Loaded" : "Empty"); + if(is_loaded) { + memset(version_buf, 0, sizeof(version_buf)); + memcpy(version_buf, astribank->fw_versions.fpga, VERSION_LEN); + fprintf(fp, "Astribank: FPGA version: %s\n", + version_buf); + } +} + +void show_extrainfo(const struct extrainfo *extrainfo, FILE *fp) +{ + fprintf(fp, "Extrainfo: : %s\n", (const char *)(extrainfo->text)); +} + +int twinstar_show(struct astribank_device *astribank, FILE *fp) +{ + int watchdog; + int powerstate; + int portnum; + int i; + + if(!astribank_has_twinstar(astribank)) { + fprintf(fp, "TwinStar: NO\n"); + return 0; + } + if((watchdog = mpp_tws_watchdog(astribank)) < 0) { + ERR("Failed getting TwinStar information\n"); + return watchdog; + } + if((powerstate = mpp_tws_powerstate(astribank)) < 0) { + ERR("Failed getting TwinStar powerstate\n"); + return powerstate; + } + if((portnum = mpp_tws_portnum(astribank)) < 0) { + ERR("Failed getting TwinStar portnum\n"); + return portnum; + } + fprintf(fp, "TwinStar: Connected to : USB-%1d\n", portnum); + fprintf(fp, "TwinStar: Watchdog : %s\n", + (watchdog) ? "on-guard" : "off-guard"); + for(i = 0; i < 2; i++) { + int pw = (1 << i) & powerstate; + + fprintf(fp, "TwinStar: USB-%1d POWER : %s\n", + i, (pw) ? "ON" : "OFF"); + } + return 0; +} |