212 lines
6.6 KiB
Plaintext
212 lines
6.6 KiB
Plaintext
module CCID_Emulation {
|
|
|
|
/* This module implements multiplexing/demultiplexing of USB CCID, enabling different
|
|
* TTCN-3 test components to talk to different CCID slots
|
|
*
|
|
* (C) 2019 by Harald Welte <laforge@gnumonks.org>
|
|
* All rights reserved.
|
|
*/
|
|
|
|
|
|
import from General_Types all;
|
|
import from Osmocom_Types all;
|
|
|
|
import from USB_Types all;
|
|
import from USB_Templates all;
|
|
import from USB_PortType all;
|
|
import from USB_PortTypes all;
|
|
import from USB_Component all;
|
|
|
|
import from CCID_Types all;
|
|
import from CCID_Templates all;
|
|
|
|
type enumerated CCID_Emulation_Event_UpDown {
|
|
CCID_EVENT_UP,
|
|
CCID_EVENT_DOWN
|
|
};
|
|
|
|
type union CCID_Emulation_Event {
|
|
CCID_Emulation_Event_UpDown up_down
|
|
};
|
|
|
|
type port CCID_SLOT_PT message {
|
|
inout CCID_PDU, CCID_Emulation_Event;
|
|
} with { extension "internal" }
|
|
|
|
type record CCID_Emulation_Params {
|
|
USB_Device_Match usb_dev_match
|
|
};
|
|
|
|
type component CCID_Emulation_CT extends USB_CT {
|
|
var integer g_interface;
|
|
var integer g_ep_in;
|
|
var integer g_ep_out;
|
|
var integer g_ep_irq;
|
|
var CCID_Emulation_Params g_pars;
|
|
|
|
var integer g_next_bseq := 0;
|
|
|
|
/* ports to the test components; one for each theoretically possible slot */
|
|
port CCID_SLOT_PT SLOT[256];
|
|
}
|
|
|
|
private const octetstring c_oct261 := '000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000'O;
|
|
|
|
private function f_usb_submit_xfer(USB_endpoint ep, octetstring data := c_oct261,
|
|
USB_transfer_type ttype := USB_TRANSFER_TYPE_BULK,
|
|
integer tout_ms := 30000) runs on CCID_Emulation_CT
|
|
{
|
|
var integer req_hdl := f_usb_get_req_hdl();
|
|
var USB_transfer xfer := {
|
|
device_hdl := g_dev_hdl,
|
|
transfer_hdl := req_hdl,
|
|
endpoint := ep,
|
|
ttype := ttype,
|
|
data := data,
|
|
timeout_msec := tout_ms
|
|
};
|
|
USB.send(xfer);
|
|
}
|
|
|
|
function main(CCID_Emulation_Params pars) runs on CCID_Emulation_CT {
|
|
var USB_transfer_compl tc;
|
|
var CCID_PDU ccid_in, ccid_out;
|
|
var integer i, v_i;
|
|
|
|
g_pars := pars;
|
|
|
|
f_usb_init(g_pars.usb_dev_match);
|
|
|
|
log(f_usb_get_desc_tree());
|
|
|
|
var integer i_config := f_usb_get_config();
|
|
var USB_Descriptor_Node root;
|
|
log("USB Configuration: ", i_config);
|
|
root := f_usb_get_desc_tree();
|
|
log(root);
|
|
|
|
/* iterate over list of interfaces in current configuration */
|
|
for (i := 0; i < lengthof(root.children[i_config].children); i:=i+1) {
|
|
var USB_Descriptor_Node ifn := root.children[i_config].children[i];
|
|
var USB_InterfaceDescriptor ifd := ifn.desc.interface;
|
|
/* Search for CCID interface */
|
|
if (ifd.bInterfaceClass == '0B'O and
|
|
ifd.bInterfaceSubClass == '00'O and ifd.bInterfaceProtocol == '00'O) {
|
|
g_interface := ifd.bInterfaceNumber;
|
|
var integer j;
|
|
/* determine endpoints inside interface */
|
|
for (j := 0; j < lengthof(ifn.children); j:=j+1) {
|
|
log("Iterating over ", ifn.children[j]);
|
|
if (ischosen(ifn.children[j].desc.endpoint)) {
|
|
var USB_EndpointDescriptor epd := ifn.children[j].desc.endpoint;
|
|
select (epd.bmAttributes.TranferType) {
|
|
case (USB_EpTransfer_BULK) {
|
|
if (epd.bEndpointAddress and4b '80'O == '80'O) {
|
|
g_ep_in := oct2int(epd.bEndpointAddress);
|
|
} else {
|
|
g_ep_out := oct2int(epd.bEndpointAddress);
|
|
}
|
|
}
|
|
case (USB_EpTransfer_INTERRUPT) {
|
|
g_ep_irq := oct2int(epd.bEndpointAddress);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
|
|
log("USB Endpoints found: IN: ", int2oct(g_ep_in, 1), ", OUT: ", int2oct(g_ep_out, 1),
|
|
" IRQ: ", int2oct(g_ep_irq, 1));
|
|
|
|
f_usb_claim_interface(g_dev_hdl, g_interface);
|
|
|
|
/* submit xfer fro IN and IRQ endpoints */
|
|
f_usb_submit_xfer(g_ep_in);
|
|
f_usb_submit_xfer(g_ep_irq, ttype := USB_TRANSFER_TYPE_INTERRUPT);
|
|
|
|
/* let everyone know we're alive and kicking */
|
|
for (i := 0; i < 256; i := i+1) {
|
|
if (SLOT[i].checkstate("Connected")) {
|
|
SLOT[i].send(CCID_Emulation_Event:{up_down:=CCID_EVENT_UP});
|
|
}
|
|
}
|
|
|
|
while (true) {
|
|
|
|
alt {
|
|
[] USB.receive(tr_UsbXfer_compl(g_ep_out, USB_TRANSFER_TYPE_BULK, USB_TRANSFER_COMPLETED,
|
|
g_dev_hdl, ?)) -> value tc {
|
|
/* do nothing; normal completion of OUT transfer */
|
|
}
|
|
[] USB.receive(tr_UsbXfer_compl(g_ep_in, USB_TRANSFER_TYPE_BULK, USB_TRANSFER_COMPLETED,
|
|
g_dev_hdl, ?)) -> value tc {
|
|
/* Submit another IN transfer */
|
|
f_usb_submit_xfer(g_ep_in);
|
|
/* forward to slot-specific port */
|
|
ccid_in := dec_CCID_PDU(tc.data);
|
|
SLOT[ccid_in.hdr.bSlot].send(ccid_in);
|
|
}
|
|
[] USB.receive(tr_UsbXfer_compl(g_ep_irq, USB_TRANSFER_TYPE_INTERRUPT,
|
|
USB_TRANSFER_COMPLETED, g_dev_hdl, ?)) -> value tc {
|
|
/* Submit another IRQ transfer */
|
|
f_usb_submit_xfer(g_ep_irq, ttype := USB_TRANSFER_TYPE_INTERRUPT);
|
|
/* forward to all slot-specific ports with connected components */
|
|
/*
|
|
ccid_in := dec_CCID_PDU(tc.data);
|
|
for (i := 0; i < 256; i := i+1) {
|
|
if (SLOT[i].checkstate("Connected")) {
|
|
SLOT[i].send(ccid_in);
|
|
}
|
|
}
|
|
*/
|
|
}
|
|
[] USB.receive(tr_UsbXfer_compl(g_ep_irq, USB_TRANSFER_TYPE_INTERRUPT,
|
|
USB_TRANSFER_TIMED_OUT, g_dev_hdl, ?)) -> value tc {
|
|
/* Submit another IRQ transfer */
|
|
f_usb_submit_xfer(g_ep_irq, ttype := USB_TRANSFER_TYPE_INTERRUPT);
|
|
}
|
|
[] USB.receive(tr_UsbXfer_compl(?, ?, USB_TRANSFER_ERROR, g_dev_hdl, ?)) -> value tc {
|
|
setverdict(fail, "Unexpected USB_TRANSFER_ERROR on EP ", int2hex(tc.endpoint, 2));
|
|
mtc.stop;
|
|
}
|
|
[] USB.receive(tr_UsbXfer_compl(?, ?, USB_TRANSFER_TIMED_OUT, g_dev_hdl, ?)) -> value tc {
|
|
setverdict(fail, "Unexpected USB_TRANSFER_TIMED_OUT on EP ", int2hex(tc.endpoint, 2));
|
|
mtc.stop;
|
|
}
|
|
[] USB.receive(tr_UsbXfer_compl(?, ?, USB_TRANSFER_OVERFLOW, g_dev_hdl, ?)) -> value tc {
|
|
setverdict(fail, "Unexpected USB_TRANSFER_OVERFLOW on EP ", int2hex(tc.endpoint, 2));
|
|
mtc.stop;
|
|
}
|
|
[] USB.receive(tr_UsbXfer_compl(?, ?, ?, g_dev_hdl, ?)) -> value tc {
|
|
setverdict(fail, "Unexpected USB Endpoint ", int2hex(tc.endpoint, 2));
|
|
mtc.stop;
|
|
}
|
|
[] USB.receive(tr_UsbXfer_compl(?, ?, ?, ?, ?)) -> value tc {
|
|
setverdict(fail, "Unexpected USB Device ", tc.device_hdl);
|
|
mtc.stop;
|
|
}
|
|
[] USB.receive {
|
|
setverdict(fail, "Unexpected Message from USB");
|
|
mtc.stop;
|
|
}
|
|
|
|
[] any from SLOT.receive(CCID_PDU:?) -> value ccid_out @index value v_i {
|
|
var octetstring bin;
|
|
ccid_out.hdr.bSlot := v_i;
|
|
ccid_out.hdr.bSeq := g_next_bseq;
|
|
g_next_bseq := (g_next_bseq + 1) mod 256;
|
|
bin := enc_CCID_PDU(ccid_out);
|
|
f_usb_submit_xfer(g_ep_out, bin, tout_ms := 3000);
|
|
}
|
|
|
|
|
|
} /* alt */
|
|
} /* while (true) */
|
|
}
|
|
|
|
|
|
|
|
}
|