renamed dev loader folder
This commit is contained in:
@@ -5,6 +5,8 @@ import io.netty.channel.nio.NioEventLoopGroup
|
|||||||
import io.netty.channel.socket.nio.NioSocketChannel
|
import io.netty.channel.socket.nio.NioSocketChannel
|
||||||
import io.netty.handler.codec.http.HttpRequest
|
import io.netty.handler.codec.http.HttpRequest
|
||||||
import io.netty.util.AttributeKey
|
import io.netty.util.AttributeKey
|
||||||
|
import objects.Environment
|
||||||
|
import java.net.ConnectException
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Created by user on 7/8/16.
|
* Created by user on 7/8/16.
|
||||||
@@ -14,8 +16,8 @@ object Client {
|
|||||||
val bootstrap: Bootstrap = makeBootstrap()
|
val bootstrap: Bootstrap = makeBootstrap()
|
||||||
|
|
||||||
private fun makeBootstrap(): Bootstrap {
|
private fun makeBootstrap(): Bootstrap {
|
||||||
val group = NioEventLoopGroup();
|
val group = NioEventLoopGroup()
|
||||||
val b = Bootstrap();
|
val b = Bootstrap()
|
||||||
b.group(group).channel(NioSocketChannel().javaClass).handler(ClientInitializer())
|
b.group(group).channel(NioSocketChannel().javaClass).handler(ClientInitializer())
|
||||||
.attr(AttributeKey.newInstance<String>("url"), "")
|
.attr(AttributeKey.newInstance<String>("url"), "")
|
||||||
.attr(AttributeKey.newInstance<Int>("uid"), 0)
|
.attr(AttributeKey.newInstance<Int>("uid"), 0)
|
||||||
@@ -31,6 +33,11 @@ object Client {
|
|||||||
ch.closeFuture().sync()//wait for answer
|
ch.closeFuture().sync()//wait for answer
|
||||||
} catch (e: InterruptedException) {
|
} catch (e: InterruptedException) {
|
||||||
|
|
||||||
|
} catch (e: ConnectException) {
|
||||||
|
val carMap = Environment.instance.map
|
||||||
|
synchronized(carMap, {
|
||||||
|
carMap.remove(carUid)
|
||||||
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -40,6 +40,7 @@ class Handler : SimpleChannelInboundHandler<Any>() {
|
|||||||
val uid = environment.connectCar(data.ip, data.port)
|
val uid = environment.connectCar(data.ip, data.port)
|
||||||
answer = ConnectP.ConnectionResponse.newBuilder().setUid(uid).build().toByteArray()
|
answer = ConnectP.ConnectionResponse.newBuilder().setUid(uid).build().toByteArray()
|
||||||
}
|
}
|
||||||
|
//todo return connection error
|
||||||
}
|
}
|
||||||
routeDoneUrl -> {
|
routeDoneUrl -> {
|
||||||
var data: RouteDone? = null
|
var data: RouteDone? = null
|
||||||
@@ -58,6 +59,7 @@ class Handler : SimpleChannelInboundHandler<Any>() {
|
|||||||
success = false
|
success = false
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
//todo return connection error
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else -> {
|
else -> {
|
||||||
|
|||||||
@@ -22,7 +22,6 @@ class Initializer : ChannelInitializer<SocketChannel> {
|
|||||||
|
|
||||||
override fun initChannel(channel: SocketChannel) {
|
override fun initChannel(channel: SocketChannel) {
|
||||||
val p: ChannelPipeline = channel.pipeline()
|
val p: ChannelPipeline = channel.pipeline()
|
||||||
|
|
||||||
p.addLast(HttpServerCodec())
|
p.addLast(HttpServerCodec())
|
||||||
p.addLast(group, Handler())
|
p.addLast(group, Handler())
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user