summaryrefslogtreecommitdiff
path: root/source3
diff options
context:
space:
mode:
Diffstat (limited to 'source3')
-rw-r--r--source3/modules/vfs_smb_traffic_analyzer.c78
1 files changed, 74 insertions, 4 deletions
diff --git a/source3/modules/vfs_smb_traffic_analyzer.c b/source3/modules/vfs_smb_traffic_analyzer.c
index 15197c179b..f460515d89 100644
--- a/source3/modules/vfs_smb_traffic_analyzer.c
+++ b/source3/modules/vfs_smb_traffic_analyzer.c
@@ -168,7 +168,7 @@ static int smb_traffic_analyzer_connect_unix_socket(vfs_handle_struct *handle,
return sock;
}
-/* Private data allowing shared connection sockets. */
+/* Private data allowing shared connection sockets. */
struct refcounted_sock {
struct refcounted_sock *next, *prev;
@@ -178,7 +178,60 @@ struct refcounted_sock {
unsigned int ref_count;
};
-/* Send data over a socket */
+
+/* The marshaller for the protocol version 2. */
+static char *smb_traffic_analyzer_create_string( struct tm *tm, \
+ int seconds, vfs_handle_struct *handle, \
+ char *username, int count, ... )
+{
+
+ va_list ap;
+ char *arg = NULL;
+ char *str = NULL;
+ int len;
+ char *header = NULL;
+ char *buf = NULL;
+ char *timestr = NULL;
+
+ /* first create the data that is transfered with any VFS op */
+ len = strlen( username );
+ buf = talloc_asprintf(talloc_tos(),"%04u%s", len, username);
+ len = strlen( handle->conn->connectpath );
+ buf = talloc_asprintf_append( buf, "%04u%s", len, \
+ handle->conn->connectpath );
+ len = strlen( pdb_get_domain(handle->conn->server_info->sam_account) );
+ buf = talloc_asprintf_append( buf, "%04u%s", len, \
+ pdb_get_domain(handle->conn->server_info->sam_account) );
+ timestr = talloc_asprintf(talloc_tos(), \
+ "%04d-%02d-%02d %02d:%02d:%02d.%03d", \
+ tm->tm_year+1900, \
+ tm->tm_mon+1, \
+ tm->tm_mday, \
+ tm->tm_hour, \
+ tm->tm_min, \
+ tm->tm_sec, \
+ (int)seconds);
+ len = strlen( timestr );
+ buf = talloc_asprintf_append( buf, "%04u%s", len, timestr);
+
+ va_start( ap, count );
+ while ( count-- ) {
+ arg = va_arg( ap, char * );
+ /* protocol v2 sends a four byte string */
+ /* as a header to each block, including */
+ /* the numbers of bytes to come in the */
+ /* next string. */
+ len = strlen( arg );
+ buf = talloc_asprintf_append( buf, "%04u%s", len, arg);
+ }
+ va_end( ap );
+
+ /* now create the protocol v2 header. */
+ len = strlen( buf );
+ str = talloc_asprintf_append( str, "V2,%017u%s", len, buf);
+ DEBUG(10, ("smb_traffic_analyzer_create_string: %s\n",str));
+ return str;
+}
static void smb_traffic_analyzer_send_data(vfs_handle_struct *handle,
void *data,
@@ -275,8 +328,25 @@ static void smb_traffic_analyzer_send_data(vfs_handle_struct *handle,
tm->tm_sec,
(int)seconds);
} else if ( strcmp( protocol_version, "V2") == 0) {
- /* protocol version 2 */
- /* in development */
+
+ switch( vfs_operation ) {
+ case vfs_id_mkdir: ;
+ struct mkdir_data *s_data = \
+ (struct mkdir_data *) data;
+ str = smb_traffic_analyzer_create_string( tm, \
+ seconds, handle, username, \
+ 3, s_data->path, \
+ talloc_asprintf( talloc_tos(), "%u", \
+ s_data->mode), \
+ talloc_asprintf( talloc_tos(), "%u", \
+ s_data->result ));
+ break;
+ default:
+ DEBUG(1, ("smb_traffic_analyzer: error! "
+ "wrong VFS operation id detected!\n"));
+ return;
+ }
+
} else {
DEBUG(1, ("smb_traffic_analyzer_send_data_socket: "
"error, unkown protocol given!\n"));