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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
/*
* author Ian Formanek
* Misha Dmitriev
*/
#include <string.h>
#include <assert.h>
#include <stdlib.h>
#include <stdio.h>
#include "jvmti.h"
#include "common_functions.h"
#define JF_SERVER_JAR_1 "/jfluid-server.jar"
#ifdef CVM
#define JF_SERVER_JAR_2 "/jfluid-server-cvm.jar"
#else
#define JF_SERVER_JAR_2 "/jfluid-server-15.jar"
#endif
// these constatns must match those defined in ProfilerServer
#define ATTACH_DYNAMIC 0
#define ATTACH_DIRECT 1
static char *_jfluid_dir;
static int _port_no;
static int _time_out = 0;
void parse_options_and_extract_params(char *options) {
char *jfluid_added_boot_path, *port_str, *timeout_str;
char *jfluid_boot_class_subpaths[2];
int i, in_quoted_path = 0, quotes_present = 0, path_len = 0;
jvmtiError res;
while (in_quoted_path || (!in_quoted_path && options[path_len] != ',')) {
if (options[path_len] == '\"') {
quotes_present = 1;
in_quoted_path = !in_quoted_path;
}
path_len++;
}
port_str = options + path_len + 1;
_port_no = (int)strtol(port_str, &timeout_str, 10);
if (strlen(timeout_str) > 1) {
_time_out = atoi(timeout_str+1);
}
if (quotes_present) {
options += 1;
path_len -= 2;
}
_jfluid_dir = (char*) malloc(path_len + 1);
strncpy(_jfluid_dir, options, path_len);
_jfluid_dir[path_len] = 0;
jfluid_boot_class_subpaths[0] = JF_SERVER_JAR_1;
jfluid_boot_class_subpaths[1] = JF_SERVER_JAR_2;
for (i = 0; i < 2; i++) {
jfluid_added_boot_path = (char*) malloc(path_len + strlen(jfluid_boot_class_subpaths[i]) + 1);
strcpy(jfluid_added_boot_path, _jfluid_dir);
strcpy(jfluid_added_boot_path + path_len, jfluid_boot_class_subpaths[i]);
res = (*_jvmti)->AddToBootstrapClassLoaderSearch(_jvmti, jfluid_added_boot_path);
assert(res == JVMTI_ERROR_NONE);
free(jfluid_added_boot_path);
}
}
/*
* This routine updates the bootstrap class path (if necessary) and then calls
* ProfilerServer.activate() method.
* The activateCode parameter signals the type of attachment to the ProfilerServer:
* 0 - dynamic attachment (not used so far), 1 - attach on startup
*/
static jint setupAndCallProfilerRuntimeActivate(JNIEnv *env, jint activateCode) {
jmethodID activateMethodID;
jclass profilerServerClass;
jstring jfluidDir;
/* For some reason (null classloader?) have to use slashed name - it barks if it is dotted */
profilerServerClass = (*env)->FindClass(env, "org/netbeans/lib/profiler/server/ProfilerServer");
if (profilerServerClass == NULL) {
char *new_sun_boot_class_path;
(*_jvmti)->GetSystemProperty(_jvmti, "sun.boot.class.path", &new_sun_boot_class_path);
fprintf(stderr, "Profiler Agent Error: Can't start the profiler back end: main class not found\n");
fprintf(stderr, "Profiler Agent Error: Boot class path was set to: %s\n", new_sun_boot_class_path);
(*_jvmti)->Deallocate(_jvmti, (void*)new_sun_boot_class_path);
fprintf(stderr, "Profiler Agent Error: Please check if you have jfluid-server.jar on this path\n");
return -1;
}
activateMethodID = (*env)->GetStaticMethodID(env, profilerServerClass, "activate", "(Ljava/lang/String;III)V");
if (activateMethodID == NULL) {
fprintf(stderr, "Profiler Agent Error: Can't start the profiler back end: activate(String, int) method not found in main class\n");
return -1;
}
jfluidDir = (*env)->NewStringUTF(env, _jfluid_dir);
(*env)->CallStaticVoidMethod(env, profilerServerClass, activateMethodID, jfluidDir, _port_no, activateCode, _time_out);
(*env)->DeleteLocalRef(env, jfluidDir);
(*env)->DeleteLocalRef(env, profilerServerClass);
if ((*env)->ExceptionCheck(env)) {
(*env)->ExceptionDescribe(env);
return -1;
}
return 0;
}
/** If the VM was launched on its own, we arrange that this is called right after the VM is initialized */
void JNICALL vm_init_hook(jvmtiEnv *jvmti_env, JNIEnv* jni_env, jthread thread) {
setupAndCallProfilerRuntimeActivate(jni_env, ATTACH_DIRECT);
}
|
