proxmox-mirrors/mirror_corosync
1
0
Fork 0
mirror of https://git.proxmox.com/git/mirror_corosync synced 2025-08-05 19:02:36 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Change req_header to res_header to match rest of

Browse Source 
library, especially for out of order queued messages.

(Logical change 1.90)


git-svn-id: http://svn.fedorahosted.org/svn/corosync/trunk@325 fd59a12c-fef9-0310-b244-a6a79926bd2f
This commit is contained in:
Steven Dake 2004-10-05 20:20:12 +00:00
parent 0ad467ca41
commit b003253b26
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/amf.c
View File

@ -50,8 +50,8 @@
#include "../include/ais_msg.h"
#include "util.h"
struct message_overlay {
struct req_header header;
struct res_overlay {
struct res_header header;
char data[4096];
};
@ -209,7 +209,7 @@ saAmfDispatch (
int ignore_dispatch = 0;
int cont = 1; /* always continue do loop except when set to 0 */
int poll_fd;
struct message_overlay dispatch_data;
struct res_overlay dispatch_data;
error = saHandleInstanceGet (&amfHandleDatabase, *amfHandle,
(void *)&amfInstance);
@ -275,13 +275,13 @@ saAmfDispatch (
* Queue empty, read response from socket
*/
error = saRecvRetry (amfInstance->fd, &dispatch_data.header,
sizeof (struct req_header), MSG_WAITALL | MSG_NOSIGNAL);
sizeof (struct res_header), MSG_WAITALL | MSG_NOSIGNAL);
if (error != SA_OK) {
goto error_unlock;
}
if (dispatch_data.header.size > sizeof (struct req_header)) {
if (dispatch_data.header.size > sizeof (struct res_header)) {
error = saRecvRetry (amfInstance->fd, &dispatch_data.data,
dispatch_data.header.size - sizeof (struct req_header),
dispatch_data.header.size - sizeof (struct res_header),
MSG_WAITALL | MSG_NOSIGNAL);
if (error != SA_OK) {
goto error_unlock;