Lines Matching full:_connection
13 # not be the most efficient way (e.g. self._Connection is the
132 self._Connection = {
195 self._Connection['ServerIP'] = remote_host
209 self._Connection['ServerName'] = remote_host
211 self._Connection['ServerName'] = remote_name
221 self._NetBIOSSession = nmb.NetBIOSUDPSession(my_name, self._Connection['ServerName'], remote_host, host_type, sess_port, self._timeout)
223 self._NetBIOSSession = nmb.NetBIOSTCPSession(my_name, self._Connection['ServerName'], remote_host, host_type, sess_port, self._timeout)
229 self._Connection['SequenceWindow'] += 1
235 for i in self._Connection.items():
246 return self._Connection['ServerIP']
281 return self._Connection['Dialect']
286 if self._Connection['Dialect'] == SMB2_DIALECT_21 or self._Connection['Dialect'] == SMB2_DIALECT_002:
306 packet['MessageID'] = self._Connection['SequenceWindow']
307 self._Connection['SequenceWindow'] += 1
315 if self._Connection['SequenceWindow'] > 3:
320 if self._Session['SigningActivated'] is True and self._Connection['SequenceWindow'] > 2:
353 if self._Connection['OutstandingResponses'].has_key(packetID):
354 return self._Connection['OutstandingResponses'].pop(packetID)
405 self._Connection['SequenceWindow'] += (packet['CreditCharge'] - 1)
408 self._Connection['OutstandingResponses'][packet['MessageID']] = packet
429 self._Connection['ClientSecurityMode'] = negSession['SecurityMode']
430 self._Connection['Capabilities'] = negSession['Capabilities']
441 self._Connection['MaxTransactSize'] = min(0x100000,negResp['MaxTransactSize'])
442 self._Connection['MaxReadSize'] = min(0x100000,negResp['MaxReadSize'])
443 self._Connection['MaxWriteSize'] = min(0x100000,negResp['MaxWriteSize'])
444 self._Connection['ServerGuid'] = negResp['ServerGuid']
445 self._Connection['GSSNegotiateToken'] = negResp['Buffer']
446 self._Connection['Dialect'] = negResp['DialectRevision']
448 self._Connection['RequireSigning'] = True
450 self._Connection['SupportsFileLeasing'] = True
452 self._Connection['SupportsMultiCredit'] = True
454 if self._Connection['Dialect'] == SMB2_DIALECT_30:
458 self._Connection['SupportsDirectoryLeasing'] = True
460 self._Connection['SupportsMultiChannel'] = True
462 self._Connection['SupportsPersistentHandles'] = True
464 self._Connection['SupportsEncryption'] = True
466 self._Connection['ServerCapabilities'] = negResp['Capabilities']
467 self._Connection['ServerSecurityMode'] = negResp['SecurityMode']
549 serverName = Principal('cifs/%s' % (self._Connection['ServerName']), type=constants.PrincipalNameType.NT_SRV_INST.value)
611 self._Session['SigningRequired'] = self._Connection['RequireSigning']
616 if self._Session['SigningRequired'] is True and self._Connection['Dialect'] == SMB2_DIALECT_30:
622 if self._Connection['Dialect'] == SMB2_DIALECT_30:
677 auth = ntlm.getNTLMSSPType1('','', self._Connection['RequireSigning'])
699 self._Session['SigningRequired'] = self._Connection['RequireSigning']
743 if self._Session['SigningRequired'] is True and self._Connection['Dialect'] == SMB2_DIALECT_30:
763 if self._Connection['Dialect'] == SMB2_DIALECT_30:
797 _, _, _, _, sockaddr = socket.getaddrinfo(self._Connection['ServerIP'], 80, 0, 0, socket.IPPROTO_TCP)[0]
800 remoteHost = self._Connection['ServerIP']
824 if self._Connection['Dialect'] == SMB2_DIALECT_30:
825 if (self._Connection['SupportsEncryption'] is True) and ((treeConnectResponse['ShareFlags'] & SMB2_SHAREFLAG_ENCRYPT_DATA) == SMB2_SHAREFLAG_ENCRYPT_DATA):
877 pathName = '\\\\' + self._Connection['ServerName'] + '\\' + fileName
884 if self._Connection['Dialect'] == SMB2_DIALECT_30 and self._Connection['SupportsDirectoryLeasing'] is True:
944 if self._Connection['Dialect'] == SMB2_DIALECT_30:
1000 if self._Connection['MaxReadSize'] < bytesToRead:
1001 maxBytesToRead = self._Connection['MaxReadSize']
1005 if self._Connection['Dialect'] != SMB2_DIALECT_002 and self._Connection['SupportsMultiCredit'] is True:
1042 if self._Connection['MaxWriteSize'] < bytesToWrite:
1043 maxBytesToWrite = self._Connection['MaxWriteSize']
1047 if self._Connection['Dialect'] != SMB2_DIALECT_002 and self._Connection['SupportsMultiCredit'] is True:
1090 maxBufferSize = self._Connection['MaxReadSize']
1097 if self._Connection['Dialect'] != SMB2_DIALECT_002 and self._Connection['SupportsMultiCredit'] is True:
1356 writeData = data[:self._Connection['MaxWriteSize']]
1357 data = data[self._Connection['MaxWriteSize']:]
1471 if (fileSize-offset) < self._Connection['MaxReadSize']:
1480 data = self.read(treeId, fileId, offset, self._Connection['MaxReadSize'])
1503 data = callback(self._Connection['MaxWriteSize'])
1531 res['MaxReadSize'] = self._Connection['MaxReadSize']
1532 res['MaxWriteSize'] = self._Connection['MaxWriteSize']
1615 max_size = self._Connection['MaxReadSize']
