blob: b4e16e859b04eda4db838787ae9dcecd7f87d00a [file] [log] [blame]
/*
*
* Copyright (c) 2020-2021 Project CHIP Authors
* Copyright (c) 2018 Google LLC
* Copyright (c) 2013-2017 Nest Labs, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/**
* This file declares an implementation of Inet::UDPEndPoint using sockets.
*/
#pragma once
#include <inet/EndPointStateSockets.h>
#include <inet/UDPEndPoint.h>
namespace chip {
namespace Inet {
class UDPEndPointImplSockets : public UDPEndPoint, public EndPointStateSockets
{
public:
UDPEndPointImplSockets(EndPointManager<UDPEndPoint> & endPointManager) :
UDPEndPoint(endPointManager), mBoundIntfId(InterfaceId::Null())
{}
// UDPEndPoint overrides.
CHIP_ERROR SetMulticastLoopback(IPVersion aIPVersion, bool aLoopback) override;
InterfaceId GetBoundInterface() const override;
uint16_t GetBoundPort() const override;
void Free() override;
private:
// UDPEndPoint overrides.
#if INET_CONFIG_ENABLE_IPV4
CHIP_ERROR IPv4JoinLeaveMulticastGroupImpl(InterfaceId aInterfaceId, const IPAddress & aAddress, bool join) override;
#endif // INET_CONFIG_ENABLE_IPV4
CHIP_ERROR IPv6JoinLeaveMulticastGroupImpl(InterfaceId aInterfaceId, const IPAddress & aAddress, bool join) override;
CHIP_ERROR BindImpl(IPAddressType addressType, const IPAddress & address, uint16_t port, InterfaceId interfaceId) override;
CHIP_ERROR BindInterfaceImpl(IPAddressType addressType, InterfaceId interfaceId) override;
CHIP_ERROR ListenImpl() override;
CHIP_ERROR SendMsgImpl(const IPPacketInfo * pktInfo, chip::System::PacketBufferHandle && msg) override;
void CloseImpl() override;
CHIP_ERROR GetSocket(IPAddressType addressType);
void HandlePendingIO(System::SocketEvents events);
static void HandlePendingIO(System::SocketEvents events, intptr_t data);
InterfaceId mBoundIntfId;
uint16_t mBoundPort;
#if CHIP_SYSTEM_CONFIG_USE_PLATFORM_MULTICAST_API
public:
enum class MulticastOperation
{
kJoin,
kLeave
};
using MulticastGroupHandler = CHIP_ERROR (*)(InterfaceId, const IPAddress &, MulticastOperation operation);
static void SetMulticastGroupHandler(MulticastGroupHandler handler) { sMulticastGroupHandler = handler; }
private:
static MulticastGroupHandler sMulticastGroupHandler;
#endif // CHIP_SYSTEM_CONFIG_USE_PLATFORM_MULTICAST_API
};
using UDPEndPointImpl = UDPEndPointImplSockets;
} // namespace Inet
} // namespace chip