bkinnightskytw
/
ethercat
mirror of https://gitlab.com/bkinnightskytw/ethercat.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Implemented poll(); receiving on generic device also works.

This commit is contained in:
Florian Pose 2009-10-15 18:01:41 +02:00
parent 46da25bd9f
commit 547b1a260d
1 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
devices/generic.c
View File

@ -75,6 +75,7 @@ typedef struct {
int ec_gen_device_open(ec_gen_device_t *);
int ec_gen_device_stop(ec_gen_device_t *);
int ec_gen_device_start_xmit(ec_gen_device_t *, struct sk_buff *);
void ec_gen_device_poll(ec_gen_device_t *);
/*****************************************************************************/
@ -107,6 +108,8 @@ static int ec_gen_netdev_start_xmit(
void ec_gen_poll(struct net_device *dev)
{
ec_gen_device_t *gendev = *((ec_gen_device_t **) netdev_priv(dev));
ec_gen_device_poll(gendev);
}
/*****************************************************************************/
@ -271,6 +274,35 @@ int ec_gen_device_start_xmit(
/*****************************************************************************/
/** Polls the device.
*/
void ec_gen_device_poll(
ec_gen_device_t *dev
)
{
struct msghdr msg;
struct kvec iov;
char buf[2000]; // FIXME
int ret, budget = 10; // FIXME
iov.iov_base = buf;
iov.iov_len = 2000;
memset(&msg, 0, sizeof(msg));
do {
ret = kernel_recvmsg(dev->socket, &msg, &iov, 1, iov.iov_len,
MSG_DONTWAIT);
if (ret > 0) {
ecdev_receive(dev->ecdev, buf, ret);
} else if (ret < 0) {
break;
}
budget--;
} while (budget);
}
/*****************************************************************************/
/** Offer device.
*/
int offer_device(