mpathpersist: fix aptpl support
[multipath-tools/.git] / libmpathpersist / mpath_updatepr.c
1 #include <stdio.h>
2 #include <unistd.h>
3 #include <stdlib.h>
4 #include <stdarg.h>
5 #include <fcntl.h>
6 #include <sys/ioctl.h>
7 #include <sys/types.h>
8 #include <sys/socket.h>
9 #include <sys/un.h>
10 #include <poll.h>
11 #include <errno.h>
12 #include <libudev.h>
13 #include <mpath_persist.h>
14 #include "debug.h"
15 #include "mpath_cmd.h"
16 #include "uxsock.h"
17 #include "memory.h"
18 #include "mpathpr.h"
19
20
21 static int do_update_pr(char *alias, char *arg)
22 {
23         int fd;
24         char str[256];
25         char *reply;
26         int ret = 0;
27
28         fd = mpath_connect();
29         if (fd == -1) {
30                 condlog (0, "ux socket connect error");
31                 return -1;
32         }
33
34         snprintf(str,sizeof(str),"map %s %s", alias, arg);
35         condlog (2, "%s: pr message=%s", alias, str);
36         if (send_packet(fd, str) != 0) {
37                 condlog(2, "%s: message=%s send error=%d", alias, str, errno);
38                 mpath_disconnect(fd);
39                 return -1;
40         }
41         ret = recv_packet(fd, &reply, DEFAULT_REPLY_TIMEOUT);
42         if (ret < 0) {
43                 condlog(2, "%s: message=%s recv error=%d", alias, str, errno);
44                 ret = -1;
45         } else {
46                 condlog (2, "%s: message=%s reply=%s", alias, str, reply);
47                 if (reply && strncmp(reply,"ok", 2) == 0)
48                         ret = 0;
49                 else
50                         ret = -1;
51         }
52
53         free(reply);
54         mpath_disconnect(fd);
55         return ret;
56 }
57
58 int update_prflag(char *mapname, int set) {
59         return do_update_pr(mapname, (set)? "setprstatus" : "unsetprstatus");
60 }
61
62 int update_prkey_flags(char *mapname, uint64_t prkey, uint8_t sa_flags) {
63         char str[256];
64         char *flagstr = "";
65
66         if (sa_flags & MPATH_F_APTPL_MASK)
67                 flagstr = ":aptpl";
68         if (prkey)
69                 sprintf(str, "setprkey key %" PRIx64 "%s", prkey, flagstr);
70         else
71                 sprintf(str, "unsetprkey");
72         return do_update_pr(mapname, str);
73 }