}

}

ofpbuf *

ofpbuf *

{

{

  NS_LOG_INFO ("Creating Openflow buffer from packet.");

  NS_LOG_INFO ("Creating Openflow buffer from packet.");

  /*

  /*

   * Allocate buffer with some headroom to add headers in forwarding

   * Allocate buffer with some headroom to add headers in forwarding

   * to the controller or adding a vlan tag, plus an extra 2 bytes to

   * to the controller or adding a vlan tag, plus an extra 2 bytes to

  ofpbuf *buffer = ofpbuf_new (headroom + hard_header + mtu);

  ofpbuf *buffer = ofpbuf_new (headroom + hard_header + mtu);

  buffer->data = (char*)buffer->data + headroom + hard_header;

  buffer->data = (char*)buffer->data + headroom + hard_header;

  // We have to wrap this because PeekHeader has an assert fail if we check for an Ipv4Header that isn't there.

  // We have to wrap this because PeekHeader has an assert fail if we check for an Ipv4Header that isn't there.

  if (protocol == Ipv4L3Protocol::PROT_NUMBER)

  if (protocol == Ipv4L3Protocol::PROT_NUMBER)

          ip_h->ip_dst      = htonl (ip_hd.GetDestination ().Get ()); // Destination Address

          ip_h->ip_dst      = htonl (ip_hd.GetDestination ().Get ()); // Destination Address

          ip_h->ip_csum     = csum (&ip_h, sizeof ip_h);        // Header Checksum

          ip_h->ip_csum     = csum (&ip_h, sizeof ip_h);        // Header Checksum

          NS_LOG_INFO ("Parsed Ipv4Header");

          NS_LOG_INFO ("Parsed Ipv4Header");

          l3_length = IP_HEADER_LEN;

          l3_length = IP_HEADER_LEN;

        }

        }

          arp_h->ar_hln = sizeof arp_h->ar_tha;                         // Hardware address length.

          arp_h->ar_hln = sizeof arp_h->ar_tha;                         // Hardware address length.

          arp_h->ar_pln = sizeof arp_h->ar_tpa;                         // Protocol address length.

          arp_h->ar_pln = sizeof arp_h->ar_tpa;                         // Protocol address length.

          NS_LOG_INFO ("Parsed ArpHeader");

          NS_LOG_INFO ("Parsed ArpHeader");

          l3_length = ARP_ETH_HEADER_LEN;

          l3_length = ARP_ETH_HEADER_LEN;

        }

        }

              tcp_h->tcp_urg = tcp_hd.GetUrgentPointer ();      // Urgent Pointer

              tcp_h->tcp_urg = tcp_hd.GetUrgentPointer ();      // Urgent Pointer

              tcp_h->tcp_csum = csum (&tcp_h, sizeof tcp_h);    // Header Checksum

              tcp_h->tcp_csum = csum (&tcp_h, sizeof tcp_h);    // Header Checksum

              NS_LOG_INFO ("Parsed TcpHeader");

              NS_LOG_INFO ("Parsed TcpHeader");

              l4_length = TCP_HEADER_LEN;

              l4_length = TCP_HEADER_LEN;

            }

            }

              udp_csum = csum_continue (udp_csum, udp_h, sizeof udp_h);

              udp_csum = csum_continue (udp_csum, udp_h, sizeof udp_h);

              udp_h->udp_csum = csum_finish (csum_continue (udp_csum, buffer->data, buffer->size)); // Header Checksum

              udp_h->udp_csum = csum_finish (csum_continue (udp_csum, buffer->data, buffer->size)); // Header Checksum

              NS_LOG_INFO ("Parsed UdpHeader");

              NS_LOG_INFO ("Parsed UdpHeader");

              l4_length = UDP_HEADER_LEN;

              l4_length = UDP_HEADER_LEN;

            }

            }

        }

        }

    }

    }

  packet->CopyData ((uint8_t*)buffer->data, packet->GetSize ());

  packet->CopyData ((uint8_t*)buffer->data, packet->GetSize ());

  if (buffer->l4)

  if (buffer->l4)

      ofpbuf_push (buffer, buffer->l3, l3_length);

      ofpbuf_push (buffer, buffer->l3, l3_length);

      delete (ip_header*)buffer->l3;

      delete (ip_header*)buffer->l3;

    }

    }

  return buffer;

  return buffer;

}

}

   * \param protocol The protocol defining the packet.

   * \param protocol The protocol defining the packet.

   * \return The OpenFlow Buffer created from the packet.

   * \return The OpenFlow Buffer created from the packet.

   */

   */

private:

private:

  /**

  /**