network_bp_destination/main.c

// ////////////////////////////////////////////////////////////////////
//
// Sample program receives and sends four packets using bundle protocol 
// via ION and logs info and error messages.  Program uses 
// RegisterPrintMessage, StartLoggingMessages, CreateBPDevice, 
// RegisterReceivePacket, and SendPacket API functions.
//
// This program must be running on the destination platform prior to 
// starting the network BP polling or network BP source examples. 
//
// ION must be configured with BP service numbers 3 
// and 4. Destination eid/node = 2.
//
// ////////////////////////////////////////////////////////////////////
 
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <signal.h>
#include <string.h>
#include "ds_shared.h"
#include "bp_shared.h"
#include "trek_error.h"
#include "toolkit_ds_api_error_codes.h"
#include "trek_toolkit_common_api_ansi_c.h"
#include "toolkit_ds_api_ansi_c.h"
#ifdef __linux__
#include <unistd.h>
#else
#include <windows.h>
#endif
 
char bp_device_key3[50];
 
// ////////////////////////////////////////////////////////////////////
//
// PrintTheMessage controls how messages are processed and displayed to 
// the user.
//
// ////////////////////////////////////////////////////////////////////
 
void PrintTheMessage(message_struct_type *mess_struct_ptr)
{
    if (mess_struct_ptr->category == MSG_CAT_INFO       || 
        mess_struct_ptr->category == MSG_CAT_INFO_ALERT || 
        mess_struct_ptr->category == MSG_CAT_ERROR      || 
        mess_struct_ptr->category == MSG_CAT_ERROR_ALERT)
    {
        printf("%s\t%s\n",GetMessageCategoryAsString(mess_struct_ptr->category),
               mess_struct_ptr->message);
    }
}
 
// ////////////////////////////////////////////////////////////////////
//
// ReceivePacket's key parameter is set to the packet's origin or 
// source endpoint id string (e.g.,<source node number>.<source service 
// number>). The packet_buffer_ptr parameter points to the newly 
// received packet.
// 
// ////////////////////////////////////////////////////////////////////
 
void ReceivePacket (const char     *key,
                    int            packet_length,
                    unsigned char  *packet_buffer_ptr)
{
    char        *arg[2];
    long long   source_node_number;
    unsigned int  source_service_number; 
    
 
 
    // Print the data zone packets.
    printf("Data\t%s\n",(char *)packet_buffer_ptr + 5);
 
    // Send the packet back to its source by retrieving the
    // packet's source node number and source service number from the
    // key string that is returned with the packet.
    // NOTE: The key string is formatted as follows:
    // <source node number>.<source service number> (e.g., 1.64)
    arg[0] = strtok((char *)key,".");
    if (arg[0] != NULL)
    {
        arg[1]  = strtok(NULL,".");  // NULL allows function to continue scanning 
                                     // where a previous call to function ended
        if (arg[1] != NULL)
        {
            #ifdef _WIN32
            source_node_number = _strtoi64(arg[0],NULL,0);
            #else
            source_node_number = strtoll(arg[0],NULL,0);
            #endif
            source_service_number = (unsigned int)atof(arg[1]);
 
            SendPacketFromBPDevice (bp_device_key3,
                                    packet_length,packet_buffer_ptr,
                                    source_node_number,
                                    source_service_number);
        }
    }
}
 
// ////////////////////////////////////////////////////////////////////
//
// Sample program receives and sends four packets using bundle protocol 
// via ION and logs info and error messages.  Program uses 
// RegisterPrintMessage, StartLoggingMessages, CreateBPDevice, 
// RegisterReceivePacket, and SendPacket API functions.
//
// This program must be running on the destination platform prior to 
// starting the network BP polling or network BP source examples. 
//
// ION must be configured with BP service numbers 3 
// and 4. Destination eid/node = 2.
//
// ////////////////////////////////////////////////////////////////////
 
