LAInitiator_Protobuf.cpp 3.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. uint32_t process_protobuf_dh_msg1_generate_protobuf_dh_msg2(protobuf_sgx_dh_msg1_t& protobuf_msg1, protobuf_sgx_dh_msg2_t& protobuf_msg2)
  2. {
  3. sgx_dh_msg1_t dh_msg1; //Diffie-Hellman Message 1
  4. sgx_dh_msg2_t dh_msg2;
  5. memset(&dh_msg1, 0, sizeof(sgx_dh_msg1_t));
  6. uint32_t ret_status;
  7. if(Initiator_Transforms::decode_msg1_from_protobuf(protobuf_msg1, &dh_msg1)!=0)
  8. return -1;
  9. //Intialize the session as a session initiator
  10. ret_status = sgx_dh_init_session(SGX_DH_SESSION_INITIATOR, &sgx_dh_session);
  11. if(ret_status != SGX_SUCCESS)
  12. return ret_status;
  13. //Process the message 1 obtained from desination enclave and generate message 2
  14. ret_status = sgx_dh_initiator_proc_msg1(&dh_msg1, &dh_msg2, &sgx_dh_session);
  15. if(ret_status != SGX_SUCCESS)
  16. return ret_status;
  17. Initiator_Transforms::encode_msg2_to_protobuf(protobuf_msg2, &dh_msg2);
  18. return 0;
  19. }
  20. uint32_t process_protobuf_dh_msg3(protobuf_sgx_dh_msg3_t& protobuf_msg3) {
  21. uint32_t ret_status;
  22. sgx_dh_msg3_t dh_msg3;
  23. sgx_key_128bit_t dh_aek; // Session Key
  24. sgx_dh_session_enclave_identity_t responder_identity;
  25. memset(&dh_aek,0, sizeof(sgx_key_128bit_t));
  26. if(Initiator_Transforms::decode_msg3_from_protobuf(protobuf_msg3, &dh_msg3)!=0)
  27. return -1;
  28. //Process Message 3 obtained from the destination enclave
  29. ret_status = sgx_dh_initiator_proc_msg3(&dh_msg3, &sgx_dh_session, &dh_aek, &responder_identity);
  30. if(SGX_SUCCESS != ret_status)
  31. return ret_status;
  32. memcpy(global_session_info.active.AEK, &dh_aek, sizeof(sgx_key_128bit_t));
  33. global_session_info.session_id = 1; // TODO: session_id;
  34. global_session_info.active.counter = 0;
  35. global_session_info.status = ACTIVE;
  36. memset(&dh_aek,0, sizeof(sgx_key_128bit_t));
  37. return 0;
  38. }
  39. uint32_t conduct_la(int decryptor_fd) {
  40. // declare msg1, msg2, msg3 protobuf objects
  41. protobuf_sgx_dh_msg1_t protobuf_msg1;
  42. protobuf_sgx_dh_msg2_t protobuf_msg2;
  43. protobuf_sgx_dh_msg3_t protobuf_msg3;
  44. uint32_t protobuf_sgx_ret;
  45. setbuf(stdout,NULL);
  46. protobufReaderWriter.set_fd(decryptor_fd);
  47. if(protobufReaderWriter.read_msg(protobuf_msg1)!=0)
  48. return -1;
  49. protobuf_sgx_ret = process_protobuf_dh_msg1_generate_protobuf_dh_msg2(protobuf_msg1, protobuf_msg2);
  50. if(protobuf_sgx_ret != 0)
  51. {
  52. printf("Error in process_protobuf_dh_msg1_generate_protobuf_dh_msg2: 0x%x", protobuf_sgx_ret); fflush(stdout); return protobuf_sgx_ret;
  53. }
  54. if(protobufReaderWriter.write_msg(protobuf_msg2)!=0)
  55. return -1;
  56. if(protobufReaderWriter.read_msg(protobuf_msg3)!=0)
  57. return -1;
  58. protobuf_sgx_ret = process_protobuf_dh_msg3(protobuf_msg3);
  59. if(protobuf_sgx_ret != 0)
  60. {
  61. printf("Error in process_protobuf_dh_msg3: 0x%x", protobuf_sgx_ret); fflush(stdout); return protobuf_sgx_ret;
  62. }
  63. return 0;
  64. }
  65. uint32_t get_la_symmetric_key(uint8_t* op_key)
  66. {
  67. uint32_t counter;
  68. for(counter=0; counter<32; counter++)
  69. op_key[counter] = key[counter];
  70. // TODO: Fix this code - there is no attribute called key - it's in one of the existing attributes.
  71. }