分享mq_open函数

uqHZau

8 b/ ?& R" T( ^' jNAME
mq_open - 打开一个消息队列 (REALTIME)
. N% m2 f# Y9 ~2 }& `: ~. K
  h4 C1 m# w4 c) j& [2 r5 K
SYNOPSIS

3 N  i, r7 A& T# t6 A- k

• #include <mqueue.h>
• mqd_t mq_open(const char *name, int oflag, ...)
• mqd_t mq_open(const char *name, int oflag, mode_t mode, mq_attr* attr) //O_CREAT
  

+ U  ~  a# Y, C4 |; y9 r' wDESCRIPTION

0 s8 [. f$ o9 l- \$ _: x  U. Imq_open() 函数会通过一个消息队列描述符(类型是mqd_t)建立一个进程与一个消息队列的连接.
5 g6 y3 _7 U! G/ W6 l
该函数会创建一个打开的消息队列的描述符, 其他函数就可以通过这个描述符操作消息队列.


PARAMETERS

6 N9 E% K( ~% f+ s: k" h, j, u2 U①name
参数 name 是一个指向消息队列名称的指针. 但是名字是否出现在文件系统中,是否对其他以路径名为参数的函数可见是未定义的.
+ u0 W. W* C6 Y* I! K8 m3 \( a
参数 name 的长度限制是由系统实现决定的(如何获取这个限制),不需要遵守路径名的限制 {PATH_MAX} 和 {NAME_MAX}.

% p2 h+ \8 T5 u, h3 P2 l如果 name 参数以"/"字符开头, 只有name没有被删除,所有使用相同name值调用mq_open函数的线程,访问的都是同一个消息队列,
7 u  A3 }9 l/ y3 y- I2 m3 @
如果 name 参数不是以"/"字符开头,效果是由系统实现决定的.所以name参数一定要以"/"字符开头.
" c* m! Y$ p7 V6 @4 y, Q

②oflag
; T# I' S/ e/ H5 h
0 ]1 {9 Z6 W6 F; K/ b* P- C( W参数 oflag 表示想要访问(receive/send)消息队列的方式.
* s( D# o0 n6 Z# h8 n
" A4 t; ?  {0 r. L' {6 O参数 oflag 是由下列宏组合计算出来的, 注意必须包含前3个(访问模式) 中的一个:

" C2 ?/ \" O: g2 x* i5 e# PO_RDONLY (只读)
$ ^" [5 P2 h# x: k8 O
打开一个消息队列用来接受消息.
& b$ h7 T' L0 @" ]9 P; T6 @6 n
3 M; J5 z; v$ a- E4 B调用进程可以使用mq_open返回的描述符用于函数 mq_receive(), 但是不能用于函数 mq_send().
1 y) i! i# l3 F' t5 ?8 H0 i, K: \2 ?
3 D( c* W5 o! T2 W0 ?3 ?' @2 s一个消息队列可以在相同或不同的进程中多次打开用来接收消息.
* I3 D1 U) i8 V( s
8 U. {6 b/ z' A6 O. s7 e9 _O_WRONLY (只写)
6 [% s5 G; R) h% t
打开一个消息队列用来发送消息.
$ I7 u4 w/ Q. }- k, n" x5 u
* f( o% w; Y/ a调用进程可以使用mq_open返回的描述符用于函数 mq_send(), 但是不能用于函数 mq_receive().
0 N4 b. y) s! c/ U! B0 m. G
一个消息队列可以在相同或不同的进程中多次打开用来发送消息.
) `! n6 f6 P: [3 X8 H/ T7 J
" }/ L' p9 f2 Q% SO_RDWR (读写)

打开一个消息队列用即可用来发送消息也可以用来接受消息.

7 q6 q1 L5 v/ s0 h& j5 Q  P& y调用进程可以使用任何支持O_RDONLY 和O_WRONLY 访问模式的函数.

一个消息队列可以在相同或不同的进程中多次打开用来发送消息.
: `7 U$ t+ y" B# D
6 F5 i+ p8 x9 w2 f' w9 j

* y1 W2 }0 B1 y' G0 j- @  S; v, T# }Any combination of the remaining flags may be specified in the value of oflag:
' G8 ^% V& c& P: `2 X# x

3 W0 b& J2 U1 w6 lO_CREAT (创建)
6 o; K, k; h5 ?' ]$ N
: M/ e( i3 _; d9 _9 D4 a1 M创建一个消息队列. 使用这个参数需要追加2个参数: ③mode(类型是mode_t), 和④attr(类型是mq_attr*).
如果name参数指定的消息队列已经存在, 那么这个参数将不起任何作用, 除非像下面 O_EXCL 中提到的情况;
否则, 会创建一个空的消息队列. 消息队列的用户ID会被设置成这个进程的实际的用户ID.
消息队列的组ID会被设置成这个进程的实际的组ID; 然而, 如果参数name 指向的消息队列在文件系统中可见, 那么组ID会被设置成包含消息队列的目录的组ID.
如果参数mode中的位与文件权限中位不同,这种情况是未定义的.
, c0 a2 |9 o. y+ H如果 attr 是 NULL, 创建的消息队列是系统实现的默认属性. 如果 attr 不是 NULL 并且调用进程对参数name指定的文件有特定的权限(什么权限),
那么消息队列的属性 mq_maxmsg 和 mq_msgsize 会被设置成 attr 中的属性. 属性 mq_flags 和 mq_curmsgs 会被忽略.
如果 attr 不是 NULL , 并且调用进程对参数name指定的文件没有特定的权限,函数 mq_open() 会返回失败,不会创建消息队列.

- M: ^  [' y( o# B9 B7 n
O_EXCL (既存检查)
! c5 T. E3 j  Y
: K; L1 m" P. L" n* B# x3 Z如果 O_EXCL 和O_CREAT同时被设置了, 如果消息队列应经存在,那么函数 mq_open() 会返回失败.
! }( n& b: l- e. u2 |提供了检查消息队列是否存在的方法, 如果设置了 O_EXCL 必须同时设置 O_CREAT 否则结果未定义.
" J2 L3 _( h/ |( e5 R! H
O_NONBLOCK (非阻塞)

决定函数 mq_send() 和 mq_receive() 在获取当前无法获得的资源或消息时,是一直等待(阻塞), 还是返回失败并将 errno 设置成 [EAGAIN];
" v" F+ Y" `+ @

RETURN VALUE
) j2 Y+ o+ s1 }! Z" [7 h5 n
如果函数执行成功, 函数返回一个描述符

如果函数执行失败,函数返回 (mqd_t)-1 并且设置errno,errno的种别详见下面的ERRORS一节.
8 y7 |6 P1 ?# i& m8 [' y# s

, ^3 A5 ^& ^/ _1 ?8 H/ T
' ^% G0 e, @3 G& hERRORS
0 J/ P1 g9 `, P2 d* t7 k; P- n
[EACCES]

3 E- t( g$ w: }* s1 aThe message queue exists and the permissions specified by oflag are denied, or the message queue does not exist and permission to create the message queue is denied.
; U+ l7 r& K/ h6 y  v' @4 O
) u7 q4 P' u. H  J* b[EEXIST]
1 W4 P5 {, k5 v( ?+ P( K
0 ?% x- Q) f- S2 ^3 U, e0 S; oO_CREAT and O_EXCL are set and the named message queue already exists.

[EINTR]
: \+ ^2 P; n0 N3 x( x2 _/ F
" d, H' h; V. i6 P3 G. G3 @% |函数 mq_open() 被信号中断.
# N9 M: n3 O7 m7 E0 d! T7 d
[EINVAL]

函数 mq_open() 不支持参数name指定的路径.
. X( e4 O+ B+ `7 v; l1 w
, ~" C+ [9 q) \  }2 u0 x[EINVAL]
/ p/ T* P9 A0 D; J1 S; H& X
& E) _. b; j( R0 \' R+ T设置了O_CREAT标志, 参数3 attr 不是NULL;并且 mq_maxmsg 或 mq_msgsize 小于等于0.
( r  P4 a3 A4 D) o6 B7 M9 c
; H% s# z2 D  v/ B" P[EMFILE]
$ z) x2 g, J' U1 I7 ^- b- l7 H
本进程中使用了过多的消息队列描述符 或 文件描述符.

[ENFILE]
  n* N  m2 H3 g
系统中打开的消息队列数目超过了系统支持的最大数.

[ENOENT]

/ M0 d) d% w- C2 w; V( \没有设置O_CREAT标志,并且指定的消息队列不存在.

[ENOSPC]
1 k# r% ?% P6 X- I5 w; n& k( R
空间不足,无法创建新的消息队列.
9 c4 ~+ h  n' c% t, o$ L7 X3 [
1 t1 W& y6 R" K; R) J[ENAMETOOLONG]
3 r. q' \7 Q; O- X
参数 name 的长度超过系统定义的最大长度.
. n% P* f. C, k, [$ J) u4 @- f9 Y
3 O! O4 l# x/ s% ]- P+ _7 \在不支持XSI系统中,name 的长度超过了 {_POSIX_PATH_MAX},在支持XSI系统中,name 的长度超过了 {_XOPEN_PATH_MAX};或者

6 a4 W; ^" s' O, @5 A在不支持XSI系统中,某一级路径的长度超过了 {_POSIX_NAME_MAX},在支持XSI系统中,某一级路径的长度超过了 {_XOPEN_NAME_MAX};

" h" Q0 t" N$ j* C: a  @( [* c2 qEXAMPLES
6 I& D! W1 S6 Y# c. e

SsaaM7

分享mq_open函数