int main(int argc, char *argv[])
{ 
    unsigned int receive_service_number;
    unsigned int lifespan;
    bp_class_of_service_type cos;       // BPD_BULK_PRIORITY, BPD_STD_PRIORITY or BPD_EXPEDITED_PRIORITY 
    unsigned int ordinal;               // Values from 0-254. Only associated with EXPEDITED_PRIORITY class_of_service. 
    bp_transmission_mode_type mode;     // BPD_BEST_EFFORT, BPD_ASSURED or BPD_ASSURED_WITH_CUSTODY_TRANSFER 
    bp_criticality_type criticality;    // BPD_NOT_CRITICAL or BPD_CRITICAL 
    unsigned int key_buffer_size;
    char log_path[256];
    char log_filename[256];
    unsigned short exit_flag = 0;
    char arg1[50];
    char bp_device_key4[50];
    char bp_device_key5[50];
 
    // Register the PrintMessage callback function prior to InitToolkitCfdp
    // to process error messages that may be generated during initialization.
    RegisterMessage(&PrintTheMessage);
 
    printf("\nNetwork BP Destination\n\n");
 
    // Create a log file in the home/<username> or Users/<username> directory
    // by passing a empty string for directory path. Only log error and 
    // information messages. 
    strcpy(log_path,"");
    strcpy(log_filename,"network_bp_destination_log_file");
    StartLoggingMessages(log_path,
                         log_filename,
                         FALSE_OR_NO);
 
    // Create a BP receive device 
    receive_service_number = 3;
    lifespan = 86400;
    cos = BPD_STD_PRIORITY; 
    ordinal = 0;
    mode = BPD_ASSURED;
    criticality = BPD_NOT_CRITICAL;
 
    key_buffer_size = sizeof(bp_device_key3);
    if (CreateBPDevice(receive_service_number,
        lifespan,cos,ordinal,mode,criticality,&key_buffer_size,
        bp_device_key3) != SUCCESS)
    {
        DSCleanUp();
        return 0;
    }
 
    // Associate the ReceivePacket callback function with the BP  
    // device so all packets received by the device will  
    // be processed by ReceivePacket callback function.   
    if (RegisterReceivePacket(bp_device_key3,&ReceivePacket) != SUCCESS)
    {
        DSCleanUp();
        return 0;
    }
 
    // Create and register a second BP receive device
    receive_service_number = 4;
    if (CreateBPDevice(receive_service_number,
        lifespan,cos,ordinal,mode,criticality,&key_buffer_size,
        bp_device_key4) != SUCCESS)
    {
        DSCleanUp();
        return 0;
    }
 
    if (RegisterReceivePacket(bp_device_key4,&ReceivePacket) != SUCCESS)
    {
        DSCleanUp();
        return 0;
    }
 
    // Create and register a second BP receive device
    receive_service_number = 5;
    if (CreateBPDevice(receive_service_number,
        lifespan, cos, ordinal, mode, criticality, &key_buffer_size,
        bp_device_key5) != SUCCESS)
    {
        DSCleanUp();
        return 0;
    }
 
    if (RegisterReceivePacket(bp_device_key5, &ReceivePacket) != SUCCESS)
    {
        DSCleanUp();
        return 0;
    }
 
    printf("To exit application enter: \"e\" or \"q\" or \"exit\" or \"quit\".\n\n");
 
    while (exit_flag == 0)
    {
        fgets(arg1, 50, stdin);
        arg1[strlen(arg1)-1] = '\0';
        if (strcmp(arg1,"exit") == 0 || strcmp(arg1,"quit") == 0 || 
            strcmp(arg1,"e") == 0 || strcmp(arg1,"q") == 0)
        {
            exit_flag = 1;
        }
        else
        {
            printf("\nTo exit application enter: \"e\" or \"q\" or \"exit\" or \"quit\".\n\n");
        }
    }
    
    // Close the log file. A timetag is appended to the log file name. 
    StopLoggingMessages();
    DSCleanUp();
    return 0;
}