#include "includes.h"
#include "libsmb/libsmb.h"
#include "../lib/util/tevent_ntstatus.h"
-#include "smb_signing.h"
+#include "../libcli/smb/smb_signing.h"
+#include "../libcli/smb/smb_seal.h"
#include "async_smb.h"
+#include "../libcli/smb/smbXcli_base.h"
/*******************************************************************
Setup the word count and byte count for a client smb message.
}
/****************************************************************************
- convenience routine to find if we negotiated ucs2
+ Set the 'backup_intent' flag.
****************************************************************************/
-bool cli_ucs2(struct cli_state *cli)
+bool cli_set_backup_intent(struct cli_state *cli, bool flag)
{
- return ((cli_state_capabilities(cli) & CAP_UNICODE) != 0);
+ bool old_state = cli->backup_intent;
+ cli->backup_intent = flag;
+ return old_state;
}
/****************************************************************************
- Setup basics in a outgoing packet.
+ convenience routine to find if we negotiated ucs2
****************************************************************************/
-void cli_setup_packet_buf(struct cli_state *cli, char *buf)
+bool cli_ucs2(struct cli_state *cli)
{
- uint16 flags2;
- cli->rap_error = 0;
- SIVAL(buf,smb_rcls,0);
- SSVAL(buf,smb_pid,cli->smb1.pid);
- memset(buf+smb_pidhigh, 0, 12);
- SSVAL(buf,smb_uid, cli_state_get_uid(cli));
- SSVAL(buf,smb_mid,cli->smb1.mid);
-
- if (cli_state_protocol(cli) <= PROTOCOL_CORE) {
- return;
- }
-
- if (cli->case_sensitive) {
- SCVAL(buf,smb_flg,0x0);
- } else {
- /* Default setting, case insensitive. */
- SCVAL(buf,smb_flg,0x8);
- }
- flags2 = FLAGS2_LONG_PATH_COMPONENTS;
- if (cli_state_capabilities(cli) & CAP_UNICODE)
- flags2 |= FLAGS2_UNICODE_STRINGS;
- if ((cli_state_capabilities(cli) & CAP_DFS) && cli->dfsroot)
- flags2 |= FLAGS2_DFS_PATHNAMES;
- if (cli_state_capabilities(cli) & CAP_STATUS32)
- flags2 |= FLAGS2_32_BIT_ERROR_CODES;
- if (cli->use_spnego)
- flags2 |= FLAGS2_EXTENDED_SECURITY;
- SSVAL(buf,smb_flg2, flags2);
+ return smbXcli_conn_use_unicode(cli->conn);
}
/****************************************************************************
int signing_state, int flags)
{
struct cli_state *cli = NULL;
- bool allow_smb_signing = false;
- bool mandatory_signing = false;
- socklen_t ss_length;
- int ret;
+ bool use_spnego = lp_client_use_spnego();
+ bool force_dos_errors = false;
+ bool force_ascii = false;
+ bool use_level_II_oplocks = false;
+ uint32_t smb1_capabilities = 0;
/* Check the effective uid - make sure we are not setuid */
if (is_setuid_root()) {
return NULL;
}
+ cli->server_domain = talloc_strdup(cli, "");
+ if (!cli->server_domain) {
+ goto error;
+ }
+ cli->server_os = talloc_strdup(cli, "");
+ if (!cli->server_os) {
+ goto error;
+ }
+ cli->server_type = talloc_strdup(cli, "");
+ if (!cli->server_type) {
+ goto error;
+ }
+
cli->dfs_mountpoint = talloc_strdup(cli, "");
if (!cli->dfs_mountpoint) {
goto error;
}
cli->raw_status = NT_STATUS_INTERNAL_ERROR;
- cli->protocol = PROTOCOL_NT1;
+ cli->map_dos_errors = true; /* remove this */
cli->timeout = 20000; /* Timeout is in milliseconds. */
- cli->max_xmit = CLI_BUFFER_SIZE+4;
cli->case_sensitive = false;
- cli->use_spnego = lp_client_use_spnego();
-
- cli->capabilities = CAP_UNICODE | CAP_STATUS32 | CAP_DFS;
-
/* Set the CLI_FORCE_DOSERR environment variable to test
client routines using DOS errors instead of STATUS32
ones. This intended only as a temporary hack. */
- if (getenv("CLI_FORCE_DOSERR"))
- cli->force_dos_errors = true;
+ if (getenv("CLI_FORCE_DOSERR")) {
+ force_dos_errors = true;
+ }
+ if (flags & CLI_FULL_CONNECTION_FORCE_DOS_ERRORS) {
+ force_dos_errors = true;
+ }
+
+ if (getenv("CLI_FORCE_ASCII")) {
+ force_ascii = true;
+ }
+ if (flags & CLI_FULL_CONNECTION_FORCE_ASCII) {
+ force_ascii = true;
+ }
if (flags & CLI_FULL_CONNECTION_DONT_SPNEGO) {
- cli->use_spnego = false;
+ use_spnego = false;
} else if (flags & CLI_FULL_CONNECTION_USE_KERBEROS) {
cli->use_kerberos = true;
}
cli->use_oplocks = true;
}
if (flags & CLI_FULL_CONNECTION_LEVEL_II_OPLOCKS) {
- cli->use_level_II_oplocks = true;
+ use_level_II_oplocks = true;
}
- if (lp_client_signing()) {
- allow_smb_signing = true;
+ if (signing_state == SMB_SIGNING_DEFAULT) {
+ signing_state = lp_client_signing();
}
- if (lp_client_signing() == Required) {
- mandatory_signing = true;
- }
+ smb1_capabilities = 0;
+ smb1_capabilities |= CAP_LARGE_FILES;
+ smb1_capabilities |= CAP_NT_SMBS | CAP_RPC_REMOTE_APIS;
+ smb1_capabilities |= CAP_LOCK_AND_READ | CAP_NT_FIND;
+ smb1_capabilities |= CAP_DFS | CAP_W2K_SMBS;
+ smb1_capabilities |= CAP_LARGE_READX|CAP_LARGE_WRITEX;
+ smb1_capabilities |= CAP_LWIO;
- if (signing_state != Undefined) {
- allow_smb_signing = true;
+ if (!force_dos_errors) {
+ smb1_capabilities |= CAP_STATUS32;
}
- if (signing_state == false) {
- allow_smb_signing = false;
- mandatory_signing = false;
+ if (!force_ascii) {
+ smb1_capabilities |= CAP_UNICODE;
}
- if (signing_state == Required) {
- mandatory_signing = true;
+ if (use_spnego) {
+ smb1_capabilities |= CAP_EXTENDED_SECURITY;
}
- /* initialise signing */
- cli->signing_state = smb_signing_init(cli,
- allow_smb_signing,
- mandatory_signing);
- if (!cli->signing_state) {
- goto error;
- }
-
- cli->conn.outgoing = tevent_queue_create(cli, "cli_outgoing");
- if (cli->conn.outgoing == NULL) {
- goto error;
- }
- cli->conn.pending = NULL;
-
- cli->conn.remote_name = talloc_strdup(cli, remote_name);
- if (cli->conn.remote_name == NULL) {
- goto error;
+ if (use_level_II_oplocks) {
+ smb1_capabilities |= CAP_LEVEL_II_OPLOCKS;
}
if (remote_realm) {
- cli->conn.remote_realm = talloc_strdup(cli, remote_realm);
- if (cli->conn.remote_realm == NULL) {
+ cli->remote_realm = talloc_strdup(cli, remote_realm);
+ if (cli->remote_realm == NULL) {
goto error;
}
}
- cli->conn.fd = fd;
-
- ss_length = sizeof(cli->conn.local_ss);
- ret = getsockname(fd,
- (struct sockaddr *)(void *)&cli->conn.local_ss,
- &ss_length);
- if (ret == -1) {
- goto error;
- }
- ss_length = sizeof(cli->conn.remote_ss);
- ret = getpeername(fd,
- (struct sockaddr *)(void *)&cli->conn.remote_ss,
- &ss_length);
- if (ret == -1) {
+ cli->conn = smbXcli_conn_create(cli, fd, remote_name,
+ signing_state,
+ smb1_capabilities,
+ NULL); /* client_guid */
+ if (cli->conn == NULL) {
goto error;
}
- cli->smb1.mid = 1;
cli->smb1.pid = (uint16_t)sys_getpid();
cli->smb1.vc_num = cli->smb1.pid;
cli->smb1.tid = UINT16_MAX;
bool cli_state_encryption_on(struct cli_state *cli)
{
- return common_encryption_on(cli->trans_enc_state);
+ return smb1cli_conn_encryption_on(cli->conn);
}
cli_tdis(cli);
}
- data_blob_free(&cli->secblob);
data_blob_free(&cli->user_session_key);
cli_state_disconnect(cli);
- /*
- * Need to free pending first, they remove themselves
- */
- while (cli->conn.pending) {
- talloc_free(cli->conn.pending[0]);
- }
TALLOC_FREE(cli);
}
void cli_sockopt(struct cli_state *cli, const char *options)
{
- set_socket_options(cli->conn.fd, options);
+ smbXcli_conn_set_sockopt(cli->conn, options);
}
const struct sockaddr_storage *cli_state_local_sockaddr(struct cli_state *cli)
{
- return &cli->conn.local_ss;
+ return smbXcli_conn_local_sockaddr(cli->conn);
}
const struct sockaddr_storage *cli_state_remote_sockaddr(struct cli_state *cli)
{
- return &cli->conn.remote_ss;
+ return smbXcli_conn_remote_sockaddr(cli->conn);
}
const char *cli_state_remote_name(struct cli_state *cli)
{
- return cli->conn.remote_name;
+ return smbXcli_conn_remote_name(cli->conn);
}
const char *cli_state_remote_realm(struct cli_state *cli)
{
- return cli->conn.remote_realm;
+ return cli->remote_realm;
}
uint16_t cli_state_get_vc_num(struct cli_state *cli)
return cli->smb1.vc_num;
}
+uint32_t cli_state_server_session_key(struct cli_state *cli)
+{
+ return smb1cli_conn_server_session_key(cli->conn);
+}
+
/****************************************************************************
Set the PID to use for smb messages. Return the old pid.
****************************************************************************/
enum protocol_types cli_state_protocol(struct cli_state *cli)
{
- return cli->protocol;
+ return smbXcli_conn_protocol(cli->conn);
}
uint32_t cli_state_capabilities(struct cli_state *cli)
{
- return cli->capabilities;
+ return smb1cli_conn_capabilities(cli->conn);
+}
+
+uint32_t cli_state_available_size(struct cli_state *cli, uint32_t ofs)
+{
+ uint32_t ret = smb1cli_conn_max_xmit(cli->conn);
+
+ if (ofs >= ret) {
+ return 0;
+ }
+
+ ret -= ofs;
+
+ return ret;
+}
+
+uint16_t cli_state_max_requests(struct cli_state *cli)
+{
+ return smbXcli_conn_max_requests(cli->conn);
+}
+
+const uint8_t *cli_state_server_challenge(struct cli_state *cli)
+{
+ return smb1cli_conn_server_challenge(cli->conn);
+}
+
+const DATA_BLOB *cli_state_server_gss_blob(struct cli_state *cli)
+{
+ return smbXcli_conn_server_gss_blob(cli->conn);
+}
+
+uint16_t cli_state_security_mode(struct cli_state *cli)
+{
+ return smb1cli_conn_server_security_mode(cli->conn);
+}
+
+int cli_state_server_time_zone(struct cli_state *cli)
+{
+ return smb1cli_conn_server_time_zone(cli->conn);
+}
+
+time_t cli_state_server_time(struct cli_state *cli)
+{
+ NTTIME nt;
+ time_t t;
+
+ nt = smbXcli_conn_server_system_time(cli->conn);
+ t = nt_time_to_unix(nt);
+
+ return t;
}
struct cli_echo_state {
git.samba.org / nivanova / samba-autobuild / .git / blobdiff