ClientConnection
ClientConnection::VisitWriteRequest(WriteRequest* request)
ClientConnection::VisitCreateLinkRequest(CreateLinkRequest* request)
ClientConnection* fConnection;
ClientConnection::VisitUnlinkRequest(UnlinkRequest* request)
struct ClientConnection::VolumeNodeMonitoringEvent {
ClientConnection::VisitCreateSymlinkRequest(CreateSymlinkRequest* request)
ClientConnection::VisitReadLinkRequest(ReadLinkRequest* request)
ClientConnection::VisitRenameRequest(RenameRequest* request)
struct ClientConnection::NodeMonitoringEventQueue
ClientConnection::VisitMakeDirRequest(MakeDirRequest* request)
ClientConnection::VisitRemoveDirRequest(RemoveDirRequest* request)
struct ClientConnection::QueryHandleUnlocker {
QueryHandleUnlocker(ClientConnection* connection, NodeHandle* nodeHandle)
ClientConnection::VisitOpenDirRequest(OpenDirRequest* request)
ClientConnection::VisitReadDirRequest(ReadDirRequest* request)
ClientConnection* fConnection;
struct ClientConnection::ClientVolumeFilter {
ClientConnection::VisitWalkRequest(WalkRequest* request)
virtual bool FilterVolume(ClientConnection* connection,
ClientConnection::VisitMultiWalkRequest(MultiWalkRequest* request)
struct ClientConnection::HasQueryPermissionClientVolumeFilter
: ClientConnection::ClientVolumeFilter {
virtual bool FilterVolume(ClientConnection* connection,
ClientConnection::VisitOpenAttrDirRequest(OpenAttrDirRequest* request)
ClientConnection::VisitReadAttrDirRequest(ReadAttrDirRequest* request)
ClientConnection::ClientConnection(Connection* connection,
ClientConnection::VisitReadAttrRequest(ReadAttrRequest* request)
ClientConnection::VisitWriteAttrRequest(WriteAttrRequest* request)
ClientConnection::~ClientConnection()
ClientConnection::VisitRemoveAttrRequest(RemoveAttrRequest* request)
ClientConnection::VisitRenameAttrRequest(RenameAttrRequest* request)
ClientConnection::VisitStatAttrRequest(StatAttrRequest* request)
ClientConnection::VisitOpenQueryRequest(OpenQueryRequest* request)
ClientConnection::Init()
ClientConnection::VisitReadQueryRequest(ReadQueryRequest* request)
ClientConnection::ProcessNodeMonitoringEvent(int32 volumeID,
ClientConnection::CloseNodeMonitoringEventQueue()
ClientConnection::QueryDomainIntersectsWith(Volume* volume)
ClientConnection::ProcessQueryEvent(NodeMonitoringEvent* event)
ClientConnection::_Close()
ClientConnection::_MarkClosed(bool error)
ClientConnection::_GetNodeInfo(Node* node, NodeInfo* info)
ClientConnection::_GetEntryInfo(Entry* entry, EntryInfo* info)
ClientConnection::_GetAttrInfo(Request* request, const char* name,
ClientConnection::_GetAttrDirInfo(Request* request, AttributeDirectory* attrDir,
ClientConnection::_CreateVolume(ClientVolume** _volume)
ClientConnection::_GetVolume(int32 id)
ClientConnection::_PutVolume(ClientVolume* volume)
ClientConnection::_UnmountVolume(ClientVolume* volume)
ClientConnection::_UnmountAllVolumes()
ClientConnection::Close()
ClientConnection::_NodeMonitoringProcessorEntry(void* data)
return ((ClientConnection*)data)->_NodeMonitoringProcessor();
ClientConnection::_NodeMonitoringProcessor()
ClientConnection::_PushNodeMonitoringEvent(int32 volumeID,
ClientConnection::_EntryCreated(ClientVolume* volume, EntryCreatedEvent* event,
ClientConnection::_EntryRemoved(ClientVolume* volume, EntryRemovedEvent* event,
ClientConnection::GetReference()
ClientConnection::_EntryMoved(ClientVolume* volume, EntryMovedEvent* event,
ClientConnection::_NodeStatChanged(ClientVolume* volume,
ClientConnection::_NodeAttributeChanged(ClientVolume* volume,
ClientConnection::PutReference()
ClientConnection::_KnownAttributeType(type_code type)
ClientConnection::_ConvertAttribute(const attr_info& info, void* buffer)
ClientConnection::_OpenQuery(const char* queryString, uint32 flags,
ClientConnection::_CloseQuery(QueryHandle* handle)
ClientConnection::_LockQueryHandle(int32 cookie, QueryHandle** _handle)
ClientConnection::_UnlockQueryHandle(NodeHandle* nodeHandle)
ClientConnection::_GetAllClientVolumeIDs(int32* volumeIDs, int32 arraySize,
ClientConnection::UserRemoved(User* user)
ClientConnection::_GetContainingClientVolumes(Directory* directory,
ClientConnection::ShareRemoved(Share* share)
ClientConnection::UserPermissionsChanged(Share* share, User* user,
ClientConnection::VisitConnectionBrokenRequest(ConnectionBrokenRequest* request)
ClientConnection::VisitInitConnectionRequest(InitConnectionRequest* request)
ClientConnection::VisitMountRequest(MountRequest* request)
ClientConnection::VisitUnmountRequest(UnmountRequest* request)
ClientConnection::VisitReadVNodeRequest(ReadVNodeRequest* request)
class ClientConnection::ConnectionReference {
ClientConnection::VisitWriteStatRequest(WriteStatRequest* request)
ConnectionReference(ClientConnection* connection)
ClientConnection::VisitCreateFileRequest(CreateFileRequest* request)
ClientConnection::VisitOpenRequest(OpenRequest* request)
ClientConnection* fConnection;
struct ClientConnection::VolumeMap
ClientConnection::VisitCloseRequest(CloseRequest* request)
class ClientConnection::ClientVolumePutter {
ClientConnection::VisitReadRequest(ReadRequest* request)
ClientVolumePutter(ClientConnection* connection, ClientVolume* volume)
ClientConnection* connection,
class ClientConnection : private RequestHandler,
ClientConnection(Connection* connection,
~ClientConnection();
ClientConnection* connection = NULL;
connection = (ClientConnection*)fClosedConnections.RemoveItem((int32)0);
ClientConnection* connection
= (ClientConnection*)fClientConnections.ItemAt(i);
ClientConnection* connection
= (ClientConnection*)fClosedConnections.ItemAt(i);
ClientConnection* connection
= (ClientConnection*)fClientConnections.ItemAt(i);
ClientConnection* connection
= (ClientConnection*)fClientConnections.ItemAt(i);
ClientConnection* connection
= (ClientConnection*)fClientConnections.ItemAt(i);
NetFSServer::_AddClientConnection(ClientConnection* clientConnection)
NetFSServer::ClientConnectionClosed(ClientConnection* connection, bool broken)
ClientConnection* clientConnection = NULL;
clientConnection = new(std::nothrow) ClientConnection(fConnection,
ClientConnection* connection);
ClientConnection* connection,