本文整理汇总了Java中com.gemstone.gemfire.LogWriter类的典型用法代码示例。如果您正苦于以下问题:Java LogWriter类的具体用法?Java LogWriter怎么用?Java LogWriter使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
LogWriter类属于com.gemstone.gemfire包,在下文中一共展示了LogWriter类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: checkLoadLib
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
private void checkLoadLib(final String testName) {
invokeInEveryVM(new SerializableRunnable("verifying for " + testName) {
@Override
public void run() {
GemFireStore store = Misc.getMemStoreBootingNoThrow();
LogWriter log = getLogWriter();
if (store == null) {
log.info("SB: server not booted");
return;
}
if (!store.getMyVMKind().isAccessorOrStore()) {
log.info("SB: not a server or accessor.");
return;
}
TestUtil.assertTimerLibraryLoaded();
}
});
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:24,代码来源:StatementPlanDUnit.java
示例2: loadSampleData
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
static void loadSampleData(LogWriter logw, Connection conn, int numOfRows, String tabname, int startVal) throws SQLException {
String tablename = schemaName + "." + tabname;
logw.info("Loading data ("
+ numOfRows + " rows..."
+ startVal + " as start value)...");
String[] securities = { "IBM", "INTC", "MOT", "TEK", "AMD", "CSCO", "DELL",
"HP", "SMALL1", "SMALL2" };
PreparedStatement psInsert = conn
.prepareStatement("insert into " + tablename + " values (?, ?, ?, ?, ?, ?)");
for (int i = 0; i < numOfRows; i++) {
int baseId = i + startVal;
String custName = "CustomerWithaLongName" + baseId;
psInsert.setInt(1, baseId);
psInsert.setString(2, custName);
psInsert.setInt(3, baseId); // max volume is 500
psInsert.setString(4, securities[baseId%10]);
psInsert.setInt(5, 0);
String queryString = "Emperors club for desperate men, "
+ "Washington DC, District of Columbia";
psInsert.setString(6, queryString);
psInsert.executeUpdate();
}
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:25,代码来源:SetQueriesDUnitHelper.java
示例3: stopNetServer
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
public static boolean stopNetServer() {
if (netServer != null) {
com.gemstone.gemfire.LogWriter logger = null;
try {
logger = getLogger();
netServer.stop();
logger.info(netServer.status() + " gemfirexd network server on host "
+ SocketCreator.getLocalHost().getHostName());
} catch (Exception ex) {
if (logger != null) {
logger.error("Failed in gemfirexd network server shutdown", ex);
}
fail("Failed in gemfirexd network server shutdown: " + ex);
}
netServer = null;
return true;
}
return false;
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:20,代码来源:TestUtil.java
示例4: main
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
public static void main(String[] args) throws InterruptedException {
DistributedSystem system =
DistributedSystem.connect(new Properties());
LogWriter logger = system.getLogWriter();
for (int i = 0; i < 100; i++) {
logger.finest("Finest message");
Thread.sleep(500);
logger.finer("Finer message");
Thread.sleep(500);
logger.fine("Fine message");
Thread.sleep(500);
logger.config("Config message");
Thread.sleep(500);
logger.info("Info message");
Thread.sleep(500);
logger.warning("Warning message");
Thread.sleep(500);
logger.severe("Severe message");
Thread.sleep(500);
}
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:23,代码来源:SendAlerts.java
示例5: processMessage
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
@Override
protected void processMessage(DistributionManager dm) {
LogWriter logger = dm.getLoggerI18n().convertToLogWriter();
try {
this.executeLocally(dm, this.dumpBackingMap);
} catch (Exception ex) {
// Log a severe log in case of an exception
if (logger.severeEnabled()) {
logger.severe("GfxdDumpLocalResultMessage: SQL exception in executing "
+ "message with fields as " + this.toString(), ex);
}
if (this.processorId > 0 || dm == null) {
throw new ReplyException("Unexpected SQLException on member "
+ dm.getDistributionManagerId(), ex);
}
}
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:18,代码来源:GfxdDumpLocalResultMessage.java
示例6: executeFunctionReturningArgs
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
public void executeFunctionReturningArgs(FunctionContext context) {
DistributedSystem ds = InternalDistributedSystem.getAnyInstance();
LogWriter logger = ds.getLogWriter();
logger.info(
"Executing executeFunctionReturningArgs in TestFunction on Member : "
+ ds.getDistributedMember()+ "with Context : " + context);
if (!hasResult()) {
return;
}
Object[] args = (Object[])context.getArguments();
if(args != null){
context.getResultSender().lastResult(args[0]);
}else{
context.getResultSender().lastResult(Boolean.FALSE);
}
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:19,代码来源:TestFunction.java
示例7: println
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
/**
* @see PrintWriter#println()
*/
@Override
public void println() {
final LogWriter log;
if ((log = this.logger) != null) {
if (!this.skipPrintLnForLogger) {
log.info(SanityManager.lineSeparator);
}
else {
this.skipPrintLnForLogger = false;
}
}
else {
moveToEndOfStream();
super.println();
}
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:20,代码来源:GfxdHeaderPrintWriterImpl.java
示例8: getLogSeverityLevel
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
@Override
public int getLogSeverityLevel() {
final LogWriter log = getLogger();
if (log != null) {
// report everything for fine-level and higher
if (log.fineEnabled()) {
return ExceptionSeverity.NO_APPLICABLE_SEVERITY;
}
// for info-level, only report STATEMENT_SEVERITY or higher
if (log.infoEnabled()) {
return ExceptionSeverity.STATEMENT_SEVERITY;
}
// for warning-level, only report SESSION_SEVERITY or higher
if (log.warningEnabled()) {
return ExceptionSeverity.SESSION_SEVERITY;
}
// for severe-level, only report DATABASE_SEVERITY or higher
if (log.severeEnabled()) {
return ExceptionSeverity.DATABASE_SEVERITY;
}
// if none of the above then only report SYSTEM_SEVERITY errors
return ExceptionSeverity.SYSTEM_SEVERITY;
}
return super.getLogSeverityLevel();
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:26,代码来源:GfxdHeaderPrintWriterImpl.java
示例9: getRandomClient
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
public String getRandomClient() {
LogWriter logger = Log.getLogWriter();
Map<String, String> map = (Map<String, String>) getSharedMap().get(CONNECTOR_URL_LIST);
if (map.size() > 0) {
Random r = new Random();
int randomKey = r.nextInt(map.size());
Set<String> keys = map.keySet();
Object keysarray[] = keys.toArray();
String clientName = (String) keysarray[randomKey];
logger.info("URL for client " + clientName + " is " + map.get(clientName));
String url = map.get(clientName);
return url;
} else
return null;
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:17,代码来源:JMXBlackboard.java
示例10: printStackTrace
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
@Override
public boolean printStackTrace(Throwable error, int logSeverityLevel) {
if (logSeverityLevel >= ExceptionSeverity.STATEMENT_SEVERITY) {
// avoid logging stack traces for constraint violations, conflicts, syntax
// errors etc.
if (error instanceof StandardException) {
StandardException se = (StandardException)error;
if (se.getSQLState().startsWith(SQLState.INTEGRITY_VIOLATION_PREFIX)
|| se.getSQLState().startsWith(
SQLState.GFXD_OPERATION_CONFLICT_PREFIX)) {
return false;
}
// also skip stacks for all syntax errors at log-level < fine
final LogWriter log = getLogger();
if (log != null && !log.fineEnabled()) {
if (se.getSQLState().startsWith(SQLState.LSE_COMPILATION_PREFIX)) {
return false;
}
}
}
}
return true;
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:24,代码来源:GfxdHeaderPrintWriterImpl.java
示例11: loadRegion
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
public CacheSerializableRunnable loadRegion(
final String name)
{
CacheSerializableRunnable sr = new CacheSerializableRunnable("load region on " + name) {
public void run2()
{
Cache cache = getCache();
LogWriter logger = cache.getLogger();
Region region = cache.getRegion(name);
for (int i=0; i < 100; i++){
region.put("" +i, new Portfolio(i));
}
}
};
return sr;
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:17,代码来源:QueryIndexUsingXMLDUnitTest.java
示例12: report
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
private void report(ClassTraverser c) throws IllegalArgumentException,
IllegalAccessException {
if (!logObjectGraph) {
return;
}
LogWriter logger = Misc.getCacheLogWriter();
StringBuilder sb = c.getStack("");
if (sb == null) {
return;
}
String msg = sb.append("===== EOF ======").toString();
logger.info(msg);
System.out.println(msg);
msg = null;
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:19,代码来源:ObjectSizer.java
示例13: send
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
/**
* Sends a PartitionedRegion PutAllPRMessage to the recipient
* @param recipients the members to which the put message is sent
* @param r the PartitionedRegion for which the put was performed
* @return the processor used to await acknowledgement that the update was
* sent, or null to indicate that no acknowledgement will be sent
* @throws ForceReattemptException if the peer is no longer available
*/
public PartitionResponse send(final Set<DistributedMember> recipients, PartitionedRegion r)
throws ForceReattemptException {
//Assert.assertTrue(recipient != null, "PutAllPRMessage NULL recipient"); recipient can be null for event notifications
//Set recipients = Collections.singleton(recipient);
PutAllResponseFromRemote p = new PutAllResponseFromRemote(r.getSystem(), recipients,
getTXState(), this);
initMessage(r, recipients, false, p);
final LogWriter logger = r.getCache().getLogger();
if (logger.fineEnabled()) {
logger.fine("PutAllPRMessage.send: recipients are "+recipients+", msg is "+this);
}
Set failures =r.getDistributionManager().putOutgoing(this);
if (failures != null && failures.size() > 0) {
throw new ForceReattemptException("Failed sending <" + this + ">");
}
return p;
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:27,代码来源:PutAllPRMessage.java
示例14: setLogLevel
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
/**
* Sets the loglevel for the provided log writer
* @param l the {@link LogWriter}
* @param logLevl the new log level as specified in {@link LogWriterImpl}
* @return the old log level
*/
public static int setLogLevel(LogWriter l, int logLevl)
{
int ret = -1;
l.config("PartitionedRegionDUnitTest attempting to set log level on LogWriter instance class:" + l.getClass().getName());
if (l instanceof PureLogWriter) {
PureLogWriter pl = (PureLogWriter) l;
ret = pl.getLevel();
l.config("PartitiionedRegionDUnitTest forcing log level to " + LogWriterImpl.levelToString(logLevl)
+ " from " + LogWriterImpl.levelToString(ret));
pl.setLevel(logLevl);
} else if (l instanceof AnyLogWriter) {
AnyLogWriter al = (AnyLogWriter) l;
ret = al.getLevel();
l.config("PartitiionedRegionDUnitTest forcing log level to " + LogWriterImpl.levelToString(logLevl)
+ " from " + LogWriterImpl.levelToString(ret));
al.setLevel(logLevl);
}
return ret;
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:27,代码来源:PartitionedRegionDUnitTestCase.java
示例15: execute
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
@Override
public void execute(FunctionContext context) {
try {
String regionPath = (String) context.getArguments();
if (regionPath == null) {
throw new IllegalArgumentException(CliStrings.CREATE_REGION__MSG__SPECIFY_VALID_REGION_PATH);
}
FetchRegionAttributesFunctionResult<?, ?> result = getRegionAttributes(regionPath);
context.getResultSender().lastResult(result);
} catch (IllegalArgumentException e) {
LogWriter logger = CacheFactory.getAnyInstance().getLogger();
if (logger.fineEnabled()) {
logger.fine(e);
}
context.getResultSender().lastResult(e);
}
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:18,代码来源:FetchRegionAttributesFunction.java
示例16: main
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
public static void main(String[] args) throws Throwable {
try {
int namingPort = Integer.getInteger(DUnitLauncher.RMI_PORT_PARAM).intValue();
int vmNum = Integer.getInteger(DUnitLauncher.VM_NUM_PARAM).intValue();
LogWriter log = Log.createLogWriter("dunit-vm-" + vmNum, DUnitLauncher.LOG_LEVEL);
System.out.println("VM" + vmNum + " is launching");
DUnitLauncher.initSystemProperties(log);
MasterRemote holder = (MasterRemote) Naming.lookup("//localhost:" + namingPort + "/" + DUnitLauncher.MASTER_PARAM);
RemoteTestModule.Master = new FakeMaster();
DUnitLauncher.locatorPort = holder.getLocatorPort();
Naming.bind("//localhost:" + namingPort + "/vm" + vmNum, new FakeRemoteTestModule(log));
holder.signalVMReady();
//This loop is here so this VM will die even if the master is mean killed.
while(true) {
holder.ping();
Thread.sleep(1000);
}
} catch (Throwable t) {
t.printStackTrace();
System.exit(1);
}
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:23,代码来源:ChildVM.java
示例17: tearDown2
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
@Override
public void tearDown2() throws Exception {
// might get an interrupted exception in RemoteGfManagerAgent.JoinProcessor
// during shutdown
if (isJMX() && this.agent != null) {
final LogWriter logger = this.agent.getLogWriter();
logger.info("<ExpectedException action=add>"
+ RuntimeAdminException.class.getName() + "</ExpectedException>");
logger.info("<ExpectedException action=add>"
+ DistributedSystemDisconnectedException.class.getName()
+ "</ExpectedException>");
logger.info("<ExpectedException action=add>"
+ InterruptedException.class.getName() + "</ExpectedException>");
}
super.tearDown2();
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:17,代码来源:SystemMemberDUnitTest.java
示例18: initializeKey
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
protected void initializeKey() {
if (this._key instanceof KeyWithRegionContext) {
final LocalRegion r = getRegion();
if (r == null) {
// log a warning
final LogWriter logger = CacheFactory.getAnyInstance().getLogger();
if (logger.warningEnabled()) {
logger.warning("GatewayEventImpl.initializeKey: region "
+ this._regionName + " not found while initializing key "
+ this._key);
}
}
else if (r.keyRequiresRegionContext()) {
((KeyWithRegionContext)this._key).setRegionContext(r);
}
}
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:18,代码来源:GatewayEventImpl.java
示例19: logSizes
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
public void logSizes(LogWriter lw, String msg) {
long headAddr = this.topAddr;
long addr;
boolean concurrentModDetected;
do {
concurrentModDetected = false;
addr = headAddr;
while (addr != 0L) {
int curSize = Chunk.getSize(addr);
addr = Chunk.getNext(addr);
long curHead = this.topAddr;
if (curHead != headAddr) {
headAddr = curHead;
concurrentModDetected = true;
// Someone added or removed from the stack.
// So we break out of the inner loop and start
// again at the new head.
break;
}
// TODO construct a single log msg
// that gets reset on the concurrent mad.
lw.info(msg + curSize);
}
} while (concurrentModDetected);
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:26,代码来源:SimpleMemoryAllocatorImpl.java
示例20: test40171
import com.gemstone.gemfire.LogWriter; //导入依赖的package包/类
/**
* test that produced 40171.
*/
public void test40171() throws Exception {
startVMs(1, 1);
Connection conn = TestUtil.jdbcConn;
Statement s = conn.createStatement();
s.execute("create schema trade");// default server groups (SG1)");
s.execute("create table trade.customers (cid int not null, "
+ "cust_name varchar(100), "
+ "since int, addr varchar(100), tid int, "
+ "primary key (cid)) replicate");
s.execute("insert into trade.customers values (1, 'XXXX1', "
+ "1, 'BEAV1', 1)");
ResultSet rs = s
.executeQuery("select * from trade.customers where since=1");
while (rs.next()) {
assertEquals(1, rs.getInt(1));
assertEquals("XXXX1", rs.getString(2).trim());
assertEquals(1, rs.getInt(3));
assertEquals("BEAV1", rs.getString(4));
assertEquals(1, rs.getInt(5));
}
int numUpdate = s
.executeUpdate("update trade.customers set since=2 where cid=1");
assertEquals("Should update one row", 1, numUpdate);
rs = s.executeQuery("select * from trade.customers where since=1");
while (rs.next()) {
LogWriter logger = Log.getLogWriter();
logger.info("XXXX col1 : " + rs.getInt(1) + " #2 : "
+ rs.getString(2).trim() + " #3 : " + rs.getInt(3) + " #4 "
+ rs.getString(4) + " #5 : " + rs.getInt(5));
throw new TestException("Should not return any rows");
}
}
开发者ID:gemxd,项目名称:gemfirexd-oss,代码行数:42,代码来源:InsertUpdateForeignKeyDUnit.java
注:本文中的com.gemstone.gemfire.LogWriter类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论