ExecWriteRequest.java の 39 行で定義されています。
Public メソッド | |
ExecWriteRequest (AbstractWriteRequest request) | |
Object | executeRequest (DistributedRequestManager drm) throws SQLException |
final AbstractRequest | getRequest () |
Static Public メソッド | |
Message | getMessage (Object msg) |
Protected 変数 | |
AbstractRequest | request |
|
ExecWriteRequest.java の 44 行で定義されています。
00045 { 00046 super(request); 00047 } |
|
org.objectweb.cjdbc.controller.virtualdatabase.protocol.DistributedRequestに実装されています. ExecWriteRequest.java の 52 行で定義されています。 参照先 org.objectweb.cjdbc.common.sql.AbstractRequest.getSQLShortForm().
00054 { 00055 try 00056 { 00057 drm.scheduleExecWriteRequest((AbstractWriteRequest) request); 00058 int execWriteRequestResult = 0; 00059 try 00060 { 00061 execWriteRequestResult = drm 00062 .loadBalanceExecWriteRequest((AbstractWriteRequest) request); 00063 } 00064 catch (AllBackendsFailedException e) 00065 { 00066 drm.updateAndNotifyExecWriteRequest((AbstractWriteRequest) request, 00067 false); 00068 drm.addFailedOnAllBackends((AbstractWriteRequest) request); 00069 if (drm.getLogger().isDebugEnabled()) 00070 drm.getLogger().debug( 00071 "All backends failed locally for request " 00072 + request.getSQLShortForm(drm.getVirtualDatabase() 00073 .getSQLShortFormLength())); 00074 return e; 00075 } 00076 drm.updateAndNotifyExecWriteRequest((AbstractWriteRequest) request, true); 00077 return new Integer(execWriteRequestResult); 00078 } 00079 catch (SQLException e) 00080 { 00081 drm.getLogger().warn( 00082 "SQLException while executing distributed write request", e); 00083 throw e; 00084 } 00085 catch (RuntimeException re) 00086 { 00087 drm.getLogger().warn("Error while executing distributed write request", 00088 re); 00089 throw new SQLException(re.getMessage()); 00090 } 00091 } |
|
Builds a JGroups message from the given object. Src and dest are filled with null.
CJDBCGroupMessage.java の 47 行で定義されています。
00048 { 00049 return new Message(null, null, (Serializable) msg); 00050 } |
|
Returns the request value.
DistributedRequest.java の 58 行で定義されています。
00059 { 00060 return request; 00061 } |
|
DistributedRequest.java の 41 行で定義されています。 |