2 * Unix SMB/CIFS implementation.
4 * Copyright (C) Guenther Deschner 2008
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 3 of the License, or
9 * (at your option) any later version.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, see <http://www.gnu.org/licenses/>.
21 #include "popt_common.h"
23 #include "lib/netapi/netapi.h"
24 #include "lib/netapi/netapi_private.h"
25 #include "rpc_client/cli_pipe.h"
27 /********************************************************************
28 ********************************************************************/
30 struct client_ipc_connection {
31 struct client_ipc_connection *prev, *next;
32 struct cli_state *cli;
33 struct client_pipe_connection *pipe_connections;
36 struct client_pipe_connection {
37 struct client_pipe_connection *prev, *next;
38 struct rpc_pipe_client *pipe;
41 /********************************************************************
42 ********************************************************************/
44 static struct client_ipc_connection *ipc_cm_find(
45 struct libnetapi_private_ctx *priv_ctx, const char *server_name)
47 struct client_ipc_connection *p;
49 for (p = priv_ctx->ipc_connections; p; p = p->next) {
50 if (strequal(p->cli->desthost, server_name)) {
58 /********************************************************************
59 ********************************************************************/
61 static WERROR libnetapi_open_ipc_connection(struct libnetapi_ctx *ctx,
62 const char *server_name,
63 struct client_ipc_connection **pp)
65 struct libnetapi_private_ctx *priv_ctx =
66 (struct libnetapi_private_ctx *)ctx->private_data;
67 struct user_auth_info *auth_info = NULL;
68 struct cli_state *cli_ipc = NULL;
69 struct client_ipc_connection *p;
71 if (!ctx || !pp || !server_name) {
72 return WERR_INVALID_PARAM;
75 p = ipc_cm_find(priv_ctx, server_name);
81 auth_info = user_auth_info_init(ctx);
85 auth_info->signing_state = Undefined;
86 set_cmdline_auth_info_use_kerberos(auth_info, ctx->use_kerberos);
87 set_cmdline_auth_info_username(auth_info, ctx->username);
89 set_cmdline_auth_info_password(auth_info, ctx->password);
91 set_cmdline_auth_info_getpass(auth_info);
94 if (ctx->username && ctx->username[0] &&
95 ctx->password && ctx->password[0] &&
97 set_cmdline_auth_info_fallback_after_kerberos(auth_info, true);
100 if (ctx->use_ccache) {
101 set_cmdline_auth_info_use_ccache(auth_info, true);
104 cli_ipc = cli_cm_open(ctx, NULL,
111 cli_set_username(cli_ipc, ctx->username);
112 cli_set_password(cli_ipc, ctx->password);
113 cli_set_domain(cli_ipc, ctx->workgroup);
115 TALLOC_FREE(auth_info);
118 libnetapi_set_error_string(ctx,
119 "Failed to connect to IPC$ share on %s", server_name);
120 return WERR_CAN_NOT_COMPLETE;
123 p = TALLOC_ZERO_P(ctx, struct client_ipc_connection);
129 DLIST_ADD(priv_ctx->ipc_connections, p);
136 /********************************************************************
137 ********************************************************************/
139 WERROR libnetapi_shutdown_cm(struct libnetapi_ctx *ctx)
141 struct libnetapi_private_ctx *priv_ctx =
142 (struct libnetapi_private_ctx *)ctx->private_data;
143 struct client_ipc_connection *p;
145 for (p = priv_ctx->ipc_connections; p; p = p->next) {
146 cli_shutdown(p->cli);
152 /********************************************************************
153 ********************************************************************/
155 static NTSTATUS pipe_cm_find(struct client_ipc_connection *ipc,
156 const struct ndr_syntax_id *interface,
157 struct rpc_pipe_client **presult)
159 struct client_pipe_connection *p;
161 for (p = ipc->pipe_connections; p; p = p->next) {
163 if (!rpc_pipe_np_smb_conn(p->pipe)) {
164 return NT_STATUS_PIPE_EMPTY;
167 if (strequal(ipc->cli->desthost, p->pipe->desthost)
168 && ndr_syntax_id_equal(&p->pipe->abstract_syntax,
175 return NT_STATUS_PIPE_NOT_AVAILABLE;
178 /********************************************************************
179 ********************************************************************/
181 static NTSTATUS pipe_cm_connect(TALLOC_CTX *mem_ctx,
182 struct client_ipc_connection *ipc,
183 const struct ndr_syntax_id *interface,
184 struct rpc_pipe_client **presult)
186 struct client_pipe_connection *p;
189 p = TALLOC_ZERO_ARRAY(mem_ctx, struct client_pipe_connection, 1);
191 return NT_STATUS_NO_MEMORY;
194 status = cli_rpc_pipe_open_noauth(ipc->cli, interface, &p->pipe);
195 if (!NT_STATUS_IS_OK(status)) {
200 DLIST_ADD(ipc->pipe_connections, p);
206 /********************************************************************
207 ********************************************************************/
209 static NTSTATUS pipe_cm_open(TALLOC_CTX *ctx,
210 struct client_ipc_connection *ipc,
211 const struct ndr_syntax_id *interface,
212 struct rpc_pipe_client **presult)
214 if (NT_STATUS_IS_OK(pipe_cm_find(ipc, interface, presult))) {
218 return pipe_cm_connect(ctx, ipc, interface, presult);
221 /********************************************************************
222 ********************************************************************/
224 WERROR libnetapi_open_pipe(struct libnetapi_ctx *ctx,
225 const char *server_name,
226 const struct ndr_syntax_id *interface,
227 struct rpc_pipe_client **presult)
229 struct rpc_pipe_client *result = NULL;
232 struct client_ipc_connection *ipc = NULL;
235 return WERR_INVALID_PARAM;
238 werr = libnetapi_open_ipc_connection(ctx, server_name, &ipc);
239 if (!W_ERROR_IS_OK(werr)) {
243 status = pipe_cm_open(ctx, ipc, interface, &result);
244 if (!NT_STATUS_IS_OK(status)) {
245 libnetapi_set_error_string(ctx, "failed to open PIPE %s: %s",
246 get_pipe_name_from_syntax(talloc_tos(), interface),
247 get_friendly_nt_error_msg(status));
248 return WERR_DEST_NOT_FOUND;