]>
git.ipfire.org Git - people/ms/mstpd.git/blob - ctl_socket_client.c
1 /*****************************************************************************
2 Copyright (c) 2006 EMC Corporation.
3 Copyright (c) 2011 Factor-SPE
5 This program is free software; you can redistribute it and/or modify it
6 under the terms of the GNU General Public License as published by the Free
7 Software Foundation; either version 2 of the License, or (at your option)
10 This program is distributed in the hope that it will be useful, but WITHOUT
11 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
12 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
15 You should have received a copy of the GNU General Public License along with
16 this program; if not, write to the Free Software Foundation, Inc., 59
17 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
19 The full GNU General Public License is included in this distribution in the
22 Authors: Srinivas Aji <Aji_Srinivas@emc.com>
23 Authors: Vitalii Demianets <vitas@nppfactor.kiev.ua>
25 ******************************************************************************/
31 #include "ctl_functions.h"
37 int ctl_client_init(void)
39 struct sockaddr_un sa_svr
;
41 TST(strlen(MSTP_SERVER_SOCK_NAME
) < sizeof(sa_svr
.sun_path
), -1);
43 if(0 > (s
= socket(PF_UNIX
, SOCK_DGRAM
, 0)))
45 ERROR("Couldn't open unix socket: %m");
49 set_socket_address(&sa_svr
, MSTP_SERVER_SOCK_NAME
);
51 struct sockaddr_un sa
;
53 sprintf(tmpname
, "MSTPCTL_%d", getpid());
54 set_socket_address(&sa
, tmpname
);
55 /* We need this bind. The autobind on connect isn't working properly.
56 * The server doesn't get a proper sockaddr in recvmsg if we don't do this.
58 if(0 != bind(s
, (struct sockaddr
*)&sa
, sizeof(sa
)))
60 ERROR("Couldn't bind socket: %m");
65 if(0 != connect(s
, (struct sockaddr
*)&sa_svr
, sizeof(sa_svr
)))
67 ERROR("Couldn't connect to server");
76 void ctl_client_cleanup(void)
85 int send_ctl_message(int cmd
, void *inbuf
, int lin
, void *outbuf
, int lout
,
86 LogString
*log
, int *res
)
88 struct ctl_msg_hdr mhdr
;
97 msg
.msg_control
= NULL
;
98 msg
.msg_controllen
= 0;
103 mhdr
.llog
= sizeof(log
->buf
) - 1;
104 iov
[0].iov_base
= &mhdr
;
105 iov
[0].iov_len
= sizeof(mhdr
);
106 iov
[1].iov_base
= (void *)inbuf
;
107 iov
[1].iov_len
= lin
;
108 iov
[2].iov_base
= log
->buf
;
111 l
= sendmsg(fd
, &msg
, 0);
114 ERROR("Error sending message to server: %m");
117 if(l
!= sizeof(mhdr
) + lin
)
119 ERROR("Error sending message to server: Partial write");
123 iov
[1].iov_base
= outbuf
;
124 iov
[1].iov_len
= lout
;
125 iov
[2].iov_base
= log
->buf
;
126 iov
[2].iov_len
= sizeof(log
->buf
);
129 int timeout
= 5000; /* 5 s */
136 if(0 == (r
= poll(&pfd
, 1, timeout
)))
138 ERROR("Error getting message from server: Timeout");
143 ERROR("Error getting message from server: poll error: %m");
146 }while(0 == (pfd
.revents
& (POLLERR
| POLLHUP
| POLLNVAL
| POLLIN
)));
148 l
= recvmsg(fd
, &msg
, 0);
151 ERROR("Error getting message from server: %m");
154 if((sizeof(mhdr
) > l
)
155 || (l
!= sizeof(mhdr
) + mhdr
.lout
+ mhdr
.llog
)
159 ERROR("Error getting message from server: Bad format");
162 if(mhdr
.lout
!= lout
)
164 ERROR("Error, unexpected result length %d, expected %d\n",
168 if(sizeof(log
->buf
) <= mhdr
.llog
)
170 ERROR("Invalid log message length %d", mhdr
.llog
);
175 log
->buf
[mhdr
.llog
] = 0;