blob: 34368bef2f022de6fcefcbe40d7459b340f5c75f [file] [log] [blame]
sangho80f11cb2015-04-01 13:05:26 -07001/*
Brian O'Connor43b53542016-04-09 01:19:45 -07002 * Copyright 2015-present Open Networking Laboratory
sangho80f11cb2015-04-01 13:05:26 -07003 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16package org.onosproject.segmentrouting;
17
18import org.onlab.packet.Ethernet;
19import org.onlab.packet.IPv4;
20import org.onlab.packet.Ip4Address;
21import org.onosproject.net.ConnectPoint;
22import org.onosproject.net.DeviceId;
23import org.onosproject.net.Host;
24import org.onosproject.net.flow.DefaultTrafficTreatment;
25import org.onosproject.net.flow.TrafficTreatment;
26import org.onosproject.net.packet.DefaultOutboundPacket;
27import org.onosproject.net.packet.InboundPacket;
28import org.onosproject.net.packet.OutboundPacket;
Charles Chan319d1a22015-11-03 10:42:14 -080029import org.onosproject.segmentrouting.config.DeviceConfigNotFoundException;
30import org.onosproject.segmentrouting.config.DeviceConfiguration;
sangho80f11cb2015-04-01 13:05:26 -070031import org.slf4j.Logger;
32import org.slf4j.LoggerFactory;
33
34import java.nio.ByteBuffer;
35import java.util.concurrent.ConcurrentHashMap;
36import java.util.concurrent.ConcurrentLinkedQueue;
37
38import static com.google.common.base.Preconditions.checkNotNull;
39
Charles Chanb7f75ac2016-01-11 18:28:54 -080040/**
41 * Handler of IP packets that forwards IP packets that are sent to the controller,
42 * except the ICMP packets which are processed by @link{IcmpHandler}.
43 */
sangho80f11cb2015-04-01 13:05:26 -070044public class IpHandler {
45
46 private static Logger log = LoggerFactory.getLogger(IpHandler.class);
47 private SegmentRoutingManager srManager;
sangho9b169e32015-04-14 16:27:13 -070048 private DeviceConfiguration config;
sangho80f11cb2015-04-01 13:05:26 -070049 private ConcurrentHashMap<Ip4Address, ConcurrentLinkedQueue<IPv4>> ipPacketQueue;
50
51 /**
52 * Creates an IpHandler object.
53 *
54 * @param srManager SegmentRoutingManager object
55 */
56 public IpHandler(SegmentRoutingManager srManager) {
57 this.srManager = srManager;
sangho9b169e32015-04-14 16:27:13 -070058 this.config = checkNotNull(srManager.deviceConfiguration);
Sho SHIMIZU47b8aa22015-09-11 11:19:11 -070059 ipPacketQueue = new ConcurrentHashMap<>();
sangho80f11cb2015-04-01 13:05:26 -070060 }
61
62 /**
63 * Processes incoming IP packets.
64 *
65 * If it is an IP packet for known host, then forward it to the host.
66 * If it is an IP packet for unknown host in subnet, then send an ARP request
67 * to the subnet.
68 *
69 * @param pkt incoming packet
70 */
71 public void processPacketIn(InboundPacket pkt) {
72 Ethernet ethernet = pkt.parsed();
73 IPv4 ipv4 = (IPv4) ethernet.getPayload();
74
75 ConnectPoint connectPoint = pkt.receivedFrom();
76 DeviceId deviceId = connectPoint.deviceId();
77 Ip4Address destinationAddress =
78 Ip4Address.valueOf(ipv4.getDestinationAddress());
79
80 // IP packet for know hosts
81 if (!srManager.hostService.getHostsByIp(destinationAddress).isEmpty()) {
82 forwardPackets(deviceId, destinationAddress);
83
84 // IP packet for unknown host in the subnet of the router
85 } else if (config.inSameSubnet(deviceId, destinationAddress)) {
86 srManager.arpHandler.sendArpRequest(deviceId, destinationAddress, connectPoint);
87
88 // IP packets for unknown host
89 } else {
90 log.debug("ICMP request for unknown host {} which is not in the subnet",
91 destinationAddress);
92 // Do nothing
93 }
94 }
95
96 /**
97 * Adds the IP packet to a buffer.
98 * The packets are forwarded to corresponding destination when the destination
99 * MAC address is known via ARP response.
100 *
101 * @param ipPacket IP packet to add to the buffer
102 */
103 public void addToPacketBuffer(IPv4 ipPacket) {
104
Saurav Das2d94d312015-11-24 23:21:05 -0800105 // Better not buffer TCP packets due to out-of-order packet transfer
sangho80f11cb2015-04-01 13:05:26 -0700106 if (ipPacket.getProtocol() == IPv4.PROTOCOL_TCP) {
107 return;
108 }
109
110 Ip4Address destIpAddress = Ip4Address.valueOf(ipPacket.getDestinationAddress());
111
112 if (ipPacketQueue.get(destIpAddress) == null) {
Sho SHIMIZU47b8aa22015-09-11 11:19:11 -0700113 ConcurrentLinkedQueue<IPv4> queue = new ConcurrentLinkedQueue<>();
sangho80f11cb2015-04-01 13:05:26 -0700114 queue.add(ipPacket);
115 ipPacketQueue.put(destIpAddress, queue);
116 } else {
117 ipPacketQueue.get(destIpAddress).add(ipPacket);
118 }
119 }
120
121 /**
122 * Forwards IP packets in the buffer to the destination IP address.
123 * It is called when the controller finds the destination MAC address
Saurav Das88979182015-10-19 14:37:36 -0700124 * via ARP responses.
sangho80f11cb2015-04-01 13:05:26 -0700125 *
126 * @param deviceId switch device ID
127 * @param destIpAddress destination IP address
128 */
129 public void forwardPackets(DeviceId deviceId, Ip4Address destIpAddress) {
Srikanth Vavilapallic56a2f32015-06-05 11:40:14 -0700130 if (ipPacketQueue.get(destIpAddress) == null) {
131 return;
132 }
133
sangho80f11cb2015-04-01 13:05:26 -0700134 for (IPv4 ipPacket : ipPacketQueue.get(destIpAddress)) {
135 Ip4Address destAddress = Ip4Address.valueOf(ipPacket.getDestinationAddress());
Charles Chan319d1a22015-11-03 10:42:14 -0800136 if (config.inSameSubnet(deviceId, destAddress)) {
sangho80f11cb2015-04-01 13:05:26 -0700137 ipPacket.setTtl((byte) (ipPacket.getTtl() - 1));
138 ipPacket.setChecksum((short) 0);
139 for (Host dest: srManager.hostService.getHostsByIp(destIpAddress)) {
140 Ethernet eth = new Ethernet();
141 eth.setDestinationMACAddress(dest.mac());
Charles Chan319d1a22015-11-03 10:42:14 -0800142 try {
143 eth.setSourceMACAddress(config.getDeviceMac(deviceId));
144 } catch (DeviceConfigNotFoundException e) {
145 log.warn(e.getMessage()
146 + " Skipping forwardPackets for this destination.");
147 continue;
148 }
sangho80f11cb2015-04-01 13:05:26 -0700149 eth.setEtherType(Ethernet.TYPE_IPV4);
150 eth.setPayload(ipPacket);
151
152 TrafficTreatment treatment = DefaultTrafficTreatment.builder().
153 setOutput(dest.location().port()).build();
154 OutboundPacket packet = new DefaultOutboundPacket(deviceId,
155 treatment, ByteBuffer.wrap(eth.serialize()));
156 srManager.packetService.emit(packet);
sanghofb7c7292015-04-13 15:15:58 -0700157 ipPacketQueue.get(destIpAddress).remove(ipPacket);
sangho80f11cb2015-04-01 13:05:26 -0700158 }
sangho9b169e32015-04-14 16:27:13 -0700159 ipPacketQueue.get(destIpAddress).remove(ipPacket);
sangho80f11cb2015-04-01 13:05:26 -0700160 }
161 }
162 }
sangho9b169e32015-04-14 16:27:13 -0700163
sangho80f11cb2015-04-01 13:05:26 -0700164}