equal
deleted
inserted
replaced
348 // msg.msg_name = &dev->dest_addr; |
348 // msg.msg_name = &dev->dest_addr; |
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 (ipipe_root_p) |
353 if (rtdm_in_rt_context()) |
354 ret = nrt_rtdm_sendmsg(dev->socket, &msg); |
354 ret = nrt_rtdm_sendmsg(dev->socket, &msg); |
355 else |
355 else |
356 ret = rtdm_sendmsg(dev->socket, &msg, 0); |
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; |
404 iov.iov_len = EC_GEN_RX_BUF_SIZE; |
404 iov.iov_len = EC_GEN_RX_BUF_SIZE; |
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 (ipipe_root_p) |
409 if (rtdm_in_rt_context()) |
410 ret = nrt_rtdm_recvmsg(dev->socket, &msg); |
410 ret = nrt_rtdm_recvmsg(dev->socket, &msg); |
411 else |
411 else |
412 ret = rtdm_recvmsg(dev->socket, &msg, MSG_DONTWAIT); |
412 ret = rtdm_recvmsg(dev->socket, &msg, MSG_DONTWAIT); |
413 |
413 |
414 if (ret > 0) { |
414 if (ret > 0) { |