hi,
i think there are two issues,one thanks Mulyadi reminds me to use
kthread_should_stop,
One is i think your socket should use non-block mode,reference the
http://mail.nl.linux.org/kernelnewbies/2005-12/msg00193.html
maybe block mode makes the kthread uninterrupted. we need check the sock codes.
So i change your code to below,i test it works.
I hope it is what you expect.
BRs
Lin
#include <linux/version.h>
#include <linux/module.h>
#include <linux/types.h>
#include <linux/kernel.h>
#include <linux/sched.h>
#include <linux/mm.h>
#include <linux/string.h>
#include <linux/errno.h>
#include <linux/init.h>
#include <linux/kmod.h>
#include <linux/slab.h>
#include <asm/uaccess.h>
#include <asm/system.h>
#include <linux/proc_fs.h>
#include <linux/compiler.h>
#include <linux/netfilter.h>
#include <linux/netfilter_ipv4.h>
#include <linux/skbuff.h>
#include <linux/ip.h>
#include <linux/tcp.h>
#include <linux/in.h>
#include <linux/kernel.h>
#include <linux/byteorder/generic.h>
#include <linux/inet.h>
#include <linux/udp.h>
#include <linux/netdevice.h>
#include <linux/time.h>
#include <linux/spinlock.h>
#include <net/ip.h>
#include <net/checksum.h>
#include <linux/vmalloc.h>
#include <linux/net.h>
#include <linux/in_route.h>
#include <net/route.h>
#include <linux/kthread.h>
static struct socket *udpInserversocket=NULL;
static struct task_struct *p;
static int createUdpInSocket(void)
{
int res;
struct sockaddr_in server;
int servererror;
unsigned char *buf;
printk( KERN_ERR "createUdpInSocket\n" );
if( sock_create( PF_INET,SOCK_DGRAM,IPPROTO_UDP,&udpInserversocket)<0 ) {
printk(KERN_ERR "server: Error creating udpserversocket.\n" );
return -EIO;
}
server.sin_family = AF_INET;
server.sin_addr.s_addr = INADDR_ANY;
server.sin_port = htons((unsigned short)4000);
servererror = udpInserversocket->ops->bind(udpInserversocket,
(struct sockaddr *) &server, sizeof(server) );
{
struct msghdr msg;
struct iovec iov;
mm_segment_t oldfs;
int size = 0;
int len = 160;
iov.iov_base = buf;
// msg.msg_flags = 0;
msg.msg_flags = MSG_DONTWAIT;
msg.msg_name = &server;
msg.msg_namelen = sizeof(struct sockaddr_in);
msg.msg_control = NULL;
msg.msg_controllen = 0;
msg.msg_iov = &iov;
msg.msg_iovlen = 1;
msg.msg_control = NULL;
oldfs = get_fs();
set_fs(KERNEL_DS);
printk("before sock_recvmsg in %s %s\n",__FUNCTION__,__FILE__);
while(0 == kthread_should_stop()){
/*do something else you need*/
size = sock_recvmsg(udpInserversocket,&msg,len,msg.msg_flags);
}
printk("after sock_recvmsg in %s %s\n",__FUNCTION__,__FILE__);
set_fs(oldfs);
}
release:
if (udpInserversocket) {
//udpInserversocket->ops->shutdown(udpInserversocket,2);
sock_release(udpInserversocket);
udpInserversocket=NULL;
}
}
static int kernThread(void *arg)
{
allow_signal(SIGKILL);
createUdpInSocket();
return 1;
}
static int __init nic_init(void)
{
int ret;
void *kdata;
p = kthread_run(kernThread,kdata,"myKernThread");
return 0;
}
static void __exit nic_exit(void)
{
printk("in nic_exit\n");
if (p)
kthread_stop(p);
printk("stop kthread!\n");
}
module_init(nic_init)
module_exit(nic_exit)
MODULE_DESCRIPTION("test");
MODULE_LICENSE("GPL");
--
To unsubscribe from this list: send an email with
"unsubscribe kernelnewbies" to [email protected]
Please read the FAQ at http://kernelnewbies.org/FAQ
