Révision 2447

tmp/org.txm.searchengine.cqp.core/src/org/txm/searchengine/cqp/MemCqiClient.java (revision 2447)
32 32 
 */
33 33 
public class MemCqiClient extends AbstractCqiClient {
34 34
35 
	MemCqiServer server;
35 
	/**
36 
	 * The server to deal with.
37 
	 */
38 
	protected MemCqiServer server;
36 39
40 
	/**
41 
	 *
42 
	 * @param server
43 
	 * @throws Exception
44 
	 */
37 45 
	public MemCqiClient(MemCqiServer server) throws Exception {
38 46 
		super();
39 47 
		this.server = server;
......
43 51 
		return true;
44 52 
	}
45 53
46 
	public void stop() {
54 
	public synchronized void stop() {
47 55 
		server.stop();
48 56 
	}
49 57
......
190 198 
	}
191 199
192 200 
	@Override
193 
	public int[] alg2Cpos(String arg0, int arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
201 
	public synchronized int[] alg2Cpos(String arg0, int arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
194 202 
		if (arg0 == null) {
195 203 
			throw new CqiServerError("alg2Cpos called with NULL parameter.");
196 204 
		}
......
202 210 
	}
203 211
204 212 
	@Override
205 
	public int attributeSize(String arg0) throws IOException, UnexpectedAnswerException, CqiServerError {
213 
	public synchronized int attributeSize(String arg0) throws IOException, UnexpectedAnswerException, CqiServerError {
206 214 
		if (arg0 == null) {
207 215 
			throw new CqiServerError("attributeSize called with NULL parameter.");
208 216 
		}
......
215 223 
	}
216 224
217 225 
	@Override
218 
	public boolean connect(String arg0, String arg1) {
226 
	public synchronized boolean connect(String arg0, String arg1) {
219 227 
		return server.isLoaded;
220 228 
	};
221 229
222 230 
	@Override
223 
	public String[] corpusAlignementAttributes(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
231 
	public synchronized String[] corpusAlignementAttributes(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
224 232 
		if (arg0 == null) {
225 233 
			throw new CqiServerError("corpusAlignementAttributes called with NULL parameter.");
226 234 
		}
......
232 240 
	}
233 241
234 242 
	@Override
235 
	public String corpusCharset(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
243 
	public synchronized String corpusCharset(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
236 244 
		if (arg0 == null) {
237 245 
			throw new CqiServerError("corpusCharset called with NULL parameter.");
238 246 
		}
......
244 252 
	}
245 253
246 254 
	@Override
247 
	public String corpusFullName(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
255 
	public synchronized String corpusFullName(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
248 256 
		if (arg0 == null) {
249 257 
			throw new CqiServerError("corpusFullName called with NULL parameter.");
250 258 
		}
......
268 276 
	}
269 277
270 278 
	@Override
271 
	public String[] corpusPositionalAttributes(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
279 
	public synchronized String[] corpusPositionalAttributes(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
272 280 
		if (arg0 == null) {
273 281 
			throw new CqiServerError("corpusPositionalAttributes called with NULL parameter.");
274 282 
		}
......
280 288 
	}
281 289
282 290 
	@Override
283 
	public String[] corpusProperties(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
291 
	public synchronized String[] corpusProperties(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
284 292 
		if (arg0 == null) {
285 293 
			throw new CqiServerError("corpusProperties called with NULL parameter.");
286 294 
		}
......
292 300 
	}
293 301
294 302 
	@Override
295 
	public boolean corpusStructuralAttributeHasValues(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
303 
	public synchronized boolean corpusStructuralAttributeHasValues(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
296 304 
		if (arg0 == null) {
297 305 
			throw new CqiServerError("corpusStructuralAttributeHasValues called with NULL parameter.");
298 306 
		}
......
304 312 
	}
305 313
306 314 
	@Override
307 
	public String[] corpusStructuralAttributes(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
315 
	public synchronized String[] corpusStructuralAttributes(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
308 316 
		if (arg0 == null) {
309 317 
			throw new CqiServerError("corpusStructuralAttributes called with NULL parameter.");
310 318 
		}
......
316 324 
	}
317 325
318 326 
	@Override
319 
	public int[] cpos2Alg(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
327 
	public synchronized int[] cpos2Alg(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
320 328 
		if (arg0 == null || arg1 == null) {
321 329 
			throw new CqiServerError("cpos2Alg called with NULL parameter.");
322 330 
		}
......
328 336 
	}
329 337
330 338 
	@Override
331 
	public int[] cpos2Id(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
339 
	public synchronized int[] cpos2Id(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
332 340 
		if (arg0 == null || arg1 == null) {
333 341 
			throw new CqiServerError("cpos2Id called with NULL parameter.");
334 342 
		}
......
340 348 
	}
341 349
342 350 
	@Override
343 
	public int[] cpos2LBound(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
351 
	public synchronized int[] cpos2LBound(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
344 352 
		if (arg0 == null || arg1 == null) {
345 353 
			throw new CqiServerError("cpos2LBound called with NULL parameter.");
346 354 
		}
......
352 360 
	}
353 361
354 362 
	@Override
355 
	public int[] cpos2RBound(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
363 
	public synchronized int[] cpos2RBound(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
356 364 
		if (arg0 == null || arg1 == null) {
357 365 
			throw new CqiServerError("cpos2RBound called with NULL parameter.");
358 366 
		}
......
364 372 
	}
365 373
366 374 
	@Override
367 
	public String[] cpos2Str(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
375 
	public synchronized String[] cpos2Str(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
368 376 
		if (arg0 == null || arg1 == null) {
369 377 
			throw new CqiServerError("cpos2Str called with NULL parameter.");
370 378 
		}
......
376 384 
	}
377 385
378 386 
	@Override
379 
	public int[] cpos2Struc(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
387 
	public synchronized int[] cpos2Struc(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
380 388 
		if (arg0 == null || arg1 == null) {
381 389 
			throw new CqiServerError("cpos2Struc called with NULL parameter.");
382 390 
		}
......
388 396 
	}
389 397
390 398 
	@Override
391 
	public void cqpQuery(String arg0, String arg1, String arg2)
399 
	public synchronized void cqpQuery(String arg0, String arg1, String arg2)
392 400 
			throws IOException, UnexpectedAnswerException, CqiServerError {
393 401 
		if (arg0 == null || arg1 == null || arg2 == null) {
394 402 
			throw new CqiServerError("cqpQuery called with NULL parameter.");
......
403 411 
	}
404 412
405 413 
	@Override
406 
	public void query(String arg0)
414 
	public synchronized void query(String arg0)
407 415 
			throws IOException, UnexpectedAnswerException, CqiServerError {
408 416 
		if (arg0 == null) {
409 417 
			throw new CqiServerError("query called with NULL parameter.");
......
430 438 
	}
431 439
432 440 
	@Override
433 
	public void dropCorpus(String arg0) throws Exception {
441 
	public synchronized void dropCorpus(String arg0) throws Exception {
434 442 
		Log.finest(NLS.bind("Droping corpus {0}...", arg0)); //$NON-NLS-1$
435 443 
		if (arg0 == null) {
436 444 
			throw new Exception("dropCorpus called with NULL parameter.");
......
442 450 
	}
443 451
444 452 
	@Override
445 
	public void dropSubCorpus(String arg0) throws IOException, UnexpectedAnswerException, CqiServerError {
453 
	public synchronized void dropSubCorpus(String arg0) throws IOException, UnexpectedAnswerException, CqiServerError {
446 454 
		Log.finest(NLS.bind("Droping subcorpus {0}...", arg0)); //$NON-NLS-1$
447 455 
		if (arg0 == null) {
448 456 
			throw new CqiServerError("dropSubCorpus called with NULL parameter.");
......
454 462 
	}
455 463
456 464 
	@Override
457 
	public int[] dumpSubCorpus(String arg0, byte arg1, int arg2, int arg3)
465 
	public synchronized int[] dumpSubCorpus(String arg0, byte arg1, int arg2, int arg3)
458 466 
			throws IOException, UnexpectedAnswerException, CqiServerError {
459 467 
		if (arg0 == null) {
460 468 
			throw new CqiServerError("dumpSubCorpus called with NULL parameter.");
......
484 492
485 493 
	}
486 494
487 
	public int[] nfdist1(String arg0, int arg1, byte arg2, String arg3)
495 
	public synchronized int[] nfdist1(String arg0, int arg1, byte arg2, String arg3)
488 496 
			throws IOException, UnexpectedAnswerException, CqiServerError {
489 497 
		if (arg0 == null || arg3 == null) {
490 498 
			throw new CqiServerError("nfdist1 called with NULL parameter.");
......
517 525 
		return freqs;
518 526 
	}
519 527
520 
	public int[] nfdist2(String arg0, int arg1, byte arg2, String arg3,
528 
	public synchronized int[] nfdist2(String arg0, int arg1, byte arg2, String arg3,
521 529 
			byte arg4, String arg5) throws IOException, UnexpectedAnswerException, CqiServerError {
522 530 
		if (arg0 == null || arg3 == null || arg5 == null) {
523 531 
			throw new CqiServerError("nfdist2 called with NULL parameter.");
......
530 538 
	}
531 539
532 540 
	@Override
533 
	public String getLastCQPError() throws UnexpectedAnswerException, IOException, CqiServerError {
541 
	public synchronized String getLastCQPError() throws UnexpectedAnswerException, IOException, CqiServerError {
534 542 
		String rez = server.getLastCQPError();
535 543 
		if (rez == null) {
536 544 
			throwExceptionFromCqi(server.getErrorCode());
......
548 556 
	}
549 557
550 558 
	@Override
551 
	public int[] id2Cpos(String arg0, int arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
559 
	public synchronized int[] id2Cpos(String arg0, int arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
552 560 
		if (arg0 == null) {
553 561 
			throw new CqiServerError("id2Cpos called with NULL parameter.");
554 562 
		}
......
560 568 
	}
561 569
562 570 
	@Override
563 
	public int[] id2Freq(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
571 
	public synchronized int[] id2Freq(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
564 572 
		if (arg0 == null || arg1 == null) {
565 573 
			throw new CqiServerError("id2Freq called with NULL parameter.");
566 574 
		}
......
572 580 
	}
573 581
574 582 
	@Override
575 
	public String[] id2Str(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
583 
	public synchronized String[] id2Str(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
576 584 
		if (arg0 == null || arg1 == null) {
577 585 
			throw new CqiServerError("id2Str called with NULL parameter.");
578 586 
		}
......
584 592 
	}
585 593
586 594 
	@Override
587 
	public int[] idList2Cpos(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
595 
	public synchronized int[] idList2Cpos(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
588 596 
		if (arg0 == null || arg1 == null) {
589 597 
			throw new CqiServerError("idList2Cpos called with NULL parameter.");
590 598 
		}
......
596 604 
	}
597 605
598 606 
	@Override
599 
	public int lexiconSize(String arg0) throws IOException, UnexpectedAnswerException, CqiServerError {
607 
	public synchronized int lexiconSize(String arg0) throws IOException, UnexpectedAnswerException, CqiServerError {
600 608 
		if (arg0 == null) {
601 609 
			throw new CqiServerError("lexiconSize called with NULL parameter.");
602 610 
		}
......
608 616 
	}
609 617
610 618 
	@Override
611 
	public String[] listCorpora() throws UnexpectedAnswerException, IOException, CqiServerError {
619 
	public synchronized String[] listCorpora() throws UnexpectedAnswerException, IOException, CqiServerError {
612 620 
		String[] rez = server.listCorpora();
613 621 
		if (rez == null) {
614 622 
			throwExceptionFromCqi(server.getErrorCode());
......
617 625 
	}
618 626
619 627 
	@Override
620 
	public String[] listSubcorpora(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
628 
	public synchronized String[] listSubcorpora(String arg0) throws UnexpectedAnswerException, IOException, CqiServerError {
621 629 
		if (arg0 == null) {
622 630 
			throw new CqiServerError("listSubcorpora called with NULL parameter.");
623 631 
		}
......
634 642 
	};
635 643
636 644 
	@Override
637 
	public int[] regex2Id(String arg0, String arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
645 
	public synchronized int[] regex2Id(String arg0, String arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
638 646 
		if (arg0 == null || arg1 == null) {
639 647 
			throw new CqiServerError("regex2Id called with NULL parameter.");
640 648 
		}
......
646 654 
	}
647 655
648 656 
	@Override
649 
	public int[] str2Id(String arg0, String[] arg1) throws IOException, UnexpectedAnswerException, CqiServerError {
657 
	public synchronized int[] str2Id(String arg0, String[] arg1) throws IOException, UnexpectedAnswerException, CqiServerError {
650 658 
		if (arg0 == null || arg1 == null) {
651 659 
			throw new CqiServerError("str2Id called with NULL parameter.");
652 660 
		}
......
659 667 
	}
660 668
661 669 
	@Override
662 
	public int[] struc2Cpos(String arg0, int arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
670 
	public synchronized int[] struc2Cpos(String arg0, int arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
663 671 
		if (arg0 == null) {
664 672 
			throw new CqiServerError("struc2Cpos called with NULL parameter.");
665 673 
		}
......
671 679 
	}
672 680
673 681 
	@Override
674 
	public String[] struc2Str(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
682 
	public synchronized String[] struc2Str(String arg0, int[] arg1) throws UnexpectedAnswerException, IOException, CqiServerError {
675 683 
		if (arg0 == null || arg1 == null) {
676 684 
			throw new CqiServerError("struc2Str called with NULL parameter.");
677 685 
		}
......
683 691 
	}
684 692
685 693 
	@Override
686 
	public boolean subCorpusHasField(String arg0, byte arg1) throws IOException, UnexpectedAnswerException, CqiServerError {
694 
	public synchronized boolean subCorpusHasField(String arg0, byte arg1) throws IOException, UnexpectedAnswerException, CqiServerError {
687 695 
		Boolean rez = server.subCorpusHasField(arg0, arg1);
688 696 
		if (rez == null || !rez) {
689 697 
			throwExceptionFromCqi(server.getErrorCode());
......
692 700 
	}
693 701
694 702 
	@Override
695 
	public int subCorpusSize(String arg0) throws IOException, UnexpectedAnswerException, CqiServerError {
703 
	public synchronized int subCorpusSize(String arg0) throws IOException, UnexpectedAnswerException, CqiServerError {
696 704 
		if (arg0 == null) {
697 705 
			throw new CqiServerError("subCorpusSize called with NULL parameter.");
698 706 
		}
......
704 712 
	}
705 713
706 714 
	@Override
707 
	public boolean load_a_system_corpus(String regfilepath, String entry) throws IOException, UnexpectedAnswerException, CqiServerError {
715 
	public synchronized boolean load_a_system_corpus(String regfilepath, String entry) throws IOException, UnexpectedAnswerException, CqiServerError {
708 716 
		if (regfilepath == null) {
709 717 
			throw new CqiServerError("load_a_system_corpus called with NULL regfilepath parameter.");
710 718 
		}

Formats disponibles : Unified diff