Changeset 90 for java/main/src/main/java/com/framsticks/communication
- Timestamp:
- 07/02/13 16:20:07 (11 years ago)
- Location:
- java/main/src/main/java/com/framsticks/communication
- Files:
-
- 4 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/communication/ClientConnection.java
r88 r90 45 45 protected void joinableStart() { 46 46 try { 47 log. info("connecting to " + address);47 log.debug("connecting to " + address); 48 48 49 49 socket = new Socket(hostName, port); … … 51 51 socket.setSoTimeout(500); 52 52 53 log. info("connected to " + hostName + ":" + port);53 log.debug("connected to " + hostName + ":" + port); 54 54 connected = true; 55 55 runThreads(); … … 145 145 146 146 public void dispatchResponseProcess(final Response response) { 147 Dispatching. invokeLaterOrNow(dispatcher, new RunAt<C>() {147 Dispatching.dispatchIfNotActive(dispatcher, new RunAt<C>() { 148 148 @Override 149 149 public void run() { … … 193 193 sentQuery.dispatcher = dispatcher; 194 194 195 senderThread. invokeLater(new RunAt<Connection>(){195 senderThread.dispatch(new RunAt<Connection>(){ 196 196 @Override 197 197 public void run() { -
java/main/src/main/java/com/framsticks/communication/Connection.java
r88 r90 135 135 Dispatching.use(threads, this); 136 136 137 receiverThread. invokeLater(new RunAt<Connection>() {137 receiverThread.dispatch(new RunAt<Connection>() { 138 138 @Override 139 139 public void run() { -
java/main/src/main/java/com/framsticks/communication/ServerConnection.java
r88 r90 66 66 67 67 protected final void respond(final Response response, final Integer id) { 68 senderThread. invokeLater(new RunAt<Connection>() {68 senderThread.dispatch(new RunAt<Connection>() { 69 69 @Override 70 70 public void run() { -
java/main/src/main/java/com/framsticks/communication/Subscription.java
r85 r90 75 75 76 76 public void dispatchCall(final List<File> files) { 77 Dispatching. invokeLaterOrNow(dispatcher, new RunAt<C>() {77 Dispatching.dispatchIfNotActive(dispatcher, new RunAt<C>() { 78 78 @Override 79 79 public void run() {
Note: See TracChangeset
for help on using the changeset viewer.