Lines Matching refs:treeId
839 def disconnectTree(self, treeId): argument
840 if self._Session['TreeConnectTable'].has_key(treeId) is False:
843 if self._Session['TreeConnectTable'].has_key(treeId):
845 if self._Session['TreeConnectTable'][treeId]['NumberOfUses'] > 1:
846 treeEntry = self._Session['TreeConnectTable'][treeId]
853 packet['TreeID'] = treeId
859 shareName = self._Session['TreeConnectTable'][treeId]['ShareName']
861 del(self._Session['TreeConnectTable'][treeId])
864 …def create(self, treeId, fileName, desiredAccess, shareMode, creationOptions, creationDisposition,… argument
865 if self._Session['TreeConnectTable'].has_key(treeId) is False:
874 if self._Session['TreeConnectTable'][treeId]['IsDfsShare'] is True:
899 packet['TreeID'] = treeId
900 if self._Session['TreeConnectTable'][treeId]['IsDfsShare'] is True:
936 openFile['TreeConnect'] = treeId
959 def close(self, treeId, fileId): argument
960 if self._Session['TreeConnectTable'].has_key(treeId) is False:
967 packet['TreeID'] = treeId
985 def read(self, treeId, fileId, offset = 0, bytesToRead = 0, waitAnswer = True): argument
991 if self._Session['TreeConnectTable'].has_key(treeId) is False:
998 packet['TreeID'] = treeId
1024 …retData += self.read(treeId, fileId, offset+len(retData), readResponse['DataRemaining'], waitAnswe…
1027 def write(self, treeId, fileId, data, offset = 0, bytesToWrite = 0, waitAnswer = True): argument
1033 if self._Session['TreeConnectTable'].has_key(treeId) is False:
1040 packet['TreeID'] = treeId
1070 …bytesWritten += self.write(treeId, fileId, data[bytesWritten:], offset+bytesWritten, bytesToWrite-…
1073 …def queryDirectory(self, treeId, fileId, searchString = '*', resumeIndex = 0, informationClass = F… argument
1074 if self._Session['TreeConnectTable'].has_key(treeId) is False:
1081 packet['TreeID'] = treeId
1126 …def ioctl(self, treeId, fileId = None, ctlCode = -1, flags = 0, inputBlob = '', maxInputResponse … argument
1127 if self._Session['TreeConnectTable'].has_key(treeId) is False:
1137 packet['TreeID'] = treeId
1167 def flush(self,treeId, fileId): argument
1168 if self._Session['TreeConnectTable'].has_key(treeId) is False:
1175 packet['TreeID'] = treeId
1188 def lock(self, treeId, fileId, locks, lockSequence = 0): argument
1189 if self._Session['TreeConnectTable'].has_key(treeId) is False:
1196 packet['TreeID'] = treeId
1250 …def queryInfo(self, treeId, fileId, inputBlob = '', infoType = SMB2_0_INFO_FILE, fileInfoClass = S… argument
1251 if self._Session['TreeConnectTable'].has_key(treeId) is False:
1258 packet['TreeID'] = treeId
1282 …def setInfo(self, treeId, fileId, inputBlob = '', infoType = SMB2_0_INFO_FILE, fileInfoClass = SMB… argument
1283 if self._Session['TreeConnectTable'].has_key(treeId) is False:
1290 packet['TreeID'] = treeId
1333 treeId = self.connectTree(shareName)
1336 …fileId = self.create(treeId, oldPath, MAXIMUM_ALLOWED ,FILE_SHARE_READ | FILE_SHARE_WRITE |FILE_SH…
1342 …self.setInfo(treeId, fileId, renameReq, infoType = SMB2_0_INFO_FILE, fileInfoClass = SMB2_FILE_REN…
1345 self.close(treeId, fileId)
1346 self.disconnectTree(treeId)
1350 def writeFile(self, treeId, fileId, data, offset = 0): argument
1358 written = self.write(treeId, fileId, writeData, writeOffset, len(writeData))
1369 treeId = self.connectTree(shareName)
1374 …fileId = self.create(treeId, ntpath.dirname(path), FILE_READ_ATTRIBUTES | FILE_READ_DATA ,FILE_SHA…
1380 …res = self.queryDirectory( treeId, fileId, ntpath.basename(path), maxBufferSize = 65535, informati…
1394 self.close(treeId, fileId)
1395 self.disconnectTree(treeId)
1406 treeId = self.connectTree(shareName)
1410 …fileId = self.create(treeId, pathName,GENERIC_ALL ,FILE_SHARE_READ | FILE_SHARE_WRITE |FILE_SHARE_…
1413 self.close(treeId, fileId)
1414 self.disconnectTree(treeId)
1425 treeId = self.connectTree(shareName)
1429 …fileId = self.create(treeId, pathName, DELETE, FILE_SHARE_DELETE, FILE_DIRECTORY_FILE | FILE_DELET…
1432 self.close(treeId, fileId)
1433 self.disconnectTree(treeId)
1444 treeId = self.connectTree(shareName)
1448 …fileId = self.create(treeId, pathName,DELETE | FILE_READ_ATTRIBUTES, FILE_SHARE_DELETE, FILE_NON_D…
1451 self.close(treeId, fileId)
1452 self.disconnectTree(treeId)
1463 treeId = self.connectTree(shareName)
1467 …fileId = self.create(treeId, path, FILE_READ_DATA, shareAccessMode, FILE_NON_DIRECTORY_FILE, mode,…
1468 res = self.queryInfo(treeId, fileId)
1474 data = self.read(treeId, fileId, offset, fileSize-offset)
1480 data = self.read(treeId, fileId, offset, self._Connection['MaxReadSize'])
1486 self.close(treeId, fileId)
1487 self.disconnectTree(treeId)
1496 treeId = self.connectTree(shareName)
1499 …fileId = self.create(treeId, path, FILE_WRITE_DATA, shareAccessMode, FILE_NON_DIRECTORY_FILE, mode…
1506 written = self.write(treeId, fileId, data, writeOffset, len(data))
1510 self.close(treeId, fileId)
1511 self.disconnectTree(treeId)
1513 def waitNamedPipe(self, treeId, pipename, timeout = 5): argument
1515 if self._Session['TreeConnectTable'].has_key(treeId) is False:
1526 …return self.ioctl(treeId, None, FSCTL_PIPE_WAIT,flags=SMB2_0_IOCTL_IS_FSCTL, inputBlob=pipeWait, m…
1575 def nt_create_andx(self, treeId, fileName, smb_packet=None, cmd = None): argument
1583 return self.create(treeId, fileName, params['AccessMask'], params['ShareAccess'],
1588 return self.create(treeId, fileName,