messageProcessor.h

Go to the documentation of this file.

/*
 * Copyright (c) 2017-2019 Cisco and/or its affiliates.
 * 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.
 */
 
#ifndef messageProcessor_h
#define messageProcessor_h
 
#include <hicn/content_store/contentStoreInterface.h>
#include <hicn/core/forwarder.h>
#include <hicn/core/message.h>
 
#include <hicn/utils/commands.h>
 
#ifdef WITH_POLICY
#ifdef WITH_MAPME
#include <hicn/core/connection.h>
#endif /* WITH_MAPME */
#endif /* WITH_POLICY */
 
struct message_processor;
typedef struct message_processor MessageProcessor;
 
MessageProcessor *messageProcessor_Create(Forwarder *forwarder);
 
void messageProcessor_Destroy(MessageProcessor **processorPtr);
 
void messageProcessor_Receive(MessageProcessor *procesor, Message *message);
 
bool messageProcessor_AddOrUpdateRoute(MessageProcessor *processor,
                                       add_route_command *control,
                                       unsigned ifidx);
 
bool messageProcessor_RemoveRoute(MessageProcessor *processor,
                                  remove_route_command *control,
                                  unsigned ifidx);
 
#ifdef WITH_POLICY
 
bool messageProcessor_AddOrUpdatePolicy(MessageProcessor *processor,
        add_policy_command *control);
 
bool messageProcessor_RemovePolicy(MessageProcessor *processor,
        remove_policy_command *control);
 
#endif /* WITH_POLICY */
 
void messageProcessor_RemoveConnectionIdFromRoutes(MessageProcessor *processor,
                                                   unsigned connectionId);
 
FibEntryList *messageProcessor_GetFibEntries(MessageProcessor *processor);
 
void messageProcessor_SetContentObjectStoreSize(MessageProcessor *processor,
                                                size_t maximumContentStoreSize);
 
ContentStoreInterface *messageProcessor_GetContentObjectStore(
    const MessageProcessor *processor);
 
void messageProcessor_SetCacheStoreFlag(MessageProcessor *processor, bool val);
 
bool messageProcessor_GetCacheStoreFlag(MessageProcessor *processor);
 
void messageProcessor_SetCacheServeFlag(MessageProcessor *processor, bool val);
 
bool messageProcessor_GetCacheServeFlag(MessageProcessor *processor);
 
void messageProcessor_ClearCache(MessageProcessor *processor);
 
void processor_SetStrategy(MessageProcessor *processor, Name *prefix,
                           strategy_type strategy,
                           unsigned related_prefixes_len,
                           Name **related_prefixes);
 
#ifdef WITH_MAPME
 
FIB *messageProcessor_getFib(MessageProcessor *processor);
 
#endif /* WITH_MAPME */
 
#endif  // messageProcessor_h