- struct addrinfo hints;
- struct addrinfo *results, *res;
- int err;
-
- memset(&hints, 0, sizeof(hints));
- hints.ai_family = AF_UNSPEC;
- hints.ai_socktype = SOCK_STREAM;
- hints.ai_protocol = IPPROTO_TCP;
-
- err = getaddrinfo(tcp->address, tcp->port, &hints, &results);
-
- if (err) {
- sr_err("Address lookup failed: %s:%s: %s", tcp->address, tcp->port,
- gai_strerror(err));
- return SR_ERR;
- }
-
- for (res = results; res; res = res->ai_next) {
- if ((tcp->socket = socket(res->ai_family, res->ai_socktype,
- res->ai_protocol)) < 0)
- continue;
- if (connect(tcp->socket, res->ai_addr, res->ai_addrlen) != 0) {
- close(tcp->socket);
- tcp->socket = -1;
- continue;
- }
- break;
- }
-
- freeaddrinfo(results);
-
- if (tcp->socket < 0) {
- sr_err("Failed to connect to %s:%s: %s", tcp->address, tcp->port,
- g_strerror(errno));
- return SR_ERR;
- }
-
- return SR_OK;
+ struct addrinfo hints;
+ struct addrinfo *results, *res;
+ int err;
+
+ memset(&hints, 0, sizeof(hints));
+ hints.ai_family = AF_UNSPEC;
+ hints.ai_socktype = SOCK_STREAM;
+ hints.ai_protocol = IPPROTO_TCP;
+
+ err = getaddrinfo(tcp->address, tcp->port, &hints, &results);
+
+ if (err) {
+ sr_err("Address lookup failed: %s:%s: %s", tcp->address, tcp->port,
+ gai_strerror(err));
+ return SR_ERR;
+ }
+
+ for (res = results; res; res = res->ai_next) {
+ if ((tcp->socket = socket(res->ai_family, res->ai_socktype,
+ res->ai_protocol)) < 0)
+ continue;
+ if (connect(tcp->socket, res->ai_addr, res->ai_addrlen) != 0) {
+ close(tcp->socket);
+ tcp->socket = -1;
+ continue;
+ }
+ break;
+ }
+
+ freeaddrinfo(results);
+
+ if (tcp->socket < 0) {
+ sr_err("Failed to connect to %s:%s: %s", tcp->address, tcp->port,
+ g_strerror(errno));
+ return SR_ERR;
+ }
+
+ return SR_OK;
- int out;
-
- out = send(tcp->socket, (char*)buf, len, 0);
+ int out;
+ out = send(tcp->socket, (char*)buf, len, 0);
- if ((unsigned int)out < len) {
- sr_dbg("Only sent %d/%d bytes of data.", out, (int)len);
- }
+ if ((unsigned int)out < len) {
+ sr_dbg("Only sent %d/%d bytes of data.", out, (int)len);
+ }
int len;
len = recv(tcp->socket, (char*)(buf+received), bufsize-received, 0);
int len;
len = recv(tcp->socket, (char*)(buf+received), bufsize-received, 0);
{
devc->trigger_mask[i] = 0;
devc->trigger_value[i] = 0;
devc->trigger_mask_last[i] = 0;
devc->trigger_value_last[i] = 0;
{
devc->trigger_mask[i] = 0;
devc->trigger_value[i] = 0;
devc->trigger_mask_last[i] = 0;
devc->trigger_value_last[i] = 0;
- //sr_err("\nDATA_WITH_BYTES:%i\n",devc->DATA_WIDTH_BYTES);
-
-// devc->trigger_value[0] = 0x00;
-// devc->trigger_value_last[0] = 0xff;
-// devc->trigger_mask[0] = 0xff;
-// devc->trigger_mask_last[0] = 0xff;
-
-
- devc->num_stages = g_slist_length(trigger->stages);
- if (devc->num_stages != devc->DATA_WIDTH_BYTES)
- {
-
- sr_err("\nThis device only supports %d trigger stages.",
- devc->DATA_WIDTH_BYTES);
-
- return SR_ERR;
- }
-
devc->trigger_value[byteIndex] |= matchPattern;
devc->trigger_mask[byteIndex] |= matchPattern;
devc->trigger_mask_last[byteIndex] &= ~matchPattern;
devc->trigger_value[byteIndex] |= matchPattern;
devc->trigger_mask[byteIndex] |= matchPattern;
devc->trigger_mask_last[byteIndex] &= ~matchPattern;
devc->trigger_value[byteIndex] &= ~matchPattern;
devc->trigger_mask[byteIndex] |= matchPattern;
devc->trigger_mask_last[byteIndex] &= ~matchPattern;
devc->trigger_value[byteIndex] &= ~matchPattern;
devc->trigger_mask[byteIndex] |= matchPattern;
devc->trigger_mask_last[byteIndex] &= ~matchPattern;
devc->trigger_value_last[byteIndex] &= ~matchPattern;
devc->trigger_mask[byteIndex] |= matchPattern;
devc->trigger_mask_last[byteIndex] |= matchPattern;
devc->trigger_value_last[byteIndex] &= ~matchPattern;
devc->trigger_mask[byteIndex] |= matchPattern;
devc->trigger_mask_last[byteIndex] |= matchPattern;
devc->trigger_value_last[byteIndex] |= matchPattern;
devc->trigger_mask[byteIndex] |= matchPattern;
devc->trigger_mask_last[byteIndex] |= matchPattern;
devc->trigger_value_last[byteIndex] |= matchPattern;
devc->trigger_mask[byteIndex] |= matchPattern;
devc->trigger_mask_last[byteIndex] |= matchPattern;
-// sr_err("\n VAL LAST:%x\n",devc->trigger_value_last[0]);
-// sr_err("\n VAL:%x\n",devc->trigger_value[0]);
-// sr_err("\n MASK:%x\n",devc->trigger_mask[0]);
-// sr_err("\n MASK LAST:%x\n",devc->trigger_mask_last[0]);
-
(devc->delay_value >> 16) & 0x000000ff,
(devc->delay_value >> 24) & 0x000000ff};
(devc->delay_value >> 16) & 0x000000ff,
(devc->delay_value >> 24) & 0x000000ff};
- sendEscaping(tcp, buf, devc->ADDR_WIDTH_BYTES);
-
- //sr_warn("send delay_value: 0x%.2x", devc->delay_value);
+ for(size_t i = 0 ; i < devc->ADDR_WIDTH_BYTES ; ++i)
+ sendEscaping(tcp, &(buf[devc->ADDR_WIDTH_BYTES-1-i]), 1);
- sendEscaping(tcp, devc->trigger_mask, devc->DATA_WIDTH_BYTES);
-
- //sr_warn("send trigger_mask: %x", devc->trigger_mask[0]);
+ for(size_t k = 0 ; k < devc->DATA_WIDTH_BYTES ; ++k)
+ sendEscaping(tcp, devc->trigger_mask + devc->DATA_WIDTH_BYTES -1-k, 1);
- sendEscaping(tcp, devc->trigger_value, devc->DATA_WIDTH_BYTES);
-
- //sr_warn("send trigger_value: 0x%.2x", devc->trigger_value[0]);
-
+ for(size_t k = 0 ; k < devc->DATA_WIDTH_BYTES ; ++k)
+ sendEscaping(tcp, devc->trigger_value + devc->DATA_WIDTH_BYTES -1-k, 1);
- sendEscaping(tcp, devc->trigger_mask_last, devc->DATA_WIDTH_BYTES);
-
-
- //sr_warn("send trigger_mask_last: 0x%.2x", devc->trigger_mask_last[0]);
+ for(size_t k = 0 ; k < devc->DATA_WIDTH_BYTES ; ++k)
+ sendEscaping(tcp, devc->trigger_mask_last + devc->DATA_WIDTH_BYTES -1-k, 1);
- sendEscaping(tcp, devc->trigger_value_last, devc->DATA_WIDTH_BYTES);
+ for(size_t k = 0 ; k < devc->DATA_WIDTH_BYTES ; ++k)
+ sendEscaping(tcp, devc->trigger_value_last + devc->DATA_WIDTH_BYTES -1-k, 1);
+ /////////////////////////////////////////////edge_mask////////////////////////////////////////////////////////////
+ buf[0] = Trigger;
+ ipdbg_org_la_tcp_send(tcp, buf, 1);
+ buf[0] = Select_Edge_Mask;
+ ipdbg_org_la_tcp_send(tcp, buf, 1);
+ buf[0] = Set_Edge_Mask;
+ ipdbg_org_la_tcp_send(tcp, buf, 1);
+
+ for(size_t k = 0 ; k < devc->DATA_WIDTH_BYTES ; ++k)
+ sendEscaping(tcp, devc->trigger_edge_mask + devc->DATA_WIDTH_BYTES -1-k, 1);
devc->DATA_WIDTH_BYTES = (devc->DATA_WIDTH+HOST_WORD_SIZE -1)/HOST_WORD_SIZE;
devc->ADDR_WIDTH_BYTES = (devc->ADDR_WIDTH+HOST_WORD_SIZE -1)/HOST_WORD_SIZE;
devc->limit_samples_max = (0x01 << devc->ADDR_WIDTH);
devc->DATA_WIDTH_BYTES = (devc->DATA_WIDTH+HOST_WORD_SIZE -1)/HOST_WORD_SIZE;
devc->ADDR_WIDTH_BYTES = (devc->ADDR_WIDTH+HOST_WORD_SIZE -1)/HOST_WORD_SIZE;
devc->limit_samples_max = (0x01 << devc->ADDR_WIDTH);
//sr_err("DATA_WIDTH_BYTES: %d ADDR_WIDTH_BYTES : %d LIMIT_SAMPLES: %d", devc->DATA_WIDTH_BYTES, devc->ADDR_WIDTH_BYTES, devc->limit_samples );
//sr_err("DATA_WIDTH_BYTES: %d ADDR_WIDTH_BYTES : %d LIMIT_SAMPLES: %d", devc->DATA_WIDTH_BYTES, devc->ADDR_WIDTH_BYTES, devc->limit_samples );
devc->trigger_value = g_malloc0(devc->DATA_WIDTH_BYTES);
devc->trigger_mask_last = g_malloc0(devc->DATA_WIDTH_BYTES);
devc->trigger_value_last = g_malloc0(devc->DATA_WIDTH_BYTES);
devc->trigger_value = g_malloc0(devc->DATA_WIDTH_BYTES);
devc->trigger_mask_last = g_malloc0(devc->DATA_WIDTH_BYTES);
devc->trigger_value_last = g_malloc0(devc->DATA_WIDTH_BYTES);