|
Mercury
|
#include <stdio.h>#include <stdlib.h>#include <stdbool.h>#include <string.h>#include <sys/time.h>#include <sys/uio.h>#include <unistd.h>#include <assert.h>#include "na.h"#include "na_private.h"#include "na_error.h"#include "mercury_hash_table.h"#include "mercury_list.h"#include "mercury_queue.h"#include "mercury_thread.h"#include "mercury_thread_mutex.h"#include "mercury_thread_condition.h"#include "mercury_time.h"#include <ssm/dumb.h>#include <ssm.h>#include <ssmptcp.h>
Go to the source code of this file.
Classes | |
| struct | na_ssm_unexpected_buffer |
| struct | na_ssm_private_data |
| struct | na_ssm_addr |
| struct | na_ssm_mem_handle |
| struct | ssm_msg_send_unexpected |
| struct | ssm_msg_send_expected |
| struct | ssm_get |
| struct | ssm_msg_recv_expected |
| struct | ssm_msg_recv_unexpected |
| struct | na_ssm_opid |
Macros | |
| #define | __likely(x) (x) |
| #define | __unlikely(x) (x) |
| #define | NA_SSM_UNEXPECTED_SIZE 1024*1024*64 |
| #define | NA_SSM_EXPECTED_SIZE 1024*1024*64 |
| #define | NA_SSM_UNEXPECTED_BUFFERCOUNT 64 |
| #define | NA_SSM_TAG_UNEXPECTED_OFFSET 0 |
| #define | NA_SSM_TAG_EXPECTED_OFFSET (((ssm_bits)1)<<62) |
| #define | NA_SSM_TAG_RMA_OFFSET (((ssm_bits)1)<<63) |
| #define | NA_SSM_MAX_ADDRESS_LENGTH 64 |
| #define | NA_SSM_NEXT_UNEXPBUF_POS(n) (((n)+(1))%(NA_SSM_UNEXPECTED_BUFFERCOUNT)) |
| #define | NA_SSM_PRIVATE_DATA(a) ((struct na_ssm_private_data *) (a)->private_data) |
| #define | NA_SSM_MARK_OPID_COMPLETE(a) ((a)->status = SSM_STATUS_COMPLETED) |
| #define | NA_SSM_MARK_OPID_CANCELED(a) ((a)->status = SSM_STATUS_CANCELED) |
Typedefs | |
| typedef int | ssm_size_t |
| typedef unsigned long | ssm_msg_tag_t |
| typedef enum na_ssm_status | na_ssm_status_t |
Enumerations | |
| enum | na_ssm_status { SSM_STATUS_INVALID = 0, SSM_STATUS_INPROGRESS = 1, SSM_STATUS_COMPLETED = 2, SSM_STATUS_CANCELED = 3 } |
| #define NA_SSM_NEXT_UNEXPBUF_POS | ( | n | ) | (((n)+(1))%(NA_SSM_UNEXPECTED_BUFFERCOUNT)) |
| #define NA_SSM_PRIVATE_DATA | ( | a | ) | ((struct na_ssm_private_data *) (a)->private_data) |
| #define NA_SSM_MARK_OPID_COMPLETE | ( | a | ) | ((a)->status = SSM_STATUS_COMPLETED) |
| #define NA_SSM_MARK_OPID_CANCELED | ( | a | ) | ((a)->status = SSM_STATUS_CANCELED) |
| typedef int ssm_size_t |
| typedef unsigned long ssm_msg_tag_t |
| typedef enum na_ssm_status na_ssm_status_t |
| enum na_ssm_status |
1.8.6