Skip to content
Projeler
Gruplar
Parçacıklar
Yardım
Yükleniyor...
Oturum aç / Kaydol
Gezinmeyi değiştir
C
core
Proje
Proje
Ayrıntılar
Etkinlik
Cycle Analytics
Depo (repository)
Depo (repository)
Dosyalar
Kayıtlar (commit)
Dallar (branch)
Etiketler
Katkıda bulunanlar
Grafik
Karşılaştır
Grafikler
Konular (issue)
0
Konular (issue)
0
Liste
Pano
Etiketler
Kilometre Taşları
Birleştirme (merge) Talepleri
0
Birleştirme (merge) Talepleri
0
CI / CD
CI / CD
İş akışları (pipeline)
İşler
Zamanlamalar
Grafikler
Paketler
Paketler
Wiki
Wiki
Parçacıklar
Parçacıklar
Üyeler
Üyeler
Collapse sidebar
Close sidebar
Etkinlik
Grafik
Grafikler
Yeni bir konu (issue) oluştur
İşler
Kayıtlar (commit)
Konu (issue) Panoları
Kenar çubuğunu aç
LibreOffice
core
Commits
7af40055
Kaydet (Commit)
7af40055
authored
Haz 28, 2012
tarafından
Noel Grandin
Kaydeden (comit)
Michael Stahl
Haz 29, 2012
Dosyalara gözat
Seçenekler
Dosyalara Gözat
İndir
Eposta Yamaları
Sade Fark
Java5 update - convert code to use generics
Change-Id: Iff078cea287d0c508d2442d65cd9314ec3231c15
üst
9def9b46
Hide whitespace changes
Inline
Side-by-side
Showing
24 changed files
with
130 additions
and
135 deletions
+130
-135
BridgeFactory.java
jurt/com/sun/star/comp/bridgefactory/BridgeFactory.java
+2
-3
Implementation.java
jurt/com/sun/star/comp/connections/Implementation.java
+1
-1
FactoryHelper.java
jurt/com/sun/star/comp/loader/FactoryHelper.java
+8
-8
JavaLoader.java
jurt/com/sun/star/comp/loader/JavaLoader.java
+6
-6
RegistrationClassFinder.java
jurt/com/sun/star/comp/loader/RegistrationClassFinder.java
+4
-4
ServiceManager.java
jurt/com/sun/star/comp/servicemanager/ServiceManager.java
+27
-27
PipeConnection.java
jurt/com/sun/star/lib/connections/pipe/PipeConnection.java
+8
-8
SocketConnection.java
...com/sun/star/lib/connections/socket/SocketConnection.java
+8
-8
java_remote_bridge.java
.../star/lib/uno/bridges/java_remote/java_remote_bridge.java
+23
-25
java_environment.java
.../sun/star/lib/uno/environments/java/java_environment.java
+2
-2
JavaThreadPoolFactory.java
...ar/lib/uno/environments/remote/JavaThreadPoolFactory.java
+6
-6
Job.java
jurt/com/sun/star/lib/uno/environments/remote/Job.java
+1
-1
Cache.java
jurt/com/sun/star/lib/uno/protocols/urp/Cache.java
+2
-2
PendingRequests.java
jurt/com/sun/star/lib/uno/protocols/urp/PendingRequests.java
+5
-5
urp.java
jurt/com/sun/star/lib/uno/protocols/urp/urp.java
+2
-2
AsynchronousFinalizer.java
jurt/com/sun/star/lib/util/AsynchronousFinalizer.java
+2
-2
UrlToFileMapper.java
jurt/com/sun/star/lib/util/UrlToFileMapper.java
+4
-4
AnyConverter.java
jurt/com/sun/star/uno/AnyConverter.java
+1
-1
WeakReference.java
jurt/com/sun/star/uno/WeakReference.java
+2
-2
BridgeFactory_Test.java
...t/com/sun/star/comp/bridgefactory/BridgeFactory_Test.java
+3
-3
ProxyFactory_Test.java
...n/star/lib/uno/bridges/java_remote/ProxyFactory_Test.java
+2
-2
JobQueue_Test.java
...m/sun/star/lib/uno/environments/remote/JobQueue_Test.java
+4
-6
AnyConverter_Test.java
jurt/test/com/sun/star/uno/AnyConverter_Test.java
+1
-1
WeakReference_Test.java
jurt/test/com/sun/star/uno/WeakReference_Test.java
+6
-6
No files found.
jurt/com/sun/star/comp/bridgefactory/BridgeFactory.java
Dosyayı görüntüle @
7af40055
...
...
@@ -20,7 +20,6 @@ package com.sun.star.comp.bridgefactory;
import
java.math.BigInteger
;
import
java.util.ArrayList
;
import
java.util.Vector
;
import
com.sun.star.bridge.BridgeExistsException
;
import
com.sun.star.bridge.XBridge
;
...
...
@@ -168,7 +167,7 @@ public class BridgeFactory implements XBridgeFactory/*, XEventListener*/ {
* @see com.sun.star.bridge.XBridgeFactory
*/
public
synchronized
XBridge
[]
getExistingBridges
()
throws
com
.
sun
.
star
.
uno
.
RuntimeException
{
ArrayList
vector
=
new
ArrayList
();
ArrayList
<
XBridge
>
vector
=
new
ArrayList
<
XBridge
>
();
IBridge
iBridges
[]
=
UnoRuntime
.
getBridges
();
for
(
int
i
=
0
;
i
<
iBridges
.
length
;
++
i
)
{
...
...
@@ -180,7 +179,7 @@ public class BridgeFactory implements XBridgeFactory/*, XEventListener*/ {
XBridge
xBridges
[]=
new
XBridge
[
vector
.
size
()];
for
(
int
i
=
0
;
i
<
vector
.
size
();
++
i
)
xBridges
[
i
]
=
(
XBridge
)
vector
.
get
(
i
);
xBridges
[
i
]
=
vector
.
get
(
i
);
return
xBridges
;
}
...
...
jurt/com/sun/star/comp/connections/Implementation.java
Dosyayı görüntüle @
7af40055
...
...
@@ -52,7 +52,7 @@ final class Implementation {
*/
public
static
Object
getConnectionService
(
XMultiServiceFactory
factory
,
String
description
,
Class
serviceClass
,
Class
<?>
serviceClass
,
String
serviceType
)
throws
ConnectionSetupException
{
...
...
jurt/com/sun/star/comp/loader/FactoryHelper.java
Dosyayı görüntüle @
7af40055
...
...
@@ -56,7 +56,7 @@ public class FactoryHelper {
static
protected
class
Factory
implements
XSingleServiceFactory
,
XSingleComponentFactory
,
XServiceInfo
,
XTypeProvider
{
protected
static
Class
__objectArray
;
protected
static
Class
<?>
__objectArray
;
static
{
try
{
...
...
@@ -72,14 +72,14 @@ public class FactoryHelper {
protected
XMultiServiceFactory
_xMultiServiceFactory
;
protected
XRegistryKey
_xRegistryKey
;
protected
int
_nCode
;
protected
Constructor
_constructor
;
protected
Constructor
<?>
_constructor
;
protected
String
_implName
;
protected
String
_serviceName
;
// keeps the Id for XTypeProvider
protected
static
Object
_mutex
=
new
Object
();
private
static
byte
[]
_implementationId
;
protected
Factory
(
Class
implClass
,
protected
Factory
(
Class
<?>
implClass
,
String
serviceName
,
XMultiServiceFactory
xMultiServiceFactory
,
XRegistryKey
xRegistryKey
)
...
...
@@ -89,9 +89,9 @@ public class FactoryHelper {
_implName
=
implClass
.
getName
();
_serviceName
=
serviceName
;
Constructor
constructors
[]
=
implClass
.
getConstructors
();
Constructor
<?>
constructors
[]
=
implClass
.
getConstructors
();
for
(
int
i
=
0
;
i
<
constructors
.
length
&&
_constructor
==
null
;
++
i
)
{
Class
parameters
[]
=
constructors
[
i
].
getParameterTypes
();
Class
<?>
parameters
[]
=
constructors
[
i
].
getParameterTypes
();
if
(
parameters
.
length
==
3
&&
parameters
[
0
].
equals
(
XComponentContext
.
class
)
...
...
@@ -433,7 +433,7 @@ public class FactoryHelper {
* @param regKey the given registry key
* @see com.sun.star.lang.XServiceInfo
*/
static
public
XSingleServiceFactory
getServiceFactory
(
Class
implClass
,
static
public
XSingleServiceFactory
getServiceFactory
(
Class
<?>
implClass
,
XMultiServiceFactory
multiFactory
,
XRegistryKey
regKey
)
{
...
...
@@ -471,7 +471,7 @@ public class FactoryHelper {
* @param regKey the given registry key
* @see com.sun.star.lang.XServiceInfo
*/
static
public
XSingleServiceFactory
getServiceFactory
(
Class
implClass
,
static
public
XSingleServiceFactory
getServiceFactory
(
Class
<?>
implClass
,
String
serviceName
,
XMultiServiceFactory
multiFactory
,
XRegistryKey
regKey
)
...
...
@@ -484,7 +484,7 @@ public class FactoryHelper {
@return returns a factory object
@param implClass the implementing class
*/
static
public
Object
createComponentFactory
(
Class
implClass
,
String
serviceName
)
static
public
Object
createComponentFactory
(
Class
<?>
implClass
,
String
serviceName
)
{
return
new
Factory
(
implClass
,
serviceName
,
null
,
null
);
}
...
...
jurt/com/sun/star/comp/loader/JavaLoader.java
Dosyayı görüntüle @
7af40055
...
...
@@ -255,7 +255,7 @@ public class JavaLoader implements XImplementationLoader,
locationUrl
=
expand_url
(
locationUrl
);
Object
returnObject
=
null
;
Class
clazz
;
Class
<?>
clazz
;
DEBUG
(
"try to get factory for "
+
implementationName
);
...
...
@@ -299,7 +299,7 @@ public class JavaLoader implements XImplementationLoader,
throw
cae
;
}
Class
[]
paramTypes
=
{
String
.
class
,
XMultiServiceFactory
.
class
,
XRegistryKey
.
class
};
Class
<?>
[]
paramTypes
=
{
String
.
class
,
XMultiServiceFactory
.
class
,
XRegistryKey
.
class
};
Object
[]
params
=
{
implementationName
,
multiServiceFactory
,
xKey
};
// try to get factory from implemetation class
...
...
@@ -339,7 +339,7 @@ public class JavaLoader implements XImplementationLoader,
throw
new
CannotActivateFactoryException
(
"No factory object for "
+
implementationName
);
}
return
(
XSingleComponentFactory
)
ret
;
return
ret
;
}
else
{
...
...
@@ -350,7 +350,7 @@ public class JavaLoader implements XImplementationLoader,
Object
oRet
=
method
.
invoke
(
clazz
,
params
);
if
(
(
oRet
!=
null
)
&&
(
oRet
instanceof
XSingleServiceFactory
)
)
{
returnObject
=
(
XSingleServiceFactory
)
oRet
;
returnObject
=
oRet
;
}
}
}
...
...
@@ -401,14 +401,14 @@ public class JavaLoader implements XImplementationLoader,
try
{
Class
clazz
=
RegistrationClassFinder
.
find
(
locationUrl
);
Class
<?>
clazz
=
RegistrationClassFinder
.
find
(
locationUrl
);
if
(
null
==
clazz
)
{
throw
new
CannotRegisterImplementationException
(
"Cannot determine registration class!"
);
}
Class
[]
paramTypes
=
{
XRegistryKey
.
class
};
Class
<?>
[]
paramTypes
=
{
XRegistryKey
.
class
};
Object
[]
params
=
{
regKey
};
Method
method
=
clazz
.
getMethod
(
"__writeRegistryServiceInfo"
,
paramTypes
);
...
...
jurt/com/sun/star/comp/loader/RegistrationClassFinder.java
Dosyayı görüntüle @
7af40055
...
...
@@ -28,11 +28,11 @@ import java.util.StringTokenizer;
import
java.util.jar.Attributes
;
final
class
RegistrationClassFinder
{
public
static
Class
find
(
String
locationUrl
)
public
static
Class
<?>
find
(
String
locationUrl
)
throws
ClassNotFoundException
,
IOException
{
synchronized
(
map
)
{
Class
c
=
(
Class
)
WeakMap
.
getValue
(
map
.
get
(
locationUrl
));
Class
<?>
c
=
(
Class
<?>
)
WeakMap
.
getValue
(
map
.
get
(
locationUrl
));
if
(
c
!=
null
)
{
return
c
;
}
...
...
@@ -52,9 +52,9 @@ final class RegistrationClassFinder {
}
else
{
cl2
=
URLClassLoader
.
newInstance
(
new
URL
[]
{
url
},
cl1
);
}
Class
c
=
cl2
.
loadClass
(
name
);
Class
<?>
c
=
cl2
.
loadClass
(
name
);
synchronized
(
map
)
{
Class
c2
=
(
Class
)
WeakMap
.
getValue
(
map
.
get
(
locationUrl
));
Class
<?>
c2
=
(
Class
<?>
)
WeakMap
.
getValue
(
map
.
get
(
locationUrl
));
if
(
c2
!=
null
)
{
return
c2
;
}
...
...
jurt/com/sun/star/comp/servicemanager/ServiceManager.java
Dosyayı görüntüle @
7af40055
...
...
@@ -79,9 +79,9 @@ public class ServiceManager implements XMultiServiceFactory,
"com.sun.star.lang.ServiceManager"
};
ArrayList
eventListener
;
java
.
util
.
HashMap
factoriesByImplNames
;
java
.
util
.
HashMap
factoriesByServiceNames
;
// keys:
ArrayList
<
XEventListener
>
eventListener
;
java
.
util
.
HashMap
<
String
,
Object
>
factoriesByImplNames
;
java
.
util
.
HashMap
<
String
,
ArrayList
<
Object
>>
factoriesByServiceNames
;
// keys:
private
com
.
sun
.
star
.
uno
.
XComponentContext
m_xDefaultContext
;
...
...
@@ -89,18 +89,18 @@ public class ServiceManager implements XMultiServiceFactory,
* Creates a new instance of the <code>ServiceManager</code>.
*/
public
ServiceManager
()
{
eventListener
=
new
ArrayList
();
factoriesByImplNames
=
new
java
.
util
.
HashMap
();
factoriesByServiceNames
=
new
java
.
util
.
HashMap
();
eventListener
=
new
ArrayList
<
XEventListener
>
();
factoriesByImplNames
=
new
java
.
util
.
HashMap
<
String
,
Object
>
();
factoriesByServiceNames
=
new
java
.
util
.
HashMap
<
String
,
ArrayList
<
Object
>>
();
m_xDefaultContext
=
null
;
}
/**
* Creates a new instance of the <code>ServiceManager</code>.
*/
public
ServiceManager
(
XComponentContext
xContext
)
{
eventListener
=
new
ArrayList
();
factoriesByImplNames
=
new
java
.
util
.
HashMap
();
factoriesByServiceNames
=
new
java
.
util
.
HashMap
();
eventListener
=
new
ArrayList
<
XEventListener
>
();
factoriesByImplNames
=
new
java
.
util
.
HashMap
<
String
,
Object
>
();
factoriesByServiceNames
=
new
java
.
util
.
HashMap
<
String
,
ArrayList
<
Object
>>
();
m_xDefaultContext
=
xContext
;
}
...
...
@@ -172,9 +172,9 @@ public class ServiceManager implements XMultiServiceFactory,
try
{
// try to get the class of the implementation
Class
clazz
=
Class
.
forName
(
newImpls
[
i
]
);
Class
<?>
clazz
=
Class
.
forName
(
newImpls
[
i
]
);
Class
[]
methodClassParam
=
{
String
.
class
,
XMultiServiceFactory
.
class
,
XRegistryKey
.
class
};
Class
<?>
[]
methodClassParam
=
{
String
.
class
,
XMultiServiceFactory
.
class
,
XRegistryKey
.
class
};
java
.
lang
.
reflect
.
Method
getFactoryMeth
;
try
{
getFactoryMeth
=
clazz
.
getMethod
(
"__getServiceFactory"
,
methodClassParam
);
...
...
@@ -305,14 +305,14 @@ public class ServiceManager implements XMultiServiceFactory,
Object
factory
=
null
;
if
(
factoriesByServiceNames
.
containsKey
(
serviceName
)
)
{
ArrayList
aviableFact
=
(
ArrayList
)
factoriesByServiceNames
.
get
(
serviceName
);
ArrayList
<
Object
>
availableFact
=
factoriesByServiceNames
.
get
(
serviceName
);
DEBUG
(
""
);
DEBUG
(
"aviable factories for "
+
serviceName
+
" "
+
av
i
ableFact
);
DEBUG
(
"aviable factories for "
+
serviceName
+
" "
+
av
ail
ableFact
);
DEBUG
(
""
);
if
(
!
av
i
ableFact
.
isEmpty
()
)
factory
=
av
iableFact
.
get
(
avi
ableFact
.
size
()-
1
);
if
(
!
av
ail
ableFact
.
isEmpty
()
)
factory
=
av
ailableFact
.
get
(
avail
ableFact
.
size
()-
1
);
}
else
// not found in list of services - now try the implementations
factory
=
factoriesByImplNames
.
get
(
serviceName
);
// return null if none is aviable
...
...
@@ -341,10 +341,10 @@ public class ServiceManager implements XMultiServiceFactory,
int
i
=
0
;
String
[]
availableServiceNames
=
new
String
[
factoriesByServiceNames
.
size
()];
java
.
util
.
Iterator
keys
=
factoriesByServiceNames
.
keySet
().
iterator
();
java
.
util
.
Iterator
<
String
>
keys
=
factoriesByServiceNames
.
keySet
().
iterator
();
while
(
keys
.
hasNext
())
availableServiceNames
[
i
++]
=
(
String
)
keys
.
next
();
availableServiceNames
[
i
++]
=
keys
.
next
();
return
availableServiceNames
;
}
...
...
@@ -444,10 +444,10 @@ public class ServiceManager implements XMultiServiceFactory,
throws
com
.
sun
.
star
.
uno
.
RuntimeException
{
if
(
eventListener
!=
null
)
{
java
.
util
.
Iterator
enumer
=
eventListener
.
iterator
();
java
.
util
.
Iterator
<
XEventListener
>
enumer
=
eventListener
.
iterator
();
while
(
enumer
.
hasNext
())
{
XEventListener
listener
=
(
XEventListener
)
enumer
.
next
();
XEventListener
listener
=
enumer
.
next
();
listener
.
disposing
(
new
com
.
sun
.
star
.
lang
.
EventObject
(
this
));
}
eventListener
.
clear
();
...
...
@@ -552,15 +552,15 @@ public class ServiceManager implements XMultiServiceFactory,
String
[]
serviceNames
=
xServiceInfo
.
getSupportedServiceNames
();
ArrayList
vec
;
ArrayList
<
Object
>
vec
;
for
(
int
i
=
0
;
i
<
serviceNames
.
length
;
i
++)
{
if
(
!
factoriesByServiceNames
.
containsKey
(
serviceNames
[
i
]
)
)
{
DEBUG
(
"> no registered services found under "
+
serviceNames
[
i
]
+
": adding..."
);
factoriesByServiceNames
.
put
(
serviceNames
[
i
],
new
ArrayList
());
factoriesByServiceNames
.
put
(
serviceNames
[
i
],
new
ArrayList
<
Object
>
());
}
vec
=
(
ArrayList
)
factoriesByServiceNames
.
get
(
serviceNames
[
i
]
);
vec
=
factoriesByServiceNames
.
get
(
serviceNames
[
i
]
);
if
(
vec
.
contains
(
object
)
)
System
.
err
.
println
(
"The implementation "
+
xServiceInfo
.
getImplementationName
()
+
...
...
@@ -613,7 +613,7 @@ public class ServiceManager implements XMultiServiceFactory,
for
(
int
i
=
0
;
i
<
serviceNames
.
length
;
i
++
)
{
if
(
factoriesByServiceNames
.
containsKey
(
serviceNames
[
i
]
)
)
{
ArrayList
vec
=
(
ArrayList
)
factoriesByServiceNames
.
get
(
serviceNames
[
i
]);
ArrayList
<
Object
>
vec
=
factoriesByServiceNames
.
get
(
serviceNames
[
i
]);
if
(
!
vec
.
remove
(
object
)
)
System
.
err
.
println
(
"The implementation "
+
xServiceInfo
.
getImplementationName
()
+
...
...
@@ -675,7 +675,7 @@ public class ServiceManager implements XMultiServiceFactory,
{
XEnumeration
enumer
;
ArrayList
serviceList
=
(
ArrayList
)
factoriesByServiceNames
.
get
(
serviceName
);
ArrayList
<
Object
>
serviceList
=
factoriesByServiceNames
.
get
(
serviceName
);
if
(
serviceList
!=
null
)
enumer
=
new
ServiceEnumerationImpl
(
serviceList
.
iterator
()
);
...
...
@@ -737,7 +737,7 @@ public class ServiceManager implements XMultiServiceFactory,
* @since UDK1.0
*/
class
ServiceEnumerationImpl
implements
XEnumeration
{
java
.
util
.
Iterator
enumeration
=
null
;
java
.
util
.
Iterator
<
Object
>
enumeration
=
null
;
/**
* Constructs a new empty instance.
...
...
@@ -751,7 +751,7 @@ public class ServiceManager implements XMultiServiceFactory,
* @param enumer is the enumeration which should been wrapped.
* @see com.sun.star.container.XEnumeration
*/
public
ServiceEnumerationImpl
(
java
.
util
.
Enumeration
enumer
)
{
public
ServiceEnumerationImpl
(
java
.
util
.
Enumeration
<
Object
>
enumer
)
{
enumeration
=
Collections
.
list
(
enumer
).
iterator
();
}
...
...
@@ -761,7 +761,7 @@ public class ServiceManager implements XMultiServiceFactory,
* @param enumer is the enumeration which should been wrapped.
* @see com.sun.star.container.XEnumeration
*/
public
ServiceEnumerationImpl
(
java
.
util
.
Iterator
enumer
)
{
public
ServiceEnumerationImpl
(
java
.
util
.
Iterator
<
Object
>
enumer
)
{
enumeration
=
enumer
;
}
...
...
jurt/com/sun/star/lib/connections/pipe/PipeConnection.java
Dosyayı görüntüle @
7af40055
...
...
@@ -51,7 +51,7 @@ public class PipeConnection implements XConnection, XConnectionBroadcaster {
protected
String
_aDescription
;
protected
long
_nPipeHandle
;
protected
ArrayList
_aListeners
;
protected
ArrayList
<
XStreamListener
>
_aListeners
;
protected
boolean
_bFirstRead
;
/**
...
...
@@ -65,7 +65,7 @@ public class PipeConnection implements XConnection, XConnectionBroadcaster {
{
if
(
DEBUG
)
System
.
err
.
println
(
"##### "
+
getClass
().
getName
()
+
" - instantiated "
+
description
);
_aListeners
=
new
ArrayList
();
_aListeners
=
new
ArrayList
<
XStreamListener
>
();
_bFirstRead
=
true
;
// get pipe name from pipe descriptor
...
...
@@ -105,25 +105,25 @@ public class PipeConnection implements XConnection, XConnectionBroadcaster {
}
private
void
notifyListeners_open
()
{
Iterator
elements
=
_aListeners
.
iterator
();
Iterator
<
XStreamListener
>
elements
=
_aListeners
.
iterator
();
while
(
elements
.
hasNext
())
{
XStreamListener
xStreamListener
=
(
XStreamListener
)
elements
.
next
();
XStreamListener
xStreamListener
=
elements
.
next
();
xStreamListener
.
started
();
}
}
private
void
notifyListeners_close
()
{
Iterator
elements
=
_aListeners
.
iterator
();
Iterator
<
XStreamListener
>
elements
=
_aListeners
.
iterator
();
while
(
elements
.
hasNext
())
{
XStreamListener
xStreamListener
=
(
XStreamListener
)
elements
.
next
();
XStreamListener
xStreamListener
=
elements
.
next
();
xStreamListener
.
closed
();
}
}
private
void
notifyListeners_error
(
com
.
sun
.
star
.
uno
.
Exception
exception
)
{
Iterator
elements
=
_aListeners
.
iterator
();
Iterator
<
XStreamListener
>
elements
=
_aListeners
.
iterator
();
while
(
elements
.
hasNext
())
{
XStreamListener
xStreamListener
=
(
XStreamListener
)
elements
.
next
();
XStreamListener
xStreamListener
=
elements
.
next
();
xStreamListener
.
error
(
exception
);
}
}
...
...
jurt/com/sun/star/lib/connections/socket/SocketConnection.java
Dosyayı görüntüle @
7af40055
...
...
@@ -52,7 +52,7 @@ public class SocketConnection implements XConnection, XConnectionBroadcaster {
protected
Socket
_socket
;
protected
InputStream
_inputStream
;
protected
OutputStream
_outputStream
;
protected
ArrayList
_listeners
;
protected
ArrayList
<
XStreamListener
>
_listeners
;
protected
boolean
_firstRead
;
/**
...
...
@@ -74,7 +74,7 @@ public class SocketConnection implements XConnection, XConnectionBroadcaster {
_inputStream
=
new
BufferedInputStream
(
socket
.
getInputStream
());
_outputStream
=
new
BufferedOutputStream
(
socket
.
getOutputStream
());
_listeners
=
new
ArrayList
();
_listeners
=
new
ArrayList
<
XStreamListener
>
();
_firstRead
=
true
;
}
...
...
@@ -90,25 +90,25 @@ public class SocketConnection implements XConnection, XConnectionBroadcaster {
}
private
void
notifyListeners_open
()
{
Iterator
elements
=
_listeners
.
iterator
();
Iterator
<
XStreamListener
>
elements
=
_listeners
.
iterator
();
while
(
elements
.
hasNext
())
{
XStreamListener
xStreamListener
=
(
XStreamListener
)
elements
.
next
();
XStreamListener
xStreamListener
=
elements
.
next
();
xStreamListener
.
started
();
}
}
private
void
notifyListeners_close
()
{
Iterator
elements
=
_listeners
.
iterator
();
Iterator
<
XStreamListener
>
elements
=
_listeners
.
iterator
();
while
(
elements
.
hasNext
())
{
XStreamListener
xStreamListener
=
(
XStreamListener
)
elements
.
next
();
XStreamListener
xStreamListener
=
elements
.
next
();
xStreamListener
.
closed
();
}
}
private
void
notifyListeners_error
(
com
.
sun
.
star
.
uno
.
Exception
exception
)
{
Iterator
elements
=
_listeners
.
iterator
();
Iterator
<
XStreamListener
>
elements
=
_listeners
.
iterator
();
while
(
elements
.
hasNext
())
{
XStreamListener
xStreamListener
=
(
XStreamListener
)
elements
.
next
();
XStreamListener
xStreamListener
=
elements
.
next
();
xStreamListener
.
error
(
exception
);
}
}
...
...
jurt/com/sun/star/lib/uno/bridges/java_remote/java_remote_bridge.java
Dosyayı görüntüle @
7af40055
...
...
@@ -24,12 +24,10 @@ import java.io.OutputStream;
import
java.util.ArrayList
;
import
java.util.Enumeration
;
import
java.util.HashMap
;
import
java.util.Iterator
;
import
java.util.LinkedList
;
import
java.util.Map
;
import
java.util.Vector
;
import
com.sun.star.lib.util.DisposeListener
;
import
com.sun.star.lib.util.DisposeNotifier
;
...
...
@@ -167,7 +165,7 @@ public class java_remote_bridge
protected
MessageDispatcher
_messageDispatcher
;
protected
int
_life_count
=
0
;
// determines if this bridge is alife, which is controlled by acquire and release calls
private
final
ArrayList
_listeners
=
new
ArrayList
();
private
final
ArrayList
<
XEventListener
>
_listeners
=
new
ArrayList
<
XEventListener
>
();
protected
IThreadPool
_iThreadPool
;
...
...
@@ -215,15 +213,15 @@ public class java_remote_bridge
private
int
count
=
1
;
}
private
final
HashMap
refHolders
=
new
HashMap
();
private
final
HashMap
<
String
,
LinkedList
<
RefHolder
>>
refHolders
=
new
HashMap
<
String
,
LinkedList
<
RefHolder
>>
();
// from OID (String) to LinkedList of RefHolder
private
boolean
hasRefHolder
(
String
oid
,
Type
type
)
{
synchronized
(
refHolders
)
{
LinkedList
l
=
(
LinkedList
)
refHolders
.
get
(
oid
);
LinkedList
<
RefHolder
>
l
=
refHolders
.
get
(
oid
);
if
(
l
!=
null
)
{
for
(
Iterator
i
=
l
.
iterator
();
i
.
hasNext
();)
{
RefHolder
rh
=
(
RefHolder
)
i
.
next
();
for
(
Iterator
<
RefHolder
>
i
=
l
.
iterator
();
i
.
hasNext
();)
{
RefHolder
rh
=
i
.
next
();
if
(
type
.
isSupertypeOf
(
rh
.
getType
()))
{
return
true
;
}
...
...
@@ -235,14 +233,14 @@ public class java_remote_bridge
final
void
addRefHolder
(
Object
obj
,
Type
type
,
String
oid
)
{
synchronized
(
refHolders
)
{
LinkedList
l
=
(
LinkedList
)
refHolders
.
get
(
oid
);
LinkedList
<
RefHolder
>
l
=
refHolders
.
get
(
oid
);
if
(
l
==
null
)
{
l
=
new
LinkedList
();
l
=
new
LinkedList
<
RefHolder
>
();
refHolders
.
put
(
oid
,
l
);
}
boolean
found
=
false
;
for
(
Iterator
i
=
l
.
iterator
();
!
found
&&
i
.
hasNext
();)
{
RefHolder
rh
=
(
RefHolder
)
i
.
next
();
for
(
Iterator
<
RefHolder
>
i
=
l
.
iterator
();
!
found
&&
i
.
hasNext
();)
{
RefHolder
rh
=
i
.
next
();
if
(
rh
.
getType
().
equals
(
type
))
{
found
=
true
;
rh
.
acquire
();
...
...
@@ -257,10 +255,10 @@ public class java_remote_bridge
final
void
remRefHolder
(
Type
type
,
String
oid
)
{
synchronized
(
refHolders
)
{
LinkedList
l
=
(
LinkedList
)
refHolders
.
get
(
oid
);
LinkedList
<
RefHolder
>
l
=
refHolders
.
get
(
oid
);
if
(
l
!=
null
)
{
for
(
Iterator
i
=
l
.
iterator
();
i
.
hasNext
();)
{
RefHolder
rh
=
(
RefHolder
)
i
.
next
();
for
(
Iterator
<
RefHolder
>
i
=
l
.
iterator
();
i
.
hasNext
();)
{
RefHolder
rh
=
i
.
next
();
if
(
rh
.
getType
().
equals
(
type
))
{
try
{
if
(
rh
.
release
())
{
...
...
@@ -281,13 +279,13 @@ public class java_remote_bridge
final
void
freeHolders
()
{
synchronized
(
refHolders
)
{
for
(
Iterator
i1
=
refHolders
.
entrySet
().
iterator
();
i1
.
hasNext
();)
for
(
Iterator
<
Map
.
Entry
<
String
,
LinkedList
<
RefHolder
>>>
i1
=
refHolders
.
entrySet
().
iterator
();
i1
.
hasNext
();)
{
Map
.
Entry
e
=
(
Map
.
Entry
)
i1
.
next
();
String
oid
=
(
String
)
e
.
getKey
();
LinkedList
l
=
(
LinkedList
)
e
.
getValue
();
for
(
Iterator
i2
=
l
.
iterator
();
i2
.
hasNext
();)
{
RefHolder
rh
=
(
RefHolder
)
i2
.
next
();
Map
.
Entry
<
String
,
LinkedList
<
RefHolder
>>
e
=
i1
.
next
();
String
oid
=
e
.
getKey
();
LinkedList
<
RefHolder
>
l
=
e
.
getValue
();
for
(
Iterator
<
RefHolder
>
i2
=
l
.
iterator
();
i2
.
hasNext
();)
{
RefHolder
rh
=
i2
.
next
();
for
(
boolean
done
=
false
;
!
done
;)
{
done
=
rh
.
release
();
_java_environment
.
revokeInterface
(
oid
,
rh
.
getType
());
...
...
@@ -341,9 +339,9 @@ public class java_remote_bridge
private
void
notifyListeners
()
{
EventObject
eventObject
=
new
EventObject
(
this
);
Iterator
elements
=
_listeners
.
iterator
();
Iterator
<
XEventListener
>
elements
=
_listeners
.
iterator
();
while
(
elements
.
hasNext
())
{
XEventListener
xEventListener
=
(
XEventListener
)
elements
.
next
();
XEventListener
xEventListener
=
elements
.
next
();
try
{
xEventListener
.
disposing
(
eventObject
);
...
...
@@ -485,8 +483,8 @@ public class java_remote_bridge
}
notifyListeners
();
for
(
Iterator
i
=
disposeListeners
.
iterator
();
i
.
hasNext
();)
{
((
DisposeListener
)
i
.
next
()
).
notifyDispose
(
this
);
for
(
Iterator
<
DisposeListener
>
i
=
disposeListeners
.
iterator
();
i
.
hasNext
();)
{
i
.
next
(
).
notifyDispose
(
this
);
}
_iProtocol
.
terminate
();
...
...
@@ -698,5 +696,5 @@ public class java_remote_bridge
private
final
ProxyFactory
proxyFactory
;
// Access to disposeListeners must be synchronized on <CODE>this</CODE>:
private
final
ArrayList
disposeListeners
=
new
ArrayList
();
private
final
ArrayList
<
DisposeListener
>
disposeListeners
=
new
ArrayList
<
DisposeListener
>
();
}
jurt/com/sun/star/lib/uno/environments/java/java_environment.java
Dosyayı görüntüle @
7af40055
...
...
@@ -263,7 +263,7 @@ public final class java_environment implements IEnvironment {
private
static
final
class
Level2Entry
extends
WeakReference
<
Object
>
{
public
Level2Entry
(
String
oid
,
Type
type
,
Object
object
,
ReferenceQueue
queue
)
String
oid
,
Type
type
,
Object
object
,
ReferenceQueue
<
Object
>
queue
)
{
super
(
object
,
queue
);
this
.
oid
=
oid
;
...
...
@@ -288,7 +288,7 @@ public final class java_environment implements IEnvironment {
private
final
HashMap
<
String
,
Level1Entry
>
level1map
=
new
HashMap
<
String
,
Level1Entry
>();
private
final
ReferenceQueue
queue
=
new
ReferenceQueue
();
private
final
ReferenceQueue
<
Object
>
queue
=
new
ReferenceQueue
<
Object
>
();
}
private
boolean
isProxy
(
Object
object
)
{
...
...
jurt/com/sun/star/lib/uno/environments/remote/JavaThreadPoolFactory.java
Dosyayı görüntüle @
7af40055
...
...
@@ -43,7 +43,7 @@ final class JavaThreadPoolFactory {
public
JobQueue
getJobQueue
(
ThreadId
threadId
)
{
synchronized
(
jobQueues
)
{
return
(
JobQueue
)
jobQueues
.
get
(
threadId
);
return
jobQueues
.
get
(
threadId
);
}
}
...
...
@@ -55,8 +55,8 @@ final class JavaThreadPoolFactory {
public
void
dispose
(
Object
disposeId
,
Throwable
throwable
)
{
JobQueue
[]
qs
;
synchronized
(
jobQueues
)
{
Collection
c
=
jobQueues
.
values
();
qs
=
(
JobQueue
[])
c
.
toArray
(
new
JobQueue
[
c
.
size
()]);
Collection
<
JobQueue
>
c
=
jobQueues
.
values
();
qs
=
c
.
toArray
(
new
JobQueue
[
c
.
size
()]);
}
for
(
int
i
=
0
;
i
<
qs
.
length
;
++
i
)
{
qs
[
i
].
dispose
(
disposeId
,
throwable
);
...
...
@@ -70,7 +70,7 @@ final class JavaThreadPoolFactory {
}
else
{
ThreadId
id
;
synchronized
(
threadIdMap
)
{
id
=
(
ThreadId
)
threadIdMap
.
get
(
t
);
id
=
threadIdMap
.
get
(
t
);
if
(
id
==
null
)
{
id
=
ThreadId
.
createFresh
();
threadIdMap
.
put
(
t
,
id
);
...
...
@@ -80,6 +80,6 @@ final class JavaThreadPoolFactory {
}
}
private
static
final
WeakHashMap
threadIdMap
=
new
WeakHashMap
();
private
final
HashMap
jobQueues
=
new
HashMap
();
private
static
final
WeakHashMap
<
Thread
,
ThreadId
>
threadIdMap
=
new
WeakHashMap
<
Thread
,
ThreadId
>
();
private
final
HashMap
<
ThreadId
,
JobQueue
>
jobQueues
=
new
HashMap
<
ThreadId
,
JobQueue
>
();
}
jurt/com/sun/star/lib/uno/environments/remote/Job.java
Dosyayı görüntüle @
7af40055
...
...
@@ -67,7 +67,7 @@ public class Job {
* @param o_out_sig the out signature as an out parameter
*/
protected
Object
dispatch_queryInterface
(
Type
type
)
{
Class
zInterface
=
type
.
getTypeDescription
().
getZClass
();
Class
<?>
zInterface
=
type
.
getTypeDescription
().
getZClass
();
Object
result
=
null
;
...
...
jurt/com/sun/star/lib/uno/protocols/urp/Cache.java
Dosyayı görüntüle @
7af40055
...
...
@@ -38,7 +38,7 @@ final class Cache {
}
public
int
add
(
boolean
[]
found
,
Object
content
)
{
Entry
e
=
(
Entry
)
map
.
get
(
content
);
Entry
e
=
map
.
get
(
content
);
found
[
0
]
=
e
!=
null
;
if
(
e
==
null
)
{
if
(
map
.
size
()
<
maxSize
)
{
...
...
@@ -105,7 +105,7 @@ final class Cache {
// map contains the same entries; each entry has a unique index in the range
// 0 to maxSize - 1
private
final
int
maxSize
;
private
final
HashMap
map
=
new
HashMap
();
// from Object to Entry
private
final
HashMap
<
Object
,
Entry
>
map
=
new
HashMap
<
Object
,
Entry
>
();
// from Object to Entry
private
Entry
first
=
null
;
private
Entry
last
=
null
;
}
jurt/com/sun/star/lib/uno/protocols/urp/PendingRequests.java
Dosyayı görüntüle @
7af40055
...
...
@@ -27,17 +27,17 @@ final class PendingRequests {
public
PendingRequests
()
{}
public
synchronized
void
push
(
ThreadId
tid
,
Item
item
)
{
Stack
s
=
(
Stack
)
map
.
get
(
tid
);
Stack
<
Item
>
s
=
map
.
get
(
tid
);
if
(
s
==
null
)
{
s
=
new
Stack
();
s
=
new
Stack
<
Item
>
();
map
.
put
(
tid
,
s
);
}
s
.
push
(
item
);
}
public
synchronized
Item
pop
(
ThreadId
tid
)
{
Stack
s
=
(
Stack
)
map
.
get
(
tid
);
Item
i
=
(
Item
)
s
.
pop
();
Stack
<
Item
>
s
=
map
.
get
(
tid
);
Item
i
=
s
.
pop
();
if
(
s
.
empty
())
{
map
.
remove
(
tid
);
}
...
...
@@ -58,5 +58,5 @@ final class PendingRequests {
public
final
Object
[]
arguments
;
}
private
final
HashMap
map
=
new
HashMap
();
// from ThreadId to Stack of Item
private
final
HashMap
<
ThreadId
,
Stack
<
Item
>>
map
=
new
HashMap
<
ThreadId
,
Stack
<