2 *******************************************************************
4 * Copyright 2016 Samsung Electronics All Rights Reserved.
6 *-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
20 *-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
22 package org.iotivity.cloud.base;
24 import java.util.ArrayList;
26 import org.iotivity.cloud.base.protocols.coap.CoapRequest;
27 import org.iotivity.cloud.util.Logger;
29 import io.netty.channel.ChannelHandler.Sharable;
30 import io.netty.channel.ChannelHandlerContext;
31 import io.netty.channel.SimpleChannelInboundHandler;
34 public class ResourceManager extends SimpleChannelInboundHandler<CoapRequest> {
36 private ArrayList<Resource> resources = new ArrayList<Resource>();
37 SessionManager sessionManager = null;
39 public ResourceManager() {
43 public ResourceManager(SessionManager sessionManager) {
44 this.sessionManager = sessionManager;
48 public void channelReadComplete(ChannelHandlerContext ctx) {
53 public void channelInactive(ChannelHandlerContext ctx) throws Exception {
54 Logger.d("Channel Inactive");
55 sessionManager.removeSessionByChannel(ctx);
56 super.channelInactive(ctx);
60 public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
62 cause.printStackTrace();
67 public void channelRead0(ChannelHandlerContext ctx, CoapRequest request)
70 Resource res = queryResourceHandler(request.getUriPath());
73 res.onRequestReceived(ctx, request);
77 private Resource queryResourceHandler(String query_uri) {
81 for (Resource r : resources) {
83 String uri = r.getUri();
84 if (uri.contains(query_uri)) {
93 public void registerResource(Resource res) {
100 public void unregisterResource(Resource res) {
102 synchronized (this) {
103 resources.remove(res);