dorkbox/Network
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Added server global RMI delete()

Browse Source
This commit is contained in:
Robinson 2021-05-01 00:19:12 +02:00
parent 5196fa2d66
commit 7c5a935105
1 changed files with 48 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
src/dorkbox/network/Server.kt
View File

@ -738,7 +738,7 @@ open class Server<CONNECTION : Connection>(config: ServerConfiguration = ServerC
}
/**
* Tells us to save an an already created object, GLOBALLY using the specified ID, so a remote connection can get it via [Connection.getObject]
* Tells us to save an already created object, GLOBALLY using the specified ID, so a remote connection can get it via [Connection.getObject]
*
* FOR REMOTE CONNECTIONS:
* Methods that return a value will throw [TimeoutException] if the response is not received with the
@ -764,4 +764,51 @@ open class Server<CONNECTION : Connection>(config: ServerConfiguration = ServerC
}
return success
}
/**
* Tells us to delete a previously saved object, GLOBALLY using the specified object.
*
* After this call, this object wil no longer be available to remote connections and the ID will be recycled (don't use it again)
*
* @return true if the object was successfully deleted. If false, an error log will be emitted
*
* @see RemoteObject
*/
@Suppress("DuplicatedCode")
fun deleteGlobalObject(`object`: Any): Boolean {
val successRmiId = rmiGlobalSupport.getId(`object`)
val success = successRmiId != RemoteObjectStorage.INVALID_RMI
if (success) {
rmiGlobalSupport.removeImplObject<Any?>(successRmiId)
} else {
val exception = Exception("RMI implementation '${`object`::class.java}' could not be deleted! It does not exist")
ListenerManager.cleanStackTrace(exception)
listenerManager.notifyError(exception)
}
return success
}
/**
* Tells us to delete a previously saved object, GLOBALLY using the specified ID.
*
* After this call, this object wil no longer be available to remote connections and the ID will be recycled (don't use it again)
*
* @return true if the object was successfully deleted. If false, an error log will be emitted
*
* @see RemoteObject
*/
@Suppress("DuplicatedCode")
fun deleteGlobalObject(objectId: Int): Boolean {
val previousObject = rmiGlobalSupport.removeImplObject<Any?>(objectId)
val success = previousObject != null
if (!success) {
val exception = Exception("RMI implementation UD '$objectId' could not be deleted! It does not exist")
ListenerManager.cleanStackTrace(exception)
listenerManager.notifyError(exception)
}
return success
}
}