1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
/*******************************************************************************
* Copyright (c) 2006, 2016 Cognos Incorporated, IBM Corporation and others
* All rights reserved. This program and the accompanying materials are made
* available under the terms of the Eclipse Public License v1.0 which
* accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
******************************************************************************/
package org.eclipse.osgi.internal.log;
import java.util.Map;
import java.util.WeakHashMap;
import org.eclipse.equinox.log.ExtendedLogEntry;
import org.osgi.framework.Bundle;
import org.osgi.framework.ServiceReference;
import org.osgi.service.log.LogEntry;
public class ExtendedLogEntryImpl implements ExtendedLogEntry, LogEntry {
private static long nextSequenceNumber = 1L;
private static long nextThreadId = 1L;
private static final Map<Thread, Long> threadIds = createThreadIdMap();
private final String loggerName;
private final Bundle bundle;
private final int level;
private final String message;
private final Throwable throwable;
private final Object contextObject;
private final long time;
private final long threadId;
private final String threadName;
private final long sequenceNumber;
private static Map<Thread, Long> createThreadIdMap() {
try {
Thread.class.getMethod("getId", (Class[]) null); //$NON-NLS-1$
} catch (NoSuchMethodException e) {
return new WeakHashMap<>();
}
return null;
}
private static long getId(Thread thread) {
if (threadIds == null)
return thread.getId();
Long threadId = threadIds.get(thread);
if (threadId == null) {
threadId = new Long(nextThreadId++);
threadIds.put(thread, threadId);
}
return threadId.longValue();
}
public ExtendedLogEntryImpl(Bundle bundle, String loggerName, Object contextObject, int level, String message, Throwable throwable) {
this.time = System.currentTimeMillis();
this.loggerName = loggerName;
this.bundle = bundle;
this.level = level;
this.message = message;
this.throwable = throwable;
this.contextObject = contextObject;
Thread currentThread = Thread.currentThread();
this.threadName = currentThread.getName();
synchronized (ExtendedLogEntryImpl.class) {
this.threadId = getId(currentThread);
this.sequenceNumber = nextSequenceNumber++;
}
}
public String getLoggerName() {
return loggerName;
}
public long getSequenceNumber() {
return sequenceNumber;
}
public long getThreadId() {
return threadId;
}
public String getThreadName() {
return threadName;
}
public Bundle getBundle() {
return bundle;
}
public Throwable getException() {
return throwable;
}
public int getLevel() {
return level;
}
public String getMessage() {
return message;
}
@SuppressWarnings("rawtypes")
public ServiceReference getServiceReference() {
if (contextObject != null && contextObject instanceof ServiceReference)
return (ServiceReference) contextObject;
return null;
}
public long getTime() {
return time;
}
public Object getContext() {
return contextObject;
}
}
|
