sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-03-08 04:58:40 +03:00
Code

s3:smbd: smbd_[un]lock_socket() while accessing the socket to the client

Browse Source 
metze
This commit is contained in:
Stefan Metzmacher 2010-03-18 09:23:48 +01:00
parent 8de8554628
commit 977aa660f4
1 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
source3/smbd/process.c
View File

@ -65,6 +65,12 @@ bool srv_send_smb(int fd, char *buffer,
size_t nwritten=0;
ssize_t ret;
char *buf_out = buffer;
bool ok;
ok = smbd_lock_socket(smbd_server_conn);
if (!ok) {
exit_server_cleanly("failed to lock socket");
}
if (do_signing) {
/* Sign the outgoing packet if required. */
@ -95,6 +101,12 @@ bool srv_send_smb(int fd, char *buffer,
srv_free_enc_buffer(buf_out);
out:
SMB_PERFCOUNT_END(pcd);
ok = smbd_unlock_socket(smbd_server_conn);
if (!ok) {
exit_server_cleanly("failed to unlock socket");
}
return true;
}
@ -2113,14 +2125,25 @@ static void smbd_server_connection_read_handler(struct smbd_server_connection *c
NTSTATUS status;
uint32_t seqnum;
/* TODO: make this completely nonblocking */
bool ok;
ok = smbd_lock_socket(conn);
if (!ok) {
exit_server_cleanly("failed to lock socket");
}
/* TODO: make this completely nonblocking */
status = receive_smb_talloc(mem_ctx, smbd_server_fd(),
(char **)(void *)&inbuf,
0, /* timeout */
&unread_bytes,
&encrypted,
&inbuf_len, &seqnum);
ok = smbd_unlock_socket(conn);
if (!ok) {
exit_server_cleanly("failed to unlock");
}
if (NT_STATUS_EQUAL(status, NT_STATUS_RETRY)) {
goto process;
}