blob: 0f7cfe7ecece0b10d8619cee238b1c5642b01d60 [file] [log] [blame]
Girish Gowdraddf9a162020-01-27 12:56:27 +05301/*
2 * Copyright 2018-present Open Networking Foundation
3
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7
8 * http://www.apache.org/licenses/LICENSE-2.0
9
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16#ifndef OPENOLT_CORE_UTILS_H_
17#define OPENOLT_CORE_UTILS_H_
18#include <string>
19#include <unistd.h>
Thiyagarajan Subramani03bc66f2020-04-01 15:58:53 +053020#include <ifaddrs.h>
21#include <arpa/inet.h>
Humera Kouser6143c9e2020-06-17 22:37:31 +053022#include <sys/ioctl.h>
23#include <net/if.h>
Girish Gowdraddf9a162020-01-27 12:56:27 +053024
25#include "core.h"
26#include "core_data.h"
27#include "error_format.h"
28
29extern "C"
30{
31#include <bcmolt_api.h>
32#include <bcmolt_host_api.h>
33#include <bcmolt_api_model_supporting_enums.h>
34#include <bcmolt_api_model_supporting_structs.h>
35
36#include <bcmolt_api_conn_mgr.h>
37//CLI header files
38#include <bcmcli_session.h>
39#include <bcmcli.h>
40#include <bcm_api_cli.h>
41
42#include <bcmos_common.h>
43#include <bcm_config.h>
44// FIXME : dependency problem
45// #include <bcm_common_gpon.h>
46// #include <bcm_dev_log_task.h>
47}
48
49
50std::string serial_number_to_str(bcmolt_serial_number* serial_number);
51std::string vendor_specific_to_str(const char* const serial_number);
52uint16_t get_dev_id(void);
53int get_default_tm_sched_id(int intf_id, std::string direction);
Burak Gurdag2f2618c2020-04-23 13:20:30 +000054uint32_t get_tm_sched_id(int pon_intf_id, int onu_id, int uni_id, std::string direction, int tech_profile_id);
55void free_tm_sched_id(int pon_intf_id, int onu_id, int uni_id, std::string direction, int tech_profile_id);
56bool is_tm_sched_id_present(int pon_intf_id, int onu_id, int uni_id, std::string direction, int tech_profile_id);
Girish Gowdraddf9a162020-01-27 12:56:27 +053057bool check_tm_qmp_equality(std::vector<uint32_t> tmq_map_profileA, std::vector<uint32_t> tmq_map_profileB);
58std::string* get_valid_queues_pbit_map(std::string *queues_pbit_map, uint32_t size);
59std::vector<uint32_t> get_tmq_map_profile(std::string *queues_pbit_map, uint32_t *queues_priority_q, uint32_t size);
60int get_tm_qmp_id(std::vector<uint32_t> tmq_map_profile);
61void update_sched_qmp_id_map(uint32_t sched_id,uint32_t pon_intf_id, uint32_t onu_id,
62 uint32_t uni_id, int tm_qmp_id);
63int get_tm_qmp_id(uint32_t sched_id,uint32_t pon_intf_id, uint32_t onu_id, uint32_t uni_id);
64int get_tm_qmp_id(uint32_t sched_id,uint32_t pon_intf_id, uint32_t onu_id, uint32_t uni_id,
65 std::vector<uint32_t> tmq_map_profile);
66bool free_tm_qmp_id(uint32_t sched_id,uint32_t pon_intf_id, uint32_t onu_id,
67 uint32_t uni_id, int tm_qmp_id);
68int get_acl_id();
69void free_acl_id (int acl_id);
Girish Gowdra252f4972020-09-07 21:24:01 -070070uint16_t get_flow_id();
71bool get_flow_ids(int num_of_flow_ids, uint16_t *flow_ids);
72void free_flow_id (uint16_t flow_id);
73void free_flow_ids(uint8_t num_flows, uint16_t *flow_ids);
Girish Gowdraddf9a162020-01-27 12:56:27 +053074std::string get_qos_type_as_string(bcmolt_egress_qos_type qos_type);
75bcmolt_egress_qos_type get_qos_type(uint32_t pon_intf_id, uint32_t onu_id, uint32_t uni_id, uint32_t queue_size=0);
76void clear_qos_type(uint32_t pon_intf_id, uint32_t onu_id, uint32_t uni_id);
77std::string GetDirection(int direction);
78bcmos_errno wait_for_alloc_action(uint32_t intf_id, uint32_t alloc_id, AllocCfgAction action);
Girish Gowdra7a79dae2020-02-10 18:22:11 +053079bcmos_errno wait_for_onu_deactivate_complete(uint32_t intf_id, uint32_t onu_id);
Girish Gowdraddf9a162020-01-27 12:56:27 +053080char* openolt_read_sysinfo(const char* field_name, char* field_val);
81Status pushOltOperInd(uint32_t intf_id, const char *type, const char *state);
82void openolt_cli_get_prompt_cb(bcmcli_session *session, char *buf, uint32_t max_len);
83int _bal_apiend_cli_thread_handler(long data);
84bcmos_errno bcm_openolt_api_cli_init(bcmcli_entry *parent_dir, bcmcli_session *session);
85bcmos_errno bcm_cli_quit(bcmcli_session *session, const bcmcli_cmd_parm parm[], uint16_t n_parms);
86int get_status_bcm_cli_quit(void);
87bcmos_errno bcmolt_apiend_cli_init();
Thiyagarajan Subramaniad463232020-02-28 19:10:43 +053088bcmos_errno get_pon_interface_status(bcmolt_interface pon_ni, bcmolt_interface_state *state, bcmolt_status *los_status);
89bcmos_errno get_onu_status(bcmolt_interface pon_ni, int onu_id, bcmolt_onu_state *onu_state);
Girish Gowdraddf9a162020-01-27 12:56:27 +053090bcmos_errno bcmolt_cfg_get_mult_retry(bcmolt_oltid olt, bcmolt_cfg *cfg);
91unsigned NumNniIf_();
92unsigned NumPonIf_();
93bcmos_errno get_nni_interface_status(bcmolt_interface id, bcmolt_interface_state *state);
94Status install_gem_port(int32_t intf_id, int32_t onu_id, int32_t gemport_id);
95Status remove_gem_port(int32_t intf_id, int32_t gemport_id);
Burak Gurdaga0523592021-02-24 15:17:47 +000096Status enable_encryption_for_gem_port(int32_t intf_id, int32_t gemport_id);
Girish Gowdraddf9a162020-01-27 12:56:27 +053097Status update_acl_interface(int32_t intf_id, bcmolt_interface_type intf_type, uint32_t access_control_id,
98 bcmolt_members_update_command acl_cmd);
99Status install_acl(const acl_classifier_key acl_key);
100Status remove_acl(int acl_id);
101void formulate_acl_classifier_key(acl_classifier_key *key, const ::openolt::Classifier& classifier);
Girish Gowdra1935e6a2020-10-31 21:48:22 -0700102Status handle_acl_rule_install(int32_t onu_id, uint64_t flow_id, int32_t gemport_id,
Girish Gowdraddf9a162020-01-27 12:56:27 +0530103 const std::string flow_type, int32_t access_intf_id,
Girish Gowdra252f4972020-09-07 21:24:01 -0700104 int32_t network_intf_id,
Girish Gowdraddf9a162020-01-27 12:56:27 +0530105 const ::openolt::Classifier& classifier);
106void clear_gem_port(int gemport_id, int access_intf_id);
Girish Gowdra252f4972020-09-07 21:24:01 -0700107Status handle_acl_rule_cleanup(int16_t acl_id, int32_t intf_id, const std::string flow_type);
Girish Gowdraddf9a162020-01-27 12:56:27 +0530108Status check_bal_ready();
109Status check_connection();
Thiyagarajan Subramani03bc66f2020-04-01 15:58:53 +0530110std::string get_ip_address(const char* nw_intf);
Jason Huang1d9cfce2020-05-20 22:58:47 +0800111bcmos_errno getOnuMaxLogicalDistance(uint32_t intf_id, uint32_t *mld);
Humera Kouser6143c9e2020-06-17 22:37:31 +0530112char* get_intf_mac(const char* intf_name, char* mac_address, unsigned int max_size_of_mac_address);
Girish Gowdra252f4972020-09-07 21:24:01 -0700113void update_voltha_flow_to_cache(uint64_t voltha_flow_id, device_flow dev_flow);
114void remove_voltha_flow_from_cache(uint64_t voltha_flow_id);
115bool is_voltha_flow_installed(uint64_t voltha_flow_id );
116const device_flow* get_device_flow(uint64_t voltha_flow_id);
117const device_flow_params* get_device_flow_params(uint64_t voltha_flow_id);
Girish Gowdra1935e6a2020-10-31 21:48:22 -0700118trap_to_host_packet_type get_trap_to_host_packet_type(const ::openolt::Classifier& classifier);
119bool is_packet_allowed(bcmolt_access_control_receive_eth_packet_data *data, int32_t gemport_id);
Girish Gowdraddf9a162020-01-27 12:56:27 +0530120#endif // OPENOLT_CORE_UTILS_H_