Class Connection

java.lang.Object

com.hierynomus.smbj.common.Pooled<Connection>

com.hierynomus.smbj.connection.Connection

All Implemented Interfaces:

PacketReceiver<SMBPacketData<?>>, Closeable, AutoCloseable

public class Connection
extends Pooled<Connection>
implements Closeable, PacketReceiver<SMBPacketData<?>>

A connection to a server.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	Connection.CancelRequest
private static class	Connection.DelegatingSMBMessageConverter

Field Summary

Fields

Modifier and Type	Field	Description
private final SMBEventBus	bus
private final SMBClient	client
private SmbConfig	config
private ConnectionContext	connectionContext
private static final Connection.DelegatingSMBMessageConverter	converter
private PacketEncryptor	encryptor
private final ReentrantLock	lock
private static final org.slf4j.Logger	logger
private SMB2MessageConverter	messageConverter
(package private) OutstandingRequests	outstandingRequests
private IncomingPacketHandler	packetHandlerChain
private PathResolver	pathResolver
private SessionTable	preauthSessionTable
(package private) SequenceWindow	sequenceWindow
(package private) final ServerList	serverList
private SessionTable	sessionTable
private Signatory	signatory
(package private) TransportLayer<SMBPacket<?,?>>	transport

Constructor Summary

Constructors

Constructor	Description
Connection(Connection connection)
Connection(SmbConfig config, SMBClient client, SMBEventBus bus, ServerList serverList)

Method Summary

Modifier and Type	Method	Description
Session	authenticate(AuthenticationContext authContext)	Authenticate the user on this connection in order to start a (new) session.
private int	calculateGrantedCredits(SMB2Packet packet, int availableCredits)
void	close()
void	close(boolean force)	Close the Connection.
void	connect(String hostname, int port)
private int	creditsNeeded(int payloadSize)	[MS-SMB2] 3.1.5.2 Calculating the CreditCharge
SMBClient	getClient()
ConnectionContext	getConnectionContext()
NegotiatedProtocol	getNegotiatedProtocol()	Returns the negotiated protocol details for this connection.
(package private) SessionTable	getPreauthSessionTable()
String	getRemoteHostname()
(package private) SessionTable	getSessionTable()
void	handle(SMBPacketData<?> uncheckedPacket)
void	handleError(Throwable t)
private void	init()
boolean	isConnected()
<T extends SMB2Packet> Future<T>	send(SMB2Packet packet)	send a packet.
(package private) <T extends SMB2Packet> T	sendAndReceive(SMB2Packet packet)
private void	sessionLogoff(SessionLoggedOff loggedOff)
void	setMessageConverter(SMB2MessageConverter smb2Converter)

Methods inherited from class Pooled

lease, release

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

private static final org.slf4j.Logger logger

converter

private static final Connection.DelegatingSMBMessageConverter converter

packetHandlerChain

private IncomingPacketHandler packetHandlerChain

connectionContext

private ConnectionContext connectionContext

sessionTable

private SessionTable sessionTable

preauthSessionTable

private SessionTable preauthSessionTable

outstandingRequests

OutstandingRequests outstandingRequests

sequenceWindow

SequenceWindow sequenceWindow

messageConverter

private SMB2MessageConverter messageConverter

pathResolver

private PathResolver pathResolver

client

private final SMBClient client

serverList

final ServerList serverList

signatory

private Signatory signatory

encryptor

private PacketEncryptor encryptor

config

private SmbConfig config

transport

TransportLayer<SMBPacket<?,?>> transport

bus

private final SMBEventBus bus

lock

private final ReentrantLock lock

Constructor Details

Connection

public Connection(SmbConfig config,
 SMBClient client,
 SMBEventBus bus,
 ServerList serverList)

Connection

public Connection(Connection connection)

Method Details

getClient

public SMBClient getClient()

init

private void init()

connect

public void connect(String hostname,
 int port)
             throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

close

public void close(boolean force)
           throws IOException

Close the Connection. If force is set to true, it forgoes the Session.close() operation on the open sessions, and it just calls the TransportLayer.disconnect().

If force is set to false, the usage counter of the connection reduces with one. If the usage count drops to zero the connection will be closed.

Parameters:

force - if set, does not nicely terminate the open sessions.

Throws:

IOException - If any error occurred during close-ing.

authenticate

public Session authenticate(AuthenticationContext authContext)

Authenticate the user on this connection in order to start a (new) session.

Returns:

a (new) Session that is authenticated for the user.

send

public <T extends SMB2Packet> Future<T> send(SMB2Packet packet)
                                      throws TransportException

send a packet.

Parameters:

packet - SMBPacket to send

Returns:

a Future to be used to retrieve the response packet

Throws:

TransportException - When a transport level error occurred

sendAndReceive

<T extends SMB2Packet> T sendAndReceive(SMB2Packet packet)
                                 throws TransportException

Throws:

TransportException

calculateGrantedCredits

private int calculateGrantedCredits(SMB2Packet packet,
 int availableCredits)

creditsNeeded

private int creditsNeeded(int payloadSize)

[MS-SMB2] 3.1.5.2 Calculating the CreditCharge

getNegotiatedProtocol

public NegotiatedProtocol getNegotiatedProtocol()

Returns the negotiated protocol details for this connection.

Returns:

The negotiated protocol details

handle

public void handle(SMBPacketData<?> uncheckedPacket)
            throws TransportException

Specified by:

handle in interface PacketReceiver<SMBPacketData<?>>

Throws:

TransportException

handleError

public void handleError(Throwable t)

Specified by:

handleError in interface PacketReceiver<SMBPacketData<?>>

getRemoteHostname

public String getRemoteHostname()

isConnected

public boolean isConnected()

getConnectionContext

public ConnectionContext getConnectionContext()

sessionLogoff

private void sessionLogoff(SessionLoggedOff loggedOff)

getSessionTable

SessionTable getSessionTable()

getPreauthSessionTable

SessionTable getPreauthSessionTable()

setMessageConverter

public void setMessageConverter(SMB2MessageConverter smb2Converter)