/** * xrdp : A Remote Desktop Protocol server . * * xrdp device redirection - only drive redirection is currently supported * * Copyright ( C ) Laxmikant Rashinkar 2013 LK . Rashinkar @ gmail . com * * Licensed under the Apache License , Version 2 . 0 ( the " License " ) ; * you may not use this file except in compliance with the License . * You may obtain a copy of the License at * * http : //www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing , software * distributed under the License is distributed on an " AS IS " BASIS , * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND , either express or implied . * See the License for the specific language governing permissions and * limitations under the License . /* * TODO * o there is one difference in the protocol initialization * sequence upon reconnection : if a user is already logged on , * send a SERVER_USER_LOGGED_ON msg as per section 3 . 3 . 5 . 1 . 5 * * o how to announce / delete a drive after a connection has been * established ? * * o need to support multiple drives ; * o for multiple drives , we cannot have global device_id ' s and file_id ' s * and all functions must be reenterant * o replace printf ' s with log_xxx * o mark local funcs with static #if defined (HAVE_CONFIG_H)#include <config_ac.h>#endif #include <stdio.h>#include <unistd.h>#include <stdlib.h>#include <sys/types.h>#include <sys/stat.h>#include <sys/statvfs.h>#include <fcntl.h>#include <string.h>#include "arch.h" #include "parse.h" #include "os_calls.h" #include "string_calls.h" #include "log.h" #include "chansrv.h" #include "chansrv_fuse.h" #include "chansrv_xfs.h" #include "devredir.h" #include "smartcard.h" #include "ms-rdpefs.h" #include "ms-smb2.h" #include "ms-fscc.h" #include "ms-erref.h" /* client minor versions */ #define RDP_CLIENT_50 0 x0002#define RDP_CLIENT_51 0 x0005#define RDP_CLIENT_52 0 x000a#define RDP_CLIENT_60_61 0 x000c/* Windows time starts on Jan 1, 1601 */ /* Linux time starts on Jan 1, 1970 */ #define EPOCH_DIFF 11644473600 LL#define WINDOWS_TO_LINUX_TIME(_t) (((_t) / 10000000 ) - EPOCH_DIFF);#define LINUX_TO_WINDOWS_TIME(_t) (((_t) + EPOCH_DIFF) * 10000000 )/* * CompletionID types , used in IRPs to indicate I / O operation enum COMPLETION_TYPE1 ,/* globals */ extern int g_rdpdr_chan_id; /* in chansrv.c */ /* Capabilities from GENERAL_CAPS_SET in Client Core Capability Response */ struct client_capsint printer_redir_supported;int port_redir_supported;int drive_redir_supported;int smartcard_redir_supported;unsigned int drive_redir_version;static struct client_caps g_ccap;1 ;/* unique client ID - announced by client */ /* unique device ID - announced by client */ /* returned by client */ struct stream *g_input_stream = NULL;/* * Local functions called from devredir_proc_device_iocompletion ( ) static void devredir_proc_cid_rmdir_or_file(IRP *irp, enum NTSTATUS IoStatus);static void devredir_proc_cid_rmdir_or_file_resp(IRP *irp,enum NTSTATUS IoStatus);static void devredir_proc_cid_rename_file(IRP *irp, enum NTSTATUS IoStatus);static void devredir_proc_cid_rename_file_resp(IRP *irp,enum NTSTATUS IoStatus);static void devredir_proc_cid_lookup( IRP *irp,struct stream *s_in,enum NTSTATUS IoStatus);static void devredir_proc_cid_setattr( IRP *irp,struct stream *s_in,enum NTSTATUS IoStatus);static void devredir_proc_cid_statfs( IRP *irp,struct stream *s_in,enum NTSTATUS IoStatus);static void devredir_proc_cid_statfs_resp(IRP *irp,struct stream *s_in,enum NTSTATUS IoStatus);/* Other local functions */ static void devredir_send_server_core_cap_req(void );static void devredir_send_server_clientID_confirm(void );static void devredir_send_server_user_logged_on(void );static int devredir_proc_client_core_cap_resp(struct stream *s);static int devredir_proc_client_devlist_announce_req(struct stream *s);static int devredir_proc_client_devlist_remove_req(struct stream *s);static int devredir_proc_device_iocompletion(struct stream *s);static int devredir_proc_query_dir_response(IRP *irp,struct stream *s_in,enum NTSTATUS IoStatus);static void devredir_cvt_slash(char *path);static int devredir_string_ends_with(const char *string, char c);/*****************************************************************************/ int void )struct stream *s;int bytes;/* get a random number that will act as a unique clientID */ char *) &clientID, sizeof (clientID));/* setup stream */ 1024 );/* initiate drive redirection protocol by sending Server Announce Req */ 0 x0001); /* server major ver */ 0 x000C); /* server minor ver - pretend 2 b Win 7 */ /* unique ClientID */ /* send data to client */ return 0 ;/*****************************************************************************/ int void )return 0 ;/*****************************************************************************/ /* * Convert a COMPLETION_TYPE to a string const char *completion_type_to_str(enum COMPLETION_TYPE cid)return "CID_CREATE_DIR_REQ" :"CID_DIRECTORY_CONTROL" :"CID_CREATE_REQ" :"CID_OPEN_REQ" :"CID_READ" :"CID_WRITE" :"CID_CLOSE" :"CID_FILE_CLOSE" :"CID_RMDIR_OR_FILE" :"CID_RMDIR_OR_FILE_RESP" :"CID_RENAME_FILE" :"CID_RENAME_FILE_RESP" :"CID_LOOKUP" :"CID_SETATTR" :"CID_STATFS" :"CID_STATFS_RESP" :/* default */ "<unknown>"; /*****************************************************************************/ /* * Convert Windows permissions to Linux permissions . * * We can ' t currently support group or other permissions as separate from the * owner ( not that there ' s much point ) . We ' ll assume our caller will provide * a umask if appropriate static tui32if (wperm & W_FILE_ATTRIBUTE_DIRECTORY)0555 ; /* dirs are always readable and executable */ else 0444 ; /* files are always readable */ if (wperm & W_FILE_ATTRIBUTE_SYSTEM)0111 ; /* Executable */ if ((wperm & W_FILE_ATTRIBUTE_READONLY) == 0 )0222 ;return result;/*****************************************************************************/ static tui320 ;/* Writeable flag is common to files and directories */ if ((lperm & S_IWUSR) == 0 )if (lperm & S_IFDIR)else /* For normal files the system attribute is used to store the owner if (lperm & S_IXUSR)if (result == 0 )/* See MS-FSCC section 2.6 */ return result;/** * @ brief process incoming data * * @ return 0 on success , - 1 on failure int struct stream *s, int chan_id, int chan_flags, int length,int total_length)struct stream *ls;int rv = 0 ;/* * handle packet fragmentation if ((chan_flags & 3 ) == 3 )/* all data contained in one packet */ else /* is this is the first packet? */ if (chan_flags & 1 )/* in last packet, chan_flags & 0x02 will be true */ if ((chan_flags & 2 ) == 0 )return 0 ;/* read header from incoming data */ if (!s_check_rem_and_log(ls, 4 , "Parsing [MS-RDPEFS] RDPDR_HEADER" ))1 ;goto done;/* for now we only handle core type, not printers */ if (comp_type != RDPDR_CTYP_CORE)"invalid component type in response; expected 0x%x got 0x%x" ,1 ;goto done;/* figure out what kind of response we have gotten */ switch (pktID)case PAKID_CORE_CLIENTID_CONFIRM:if (!s_check_rem_and_log(ls, 6 , "Parsing [MS-RDPEFS] DR_CORE_CLIENT_ANNOUNCE_RSP" ))1 ;else 2 ); /* major version, we ignore it */ switch (minor_ver)case RDP_CLIENT_50:break ;case RDP_CLIENT_51:break ;case RDP_CLIENT_52:break ;case RDP_CLIENT_60_61:break ;break ;case PAKID_CORE_CLIENT_NAME:/* client is telling us its computer name; do we even care? */ /* See 3.3.5.1.6 for sequencing rules */ if (g_client_rdp_version >= RDP_CLIENT_51)/* let client know our capabilities */ /* send confirm clientID */ break ;case PAKID_CORE_CLIENT_CAPABILITY:if (rv == 0 )if ((g_ccap.extended_pdu & RDPDR_USER_LOGGEDON_PDU) != 0 )/* Tell client to announce remaining devices */ else if (g_client_rdp_version >= RDP_CLIENT_51)/* See 3.3.5.1.7 */ break ;case PAKID_CORE_DEVICELIST_ANNOUNCE:break ;case PAKID_CORE_DEVICELIST_REMOVE:break ;case PAKID_CORE_DEVICE_IOCOMPLETION:break ;default :"got unknown response 0x%x" , pktID);break ;if (g_input_stream)return rv;/*****************************************************************************/ int int *count, int *timeout)if (g_ccap.smartcard_redir_supported)return scard_get_wait_objs(objs, count, timeout);return 0 ;/*****************************************************************************/ int void )if (g_ccap.smartcard_redir_supported)return scard_check_wait_objs();return 0 ;/** * @ brief let client know our capabilities static void void )struct stream *s;int bytes;int caps_count = 4 ;#ifdef XRDP_SMARTCARD#endif 1024 );/* setup header */ /* num of caps we are sending */ 0 x0000); /* padding */ /* setup general capability */ /* CapabilityType */ 44 ); /* CapabilityLength - len of this */ /* CAPABILITY_SET in bytes, inc */ /* the header */ 2 ); /* Version */ 2 ); /* O.S type */ 0 ); /* O.S version */ 1 ); /* protocol major version */ /* protocol minor version */ 0 xffff); /* I/O code 1 */ 0 ); /* I/O code 2 */ 7 ); /* Extended PDU */ 0 ); /* extra flags 1 */ 0 ); /* extra flags 2 */ 2 ); /* special type device cap */ /* setup printer capability */ 8 );1 );/* setup serial port capability */ 8 );1 );/* setup file system capability */ /* CapabilityType */ 8 ); /* CapabilityLength - len of this */ /* CAPABILITY_SET in bytes, inc */ /* the header */ 2 ); /* Version */ #ifdef XRDP_SMARTCARD/* setup smart card capability */ 8 );1 );#endif /* send to client */ static void void )struct stream *s;int bytes;1024 );/* setup stream */ 0 x0001);/* send to client */ static void void )struct stream *s;int bytes;1024 );/* setup stream */ /* send to client */ static void enum NTSTATUS result_code)struct stream *s;int bytes;1024 );/* setup stream */ /* send to client */ /** * Create a file system object * * See [ MS - RDPEFS ] 2 . 2 . 1 . 4 . 1 ( DR_CREATE_REQ ) * * @ return 0 on success , - 1 on failure static int const char *path,struct stream *s;int bytes;int path_len;unsigned int unicode_byte_count;"device_id=%d path=\" %s\"" " DesiredAccess=0x%x CreateDisposition=0x%x" " FileAttributes=0x%x CreateOptions=0x%x" " CompletionId=%d" ,/* Find number of bytes required for Unicode path + terminator */ 1 ; // includes terminator 2 ;int )(64 + unicode_byte_count));/* FILE_SHARE_DELETE allows files to be renamed while in use 0 ,/* DesiredAccess */ 0 ); /* AllocationSize high unused */ 0 ); /* AllocationSize low unused */ /* FileAttributes */ /* SharedAccess */ /* CreateDisposition */ /* CreateOptions */ /* PathLength */ /* Path */ /* send to client */ return 0 ;/** * Close a request previously created by devredir_send_drive_create_request ( ) static int enum IRP_MJ MajorFunction,enum IRP_MN MinorFunc,int pad_len)struct stream *s;int bytes;1024 );if (pad_len)/* send to client */ "sent close request; expect CID_FILE_CLOSE" );return 0 ;/** * @ brief ask client to enumerate directory * * See [ MS - RDPEFS ] 2 . 2 . 3 . 3 . 10 ( DR_DRIVE_QUERY_DIRECTORY_REQ ) static void char *Path)struct stream *s;int bytes;unsigned int path_len;unsigned int unicode_byte_count;/* during Initial Query, Path cannot be NULL */ if (InitialQuery && Path != NULL)/* Find number of words required for Unicode path */ 1 ; // includes terminator 2 ;else 0 ;0 ;int )(64 + unicode_byte_count));/* FsInformationClass */ /* InitialQuery */ /* PathLength */ 23 ); /* Padding */ /* Path */ /* send to client */ /******************************************************************************* * process data received from client * * /** * Process a GENERAL_CAPS_SET packet from the client * @ param s Stream . CAPABILITY_HEADER is already read * @ param cap_len Amount of data left in stream for the packet * @ return 0 for success , - 1 otherwise * * Caller is responsible for skipping unused data from this * capability in the input stream . static int struct stream *s, unsigned int cap_len,struct client_caps *ccap)int rv = -1 ;// Data we don't check at the start of the packet #define PACKET_SKIP_LENGTH ( \4 + /* osType */ \ 4 + /* osVersion */ \ 2 + /* protocolMajorVersion */ \ 2 + /* protocolMinorVersion */ \ 4 + /* ioCode1 */ \ 4 ) /* ioCode2 */ if (cap_len < (PACKET_SKIP_LENGTH + 4 ))"[MS-RDPEFS] GENERAL_CAPS_SET: Short packet (%u bytes) encountered" ,else 0 ;return rv;#undef PACKET_SKIP_LENGTH/** * @ brief process client ' s response to our core_capability_req ( ) msg * * @ param s stream containing client ' s response * @ return 0 for success , - 1 otherwise static int struct stream *s)#define CAPABILITY_HEADER_LEN 8 int i;// Reset to defaults 0 , sizeof (g_ccap));1 ;if (!s_check_rem_and_log(s, 4 , "Parsing [MS-RDPEFS] DR_CORE_CAPABLITY_RSP" ))return -1 ;2 ); /* padding */ for (i = 0 ; i < num_caps; i++)if (!s_check_rem_and_log(s, CAPABILITY_HEADER_LEN,"Parsing [MS-RDPEFS] CAPABILITY_HEADER" ))return -1 ;/* Convert the length to a remaining length. Underflow is possible, if (!s_check_rem_and_log(s, cap_len,"Parsing [MS-RDPEFS] CAPABILITY_HEADER data" ))return -1 ;// Save our stream position. iso_hdr is otherwise // unused in this stream 0 );switch (cap_type)case CAP_GENERAL_TYPE:"got CAP_GENERAL_TYPE" );if (process_client_general_caps_set(s, cap_len, &g_ccap) < 0 )return -1 ;break ;case CAP_PRINTER_TYPE:"got CAP_PRINTER_TYPE" );1 ;break ;case CAP_PORT_TYPE:"got CAP_PORT_TYPE" );1 ;break ;case CAP_DRIVE_TYPE:"got CAP_DRIVE_TYPE" );1 ;if (cap_version == 2 )2 ;break ;case CAP_SMARTCARD_TYPE:"got CAP_SMARTCARD_TYPE" );0 );break ;// Move back to start of capability data return 0 ;#undef CAPABILITY_HEADER_LENstatic int struct stream *s)unsigned int i;int j;char preferred_dos_name[9 ];enum NTSTATUS response_status;/* get number of devices being announced */ if (!s_check_rem_and_log(s, 4 , "Parsing [MS-RDPEFS] DR_CORE_DEVICELIST_ANNOUNCE_REQ" ))return -1 ;"num of devices announced: %d" , device_count);for (i = 0 ; i < device_count; i++)if (!s_check_rem_and_log(s, 4 + 4 + 8 + 4 ,"Parsing [MS-RDPEFS] DEVICE_ANNOUNCE" ))return -1 ;/* get preferred DOS name for (j = 0 ; j < 8 ; j++)8 ] = 0 ;/* Assume this device isn't supported by us */ /* Read the device data length from the stream */ if (device_data_len > 0 &&"Parsing [MS-RDPEFS] DEVICE_ANNOUNCE devdata" ))return -1 ;switch (device_type)case RDPDR_DTYP_FILESYSTEM:/* At present we don't use the full name - see "Detected remote drive '%s'" ,"device_type=FILE_SYSTEM device_id=0x%x dosname=%s " "device_data_len=%d" , g_device_id,/* create share directory in xrdp file system; */ /* think of this as the mount point for this share */ break ;case RDPDR_DTYP_SMARTCARD:"Detected remote smartcard '%s'" ,"device_type=SMARTCARD device_id=0x%x dosname=%s" ,if (scard_device_announce(g_device_id) == 0 )break ;default :/* All other devices are unsupported */ const char *description ="serial port" :"parallel port" :"printer" :/* default */ "unknown device"; "Detected remote %s '%s' (not supported)" ,"description=%s dosname=%s device_id=0x%x" ,break ;/* Tell the client wheth or not we're supporting this one */ return 0 ;static int struct stream *s)unsigned int i;/* get number of devices being announced */ if (!s_check_rem_and_log(s, 4 , "Parsing [MS-RDPEFS] DR_DEVICELIST_REMOVE" ))return -1 ;if (!s_check_rem_and_log(s, 4 * device_count,"Parsing [MS-RDPEFS] DR_DEVICELIST_REMOVE list" ))return -1 ;"num of devices removed: %d" , device_count);for (i = 0 ; i < device_count; i++)return 0 ;static int struct stream *s)enum COMPLETION_TYPE comp_type;if (!s_check_rem_and_log(s, 12 , "Parsing [MS-RDPEFS] DR_DEVICE_IOCOMPLETION" ))return -1 ;enum NTSTATUS IoStatus = (enum NTSTATUS) IoStatus32; /* Needed by C++ */ if ((irp = devredir_irp_find(CompletionId)) == NULL)"IRP with completion ID %d not found" , CompletionId);else if (irp->callback)/* Callback has been set - call it */ else enum COMPLETION_TYPE) irp->completion_type;/* Log something about the IRP */ if (IoStatus == STATUS_SUCCESS ||/* Successes or common occurrences - debug logging only */ "got %s" , completion_type_to_str(comp_type));else "CompletionType = %s, IoStatus=%08x " "Pathname = %s" ,"<none>" );switch (comp_type)case CID_CREATE_DIR_REQ:if (IoStatus != STATUS_SUCCESS)struct state_dirscan *) irp->fuse_info, IoStatus);else if (!s_check_rem_and_log(s, 4 , "Parsing [MS-RDPEFS] DR_CREATE_RSP" ))return -1 ;1 , irp->pathname);break ;case CID_CREATE_REQ:if (!s_check_rem_and_log(s, 4 , "Parsing [MS-RDPEFS] DR_CREATE_RSP" ))return -1 ;struct state_create *) irp->fuse_info,if (irp->gen.create.creating_dir || IoStatus != STATUS_SUCCESS)break ;case CID_OPEN_REQ:if (!s_check_rem_and_log(s, 4 , "Parsing [MS-RDPEFS] DR_CREATE_RSP" ))return -1 ;struct state_open *) irp->fuse_info,if (IoStatus != STATUS_SUCCESS)break ;case CID_READ:if (!s_check_rem_and_log(s, 4 , "Parsing [MS-RDPEFS] DR_READ_RSP" ))return -1 ;if (!s_check_rem_and_log(s, Length, "Parsing [MS-RDPEFS] DR_READ_RSP" ))return -1 ;struct state_read *) irp->fuse_info,break ;case CID_WRITE:if (!s_check_rem_and_log(s, 4 , "Parsing [MS-RDPEFS] DR_WRITE_RSP" ))return -1 ;struct state_write *) irp->fuse_info,break ;case CID_CLOSE:break ;case CID_FILE_CLOSE:struct state_close *) irp->fuse_info);break ;case CID_DIRECTORY_CONTROL:if (devredir_proc_query_dir_response(irp, s, DeviceId,0 )return -1 ;break ;case CID_RMDIR_OR_FILE:if (!s_check_rem_and_log(s, 4 , "Parsing [MS-RDPEFS] DR_CREATE_RSP" ))return -1 ;break ;case CID_RMDIR_OR_FILE_RESP:break ;case CID_RENAME_FILE:if (!s_check_rem_and_log(s, 4 , "Parsing [MS-RDPEFS] DR_CREATE_RSP" ))return -1 ;break ;case CID_RENAME_FILE_RESP:break ;case CID_LOOKUP:break ;case CID_SETATTR:break ;case CID_STATFS:break ;case CID_STATFS_RESP:break ;default :"got unknown CompletionID: DeviceId=0x%x " "CompletionId=0x%x IoStatus=0x%x" ,break ;return 0 ;/** * Parse a query directory response * * See : - * - [ MS - RDPEFS ] 2 . 2 . 3 . 4 . 10 ( DR_DRIVE_QUERY_DIRECTORY_RSP ) * - [ MS - FSCC ] 2 . 4 . 10 ( FileDirectoryInformation ) * * return 0 on success , - 1 on failure static int struct stream *s_in,enum NTSTATUS IoStatus)// Size of FILE_DIRECTORY_INFORMATION structure with a particular // filename length #define FILE_DIRECTORY_INFORMATION_SIZE(FileNameLength) \4 + 4 + 8 + 8 + 8 + 8 + 8 + 8 + 4 + 4 ) + FileNameLength)4 ); /* Length */ if (IoStatus == STATUS_SUCCESS)/* process FILE_DIRECTORY_INFORMATION structures */ while (1 )/* Can we read up to the filename? */ if (!s_check_rem_and_log(s_in,0 ),"FILE_DIRECTORY_INFORMATION" ))return -1 ;// Size the filename buffer so it's big enough for // storing the file in our filesystem if we need to. char filename[XFS_MAXFILENAMELEN + 1 ];struct file_attr fattr;unsigned int flen;4 ); /* FileIndex */ 8 ); /* CreationTime */ 8 ); /* ChangeTime */ 8 ); /* AllocationSize */ if (!s_check_rem_and_log(s_in,"FILE_DIRECTORY_INFORMATION:FileName" ))return -1 ;2 ,sizeof (filename));if (flen > sizeof (filename))"Buffer was %d bytes too small for filename" ,int )(flen - sizeof (filename)));//LOG_DEVEL(LOG_LEVEL_DEBUG, "LastAccessTime: 0x%llx", LastAccessTime); //LOG_DEVEL(LOG_LEVEL_DEBUG, "LastWriteTime: 0x%llx", LastWriteTime); //LOG_DEVEL(LOG_LEVEL_DEBUG, "EndOfFile: %lld", EndOfFile); //LOG_DEVEL(LOG_LEVEL_DEBUG, "FileAttributes: 0x%x", FileAttributes); //LOG_DEVEL(LOG_LEVEL_DEBUG, "FileNameLength: %d", FileNameLength); "FileName: %s" , filename);/* add this entry to xrdp file system */ struct state_dirscan *) irp->fuse_info,/* From [MS-FSCC] * { NextEntryOffset } MUST be zero if no other entries follow * this one . An implementation MUST use this value to determine * the location of the next entry ( if multiple entries are if (NextEntryOffset == 0 )break ;int pad = NextEntryOffset -if (pad > 0 )if (!s_check_rem_and_log(s_in,"FILE_DIRECTORY_INFORMATION:pad" ))return -1 ;/* Ask for more directory entries */ 0 , NULL);else if (IoStatus == STATUS_NO_MORE_FILES)struct state_dirscan *)irp->fuse_info,32 );return 0 ;#undef FILE_DIRECTORY_INFORMATION_SIZE/** * FUSE calls this function whenever it wants us to enumerate a dir * * @ param fusep opaque data struct that we just pass back to FUSE when done * @ param device_id device_id of the redirected share * @ param path the dir path to enumerate * * @ return 0 on success , - 1 on failure int struct state_dirscan *fusep, tui32 device_id,const char *path)int rval = -1 ;/* * We need to be able to append two additional characters to the * path after we create the IRP if ((irp = devredir_irp_with_pathnamelen_new(strlen(path) + 2 )) != NULL)/* convert / to windows compatible \ */ 0 , CreateDisposition,"looking for device_id=%d path=%s" , device_id, irp->pathname);/* when we get a response to devredir_send_drive_create_request(), we * call devredir_send_drive_dir_request ( ) , which needs the following if (devredir_string_ends_with(irp->pathname, '\\' ))"*" );else "\\*" );return rval;/** * FUSE calls this function whenever it wants us to lookup a file or directory * * @ param fusep opaque data struct that we just pass back to FUSE when done * @ param device_id device_id of the redirected share * @ param path the name of the directory containing the file * @ param file the filename * * @ return 0 on success , - 1 on failure int struct state_lookup *fusep, tui32 device_id,const char *path)int rval = -1 ;"fusep=%p" , fusep);if ((irp = devredir_irp_with_pathname_new(path)) != NULL)/* convert / to windows compatible \ */ /* * Allocate an IRP to open the file , read the basic attributes , * read the standard attributes , and then close the file 0 ;"lookup for device_id=%d path=%s CompletionId=%d" ,0 , CreateDisposition,return rval;/** * FUSE calls this function whenever it wants us to set the attributes for * a file or directory . * * @ param fusep opaque data struct that we just pass back to FUSE when done * @ param device_id device_id of the redirected share * @ param filename the name of the file * @ param fattr the file attributes to set for the file * @ param to_set Which bits of the file attributes have changed * * @ return 0 on success , - 1 on failure int struct state_setattr *fusep, tui32 device_id,const char *filename,const struct file_attr *fattr,int rval = -1 ;"fusep=%p" , fusep);if ((irp = devredir_irp_with_pathname_new(filename)) != NULL)/* convert / to windows compatible \ */ /* * Allocate an IRP to open the file , update the attributes * and close the file . /* * Don ' t set DA_FILE_WRITE_DATA unless we ' re changing the * EndOfFile pointer . Otherwise we can ' t change the attributes if (to_set & TO_SET_SIZE)0 ;"lookup for device_id=%d path=%s" ,0 , CreateDisposition,return rval;/** * FUSE calls this function whenever it wants us to run a statfs * * @ param fusep opaque data struct that we just pass back to FUSE when done * @ param device_id device_id of the redirected share * * @ return 0 on success , - 1 on failure int struct state_statfs *fusep, tui32 device_id, const char *path)int rval = -1 ;"fusep=%p" , fusep);if ((irp = devredir_irp_with_pathname_new(path)) != NULL)/* convert / to windows compatible \ */ /* * Allocate an IRP to open the file , read the filesystem size * attributes and then close the file 0 ;"statfs for device_id=%d CompletionId=%d" ,0 , CreateDisposition,return rval;int struct state_create *fusep, tui32 device_id,const char *path, int mode)0 ;int rval = -1 ;"device_id=%d path=%s mode=0%o" , device_id, path, mode);if ((irp = devredir_irp_with_pathname_new(path)) != NULL)/* convert / to windows compatible \ */ 0 x0016019f; /* got this value from windows */ if (mode & S_IFDIR)"creating dir" );1 ;else "creating file" );0 x44; /* got this value from windows */ 0 ;//CreateDisposition = CD_FILE_CREATE; 0 x02; /* got this value from windows */ return rval;int struct state_open *fusep, tui32 device_id,const char *path, int flags)0 ;int rval = -1 ;"device_id=%d path=%s flags=0%x" ,if ((irp = devredir_irp_with_pathname_new(path)) != NULL)/* convert / to windows compatible \ */ switch (flags & O_ACCMODE)case O_RDONLY:"open file in O_RDONLY" );break ;case O_WRONLY:"open file in O_WRONLY" );break ;default :/* * The access mode could conceivably be invalid here , * but we assume this has been checked by the caller "open file in O_RDWR" );/* without the 0x00000010 rdesktop opens files in */ /* O_RDONLY instead of O_RDWR mode */ 0 x00000010;// WAS 1 return rval;int devredir_file_close(struct state_close *fusep, tui32 device_id,"entered: fusep=%p device_id=%d FileId=%d" ,#if 0 if ((irp = devredir_irp_new()) == NULL)return -1 ;#else if ((irp = devredir_irp_find_by_fileid(FileId)) == NULL)"no IRP found with FileId = %d" , FileId);return -1 ;#endif return devredir_send_drive_close_request(RDPDR_CTYP_CORE,32 );/** * Remove ( delete ) a directory or file int struct state_remove *fusep, tui32 device_id,const char *path)int rval = -1 ;if ((irp = devredir_irp_with_pathname_new(path)) != NULL)/* convert / to windows compatible \ */ //DesiredAccess = DA_DELETE | DA_FILE_READ_ATTRIBUTES | DA_SYNCHRONIZE; 0 x00100080; /* got this value from windows */ //CreateOptions = CO_FILE_DELETE_ON_CLOSE | CO_FILE_DIRECTORY_FILE | // CO_FILE_SYNCHRONOUS_IO_NONALERT; 0 x020; /* got this value from windows */ //CreateDisposition = CD_FILE_OPEN; // WAS 1 0 x01; /* got this value from windows */ 0 , CreateDisposition,return rval;/** * Read data from previously opened file * * Errors are reported via xfuse_devredir_cb_read_file ( ) void struct state_read *fusep, tui32 DeviceId, tui32 FileId,struct stream *s;int bytes;1024 );/* Check we've got an open IRP for this file already */ if ((irp = devredir_irp_find_by_fileid(FileId)) == NULL)"no IRP found with FileId = %d" , FileId);0 );/* create a new IRP for this request */ else if ((new_irp = devredir_irp_new()) == NULL)/* system out of memory */ 0 );else 20 );/* send to client */ /** * Read data from previously opened file * * Errors are reported via xfuse_devredir_cb_write_file ( ) void struct state_write *fusep, tui32 DeviceId, tui32 FileId,const char *buf, int Length, tui64 Offset)struct stream *s;int bytes;"DeviceId=%d FileId=%d Length=%d Offset=%lld" ,long long )Offset);1024 + Length);if ((irp = devredir_irp_find_by_fileid(FileId)) == NULL)"no IRP found with FileId = %d" , FileId);0 , 0 );/* create a new IRP for this request */ else if ((new_irp = devredir_irp_new()) == NULL)/* system out of memory */ 0 , 0 );else /* Offset needed after write to calculate new EOF */ 20 ); /* padding */ /* now insert real data */ /* send to client */ int devredir_file_rename(struct state_rename *fusep, tui32 device_id,const char *old_name,const char *new_name)0 ;int rval = -1 ;unsigned int len;"device_id=%d old_name=%s new_name=%s" ,/* * Allocate an IRP with enough space for both the old and new names . * We ' ll store the new name after the old name : - * * | n | a | m | e | 1 | \ 0 | n | a | m | e | 2 | \ 0 | * ^ ^ * irp - > pathname - - - - + | * irp - > gen . rename . new_name - - - - - - - - - - - - - - - - - - + 1 + strlen(new_name);if ((irp = devredir_irp_with_pathnamelen_new(len)) != NULL)/* Set up pointer to new name string */ 1 ;/* Copy both strings, and change'/' to '\\' characters */ 0 ;// WAS 1 return rval;/******************************************************************************* * miscellaneous stuff * * void struct stream *s,enum IRP_MJ MajorFunction,enum IRP_MN MinorFunction)/* setup DR_DEVICE_IOREQUEST header */ /** * Convert / to windows compatible \ static void char *path)char *cptr = path;while (*cptr != 0 )if (*cptr == '/' )'\\' ;static int const char *string, char c)return (len > 0 && string[len - 1 ] == c) ? 1 : 0 ;static void enum NTSTATUS IoStatus)struct stream *s;int bytes;if (IoStatus != STATUS_SUCCESS)struct state_remove *) irp->fuse_info,return ;1024 );0 ); /* length is zero */ 24 ); /* padding */ /* send to client */ return ;static void enum NTSTATUS IoStatus)struct state_remove *)irp->fuse_info,if (IoStatus != STATUS_SUCCESS)return ;32 );/** * Rename a file on response to the create drive request * * See : - * - [ MS - RDPEFS ] 2 . 2 . 3 . 3 . 9 ( DR_DRIVE_SET_INFORMATION_REQ ) ` * - [ MS - RDPEFS ] 2 . 2 . 3 . 3 . 9 . 1 ( RDP_FILE_RENAME_INFORMATION ) static void enum NTSTATUS IoStatus)struct stream *s;int bytes;unsigned int flen; /* FileNameLength */ unsigned int unicode_byte_count; /* Bytes to represent new name in UTF-16 */ unsigned int sblen; /* SetBuffer length */ if (IoStatus != STATUS_SUCCESS)"rename returned with IoStatus=0x%x" , IoStatus);struct state_rename *)irp->fuse_info,return ;/* Find number of words required for Unicode path */ 1 ; // includes terminator 2 ;/* Length of RDP_FILE_RENAME_INFORMATION struct */ 1 + 1 + 4 ) + unicode_byte_count;int )(64 + unicode_byte_count));/* number of bytes after padding */ 24 ); /* padding */ 1 ); /* ReplaceIfExists */ 0 ); /* RootDirectory */ /* FileNameLength */ /* filename in Unicode */ /* send to client */ return ;static void enum NTSTATUS IoStatus)struct state_rename *)irp->fuse_info,if (IoStatus != STATUS_SUCCESS)return ;32 );/* * Re - uses the specified IRP to issue a request to get file attributes * of varying types * * References : [ MS - RDPEFS ] 2 . 2 . 3 . 3 . 9 [ MS - FSCC ] 2 . 4 static void issue_lookup(IRP *irp, int lookup_type)struct stream *s;int bytes;0 ;1024 );/* buffer length */ 24 ); /* padding */ /* buffer */ /* send to client */ /* * Parses an incoming FileBasicInformation structure static void lookup_read_basic_attributes(IRP *irp, struct stream *s_in)"processing FILE_BASIC_INFORMATION" );8 ); /* CreationTime */ 8 ); /* ChangeTime */ //LOG_DEVEL(LOG_LEVEL_DEBUG, "LastAccessTime: 0x%llx", // (unsigned long long)LastAccessTime); //LOG_DEVEL(LOG_LEVEL_DEBUG, "LastWriteTime: 0x%llx", // (unsigned long long)LastWriteTime); //LOG_DEVEL(LOG_LEVEL_DEBUG, "ChangeTime: 0x%llx", // (unsigned long long)ChangeTime); //LOG_DEVEL(LOG_LEVEL_DEBUG, "FileAttributes: 0x%x", (unsigned int)FileAttributes); /* Save the basic attributes in the IRP */ /* * Parses an incoming FileStandardInformation structure static void lookup_read_standard_attributes(IRP *irp, struct stream *s_in)"processing FILE_STD_INFORMATION" );8 ); /* AllocationSize */ //LOG_DEVEL(LOG_LEVEL_DEBUG, "EndOfFile: %lld", // (unsigned long long)EndOfFile); /* * Completes a lookup request and returns status to the caller . * * Unless IoStatus is STATUS_SUCCESS , the lookup has failed . static void lookup_done(IRP *irp, enum NTSTATUS IoStatus)"Lookup with completion_id=%d returning 0x%x" ,struct state_lookup *)irp->fuse_info,if (irp->FileId == 0 )/* Open failed - no file handle */ else /* Close the file handle */ 32 );/* * lookup has a mini state machine built - in , as it needs to issue * multiple I / O requests , but unlike lookup these are not always the same . static void struct stream *s_in,enum NTSTATUS IoStatus)"entry state is %d" , irp->gen.lookup.state);if (IoStatus != STATUS_SUCCESS)/* This is common to all setattr states */ "last lookup returned with IoStatus=0x%08x" , IoStatus);else /* Read and validate any data we've got queued up */ switch (irp->gen.lookup.state)case E_LOOKUP_GET_FH:/* We've been sent the file ID */ break ;case E_LOOKUP_CHECK_BASIC:/* Returned length what we expected? */ if (Length != FILE_BASIC_INFORMATION_SIZE)"Expected FILE_BASIC_INFORMATION length" "%d, got len=%d" ,else break ;case E_LOOKUP_CHECK_EOF:/* Returned length what we expected? */ if (Length != FILE_STD_INFORMATION_SIZE)"Expected FILE_STD_INFORMATION length" "%d, got len=%d" ,else break ;/*****************************************************************************/ static void struct stream *s_in,enum NTSTATUS IoStatus)struct stream *s;int bytes;char size_info_struct[FILE_FS_FULL_SIZE_INFORMATION_SIZE] = {0 };if (IoStatus != STATUS_SUCCESS)struct statvfs fss = {0 };"statfs returned with IoStatus=0x%x" , IoStatus);struct state_statfs *)irp->fuse_info,return ;int )(64 + sizeof (size_info_struct)));sizeof (size_info_struct));/* number of bytes after padding */ 24 ); /* padding */ sizeof (size_info_struct));/* Queried structure */ /* send to client */ /* [MS-RDPEFS] 2.2.3.4.6 */ static void struct stream *s_in,enum NTSTATUS IoStatus)struct statvfs fss = {0 };if (IoStatus == STATUS_SUCCESS)if (Length != FILE_FS_FULL_SIZE_INFORMATION_SIZE)"Expected FILE_FS_FULL_SIZE_INFORMATION_SIZE length" " %d, got len=%d" ,else unsigned int block_size;if (block_size < 512 || block_size > 131072 )"Unreasonable block size for file system : %u" ,else // Following values do not seem to be needed by // any applications. btrfs also returns 0 for these //fss.f_files = ???; //fss.f_ffree = ???; //fss.f_favail = fss.f_ffree; // Chromium 130 needs this set, or the user can't save // to our filesystem struct state_statfs *)irp->fuse_info,if (IoStatus != STATUS_SUCCESS)else 32 );/* * Re - uses the specified IRP to issue a request to set basic file attributes * * References : [ MS - RDPEFS ] 2 . 2 . 3 . 3 . 9 [ MS - FSCC ] 2 . 4 . 7 static void issue_setattr_basic(IRP *irp)struct stream *s;int bytes;const struct file_attr *fattr = &irp->gen.setattr.fattr;0 ;0 ;0 ;if (to_set & TO_SET_MODE)if (to_set & TO_SET_ATIME)if (to_set & TO_SET_MTIME)1024 );/* buffer length */ 24 ); /* padding */ 0 LL); /* CreationTime */ /* LastAccessTime */ /* LastWriteTime */ 0 LL); /* ChangeTime */ /* FileAttributes */ /* send to client */ /* * Re - uses the specified IRP to issue a request to set file EOF * * References : [ MS - RDPEFS ] 2 . 2 . 3 . 3 . 9 [ MS - FSCC ] 2 . 4 . 13 static void issue_setattr_eof(IRP *irp)struct stream *s;int bytes;1024 );/* buffer length */ 24 ); /* padding */ /* File size */ /* send to client */ /* * Completes a setattr request and returns status to the caller . static void setattr_done(IRP *irp, enum NTSTATUS IoStatus)struct state_setattr *) irp->fuse_info,if (irp->FileId == 0 )/* Open failed - no file handle */ else /* Close the file handle */ 32 );/* * setattr has a mini state machine built - in , as it needs to issue * multiple I / O requests , but unlike lookup these are not always the same . static void struct stream *s_in,enum NTSTATUS IoStatus)#define TO_SET_BASIC_ATTRS (TO_SET_MODE | \"entry state is %d" , irp->gen.setattr.state);if (IoStatus != STATUS_SUCCESS)/* This is common to all setattr states */ "last setattr returned with IoStatus=0x%08x" , IoStatus);else /* Read and validate any data we've got queued up */ switch (irp->gen.setattr.state)case E_SETATTR_GET_FH:/* We've been sent the file ID */ break ;case E_SETATTR_CHECK_BASIC:/* Returned length what we expected? */ if (Length != FILE_BASIC_INFORMATION_SIZE)"Expected FILE_BASIC_INFORMATION length" "%d, got len=%d" ,/* Clear the basic bits so we don't end up in here again */ break ;case E_SETATTR_CHECK_EOF:/* Returned length what we expected? */ if (Length != FILE_END_OF_FILE_INFORMATION_SIZE)"Expected FILE_END_OF_FILE_INFORMATION length" "%d, got len=%d" ,/* Clear the size bits so we don't end up in here again */ break ;/* Work out the next call to issue */ if (irp->gen.setattr.to_set & TO_SET_BASIC_ATTRS)else if (irp->gen.setattr.to_set & TO_SET_SIZE)else #undef TO_SET_BASIC_ATTRS
Messung V0.5 in Prozent C=92 H=98 G=94
¤ Dauer der Verarbeitung: 0.57 Sekunden
(vorverarbeitet am 2026-07-10)
¤ *© Formatika GbR, Deutschland
