-
Notifications
You must be signed in to change notification settings - Fork 378
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Implementation of transport using plain sockets.
- Loading branch information
Showing
3 changed files
with
204 additions
and
16 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
148 changes: 148 additions & 0 deletions
148
org.jboss.tools.vscode.ipc/src/org/jboss/tools/langs/transport/SocketConnection.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,148 @@ | ||
| /******************************************************************************* | ||
| * Copyright (c) 2016 Red Hat Inc. and others. | ||
| * All rights reserved. This program and the accompanying materials | ||
| * are made available under the terms of the Eclipse Public License v1.0 | ||
| * which accompanies this distribution, and is available at | ||
| * http://www.eclipse.org/legal/epl-v10.html | ||
| * | ||
| * Contributors: | ||
| * Red Hat Inc. - initial API and implementation | ||
| *******************************************************************************/ | ||
| package org.jboss.tools.langs.transport; | ||
|
|
||
| import java.io.IOException; | ||
| import java.io.InputStream; | ||
| import java.io.OutputStream; | ||
| import java.net.ServerSocket; | ||
| import java.net.Socket; | ||
| import java.nio.charset.Charset; | ||
|
|
||
| import org.jboss.tools.vscode.internal.ipc.IPCPlugin; | ||
|
|
||
| public class SocketConnection extends AbstractConnection { | ||
|
|
||
|
|
||
| private class ReaderThread extends Thread{ | ||
|
|
||
| private InputStream stream; | ||
|
|
||
| public ReaderThread() { | ||
| super("LSP_ReaderThread"); | ||
| } | ||
|
|
||
| @Override | ||
| public void run() { | ||
| try { | ||
| stream = connectReadChannel(); | ||
| startWriterThread(); | ||
| } catch (IOException e1) { | ||
| //TODO: write failed to connect. | ||
| } | ||
|
|
||
| while(true){ | ||
| TransportMessage message; | ||
| try { | ||
| message = TransportMessage.fromStream(stream, DEFAULT_CHARSET); | ||
| if(message == null ){ | ||
| //Stream disconnected exit reader thread | ||
| IPCPlugin.logError("Empty message read"); | ||
| break; | ||
| } | ||
| inboundQueue.add(message); | ||
| } catch (IOException e) { | ||
| //continue | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private class WriterThread extends Thread{ | ||
|
|
||
| private OutputStream stream; | ||
|
|
||
| public WriterThread() { | ||
| super("LSP_WriterThread"); | ||
| } | ||
|
|
||
| @Override | ||
| public void run() { | ||
| try { | ||
| stream = connectWriteChannel(); | ||
| } catch (IOException e1) { | ||
| // TODO Auto-generated catch block | ||
| e1.printStackTrace(); | ||
| } | ||
| while (true) { | ||
| try { | ||
| TransportMessage message = outboundQueue.take(); | ||
| message.send(stream, DEFAULT_CHARSET); | ||
| stream.flush(); | ||
| } catch (InterruptedException e) { | ||
| break;//exit | ||
| } catch (IOException e) { | ||
| // TODO Auto-generated catch block | ||
| e.printStackTrace(); | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private static final Charset DEFAULT_CHARSET = Charset.forName("UTF-8"); | ||
|
|
||
| private final String readHost; | ||
| private final String writeHost; | ||
| private final int readPort; | ||
| private final int writePort; | ||
|
|
||
| private Socket writeSocket; | ||
| private Socket readSocket; | ||
|
|
||
| private ServerSocket server; | ||
|
|
||
| public SocketConnection(String readHost, int readPort , String writeHost, int writePort) { | ||
| this.readHost = readHost; | ||
| this.readPort = readPort; | ||
| this.writeHost = writeHost; | ||
| this.writePort = writePort; | ||
| } | ||
|
|
||
| @Override | ||
| public void start() throws IOException { | ||
| ReaderThread readerThread = new ReaderThread(); | ||
| readerThread.setDaemon(true); | ||
| readerThread.start(); | ||
| } | ||
|
|
||
| public void startWriterThread() throws IOException{ | ||
|
|
||
| WriterThread writerThread = new WriterThread(); | ||
| writerThread.setDaemon(true); | ||
| writerThread.start(); | ||
| } | ||
|
|
||
| @Override | ||
| public void close() { | ||
| try { | ||
| if(readSocket != null) | ||
| readSocket.close(); | ||
| if(writeSocket != null ) | ||
| writeSocket.close(); | ||
| if(server != null) | ||
| server.close(); | ||
| } catch (IOException e) { | ||
| // TODO: handle exception | ||
| } | ||
| } | ||
|
|
||
| private InputStream connectReadChannel() throws IOException{ | ||
| readSocket = new Socket(readHost,readPort); | ||
| return readSocket.getInputStream(); | ||
| } | ||
|
|
||
| private OutputStream connectWriteChannel() throws IOException{ | ||
| writeSocket = new Socket(writeHost, writePort); | ||
| return writeSocket.getOutputStream(); | ||
|
|
||
| } | ||
|
|
||
| } |