catarrh/simtrace2
1
0
Fork 0
mirror of https://gitea.osmocom.org/sim-card/simtrace2.git synced 2026-03-16 21:28:33 +03:00
Code Issues Packages Projects Releases Wiki Activity

WIP: Introduce support for asynchronous USB transmission

Browse Source 
Change-Id: Ib8939bdb7f533cd20a34a30a97f12b782b9816c2
This commit is contained in:
Harald Welte
2020-02-22 16:45:05 +01:00
parent 823f453d83
commit 4e9beae46a
2 changed files with 69 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
host/include/osmocom/simtrace2/simtrace2_api.h
View File

@@ -12,6 +12,8 @@ struct osmo_st2_transport {
uint8_t out; uint8_t out;
uint8_t irq_in; uint8_t irq_in;
} usb_ep; } usb_ep;
/* use non-blocking / asynchronous libusb I/O */
bool usb_async;
/* UDP */ /* UDP */
int udp_fd; int udp_fd;
@@ -39,8 +41,6 @@ struct osmo_st2_cardem_inst {
void *priv; void *priv;
}; };
int osmo_st2_transp_tx_msg(struct osmo_st2_transport *transp, struct msgb *msg);
int osmo_st2_slot_tx_msg(struct osmo_st2_slot *slot, struct msgb *msg, int osmo_st2_slot_tx_msg(struct osmo_st2_slot *slot, struct msgb *msg,
uint8_t msg_class, uint8_t msg_type); uint8_t msg_class, uint8_t msg_type);

74
host/lib/simtrace2_api.c
View File

@@ -57,23 +57,60 @@ static struct msgb *st_msgb_alloc(void)
return msgb_alloc_headroom(1024+32, 32, "SIMtrace"); return msgb_alloc_headroom(1024+32, 32, "SIMtrace");
} }
/*! \brief Transmit a given command to the SIMtrace2 device */
int osmo_st2_transp_tx_msg(struct osmo_st2_transport *transp, struct msgb *msg) static void usb_out_xfer_cb(struct libusb_transfer *xfer)
{ {
struct msgb *msg = xfer->user_data;
switch (xfer->status) {
case LIBUSB_TRANSFER_COMPLETED:
break;
case LIBUSB_TRANSFER_NO_DEVICE:
fprintf(stderr, "USB device disappeared\n");
exit(1);
break;
default:
fprintf(stderr, "USB OUT transfer failed, status=%u\n", xfer->status);
exit(1);
break;
}
msgb_free(msg);
libusb_free_transfer(xfer);
}
static int st2_transp_tx_msg_usb_async(struct osmo_st2_transport *transp, struct msgb *msg)
{
struct libusb_transfer *xfer;
int rc; int rc;
printf("<- %s\n", msgb_hexdump(msg)); xfer = libusb_alloc_transfer(0);
OSMO_ASSERT(xfer);
xfer->dev_handle = transp->usb_devh;
xfer->flags = 0;
xfer->type = LIBUSB_TRANSFER_TYPE_BULK;
xfer->endpoint = transp->usb_ep.out;
xfer->timeout = 100000;
xfer->user_data = msg;
xfer->length = msgb_length(msg);
xfer->buffer = msgb_data(msg);
xfer->callback = usb_out_xfer_cb;
if (transp->udp_fd < 0) { rc = libusb_submit_transfer(xfer);
OSMO_ASSERT(rc == 0);
return rc;
}
/*! \brief Transmit a given command to the SIMtrace2 device */
static int st2_transp_tx_msg_usb_sync(struct osmo_st2_transport *transp, struct msgb *msg)
{
int rc;
int xfer_len; int xfer_len;
rc = libusb_bulk_transfer(transp->usb_devh, transp->usb_ep.out, rc = libusb_bulk_transfer(transp->usb_devh, transp->usb_ep.out,
msgb_data(msg), msgb_length(msg), msgb_data(msg), msgb_length(msg),
&xfer_len, 100000); &xfer_len, 100000);
} else {
rc = write(transp->udp_fd, msgb_data(msg), msgb_length(msg));
}
msgb_free(msg); msgb_free(msg);
return rc; return rc;
} }
@@ -98,9 +135,24 @@ static struct simtrace_msg_hdr *st_push_hdr(struct msgb *msg, uint8_t msg_class,
int osmo_st2_slot_tx_msg(struct osmo_st2_slot *slot, struct msgb *msg, int osmo_st2_slot_tx_msg(struct osmo_st2_slot *slot, struct msgb *msg,
uint8_t msg_class, uint8_t msg_type) uint8_t msg_class, uint8_t msg_type)
{ {
st_push_hdr(msg, msg_class, msg_type, slot->slot_nr); struct osmo_st2_transport *transp = slot->transp;
int rc;
return osmo_st2_transp_tx_msg(slot->transp, msg); OSMO_ASSERT(transp);
st_push_hdr(msg, msg_class, msg_type, slot->slot_nr);
printf("SIMtrace <- %s\n", msgb_hexdump(msg));
if (transp->udp_fd < 0) {
if (transp->usb_async)
rc = st2_transp_tx_msg_usb_async(transp, msg);
else
rc = st2_transp_tx_msg_usb_sync(transp, msg);
} else {
rc = write(transp->udp_fd, msgb_data(msg), msgb_length(msg));
msgb_free(msg);
}
return rc;
} }
/*********************************************************************** /***********************************************************************