← Back to branch summary

~pbeaman/akiban-persistit/fix_1005206_infinite_loop

« back to all changes in this revision

Viewing changes to core/src/main/java/com/persistit/mxbeans/ManagementMXBean.java

  • Committer: build-akiban
  • Date: 2012-05-15 21:24:26 UTC
  • mfrom: (292.3.38 fix_959456)
  • Revision ID: build-akiban-20120515212426-6lp526nql1wu790g
merge pbeaman: This branch fixes several problems related to https://bugs.launchpad.net/akiban-persistit/+bug/959456 Journal copier falls behind in 4-hour Persistit TPCC test.

https://code.launchpad.net/~pbeaman/akiban-persistit/fix_959456/+merge/105529

Show diffs side-by-side

added added

removed removed

Lines of Context:
core/src/main/java/com/persistit/mxbeans/ManagementMXBean.java
54
54
     * 
55
55
     * @return The state
56
56
     */
57
 
    public boolean isInitialized() throws RemoteException;
 
57
    boolean isInitialized() throws RemoteException;
58
58
 
59
59
    /**
60
60
     * Return the version name of the current Persistit instance.
61
61
     * 
62
62
     * @return the version name
63
63
     */
64
 
    public String getVersion() throws RemoteException;
 
64
    String getVersion() throws RemoteException;
65
65
 
66
66
    /**
67
67
     * Return the copyright notice for the current Persistit instance.
68
68
     * 
69
69
     * @return the copyright notice
70
70
     */
71
 
    public String getCopyright() throws RemoteException;
 
71
    String getCopyright() throws RemoteException;
72
72
 
73
73
    /**
74
74
     * Return the system time at which Persistit was initialized.
75
75
     * 
76
76
     * @return start time, in milliseconds since January 1, 1970 00:00:00 GMT.
77
77
     */
78
 
    public long getStartTime() throws RemoteException;
 
78
    long getStartTime() throws RemoteException;
79
79
 
80
80
    /**
81
81
     * Return the elapsed time since startup in milliseconds
82
82
     * 
83
83
     * @return elapsed time in milliseconds
84
84
     */
85
 
    public long getElapsedTime() throws RemoteException;
 
85
    long getElapsedTime() throws RemoteException;
86
86
 
87
87
    /**
88
88
     * Return the port on which a local RMI server has been registered, or -1 if
91
91
     * @return the port
92
92
     * @throws RemoteException
93
93
     */
94
 
    public int getRmiPort() throws RemoteException;
 
94
    int getRmiPort() throws RemoteException;
95
95
 
96
96
    /**
97
97
     * Return the aggregate number of transactions committed since Persistit was
100
100
     * @return total number of transactions committed
101
101
     * @throws RemoteException
102
102
     */
103
 
    public long getCommittedTransactionCount() throws RemoteException;
 
103
    long getCommittedTransactionCount() throws RemoteException;
104
104
 
105
105
    /**
106
106
     * Return the aggregate number of transaction rollback events since
109
109
     * @return total number of transactions rolled back
110
110
     * @throws RemoteException
111
111
     */
112
 
    public long getRollbackCount() throws RemoteException;
 
112
    long getRollbackCount() throws RemoteException;
113
113
 
114
114
    /**
115
115
     * Return an array of information of all volumes that Persistit
118
118
     * @return array of volumes
119
119
     * @throws RemoteException
120
120
     */
121
 
    public Management.VolumeInfo[] getVolumes() throws RemoteException;
 
121
    Management.VolumeInfo[] getVolumes() throws RemoteException;
122
122
 
123
123
    /**
124
124
     * @param max Maximum number of transactions to report on.
125
125
     * @return Report on the <code>max</code> longest-running transactions.
126
126
     * @throws RemoteException
127
127
     */
128
 
    public String transactionReport(int max) throws RemoteException;
 
128
    String transactionReport(int max) throws RemoteException;
 
129
 
 
130
    /**
 
131
     * @return the name of the current default <code>CommitPolicy<code>
 
132
     */
 
133
    String getDefaultCommitPolicy() throws RemoteException;
 
134
    
 
135
    /**
 
136
     * Modify the current default <code>CommitPolicy</code>.  The
 
137
     * policy name must be one of "hard", "group" or "commit".
 
138
     * @param policyName name of the <code>CommitPolicy</code> to set.
 
139
     */
 
140
    void setDefaultCommitPolicy(String policyName) throws RemoteException;
129
141
 
130
142
    /**
131
143
     * Indicate whether Persistit will suspend its shutdown activities on
138
150
     *         close; <code>false</code> if the <code>close</code> operation
139
151
     *         will not be suspended.
140
152
     */
141
 
    public boolean isShutdownSuspended() throws RemoteException;
 
153
    boolean isShutdownSuspended() throws RemoteException;
142
154
 
143
155
    /**
144
156
     * Control whether Persistit will suspend its shutdown activities on
151
163
     *            <code>true</code> to specify that Persistit will wait when
152
164
     *            attempting to close; otherwise <code>false</code>.
153
165
     */
154
 
    public void setShutdownSuspended(boolean suspended) throws RemoteException;
 
166
    void setShutdownSuspended(boolean suspended) throws RemoteException;
155
167
 
156
168
    /**
157
169
     * Indicate whether Persistit is suspending all update operations. When
162
174
     *         a <code>Volume</code>; otherwise <code>false</code>.
163
175
     * @throws RemoteException
164
176
     */
165
 
    public boolean isUpdateSuspended() throws RemoteException;
 
177
    boolean isUpdateSuspended() throws RemoteException;
166
178
 
167
179
    /**
168
180
     * Control whether Persistit will suspend all update operations. When
172
184
     * @param suspended
173
185
     * @throws RemoteException
174
186
     */
175
 
    public void setUpdateSuspended(boolean suspended) throws RemoteException;
 
187
    void setUpdateSuspended(boolean suspended) throws RemoteException;
176
188
 
177
189
    /**
178
190
     * Flush and sync all dirty data in Persistit by invoking
180
192
     * 
181
193
     * @throws RemoteException
182
194
     */
183
 
    public void flushAndForce() throws RemoteException;
 
195
    void flushAndForce() throws RemoteException;
184
196
 
185
197
    /**
186
198
     * Use a simple command-line processor to invoke a task. Allows task
193
205
     * @return The final status of the Task, as a String
194
206
     * @throws RemoteException
195
207
     */
196
 
    public String execute(final String commandLine) throws RemoteException;
 
208
    String execute(final String commandLine) throws RemoteException;
197
209
 
198
210
    /**
199
211
     * Use a simple command-line processor to start a task. Allows task
205
217
     * @return The taskId, as a String
206
218
     * @throws RemoteException
207
219
     */
208
 
    public String launch(final String commandLine) throws RemoteException;
 
220
    String launch(final String commandLine) throws RemoteException;
209
221
 
210
222
    /**
211
223
     * Query information about a specific volume from it's name.
214
226
     * @return information about the volume, or null if none found
215
227
     * @throws RemoteException
216
228
     */
217
 
    public Management.VolumeInfo volumeByName(final String volumeName) throws RemoteException;
 
229
    Management.VolumeInfo volumeByName(final String volumeName) throws RemoteException;
218
230
}