udp_stream.h revision aa97dd1c
1aa97dd1cSKonstantin Ananyev/*
2aa97dd1cSKonstantin Ananyev * Copyright (c) 2016  Intel Corporation.
3aa97dd1cSKonstantin Ananyev * Licensed under the Apache License, Version 2.0 (the "License");
4aa97dd1cSKonstantin Ananyev * you may not use this file except in compliance with the License.
5aa97dd1cSKonstantin Ananyev * You may obtain a copy of the License at:
6aa97dd1cSKonstantin Ananyev *
7aa97dd1cSKonstantin Ananyev *     http://www.apache.org/licenses/LICENSE-2.0
8aa97dd1cSKonstantin Ananyev *
9aa97dd1cSKonstantin Ananyev * Unless required by applicable law or agreed to in writing, software
10aa97dd1cSKonstantin Ananyev * distributed under the License is distributed on an "AS IS" BASIS,
11aa97dd1cSKonstantin Ananyev * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12aa97dd1cSKonstantin Ananyev * See the License for the specific language governing permissions and
13aa97dd1cSKonstantin Ananyev * limitations under the License.
14aa97dd1cSKonstantin Ananyev */
15aa97dd1cSKonstantin Ananyev
16aa97dd1cSKonstantin Ananyev#ifndef _UDP_STREAM_H_
17aa97dd1cSKonstantin Ananyev#define _UDP_STREAM_H_
18aa97dd1cSKonstantin Ananyev
19aa97dd1cSKonstantin Ananyev#include <rte_vect.h>
20aa97dd1cSKonstantin Ananyev#include <tle_dring.h>
21aa97dd1cSKonstantin Ananyev#include <tle_udp.h>
22aa97dd1cSKonstantin Ananyev#include <tle_event.h>
23aa97dd1cSKonstantin Ananyev
24aa97dd1cSKonstantin Ananyev#include "osdep.h"
25aa97dd1cSKonstantin Ananyev#include "ctx.h"
26aa97dd1cSKonstantin Ananyev#include "stream.h"
27aa97dd1cSKonstantin Ananyev
28aa97dd1cSKonstantin Ananyev#ifdef __cplusplus
29aa97dd1cSKonstantin Ananyevextern "C" {
30aa97dd1cSKonstantin Ananyev#endif
31aa97dd1cSKonstantin Ananyev
32aa97dd1cSKonstantin Ananyevunion udph {
33aa97dd1cSKonstantin Ananyev	uint64_t raw;
34aa97dd1cSKonstantin Ananyev	struct {
35aa97dd1cSKonstantin Ananyev		union l4_ports ports;
36aa97dd1cSKonstantin Ananyev		uint16_t len;
37aa97dd1cSKonstantin Ananyev		uint16_t cksum;
38aa97dd1cSKonstantin Ananyev	};
39aa97dd1cSKonstantin Ananyev};
40aa97dd1cSKonstantin Ananyev
41aa97dd1cSKonstantin Ananyevstruct tle_udp_stream {
42aa97dd1cSKonstantin Ananyev
43aa97dd1cSKonstantin Ananyev	struct tle_stream s;
44aa97dd1cSKonstantin Ananyev
45aa97dd1cSKonstantin Ananyev	struct {
46aa97dd1cSKonstantin Ananyev		struct rte_ring *q;
47aa97dd1cSKonstantin Ananyev		struct tle_event *ev;
48aa97dd1cSKonstantin Ananyev		struct tle_stream_cb cb;
49aa97dd1cSKonstantin Ananyev		rte_atomic32_t use;
50aa97dd1cSKonstantin Ananyev	} rx __rte_cache_aligned;
51aa97dd1cSKonstantin Ananyev
52aa97dd1cSKonstantin Ananyev	struct {
53aa97dd1cSKonstantin Ananyev		rte_atomic32_t use;
54aa97dd1cSKonstantin Ananyev		struct {
55aa97dd1cSKonstantin Ananyev			uint32_t nb_elem;  /* number of obects per drb. */
56aa97dd1cSKonstantin Ananyev			uint32_t nb_max;   /* number of drbs per stream. */
57aa97dd1cSKonstantin Ananyev			struct rte_ring *r;
58aa97dd1cSKonstantin Ananyev		} drb;
59aa97dd1cSKonstantin Ananyev		struct tle_event *ev;
60aa97dd1cSKonstantin Ananyev		struct tle_stream_cb cb;
61aa97dd1cSKonstantin Ananyev	} tx __rte_cache_aligned;
62aa97dd1cSKonstantin Ananyev
63aa97dd1cSKonstantin Ananyev	struct tle_udp_stream_param prm;
64aa97dd1cSKonstantin Ananyev} __rte_cache_aligned;
65aa97dd1cSKonstantin Ananyev
66aa97dd1cSKonstantin Ananyev#define UDP_STREAM(p)	\
67aa97dd1cSKonstantin Ananyev((struct tle_udp_stream *)((uintptr_t)(p) - offsetof(struct tle_udp_stream, s)))
68aa97dd1cSKonstantin Ananyev
69aa97dd1cSKonstantin Ananyev#define UDP_STREAM_TX_PENDING(s)	\
70aa97dd1cSKonstantin Ananyev	((s)->tx.drb.nb_max != rte_ring_count((s)->tx.drb.r))
71aa97dd1cSKonstantin Ananyev
72aa97dd1cSKonstantin Ananyev#define UDP_STREAM_TX_FINISHED(s)	\
73aa97dd1cSKonstantin Ananyev	((s)->tx.drb.nb_max == rte_ring_count((s)->tx.drb.r))
74aa97dd1cSKonstantin Ananyev
75aa97dd1cSKonstantin Ananyev#ifdef __cplusplus
76aa97dd1cSKonstantin Ananyev}
77aa97dd1cSKonstantin Ananyev#endif
78aa97dd1cSKonstantin Ananyev
79aa97dd1cSKonstantin Ananyev#endif /* _UDP_STREAM_H_ */
80