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 行で定義されています。 |
1.3.6