Skip to content

Commit

Permalink
[agent][collector][client] support golang dump request. (cpu, mutex, …
Browse files Browse the repository at this point in the history
…block)
  • Loading branch information
gunlee01 committed Jan 23, 2021
1 parent 46a67c4 commit 7cf4bf7
Show file tree
Hide file tree
Showing 13 changed files with 697 additions and 209 deletions.
392 changes: 199 additions & 193 deletions scouter.client/src/scouter/client/constants/MenuStr.java

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
@@ -0,0 +1,63 @@
/*
* Copyright 2015 the original author or authors.
* @https://github.com/scouter-project/scouter
*
* Licensed 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.
*
*/
package scouter.client.context.actions;

import org.eclipse.jface.action.Action;
import scouter.client.net.TcpProxy;
import scouter.client.util.ConsoleProxy;
import scouter.client.util.ExUtil;
import scouter.lang.pack.MapPack;
import scouter.lang.pack.Pack;
import scouter.net.RequestCmd;
import scouter.util.StringUtil;

public class OpenCxtmenuProfileBlockAction extends Action {
public final static String ID = OpenCxtmenuProfileBlockAction.class.getName();

private int objHash;
private int serverId;
public OpenCxtmenuProfileBlockAction(String label, int objHash, int serverId) {
this.objHash = objHash;
this.serverId = serverId;
setText(label);
}

public void run() {
ExUtil.asyncRun(new Runnable() {
public void run() {
TcpProxy tcp = TcpProxy.getTcpProxy(serverId);
try {
MapPack param = new MapPack();
param.put("objHash", objHash);
Pack p = tcp.getSingle(RequestCmd.TRIGGER_BLOCK_PROFILE, param);
if (p != null && p instanceof MapPack) {
MapPack m = (MapPack) p;
String filename = m.getText("name");
if (StringUtil.isNotEmpty(filename)) {
ConsoleProxy.infoSafe("Dump complete : " + filename);
return;
}
}
ConsoleProxy.errorSafe("Dump failed");
} finally {
TcpProxy.putTcpProxy(tcp);
}
}
});
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,63 @@
/*
* Copyright 2015 the original author or authors.
* @https://github.com/scouter-project/scouter
*
* Licensed 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.
*
*/
package scouter.client.context.actions;

import org.eclipse.jface.action.Action;
import scouter.client.net.TcpProxy;
import scouter.client.util.ConsoleProxy;
import scouter.client.util.ExUtil;
import scouter.lang.pack.MapPack;
import scouter.lang.pack.Pack;
import scouter.net.RequestCmd;
import scouter.util.StringUtil;

public class OpenCxtmenuProfileMutexAction extends Action {
public final static String ID = OpenCxtmenuProfileMutexAction.class.getName();

private int objHash;
private int serverId;
public OpenCxtmenuProfileMutexAction(String label, int objHash, int serverId) {
this.objHash = objHash;
this.serverId = serverId;
setText(label);
}

public void run() {
ExUtil.asyncRun(new Runnable() {
public void run() {
TcpProxy tcp = TcpProxy.getTcpProxy(serverId);
try {
MapPack param = new MapPack();
param.put("objHash", objHash);
Pack p = tcp.getSingle(RequestCmd.TRIGGER_MUTEX_PROFILE, param);
if (p != null && p instanceof MapPack) {
MapPack m = (MapPack) p;
String filename = m.getText("name");
if (StringUtil.isNotEmpty(filename)) {
ConsoleProxy.infoSafe("Dump complete : " + filename);
return;
}
}
ConsoleProxy.errorSafe("Dump failed");
} finally {
TcpProxy.putTcpProxy(tcp);
}
}
});
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,92 @@
/*
* Copyright 2015 the original author or authors.
* @https://github.com/scouter-project/scouter
*
* Licensed 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.
*
*/
package scouter.client.heapdump.actions;


import org.eclipse.jface.action.Action;
import org.eclipse.swt.graphics.Image;
import org.eclipse.ui.IWorkbenchWindow;
import scouter.client.net.TcpProxy;
import scouter.client.util.ConsoleProxy;
import scouter.client.util.ExUtil;
import scouter.client.util.ImageUtil;
import scouter.lang.pack.MapPack;
import scouter.lang.value.BooleanValue;
import scouter.net.RequestCmd;
import scouter.util.CastUtil;

public class BlockProfileAction extends Action {
public final static String ID = BlockProfileAction.class.getName();

private final IWorkbenchWindow window;
@SuppressWarnings("unused")
private String key;
private int objHash;
private String objName;
private String fName;
private long time;
private int serverId;

public BlockProfileAction(IWorkbenchWindow window, String label, String key, int objHash, String fName, long time, Image image, int serverId) {
this.window = window;
this.key = key;
this.objHash = objHash;
this.objName = fName;
this.fName = fName + "_block";
this.time = time;
this.serverId = serverId;

setText(label);
setId(ID);
setImageDescriptor(ImageUtil.getImageDescriptor(image));

}

public void run() {
ExUtil.asyncRun(new Runnable() {
public void run() {
TcpProxy tcp = TcpProxy.getTcpProxy(serverId);
try {
MapPack param = new MapPack();
param.put("objHash", objHash);
param.put("fName", fName);
param.put("time", time);
MapPack out = (MapPack) tcp.getSingle(RequestCmd.OBJECT_CALL_BLOCK_PROFILE, param);

if(out != null){
if(!CastUtil.cboolean((BooleanValue)out.get("success"))){
ConsoleProxy.infoSafe(out.getText("msg"));
}
}
// ExUtil.exec(window.getShell().getDisplay(), new Runnable(){
// public void run() {
// try{
// Action act = new HeapDumpListAction(window, "Dumps", objName, objHash, Images.heap, serverId);
// act.run();
// }catch(Exception e){
// e.printStackTrace();
// }
// }
// });
} finally {
TcpProxy.putTcpProxy(tcp);
}
}
});
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,92 @@
/*
* Copyright 2015 the original author or authors.
* @https://github.com/scouter-project/scouter
*
* Licensed 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.
*
*/
package scouter.client.heapdump.actions;


import org.eclipse.jface.action.Action;
import org.eclipse.swt.graphics.Image;
import org.eclipse.ui.IWorkbenchWindow;
import scouter.client.net.TcpProxy;
import scouter.client.util.ConsoleProxy;
import scouter.client.util.ExUtil;
import scouter.client.util.ImageUtil;
import scouter.lang.pack.MapPack;
import scouter.lang.value.BooleanValue;
import scouter.net.RequestCmd;
import scouter.util.CastUtil;

public class CpuProfileAction extends Action {
public final static String ID = CpuProfileAction.class.getName();

private final IWorkbenchWindow window;
@SuppressWarnings("unused")
private String key;
private int objHash;
private String objName;
private String fName;
private long time;
private int serverId;

public CpuProfileAction(IWorkbenchWindow window, String label, String key, int objHash, String fName, long time, Image image, int serverId) {
this.window = window;
this.key = key;
this.objHash = objHash;
this.objName = fName;
this.fName = fName + "_block";
this.time = time;
this.serverId = serverId;

setText(label);
setId(ID);
setImageDescriptor(ImageUtil.getImageDescriptor(image));

}

public void run() {
ExUtil.asyncRun(new Runnable() {
public void run() {
TcpProxy tcp = TcpProxy.getTcpProxy(serverId);
try {
MapPack param = new MapPack();
param.put("objHash", objHash);
param.put("fName", fName);
param.put("time", time);
MapPack out = (MapPack) tcp.getSingle(RequestCmd.OBJECT_CALL_CPU_PROFILE, param);

if(out != null){
if(!CastUtil.cboolean((BooleanValue)out.get("success"))){
ConsoleProxy.infoSafe(out.getText("msg"));
}
}
// ExUtil.exec(window.getShell().getDisplay(), new Runnable(){
// public void run() {
// try{
// Action act = new HeapDumpListAction(window, "Dumps", objName, objHash, Images.heap, serverId);
// act.run();
// }catch(Exception e){
// e.printStackTrace();
// }
// }
// });
} finally {
TcpProxy.putTcpProxy(tcp);
}
}
});
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ public void run() {
ExUtil.exec(window.getShell().getDisplay(), new Runnable(){
public void run() {
try{
Action act = new HeapDumpListAction(window, "Heap Dump", objName, objHash, Images.heap, serverId);
Action act = new HeapDumpListAction(window, "Dumps", objName, objHash, Images.heap, serverId);
act.run();
}catch(Exception e){
e.printStackTrace();
Expand Down
Loading

0 comments on commit 7cf4bf7

Please sign in to comment.