/** @file Net subsystem @section license License Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you 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. @section details Details Net subsystem is a layer on top the operations system network apis. It provides an interface for accepting/creating new connection oriented (TCP) and connection less (UDP) connections and for reading/writing data through these. The net system can manage 1000s of connections very efficiently. Another advantage of using the net system is that the SMs dont have be concerned about differences in the net apis of various operations systems. SMs use the netProcessor global object of the Net System to create new connections or to accept incoming connections. When a new connection is created the SM gets a NetVConnection which is a handle for the underlying connections. The SM can then use the NetVConnection to get properties of the connection, read and write data. Net system also has socks and ssl support. */ #pragma once #include "tscore/I_Version.h" #include "I_EventSystem.h" #include #ifndef UIO_MAXIOV #define NET_MAX_IOV 16 // UIO_MAXIOV shall be at least 16 1003.1g (5.4.1.1) #else #define NET_MAX_IOV UIO_MAXIOV #endif static constexpr ts::ModuleVersion NET_SYSTEM_MODULE_PUBLIC_VERSION(1, 0, ts::ModuleVersion::PUBLIC); static constexpr int NO_FD = -1; // All in milli-seconds extern int net_config_poll_timeout; extern int net_event_period; extern int net_accept_period; extern int net_retry_delay; extern int net_throttle_delay; extern std::string_view net_ccp_in; extern std::string_view net_ccp_out; #define NET_EVENT_OPEN (NET_EVENT_EVENTS_START) #define NET_EVENT_OPEN_FAILED (NET_EVENT_EVENTS_START + 1) #define NET_EVENT_ACCEPT (NET_EVENT_EVENTS_START + 2) #define NET_EVENT_ACCEPT_SUCCEED (NET_EVENT_EVENTS_START + 3) #define NET_EVENT_ACCEPT_FAILED (NET_EVENT_EVENTS_START + 4) #define NET_EVENT_CANCEL (NET_EVENT_EVENTS_START + 5) #define NET_EVENT_DATAGRAM_READ_COMPLETE (NET_EVENT_EVENTS_START + 6) #define NET_EVENT_DATAGRAM_READ_ERROR (NET_EVENT_EVENTS_START + 7) #define NET_EVENT_DATAGRAM_WRITE_COMPLETE (NET_EVENT_EVENTS_START + 8) #define NET_EVENT_DATAGRAM_WRITE_ERROR (NET_EVENT_EVENTS_START + 9) #define NET_EVENT_DATAGRAM_READ_READY (NET_EVENT_EVENTS_START + 10) #define NET_EVENT_DATAGRAM_OPEN (NET_EVENT_EVENTS_START + 11) #define NET_EVENT_DATAGRAM_ERROR (NET_EVENT_EVENTS_START + 12) #define NET_EVENT_ACCEPT_INTERNAL (NET_EVENT_EVENTS_START + 22) #define NET_EVENT_CONNECT_INTERNAL (NET_EVENT_EVENTS_START + 23) #define MAIN_ACCEPT_PORT -1 /* * Net system uses event threads * so, the net thread group id is the event thread group id */ #define ET_NET ET_CALL #include "I_NetVConnection.h" #include "I_NetProcessor.h" #include "I_SessionAccept.h" void ink_net_init(ts::ModuleVersion version);