netfs/server/ClientConnection.cpp

123 	VolumeNodeMonitoringEvent(int32 volumeID, NodeMonitoringEvent* event)
125 		  event(event)
127 		if (event)
128 			event->AcquireReference();
133 		if (event)
134 			event->ReleaseReference();
138 	NodeMonitoringEvent*	event;
255 	// create the node monitoring event queue
2499 	NodeMonitoringEvent* event)
2506 	_PushNodeMonitoringEvent(volumeID, event);
2554 ClientConnection::ProcessQueryEvent(NodeMonitoringEvent* event)
2558 	if (event->opcode == B_ENTRY_CREATED) {
2559 		// "entry created" event
2561 			= dynamic_cast<EntryCreatedEvent*>(event);
2567 	} else if (event->opcode == B_ENTRY_REMOVED) {
2568 		// "entry removed" event
2570 			= dynamic_cast<EntryRemovedEvent*>(event);
2579 		ERROR("Ignoring unexpected query event: opcode: 0x%" B_PRIx32 "\n",
2580 			event->opcode);
2583 	PRINT("ClientConnection::ProcessQueryEvent(): event: %p, type: %s:"
2585 		event, typeid(event).name(), volumeID, directoryID);
2610 		// ignore the event.
2611 		if (event->opcode == B_ENTRY_REMOVED) {
2617 	// now push the event for each concerned client volume
2619 		_PushNodeMonitoringEvent(volumeIDs[i], event);
2827 	// push a notification event
2828 	if (VolumeUnmountedEvent* event = new(std::nothrow) VolumeUnmountedEvent) {
2831 		event->opcode = B_DEVICE_UNMOUNTED;
2832 		_PushNodeMonitoringEvent(volume->GetID(), event);
2833 		event->ReleaseReference();
2914 	NodeMonitoringEvent* event)
2916 	if (!event)
2921 	if (!volume && event->opcode != B_DEVICE_UNMOUNTED)
2928 	switch (event->opcode) {
2931 				dynamic_cast<EntryCreatedEvent*>(event), request);
2935 				dynamic_cast<EntryRemovedEvent*>(event), request);
2939 				dynamic_cast<EntryMovedEvent*>(event), request);
2943 				dynamic_cast<StatChangedEvent*>(event), request);
2947 				dynamic_cast<AttributeChangedEvent*>(event), request);
2962 		request->opcode = event->opcode;
2976 ClientConnection::_EntryCreated(ClientVolume* volume, EntryCreatedEvent* event,
2986 	const char* name = event->name.GetString();
2989 	request->directoryID = NodeID(event->volumeID, event->directoryID);
2990 	request->nodeID = NodeID(event->volumeID, event->nodeID);
2992 	if (event->queryHandler) {
2993 		request->port = event->remotePort;
2994 		request->token = event->remoteToken;
3001 	if (VolumeManager::GetDefault()->LoadEntry(event->volumeID,
3002 			event->directoryID, name, true, &entry) == B_OK
3003 		&& entry->GetNode()->GetVolumeID() == event->volumeID
3004 		&& entry->GetNode()->GetID() == event->nodeID) {
3017 ClientConnection::_EntryRemoved(ClientVolume* volume, EntryRemovedEvent* event,
3022 	if (!event->queryHandler
3023 		&& NodeRef(event->nodeVolumeID, event->nodeID)
3025 		NoAllocEntryRef ref(event->nodeVolumeID, event->nodeID, ".");
3030 		// don't send the "entry removed" event
3041 	const char* name = event->name.GetString();
3044 	request->directoryID = NodeID(event->volumeID, event->directoryID);
3045 	request->nodeID = NodeID(event->nodeVolumeID, event->nodeID);
3047 	if (event->queryHandler) {
3048 		request->port = event->remotePort;
3049 		request->token = event->remoteToken;
3061 ClientConnection::_EntryMoved(ClientVolume* volume, EntryMovedEvent* event,
3071 	int32 fromNameLen = event->fromName.GetLength();
3073 		= (fromNameLen > 0 ? event->fromName.GetString() : NULL);
3074 	const char* toName = event->toName.GetString();
3077 	request->fromDirectoryID = NodeID(event->volumeID, event->fromDirectoryID);
3078 	request->toDirectoryID = NodeID(event->volumeID, event->toDirectoryID);
3079 	request->nodeID = NodeID(event->nodeVolumeID, event->nodeID);
3086 	if (VolumeManager::GetDefault()->LoadEntry(event->volumeID,
3087 			event->toDirectoryID, toName, true, &entry) == B_OK
3088 		&& entry->GetNode()->GetVolumeID() == event->nodeVolumeID
3089 		&& entry->GetNode()->GetID() == event->nodeID) {
3103 	StatChangedEvent* event, NodeMonitoringRequest*& _request)
3106 	Node* node = volume->GetNode(event->volumeID, event->nodeID);
3117 	request->nodeID = NodeID(event->volumeID, event->nodeID);
3129 	AttributeChangedEvent* event, NodeMonitoringRequest*& _request)
3132 	Node* node = volume->GetNode(event->volumeID, event->nodeID);
3141 	status_t error = node->UpdateAttribute(event->attribute.GetString(),
3160 	const char* name = event->attribute.GetString();
3163 	request->nodeID = NodeID(event->volumeID, event->nodeID);