blob: 37d9f598bccbe47c76233b18793bc4be6419c361 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
// Copyright 2019 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file
#ifndef PLATFORM_API_UDP_READ_CALLBACK_H_
#define PLATFORM_API_UDP_READ_CALLBACK_H_
#include <array>
#include <cstdint>
#include <memory>
#include "osp_base/ip_address.h"
namespace openscreen {
namespace platform {
class NetworkRunner;
class UdpSocket;
static constexpr int kUdpMaxPacketSize = 1 << 16;
class UdpReadCallback {
public:
struct Packet : std::array<uint8_t, kUdpMaxPacketSize> {
Packet() = default;
~Packet() = default;
IPEndpoint source;
IPEndpoint original_destination;
size_t length;
// TODO(btolsch): When this gets to implementation, make sure the callback
// is never called with a |socket| that could have been destroyed (e.g.
// between queueing the read data and running the task).
UdpSocket* socket;
// Override the default implementation since we want the number of elements,
// not kUdpMaxPacketSize.
size_t size() const { return length; }
};
virtual ~UdpReadCallback() = default;
virtual void OnRead(std::unique_ptr<Packet> data,
NetworkRunner* network_runner) = 0;
};
} // namespace platform
} // namespace openscreen
#endif // PLATFORM_API_UDP_READ_CALLBACK_H_
|
