]>
git.ipfire.org Git - people/ms/rstp.git/blob - ctl_socket_client.c
1 /*****************************************************************************
2 Copyright (c) 2006 EMC Corporation.
4 This program is free software; you can redistribute it and/or modify it
5 under the terms of the GNU General Public License as published by the Free
6 Software Foundation; either version 2 of the License, or (at your option)
9 This program is distributed in the hope that it will be useful, but WITHOUT
10 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
14 You should have received a copy of the GNU General Public License along with
15 this program; if not, write to the Free Software Foundation, Inc., 59
16 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
18 The full GNU General Public License is included in this distribution in the
21 Authors: Srinivas Aji <Aji_Srinivas@emc.com>
23 ******************************************************************************/
25 #include "ctl_socket.h"
27 #include <sys/types.h>
28 #include <sys/socket.h>
39 int ctl_client_init(void)
41 struct sockaddr_un sa_svr
;
43 TST (strlen(RSTP_SERVER_SOCK_NAME
) < sizeof(sa_svr
.sun_path
), -1);
45 s
= socket(PF_UNIX
, SOCK_DGRAM
, 0);
47 ERROR("Couldn't open unix socket: %m");
51 set_socket_address(&sa_svr
, RSTP_SERVER_SOCK_NAME
);
53 struct sockaddr_un sa
;
55 sprintf(tmpname
, "RSTPCTL_%d", getpid());
56 set_socket_address(&sa
, tmpname
);
57 /* We need this bind. The autobind on connect isn't working properly.
58 The server doesn't get a proper sockaddr in recvmsg if we don't do this.
60 if (bind(s
, (struct sockaddr
*)&sa
, sizeof(sa
)) != 0) {
61 ERROR("Couldn't bind socket: %m");
66 if (connect(s
, (struct sockaddr
*)&sa_svr
, sizeof(sa_svr
)) != 0) {
67 ERROR("Couldn't connect to server");
76 void ctl_client_cleanup(void)
84 int send_ctl_message(int cmd
, void *inbuf
, int lin
, void *outbuf
, int *lout
,
87 struct ctl_msg_hdr mhdr
;
92 msg
.msg_name
= NULL
; msg
.msg_namelen
= 0;
93 msg
.msg_iov
= iov
; msg
.msg_iovlen
= 2;
94 msg
.msg_control
= NULL
; msg
.msg_controllen
= 0;
98 mhdr
.lout
= lout
!= NULL
? *lout
: 0;
99 iov
[0].iov_base
= &mhdr
; iov
[0].iov_len
= sizeof(mhdr
);
100 iov
[1].iov_base
= (void *)inbuf
; iov
[1].iov_len
= lin
;
102 l
= sendmsg(fd
, &msg
, 0);
104 ERROR("Error sending message to server: %m");
107 if (l
!= sizeof(mhdr
) + lin
) {
108 ERROR("Error sending message to server: Partial write");
112 iov
[1].iov_base
= outbuf
;
113 iov
[1].iov_len
= lout
!= NULL
? *lout
: 0;
117 int timeout
= 5000; /* 5 s */
123 r
= poll(&pfd
, 1, timeout
);
125 ERROR("Error getting message from server: Timeout");
129 ERROR("Error getting message from server: poll error: %m");
132 } while ((pfd
.revents
& (POLLERR
| POLLHUP
| POLLNVAL
| POLLIN
)) == 0);
134 l
= recvmsg(fd
, &msg
, 0);
136 ERROR("Error getting message from server: %m");
139 if (l
< sizeof(mhdr
) || l
!= sizeof(mhdr
) + mhdr
.lout
|| mhdr
.cmd
!= cmd
) {
140 ERROR("Error getting message from server: Bad format");