Subversion Repositories funbase_ip_library

 
#include <mcapi.h>
#include "headers.h"
 
#define MAIN_NODE_NUM 0
#define DCT_NODE_NUM 1
 
#define WAIT_TIMEOUT 0xFFFFFFFF
 
#define mcapi_assert_success(s) \
        if (s != MCAPI_SUCCESS) { printf("%s:%d status %d\n", __FILE__, __LINE__, s); abort(); }
 
 
extern void fdct_8x8(uint8 *input_data, sint16 *output_data, sint32 num_fdcts);
 
int main_dct(){
 
  //printf("DCT starts MCAPI initialization\r\n");
 
  mcapi_status_t status;
  mcapi_request_t request, recv_request, send_request;
  size_t size;
  mcapi_version_t version;
  mcapi_endpoint_t  block_count_in, dct_data_out, dct_data_in , ext_dct_data_in;  
 
  mcapi_pktchan_send_hndl_t       send_handle;
  mcapi_pktchan_recv_hndl_t       recv_handle;
 
  unsigned int my_node_id = DCT_NODE_NUM;
 
  mcapi_initialize(my_node_id,&version,&status);
  mcapi_assert_success(status);
 
  /* create endpoints */
  block_count_in = mcapi_create_endpoint ( 0 ,&status);
  dct_data_in = mcapi_create_endpoint ( 1 ,&status);
  dct_data_out =mcapi_create_endpoint ( 2 ,&status);
 
  //printf("Endpoints created succesfully\r\n");
 
 
  /* get main endpoint from database */ 
  ext_dct_data_in = mcapi_get_endpoint (MAIN_NODE_NUM, 1 , &status);
 
  //printf("Remote endpoint obtained succesfully\r\n");
 
 
  /* open pktchan for sending macroblocks */
  mcapi_open_pktchan_recv_i(&recv_handle, dct_data_in, &recv_request, &status);
  //mcapi_assert_success(status);
 
  /* open pktchan for receiving macroblocks from DCT */
  mcapi_open_pktchan_send_i(&send_handle, dct_data_out, &send_request, &status);
  //mcapi_assert_success(status);
 
  mcapi_wait(&send_request, &size, &status, WAIT_TIMEOUT);	
  mcapi_assert_success(status);
 
  //printf("First wait!\r\n");
 
  mcapi_wait(&recv_request, &size, &status, WAIT_TIMEOUT);	
  mcapi_assert_success(status);
 
 
  //printf("Packet channels opened successfully\r\n");
 
  // MCAPI INITIALIZATION DONE!
 
  /* Receive block count configuration from main node */
  size = 1;
  uint8 block_count;
 
  //printf("Waiting for config message..");
  mcapi_msg_recv(block_count_in, &block_count, 1 , &size ,&status);
  //printf("received %X\r\n", block_count);
  uint8 i = 0;
  uint8 ii = 0;
  uint8 *mb_data;
  sint16 *dct_data;
  dct_data=(sint16*)malloc(2*6*8*8);
 
  while(1) {
 
    /* receive data from main */
    //printf("Receiving macroblock packet from the main.\r\n");
    mcapi_pktchan_recv(recv_handle,(void *)&mb_data,&size,&status);
    mcapi_assert_success(status);
    mcapi_pktchan_free((void *)mb_data, &status);
    //printf("Transforming macroblocks\n");
 
 
    for(ii = 0; ii < 10; ii++)
    fdct_8x8(mb_data, dct_data, block_count);
 
    /* send transformed six macro blocks to main via mcapi */
    size =2*6*8*8;
    //printf("Sending transformed macroblocks to main\r\n");
    mcapi_pktchan_send(send_handle,dct_data,size,&status);     
    mcapi_assert_success(status);
    //printf("Counter %u\n", i);
      i++;
    }
  free(dct_data);
  return 1;
 
}