summaryrefslogtreecommitdiffstats
path: root/kdejava/koala/org/kde/koala/Scheduler.java
blob: 1493b2d0ccf20b2d077d5e4d596a369e2e578def (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
//Auto-generated by kalyptus. DO NOT EDIT.
package org.kde.koala;

import org.kde.qt.Qt;
import org.kde.qt.TQMetaObject;
import org.kde.qt.QtSupport;
import org.kde.qt.TQObject;
import java.util.ArrayList;
import org.kde.qt.TQWidget;
import org.kde.qt.TQObject;

/**

 The TDEIO.Scheduler manages io-slaves for the application.
 It also queues jobs and assigns the job to a slave when one
 becomes available.
 There are 3 possible ways for a job to get a slave:
 <h3>1. Direct</h3>
 This is the default. When you create a job the
 TDEIO.Scheduler will be notified and will find either an existing
 slave that is idle or it will create a new slave for the job.
 Example:
 <pre>
    TransferJob job = TDEIO.get(KURL("http://www.kde.org"));
 </pre>
 <h3>2. Scheduled</h3>
 If you create a lot of jobs, you might want not want to have a
 slave for each job. If you schedule a job, a maximum number
 of slaves will be created. When more jobs arrive, they will be
 queued. When a slave is finished with a job, it will be assigned
 a job from the queue.
 Example:
 <pre>
    TransferJob job = TDEIO.get(KURL("http://www.kde.org"));
    TDEIO.Scheduler.scheduleJob(job);
 </pre>
 <h3>3. Connection Oriented</h3>
 For some operations it is important that multiple jobs use
 the same connection. This can only be ensured if all these jobs
 use the same slave.
 You can ask the scheduler to open a slave for connection oriented
 operations. You can then use the scheduler to assign jobs to this
 slave. The jobs will be queued and the slave will handle these jobs
 one after the other.
 Example:
 <pre>
    Slave slave = TDEIO.Scheduler.getConnectedSlave(
            KURL("pop3://bastian:password@mail.kde.org"));
    TransferJob job1 = TDEIO.get(
            KURL("pop3://bastian:password@mail.kde.org/msg1"));
    TDEIO.Scheduler.assignJobToSlave(slave, job1);
    TransferJob job2 = TDEIO.get(
            KURL("pop3://bastian:password@mail.kde.org/msg2"));
    TDEIO.Scheduler.assignJobToSlave(slave, job2);
    TransferJob job3 = TDEIO.get(
            KURL("pop3://bastian:password@mail.kde.org/msg3"));
    TDEIO.Scheduler.assignJobToSlave(slave, job3);
    // ... Wait for jobs to finish...
    TDEIO.Scheduler.disconnectSlave(slave);
 </pre>
 Note that you need to explicitly disconnect the slave when the 
 connection goes down, so your error handler should contain:
 <pre>
    if (error == TDEIO.ERR_CONNECTION_BROKEN)
        TDEIO.Scheduler.disconnectSlave(slave);
 </pre>
 See {@link SchedulerSignals} for signals emitted by Scheduler
		@short    The TDEIO.Scheduler manages io-slaves for the application.
		@see Slave
		@see Job

*/
public class Scheduler extends TQObject implements DCOPObjectInterface {
	protected Scheduler(Class dummy){super((Class) null);}
	public native TQMetaObject metaObject();
	public native String className();
	public native boolean connect(TQObject sender, String signal, String member);
	public native void debug_info();
	public native boolean process(String fun, byte[] data, StringBuffer replyType, byte[] replyData);
	public native ArrayList functions();
	public native void slotSlaveDied(Slave slave);
	public native void slotSlaveStatus(int pid, String protocol, String host, boolean connected);
	/**	
		 Register <code>job</code> with the scheduler. 
		 The default is to create a new slave for the job if no slave
		 is available. This can be changed by calling scheduleJob.
			@param job the job to register
		         		@short    Register <code>job</code> with the scheduler.
	*/
	public static native void doJob(SimpleJob job);
	/**	
		 Calling ths function makes that <code>job</code> gets scheduled for later
		 execution, if multiple jobs are registered it might wait for
		 other jobs to finish.
			@param job the job to schedule
		         		@short    Calling ths function makes that <code>job</code> gets scheduled for later  execution, if multiple jobs are registered it might wait for  other jobs to finish.
	*/
	public static native void scheduleJob(SimpleJob job);
	/**	
		 Stop the execution of a job.
			@param job the job to cancel
		         		@short    Stop the execution of a job.
	*/
	public static native void cancelJob(SimpleJob job);
	/**	
		 Called when a job is done.
			@param job the finished job
			@param slave the slave that executed the <code>job</code>
		         		@short    Called when a job is done.
	*/
	public static native void jobFinished(SimpleJob job, Slave slave);
	/**	
		 Puts a slave on notice. A next job may reuse this slave if it
		 requests the same URL.
			 A job can be put on hold after it has emit'ed its mimetype.
		 Based on the mimetype, the program can give control to another
		 component in the same process which can then resume the job
		 by simply asking for the same URL again.
			@param job the job that should be stopped
			@param url the URL that is handled by the <code>url</code>
		         		@short    Puts a slave on notice.
	*/
	public static native void putSlaveOnHold(SimpleJob job, KURL url);
	/**	
		 Removes any slave that might have been put on hold. If a slave 
		 was put on hold it will be killed.
		         		@short    Removes any slave that might have been put on hold.
	*/
	public static native void removeSlaveOnHold();
	/**	
		 Send the slave that was put on hold back to TDELauncher. This
		 allows another process to take over the slave and resume the job
		 that was started.
		         		@short    Send the slave that was put on hold back to TDELauncher.
	*/
	public static native void publishSlaveOnHold();
	/**	
		 Requests a slave for use in connection-oriented mode.
			@param url This defines the username,password,host & port to
		            connect with.
			@param config Configuration data for the slave.
				@return A pointer to a connected slave or 0 if an error occurred.

		@short    Requests a slave for use in connection-oriented mode.
		@see #assignJobToSlave
		@see #disconnectSlave
	*/
	// TDEIO::Slave* getConnectedSlave(const KURL& arg1,const TDEIO::MetaData& arg2); >>>> NOT CONVERTED
	public static native Slave getConnectedSlave(KURL url);
	public static native boolean assignJobToSlave(Slave slave, SimpleJob job);
	public static native boolean disconnectSlave(Slave slave);
	/**	
		 Send the slave that was put on hold back to TDELauncher. This
		 allows another process to take over the slave and resume the job
		 the that was started.
		 Register the mainwindow <code>wid</code> with the KIO subsystem
		 Do not call this, it is called automatically from
		 void TDEIO.Job.setWindow(TQWidget).
			@param wid the window to register
				@short    Send the slave that was put on hold back to TDELauncher.
	*/
	public static native void registerWindow(TQWidget wid);
	/**	
			 Unregisters the window registered by registerWindow().
		         		@short
	*/
	public static native void unregisterWindow(TQObject wid);
	/**	
		 Function to connect signals emitted by the scheduler.
				@short    Function to connect signals emitted by the scheduler.
		@see #slaveConnected
		@see #slaveError
	*/
	public static native boolean connect(String signal, TQObject receiver, String member);
	public static native boolean connect(TQObject sender, String signal, TQObject receiver, String member);
	public static native boolean disconnect(TQObject sender, String signal, TQObject receiver, String member);
	/**	
		 When true, the next job will check whether TDELauncher has a slave 
		 on hold that is suitable for the job.
			@param b true when TDELauncher has a job on hold
		         		@short    When true, the next job will check whether TDELauncher has a slave   on hold that is suitable for the job.
	*/
	public static native void checkSlaveOnHold(boolean b);
	// void setupSlave(TDEIO::Slave* arg1,const KURL& arg2,const TQString& arg3,const TQString& arg4,bool arg5,const TDEIO::MetaData* arg6); >>>> NOT CONVERTED
	protected native void setupSlave(Slave slave, KURL url, String protocol, String proxy, boolean newSlave);
	// bool startJobScheduled(TDEIO::Scheduler::ProtocolInfo* arg1); >>>> NOT CONVERTED
	protected native boolean startJobDirect();
	public Scheduler() {
		super((Class) null);
		newScheduler();
	}
	private native void newScheduler();
	protected native void startStep();
	protected native void slotCleanIdleSlaves();
	protected native void slotSlaveConnected();
	protected native void slotSlaveError(int error, String errorMsg);
	protected native void slotScheduleCoSlave();
	protected native void slotUnregisterWindow(TQObject arg1);
	/**	
		 Returns the object id of the DCOPObject.
				@return the object's id
   
		@short    Returns the object id of the DCOPObject.
	*/
	public native String objId();
	/**	
		 Renames a dcop object, if no other with the same name exists
		 Use with care, all dcop signals are disconnected
			@param objId the new object id
				@short    Renames a dcop object, if no other with the same name exists  Use with care, all dcop signals are disconnected
	*/
	public native boolean setObjId(String objId);
	/**	
		 This function is of interest when you used an IDL compiler
		 to generate the implementation for process() but
		 you still want to dispatch some functions dynamically.
		 Dynamically means that methods may appear and vanish
		 during runtime.
			@param fun is the normalized function signature.
		            Such a signature usually looks like
		            foobar(String,int). The return type,
		            qualifiers like "const" etc. are not part of
		            the signature.
			@param data the received data
			@param replyType write the reply type in this string
			@param replyData write the reply data in this array
				@return true if successful, false otherwise. The default implementation
         returns always false.

		@short    This function is of interest when you used an IDL compiler  to generate the implementation for process() but  you still want to dispatch some functions dynamically.
		@see #process
		@see DCOPClient#normalizeFunctionSignature
		@see #functions
		@see DCOPClient#process
	*/
	public native boolean processDynamic(String fun, byte[] data, StringBuffer replyType, byte[] replyData);
	/**	
		 This function is of interest when you used an IDL compiler
		 to generate the implementation for functions() but
		 you still want to list some functions dynamically.
		 Dynamically means that the methods may appear and vanish
		 during runtime.
				@return A list of the additional functions, default is an empty list.

		@short    This function is of interest when you used an IDL compiler  to generate the implementation for functions() but  you still want to list some functions dynamically.
		@see #functions
	*/
	public native ArrayList functionsDynamic();
	/**	
		 This function is of interest when you used an IDL compiler
		 to generate the implementation for interfaces() but
		 you still want to list some interfaces dynamically.
		 Dynamically means that they may appear and vanish
		 during runtime.
				@return A list of the additional interfaces, default is an empty list.

		@short    This function is of interest when you used an IDL compiler  to generate the implementation for interfaces() but  you still want to list some interfaces dynamically.
		@see #interfaces
	*/
	public native ArrayList interfacesDynamic();
	/**	
		 Returns the names of the interfaces, specific ones last. The
		 functions gets reimplemented by the IDL compiler. If you don't
		 use the IDL compiler, consider implementing this function
		 manually if you want your object to be easily explorable.
				@return a list of interfaces

		@short    Returns the names of the interfaces, specific ones last.
		@see #functions
	*/
	public native ArrayList interfaces();
	/**	
		 Emit <code>signal</code> as DCOP signal from this object with <code>data</code> as
		 arguments
			@param signal the signal to emit
			@param data the data to send
		   		@short    Emit <code>signal</code> as DCOP signal from this object with <code>data</code> as  arguments
	*/
	public native void emitDCOPSignal(String signal, byte[] data);
	/**	
		 Connects to a DCOP signal.
			@param sender the name of the client that emits the signal. When empty
		 the signal will be passed from any client.
			@param senderObj the name of the sending object that emits the signal.
			@param signal the name of the signal. The arguments should match with slot.
			@param slot The name of the slot to call. Its arguments should match with signal.
			@param Volatile If true, the connection will not be reestablished when
		 <code>sender</code> unregisters and reregisters with DCOP. In this case the <code>sender</code>
		 must be registered when the connection is made.
		 If false, the connection will be reestablished when <code>sender</code> reregisters.
		 In this case the connection can be made even if <code>sender</code> is not registered
		 at that time.
		
			<li>
			<code>Volatile</code> is true and <code>sender</code>  does not exist.
			</li>
			
			<li>
			<code>signal</code> and <code>slot</code> do not have matching arguments.
			   
			</li>		@return false if a connection could not be established.
 This will be the case when

		@short    Connects to a DCOP signal.
	*/
	public native boolean connectDCOPSignal(String sender, String senderObj, String signal, String slot, boolean Volatile);
	/**	
		 Disconnects a DCOP signal.
			 A special case is when both <code>sender</code> & <code>signal</code> are empty. In this
		 case all connections related to this object in the current client
		 are disconnected. (Both connections from as well as to this object!)
			@param sender the name of the client that emits the signal.
			@param senderObj the name of the object that emits the signal.
		 If empty all objects will be disconnected.
			@param signal the name of the signal. The arguments should match with slot.
		 If empty all objects will be disconnected.
			@param slot The name of the slot the signal is connected to.
		 If empty all slots will be disconnected.
				@return false if no connection(s) where removed.
   
		@short    Disconnects a DCOP signal.
	*/
	public native boolean disconnectDCOPSignal(String sender, String senderObj, String signal, String slot);
	/**	
		 Returns the DCOPClient responsible for making the call. 
		 Only call this function while you are handling a DCOP call.
				@return the DCOPClient responsible for making the call. 
 This information is only guaranteed to be correct when 
 entering your DCOP function.

		@short    Returns the DCOPClient responsible for making the call.
	*/
	public native DCOPClient callingDcopClient();
	/**	
				@short
	*/
	public native void setCallingDcopClient(DCOPClient arg1);
	/**	
		 Checks whether an object with the given id is known in this process.
			 DCOPObjectProxy
		   		@return true if an object with the questionable <code>objId</code> is
         known in this process. This query does not ask proxies.

		@short    Checks whether an object with the given id is known in this process.
	*/
	public static native boolean hasObject(String objId);
	/**	
		 Try to find a dcop object with the given id.
		 This function does not query the DCOPObjectProxy.
			@param objId the object id to search
				@return the  DCOPObject for the id <code>objId.</code>
   
		@short    Try to find a dcop object with the given id.
	*/
	public static native DCOPObjectInterface find(String objId);
	/**	
		 Tries to find an object using a partial object id.
		 This function is used for multicasting a DCOP message to
		 several objects inside a single process.
			@param partialId the partial object id to search for
				@return a list of DCOPObjects beginning with the string
 contained in <code>partialId.</code>
   
		@short    Tries to find an object using a partial object id.
	*/
	// TQPtrList<DCOPObject> match(const TQCString& arg1); >>>> NOT CONVERTED
	/**	
		 Creates an object id for the TQObject <code>obj.</code> This is done
		 using the TQObject.name() function.
			@param obj the object whose name will be used
				@return the created object id
   
		@short    Creates an object id for the TQObject <code>obj.</code>
	*/
	public static native String objectName(TQObject arg1);
}