equal
deleted
inserted
replaced
349 // msg.msg_namelen = sizeof(dev->dest_addr); |
349 // msg.msg_namelen = sizeof(dev->dest_addr); |
350 msg.msg_iov = &iov; |
350 msg.msg_iov = &iov; |
351 msg.msg_iovlen = 1; |
351 msg.msg_iovlen = 1; |
352 |
352 |
353 if (rtdm_in_rt_context()) |
353 if (rtdm_in_rt_context()) |
|
354 ret = rtdm_sendmsg(dev->socket, &msg, 0); |
|
355 else |
354 ret = nrt_rtdm_sendmsg(dev->socket, &msg); |
356 ret = nrt_rtdm_sendmsg(dev->socket, &msg); |
355 else |
|
356 ret = rtdm_sendmsg(dev->socket, &msg, 0); |
|
357 |
357 |
358 return ret == len ? NETDEV_TX_OK : NETDEV_TX_BUSY; |
358 return ret == len ? NETDEV_TX_OK : NETDEV_TX_BUSY; |
359 } |
359 } |
360 |
360 |
361 /*****************************************************************************/ |
361 /*****************************************************************************/ |
405 memset(&msg, 0, sizeof(msg)); |
405 memset(&msg, 0, sizeof(msg)); |
406 msg.msg_iov = &iov; |
406 msg.msg_iov = &iov; |
407 msg.msg_iovlen = 1; |
407 msg.msg_iovlen = 1; |
408 |
408 |
409 if (rtdm_in_rt_context()) |
409 if (rtdm_in_rt_context()) |
|
410 ret = rtdm_recvmsg(dev->socket, &msg, MSG_DONTWAIT); |
|
411 else |
410 ret = nrt_rtdm_recvmsg(dev->socket, &msg); |
412 ret = nrt_rtdm_recvmsg(dev->socket, &msg); |
411 else |
|
412 ret = rtdm_recvmsg(dev->socket, &msg, MSG_DONTWAIT); |
|
413 |
413 |
414 if (ret > 0) { |
414 if (ret > 0) { |
415 ecdev_receive(dev->ecdev, dev->rx_buf, ret); |
415 ecdev_receive(dev->ecdev, dev->rx_buf, ret); |
416 } else if (ret < 0) { |
416 } else if (ret < 0) { |
417 break; |
417 break; |