- Timestamp:
- 06/30/13 12:48:20 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/hosting/InstanceClient.java
r85 r88 10 10 import com.framsticks.parsers.Savers; 11 11 import com.framsticks.core.LocalInstance; 12 import com.framsticks.util.dispatching.AbstractJoinable; 13 import com.framsticks.util.dispatching.Dispatching; 12 14 import com.framsticks.util.dispatching.Future; 15 import com.framsticks.util.dispatching.Joinable; 16 import com.framsticks.util.dispatching.JoinableParent; 17 import com.framsticks.util.dispatching.JoinableState; 13 18 14 19 import java.net.Socket; … … 21 26 * @author Piotr Sniegowski 22 27 */ 23 public class InstanceClient implements RequestHandler{28 public class InstanceClient extends AbstractJoinable implements RequestHandler, JoinableParent { 24 29 25 30 protected final LocalInstance instance; … … 29 34 this.instance = instance; 30 35 connection = new ServerConnection(socket, this); 31 connection.start();32 36 } 33 37 … … 36 40 return instance + "|" + connection.toString(); 37 41 } 38 39 42 40 43 @Override … … 94 97 95 98 } 99 100 @Override 101 protected void joinableStart() { 102 Dispatching.use(connection, this); 103 } 104 105 @Override 106 protected void joinableInterrupt() { 107 Dispatching.drop(connection, this); 108 } 109 110 @Override 111 protected void joinableFinish() { 112 } 113 114 @Override 115 protected void joinableJoin() throws InterruptedException { 116 Dispatching.join(connection); 117 } 118 119 @Override 120 public void childChangedState(Joinable joinable, JoinableState state) { 121 proceedToState(state); 122 } 123 96 124 }
Note: See TracChangeset
for help on using the changeset viewer.