See subject.
Index: lib/evt.c
===================================================================
--- lib/evt.c (revision 1838)
+++ lib/evt.c (working copy)
@@ -360,7 +360,13 @@
/*
* Set up communication with the event server
*/
- error = coroipcc_service_connect (IPC_SOCKET_NAME, EVT_SERVICE, &evti->ipc_ctx);
+ error = coroipcc_service_connect (
+ IPC_SOCKET_NAME,
+ EVT_SERVICE,
+ IPC_REQUEST_SIZE,
+ IPC_RESPONSE_SIZE,
+ IPC_DISPATCH_SIZE,
+ &evti->ipc_ctx);
if (error != SA_AIS_OK) {
goto error_handle_put;
}
Index: lib/ckpt.c
===================================================================
--- lib/ckpt.c (revision 1838)
+++ lib/ckpt.c (working copy)
@@ -259,7 +259,13 @@
goto error_destroy;
}
- error = coroipcc_service_connect (IPC_SOCKET_NAME, CKPT_SERVICE, &ckptInstance->ipc_ctx);
+ error = coroipcc_service_connect (
+ IPC_SOCKET_NAME,
+ CKPT_SERVICE,
+ IPC_REQUEST_SIZE,
+ IPC_RESPONSE_SIZE,
+ IPC_DISPATCH_SIZE,
+ &ckptInstance->ipc_ctx);
if (error != SA_AIS_OK) {
goto error_put_destroy;
}
Index: lib/tmr.c
===================================================================
--- lib/tmr.c (revision 1838)
+++ lib/tmr.c (working copy)
@@ -128,7 +128,13 @@
goto error_destroy;
}
- error = coroipcc_service_connect (IPC_SOCKET_NAME, TMR_SERVICE, &tmrInstance->ipc_ctx);
+ error = coroipcc_service_connect (
+ IPC_SOCKET_NAME,
+ TMR_SERVICE,
+ IPC_REQUEST_SIZE,
+ IPC_RESPONSE_SIZE,
+ IPC_DISPATCH_SIZE,
+ &tmrInstance->ipc_ctx);
if (error != SA_AIS_OK) {
goto error_put_destroy;
}
Index: lib/amf.c
===================================================================
--- lib/amf.c (revision 1838)
+++ lib/amf.c (working copy)
@@ -122,7 +122,13 @@
goto error_destroy;
}
- error = coroipcc_service_connect (IPC_SOCKET_NAME, CPG_SERVICE, &amfInstance->ipc_ctx);
+ error = coroipcc_service_connect (
+ IPC_SOCKET_NAME,
+ CPG_SERVICE,
+ IPC_REQUEST_SIZE,
+ IPC_RESPONSE_SIZE,
+ IPC_DISPATCH_SIZE,
+ &amfInstance->ipc_ctx);
if (error != SA_AIS_OK) {
goto error_put_destroy;
}
Index: lib/lck.c
===================================================================
--- lib/lck.c (revision 1838)
+++ lib/lck.c (working copy)
@@ -238,7 +238,13 @@
goto error_destroy;
}
- error = coroipcc_service_connect (IPC_SOCKET_NAME, LCK_SERVICE, &lckInstance->ipc_ctx);
+ error = coroipcc_service_connect (
+ IPC_SOCKET_NAME,
+ LCK_SERVICE,
+ IPC_REQUEST_SIZE,
+ IPC_RESPONSE_SIZE,
+ IPC_DISPATCH_SIZE,
+ &lckInstance->ipc_ctx);
if (error != SA_AIS_OK) {
goto error_put_destroy;
}
@@ -826,7 +832,13 @@
goto error_destroy;
}
- error = coroipcc_service_connect (IPC_SOCKET_NAME, LCK_SERVICE, &lock_ctx);
+ error = coroipcc_service_connect (
+ IPC_SOCKET_NAME,
+ LCK_SERVICE,
+ IPC_REQUEST_SIZE,
+ IPC_RESPONSE_SIZE,
+ IPC_DISPATCH_SIZE,
+ &lock_ctx);
if (error != SA_AIS_OK) { // TODO error handling
goto error_destroy;
}
@@ -919,7 +931,13 @@
goto error_destroy;
}
- error = coroipcc_service_connect (IPC_SOCKET_NAME, LCK_SERVICE, &lock_ctx);
+ error = coroipcc_service_connect (
+ IPC_SOCKET_NAME,
+ LCK_SERVICE,
+ IPC_REQUEST_SIZE,
+ IPC_RESPONSE_SIZE,
+ IPC_DISPATCH_SIZE,
+ &lock_ctx);
if (error != SA_AIS_OK) { // TODO error handling
goto error_destroy;
}
Index: lib/clm.c
===================================================================
--- lib/clm.c (revision 1838)
+++ lib/clm.c (working copy)
@@ -163,7 +163,13 @@
goto error_destroy;
}
- error = coroipcc_service_connect (IPC_SOCKET_NAME, CLM_SERVICE, &clmInstance->ipc_ctx);
+ error = coroipcc_service_connect (
+ IPC_SOCKET_NAME,
+ CLM_SERVICE,
+ IPC_REQUEST_SIZE,
+ IPC_RESPONSE_SIZE,
+ IPC_DISPATCH_SIZE,
+ &clmInstance->ipc_ctx);
if (error != SA_AIS_OK) {
goto error_put_destroy;
}
Index: lib/util.h
===================================================================
--- lib/util.h (revision 1838)
+++ lib/util.h (working copy)
@@ -54,5 +54,9 @@
SaTimeT clustTimeNow(void);
+#define IPC_REQUEST_SIZE 8192*128
+#define IPC_RESPONSE_SIZE 8192*128
+#define IPC_DISPATCH_SIZE 8192*128
+
#endif /* AIS_UTIL_H_DEFINED */
Index: lib/msg.c
===================================================================
--- lib/msg.c (revision 1838)
+++ lib/msg.c (working copy)
@@ -153,7 +153,13 @@
goto error_destroy;
}
- error = coroipcc_service_connect (IPC_SOCKET_NAME, MSG_SERVICE, &msgInstance->ipc_ctx);
+ error = coroipcc_service_connect (
+ IPC_SOCKET_NAME,
+ MSG_SERVICE,
+ IPC_REQUEST_SIZE,
+ IPC_RESPONSE_SIZE,
+ IPC_DISPATCH_SIZE,
+ &msgInstance->ipc_ctx);
if (error != SA_AIS_OK) {
goto error_put_destroy;
}
_______________________________________________
Openais mailing list
[email protected]
https://lists.linux-foundation.org/mailman/listinfo/openais
