42 	ring_buffer* r_buff = calloc (1, sizeof(ring_buffer));  in InitBuffer()  local
43 	r_buff->head = malloc(size);  in InitBuffer()
44 	r_buff->data = r_buff->head;  in InitBuffer()
45 	r_buff->tot_size = size;  in InitBuffer()
46 	return r_buff;  in InitBuffer()
49 int GetTotSizeRBuffer(ring_buffer* r_buff)   in GetTotSizeRBuffer()  argument
51 	return  r_buff->tot_size;  in GetTotSizeRBuffer()
54 int GetDataSizeRBuffer(ring_buffer* r_buff)   in GetDataSizeRBuffer()  argument
56 	return  r_buff->data_size;  in GetDataSizeRBuffer()
59 int GetCumSizeRBuffer(ring_buffer* r_buff)   in GetCumSizeRBuffer()  argument
61 	return  r_buff->cum_size;  in GetCumSizeRBuffer()
64 int GetRemainBufferSize(ring_buffer *r_buff)   in GetRemainBufferSize()  argument
66 	assert(r_buff->head <= r_buff->data);  in GetRemainBufferSize()
68 	int data_offset = r_buff->data - r_buff->head;  in GetRemainBufferSize()
69 	assert (data_offset <= r_buff->tot_size - 1);  in GetRemainBufferSize()
71 	if (data_offset > r_buff->tot_size / 2) {  in GetRemainBufferSize()
72 		memmove(r_buff->head, r_buff->data, r_buff->data_size);  in GetRemainBufferSize()
73 		r_buff->data = r_buff->head;  in GetRemainBufferSize()
75 		return r_buff->tot_size - r_buff->data_size;  in GetRemainBufferSize()
78 	return r_buff->tot_size -  r_buff->data_size - data_offset;  in GetRemainBufferSize()
81 int CheckAvailableSize(ring_buffer *r_buff, int size)  in CheckAvailableSize()  argument
83 	int remain_size = GetRemainBufferSize(r_buff);  in CheckAvailableSize()
90 u_char* GetDataPoint(ring_buffer* r_buff)   in GetDataPoint()  argument
92 	return r_buff->data;  in GetDataPoint()
95 u_char* GetInputPoint(ring_buffer *r_buff)   in GetInputPoint()  argument
97 	assert(r_buff->data_size <= r_buff->tot_size);  in GetInputPoint()
98 	return r_buff->data + r_buff->data_size;  in GetInputPoint()
101 int RemoveDataFromBuffer(ring_buffer* r_buff, int size)   in RemoveDataFromBuffer()  argument
106 	if (size > r_buff->data_size)  in RemoveDataFromBuffer()
109 	r_buff->data_size -= size;  in RemoveDataFromBuffer()
111 	if (r_buff->data_size == 0)  in RemoveDataFromBuffer()
112 		r_buff->data = r_buff->head;  in RemoveDataFromBuffer()
114 		r_buff->data += size;  in RemoveDataFromBuffer()
119 int AddDataLen(ring_buffer *r_buff, int size)  in AddDataLen()  argument
121 	assert(r_buff->data_size + size <= r_buff->tot_size);  in AddDataLen()
122 	r_buff->data_size += size;  in AddDataLen()
123 	r_buff->cum_size += size;  in AddDataLen()
124 	return r_buff->data_size;  in AddDataLen()
222 int MtcpWriteFromBuffer(mctx_t mctx, int fid, ring_buffer *r_buff)  in MtcpWriteFromBuffer()  argument
225 	to_send = GetDataSizeRBuffer(r_buff);  in MtcpWriteFromBuffer()
229 	wr = mtcp_write(mctx, fid, GetDataPoint(r_buff), to_send);  in MtcpWriteFromBuffer()
235 	ret = RemoveDataFromBuffer(r_buff, wr);  in MtcpWriteFromBuffer()
241 int MtcpReadFromBuffer(mctx_t mctx, int fid, ring_buffer *r_buff)  in MtcpReadFromBuffer()  argument
246 	free_len = GetRemainBufferSize(r_buff);  in MtcpReadFromBuffer()
247 	ip = GetInputPoint(r_buff);  in MtcpReadFromBuffer()
254 	AddDataLen(r_buff, ret);  in MtcpReadFromBuffer()