diff options
Diffstat (limited to 'java/demo/Freeze/library/LibraryI.java')
| -rw-r--r-- | java/demo/Freeze/library/LibraryI.java | 235 |
1 files changed, 235 insertions, 0 deletions
diff --git a/java/demo/Freeze/library/LibraryI.java b/java/demo/Freeze/library/LibraryI.java new file mode 100644 index 00000000000..8f1fd783033 --- /dev/null +++ b/java/demo/Freeze/library/LibraryI.java @@ -0,0 +1,235 @@ +// ********************************************************************** +// +// Copyright (c) 2001 +// MutableRealms, Inc. +// Huntsville, AL, USA +// +// All Rights Reserved +// +// ********************************************************************** + +class LibraryI extends _LibraryDisp +{ + private BookPrx + isbnToBook(String isbn) + { + return BookPrxHelper.uncheckedCast(_adapter.createProxy(BookI.createIdentity(isbn))); + } + + public synchronized BookPrx + createBook(BookDescription description, Ice.Current current) + throws DatabaseException, BookExistsException + { + BookPrx book = isbnToBook(description.isbn); + + try + { + book.ice_ping(); + + // + // The book already exists. + // + throw new BookExistsException(); + } + catch(Ice.ObjectNotExistException e) + { + // + // Book doesn't exist, ignore the exception. + // + } + + // + // Create a new book Servant. + // + BookI bookI = new BookI(this, _evictor); + bookI._description = description; + + Ice.Identity ident = BookI.createIdentity(description.isbn); + + // + // Create a new Ice Object in the evictor, using the new + // identity and the new Servant. + // + // This can throw EvictorDeactivatedException (which indicates + // an internal error). The exception is currently ignored. + // + _evictor.createObject(ident, bookI); + + try + { + // + // Add the isbn number to the authors map. + // + String[] isbnSeq = (String[])_authors.get(description.authors); + int length = (isbnSeq == null) ? 0 : isbnSeq.length; + String[] newIsbnSeq = new String[length+1]; + + if (isbnSeq != null) + { + System.arraycopy(isbnSeq, 0, newIsbnSeq, 0, length); + } + newIsbnSeq[length] = description.isbn; + + _authors.put(description.authors, newIsbnSeq); + + return book; + } + catch(Freeze.DBException ex) + { + DatabaseException e = new DatabaseException(); + e.message = ex.message; + throw e; + } + } + + // + // No locking is necessary since no internal mutable state is + // accessed. + // + public BookPrx + findByIsbn(String isbn, Ice.Current current) + throws DatabaseException + { + try + { + BookPrx book = isbnToBook(isbn); + book.ice_ping(); + + return book; + } + catch(Ice.ObjectNotExistException ex) + { + // + // Book doesn't exist, return a null proxy. + // + return null; + } + } + + public synchronized BookPrx[] + findByAuthors(String authors, Ice.Current current) + throws DatabaseException + { + try + { + // + // Lookup all phone book books that match a name, and + // return them to the caller. See the comment in + // getNewIdentity why the prefix "N" is needed. + // + String[] isbnSeq = (String[])_authors.get(authors); + + int length = (isbnSeq == null) ? 0 : isbnSeq.length; + BookPrx[] books = new BookPrx[length]; + + if (isbnSeq != null) + { + for (int i = 0; i < length; ++i) + { + books[i] = isbnToBook(isbnSeq[i]); + } + } + + return books; + } + catch(Freeze.DBException ex) + { + DatabaseException e = new DatabaseException(); + e.message = ex.message; + throw e; + } + } + + public void + setEvictorSize(int size, Ice.Current current) + throws DatabaseException + { + // + // No synchronization necessary, _evictor is immutable. + // + _evictor.setSize(size); + } + + public void + shutdown(Ice.Current current) + { + // + // No synchronization necessary, _adapter is immutable. + // + _adapter.getCommunicator().shutdown(); + } + + protected synchronized void + remove(BookDescription description) + throws DatabaseException + { + try + { + String[] isbnSeq = (String[])_authors.get(description.authors); + + // + // If the title isn't found then raise a record not found + // exception. + // + if (isbnSeq == null) + { + throw new Freeze.DBNotFoundException(); + } + + int i; + for (i = 0; i < isbnSeq.length; ++i) + { + if (isbnSeq[i].equals(description.isbn)) + { + break; + } + } + + if (i >= isbnSeq.length) + { + throw new Freeze.DBNotFoundException(); + } + + if (isbnSeq.length == 1) + { + // + // If there are no further associated isbn numbers then remove + // the record. + // + _authors.remove(description.authors); + } + else + { + // + // Remove the isbn number from the sequence and write + // back the new record. + // + String[] newIsbnSeq = new String[isbnSeq.length-1]; + System.arraycopy(isbnSeq, 0, newIsbnSeq, 0, i); + if (i < newIsbnSeq.length - 1) + { + System.arraycopy(isbnSeq, i+1, newIsbnSeq, i, isbnSeq.length - i - 1); + } + + _authors.put(description.authors, newIsbnSeq); + } + } + catch(Freeze.DBException ex) + { + DatabaseException e = new DatabaseException(); + e.message = ex.message; + throw e; + } + } + + LibraryI(Ice.ObjectAdapter adapter, Freeze.DB db, Freeze.Evictor evictor) + { + _adapter = adapter; + _evictor = evictor; + _authors = new StringIsbnSeqDict(db); + } + + private Ice.ObjectAdapter _adapter; + private Freeze.Evictor _evictor; + private StringIsbnSeqDict _authors; +} |