Attachment #124694 for bug #217734

This Bugzilla instance is a read-only archive of historic NetBeans bug reports. To report a bug in NetBeans please follow the project's instructions for reporting issues.

View | Details | Raw Unified | Return to bug 217734
Collapse All | Expand All




     * @param skip   Skip to the end of the log file.
     */
    @SuppressWarnings("LeakingThisInConstructor")
    FetchLogPiped(final GlassFishServer server, boolean skip) {
        super(server, skip);
        try {
            out = new PipedOutputStream((PipedInputStream)this.in);

                    FetchLogException.OUTPUT_STREAM_EXCEPTION, ioe);
        }
        taksExecute = true;
        executor = new ThreadPoolExecutor(1, 1,
                0L, TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<Runnable>(), new ThreadFactory() {

            @Override
            public Thread newThread(Runnable r) {
                Thread t = new Thread(FetchLogPiped.class.getName() + server.getUrl());
                t.setDaemon(true);
                return t;
            }
        });
        task = executor.submit(this);
    }


Return to bug 217734

Lines 107-113 Link Here

(-)a/sdk/src/main/java/org/glassfish/tools/ide/server/FetchLogPiped.java (-2 / +12 lines)
107	* @param skip Skip to the end of the log file.	107	* @param skip Skip to the end of the log file.
108	*/	108	*/
109	@SuppressWarnings("LeakingThisInConstructor")	109	@SuppressWarnings("LeakingThisInConstructor")
110	FetchLogPiped(GlassFishServer server, boolean skip) {	110	FetchLogPiped(final GlassFishServer server, boolean skip) {
111	super(server, skip);	111	super(server, skip);
112	try {	112	try {
113	out = new PipedOutputStream((PipedInputStream)this.in);	113	out = new PipedOutputStream((PipedInputStream)this.in);
Lines 117-123 Link Here
117	FetchLogException.OUTPUT_STREAM_EXCEPTION, ioe);	117	FetchLogException.OUTPUT_STREAM_EXCEPTION, ioe);
118	}	118	}
119	taksExecute = true;	119	taksExecute = true;
120	executor = Executors.newFixedThreadPool(1);	120	executor = new ThreadPoolExecutor(1, 1,
		121	0L, TimeUnit.MILLISECONDS,
		122	new LinkedBlockingQueue<Runnable>(), new ThreadFactory() {
		123
		124	@Override
		125	public Thread newThread(Runnable r) {
		126	Thread t = new Thread(FetchLogPiped.class.getName() + server.getUrl());
		127	t.setDaemon(true);
		128	return t;
		129	}
		130	});
121	task = executor.submit(this);	131	task = executor.submit(this);
122	}	132	}
123		133