socket_protocol_layer.h

程序实现了在ip协议之上加一层RUDP协议

// SOCKET_Protocol_Layer.h: interface for the SOCKET_Protocol_Layer class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_SOCKET_PROTOCOL_LAYER_H__FD0DF016_8948_4084_AC9B_51F0411D3185__INCLUDED_)
#define AFX_SOCKET_PROTOCOL_LAYER_H__FD0DF016_8948_4084_AC9B_51F0411D3185__INCLUDED_

#include <pthread.h>
#include <iostream.h>
#include <stdio.h>

#include"SOCKET_Transmit_Protocol_Handler.h"
#include"SOCKET_ACTIVITY_LIST_Handler.h"
#include"SOCKET_Receive_Data_Buff.h"
#include"SOCKET_Sequence_Manager.h"
#include"Socket_SR.h"
#include"SOCKET_Receive_Protocol_Handler.h"
#include "SOCKET_Control_Protocol_Handler.h"

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

//定义互斥信号量
pthread_mutex_t  retransmit_queue_lock;

void* send_thread(void* arg);
void* receive_thread(void* arg);
void* port_listen_thread(void* arg);
bool  f_SOCKET_Message_Transmit_Queue_Listneing_Handler(Message *msg);


SOCKET_Transmit_Protocol_Handler* socket_transmit_protocol_handler_ptr;
SOCKET_ACTIVITY_LIST_Handler* activity_list_manager_ptr;
SOCKET_Receive_Data_Buff* receive_data_buff;
SOCKET_Sequence_Manager* seq_manager_ptr;
Socket_SR* socket_sr_ptr;
SOCKET_Receive_Protocol_Handler* receive_protocol_handler_ptr;

SOCKET_Control_Protocol_Handler* control_protocol_handler_ptr;

#endif // !defined(AFX_SOCKET_PROTOCOL_LAYER_H__FD0DF016_8948_4084_AC9B_51F0411D3185__INCLUDED_)