QNX驱动开发—进程调度和进程通信

锋影

e-mail&＃xff1a;174176320&＃64;qq.com

一、进程调度方法

1.FIFO&＃xff1a;先进先出队列法。一个最高优先级的线程可以一直执行到结束或是主动放弃CPU。高优先级的线程可以随时中断低优先级的线程&＃xff0c;获得CPU的使用权限&＃xff0c;与之相同优先级的CPU也只能等待其交出CPU的使用权限后才能按排队的顺序先后执行。

2.Round Robin&＃xff1a;循环法。除了对于最高的相同优先级的使用时间片轮转的方法外&＃xff0c;其他特点与FIFO法相同。注意此处的时间片轮转与windows的不一样&＃xff0c;是随时可以被高优先级任务抢占的。

二、进程间通信

      QNX所有功能实现都是靠消息传递的机制实现的&＃xff0c;并可以轻松实现网络通信。其中POSIX函数与底层的通信就是靠消息实现的。

      通信的过程分为三个步骤&＃xff1a;client向server发送消息&＃xff1b;server向client接受消息&＃xff1b;server处理并将结果返回给client。

      A useful minimal set of functions is ChannelCreate(),ConnectAttach(),MsgReply(),MsgSend(), andMsgReceive().

对于client想要与server通信要通过ConnectAttach 与server建立连接&＃xff0c;使用MsgSend向server发送一个消息。

对于server:

       首先要通过ChannelCreate创建一个通道&＃xff0c;然后有“receive”和“reply”两个阶段来处理消息。

chid &＃61; ChannelCreate (0);或者&＃xff08;Name_attach_t *attach &＃61; name_attach(NULL,(char *)”myserver”,0);&＃xff09;

rcvid &＃61; MsgReceive (chid, message, sizeof (message),NULL);

MsgReply (rcvid, EOK, message, sizeof (message));

    对于client&＃xff1a;

    需要做两件事情&＃xff0c;一是要通过ConnetAttach与server的channel建立连接&＃xff0c;二是要通过MsgSend向server发送消息。

     1&＃xff09;与server建立连接

int ConnectAttach (int nd,

pid_t pid,

int chid,

unsigned index,

int flags);

例如coid &＃61; ConnectAttach (0, 77, 1, 0, 0);是连接了自己节点&＃xff08;0&＃xff09;的&＃xff0c;进程号为77的一个进程的1号channel。可是如何获得server的ND/PID/CHID这几参数呢&＃xff1f;

QNX提供了几种方法&＃xff1a;

1.server向一个文件中写入自己的ND/PID/CHID参数&＃xff0c;client发送消息时打开文件&＃xff0c;读出字符串。&＃xff08;文件过多&＃xff09;

2.使用全局变量来存储这几个参数。&＃xff08;非常有局限性&＃xff0c;如果有共享内存&＃xff0c;无法使用网络连接到&＃xff01;&＃xff09;

3.使用命名功能来把client注册一个名字。

4.把server升级为一个resource manger&＃xff0c;这样就可以打开/dev/**来建立通信消息。&＃xff08;一般不这样做&＃xff09;。

        在通常情况下&＃xff0c;命名功能name_attach() and name_open()来完成比较方便。

比如&＃xff1a;server_coid &＃61; name_open((char *)”myserver” ,0);来打开server创建的/dev/name/local/myserver,与server创建的channel建立连接。

在server端可以使用name_attach()在命名空间创建一个name&＃xff0c;如

Name_attach_t *attach &＃61; name_attach(NULL,(char *)”myserver”,0);当server的线程结束时&＃xff0c;此命名也自动地跟着删除掉。这就很好的解决了建立通道的问题。

        2&＃xff09;向server发送消息

       这里可以分为几种情况&＃xff0c;需要回复数据、回复成功或失败但是不回复数据。于是我们可以使用一下函数完成功能。

int MsgSend (int coid, const void *smsg, int sbytes, void *rmsg, int rbytes);

MsgReply (rcvid, EOK, NULL, 0); //successful

MsgError (rcvid, EROFS); //failed

       Client和Server各参数之间的关系如下图所示&＃xff1a;

        我做了一个这样的实验&＃xff0c;在工程中建立一个名为server的工程和一个名为client的工程&＃xff0c;两个进程之间完全时陌生的&＃xff0c;通过name_attach和name_open的方式建立通道&＃xff0c;这样就不需要获得ND/PID/CHID这几个参数了。在实验的过程中发现使用消息进行通信时非常方便的&＃xff0c;但是最好自己定义一个命令消息格式&＃xff0c;滤除掉不是原client发来的消息&＃xff08;系统还会对server发送消息进行控制&＃xff09;&＃xff0c;这样就不会出现误触发。

建立一个结构体

Struct _io_message{

Int nbyte;

Int type;

Char msg[1024];

};

        就可以很方便的判断传入消息的大小、消息类型以及消息的多少了&＃xff0c;如果server的接收buffer太小&＃xff0c;使得接收的数据丢失&＃xff0c;可以通过判断实际传过来的nbyte和定义buffer的大小来判断这一情况&＃xff0c;使用MsgRead&＃xff08;&＃xff09;和MsgWrite&＃xff08;&＃xff09;再把实际大小的数据读回来。