num_probes = DEFAULT_NUM_PROBES;
/* create a virtual device */
- in->vdevice = device_new(NULL, 0, num_probes);
+ in->vdevice = sr_device_new(NULL, 0, num_probes);
return SR_OK;
}
packet.type = SR_DF_HEADER;
packet.length = sizeof(struct sr_datafeed_header);
packet.payload = &header;
- session_bus(in->vdevice, &packet);
+ sr_session_bus(in->vdevice, &packet);
/* chop up the input file into chunks and feed it into the session bus */
packet.type = SR_DF_LOGIC;
packet.payload = buffer;
while ((size = read(fd, buffer, CHUNKSIZE)) > 0) {
packet.length = size;
- session_bus(in->vdevice, &packet);
+ sr_session_bus(in->vdevice, &packet);
}
close(fd);
/* end of stream */
packet.type = SR_DF_END;
packet.length = 0;
- session_bus(in->vdevice, &packet);
+ sr_session_bus(in->vdevice, &packet);
return SR_OK;
}