corba/src/share/classes/com/sun/corba/se/impl/transport/SocketOrChannelConnectionImpl.java

Print this page

        

*** 1,7 **** /* ! * Copyright (c) 2001, 2010, Oracle and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation. Oracle designates this --- 1,7 ---- /* ! * Copyright (c) 2001, 2012, Oracle and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation. Oracle designates this
*** 1519,1529 **** // Signal all threads with outstanding requests on this // connection and give them the SystemException; responseWaitingRoom.signalExceptionToAllWaiters(systemException); ! if (contactInfo != null) { ((OutboundConnectionCache)getConnectionCache()).remove(contactInfo); } else if (acceptor != null) { ((InboundConnectionCache)getConnectionCache()).remove(this); } --- 1519,1529 ---- // Signal all threads with outstanding requests on this // connection and give them the SystemException; responseWaitingRoom.signalExceptionToAllWaiters(systemException); ! } finally { if (contactInfo != null) { ((OutboundConnectionCache)getConnectionCache()).remove(contactInfo); } else if (acceptor != null) { ((InboundConnectionCache)getConnectionCache()).remove(this); }
*** 1540,1550 **** // 4. purge_call waiters: // writeUnlock(); - } finally { if (orb.transportDebugFlag) { dprint(".purgeCalls<-: " + minor_code + "/" + die + "/" + lockHeld + " " + this); } --- 1540,1549 ----