Author: rhs
Date: Tue Mar 13 20:02:59 2012
New Revision: 1300321
URL: http://svn.apache.org/viewvc?rev=1300321&view=rev
Log:
EOM -> PN_EOM
Modified:
qpid/proton/proton-c/include/proton/engine.h
qpid/proton/proton-c/src/engine/engine.c
qpid/proton/proton-c/src/proton.c
Modified: qpid/proton/proton-c/include/proton/engine.h
URL:
http://svn.apache.org/viewvc/qpid/proton/proton-c/include/proton/engine.h?rev=1300321&r1=1300320&r2=1300321&view=diff
==============================================================================
--- qpid/proton/proton-c/include/proton/engine.h (original)
+++ qpid/proton/proton-c/include/proton/engine.h Tue Mar 13 20:02:59 2012
@@ -102,7 +102,7 @@ ssize_t pn_send(pn_sender_t *sender, con
void pn_abort(pn_sender_t *sender);
// receiver
-#define EOM (-1)
+#define PN_EOM (-1)
void pn_flow(pn_receiver_t *receiver, int credits);
ssize_t pn_recv(pn_receiver_t *receiver, char *bytes, size_t n);
Modified: qpid/proton/proton-c/src/engine/engine.c
URL:
http://svn.apache.org/viewvc/qpid/proton/proton-c/src/engine/engine.c?rev=1300321&r1=1300320&r2=1300321&view=diff
==============================================================================
--- qpid/proton/proton-c/src/engine/engine.c (original)
+++ qpid/proton/proton-c/src/engine/engine.c Tue Mar 13 20:02:59 2012
@@ -1428,11 +1428,11 @@ ssize_t pn_recv(pn_receiver_t *receiver,
delivery->size -= size;
return size;
} else {
- return EOM;
+ return PN_EOM;
}
} else {
// XXX: ?
- return EOM;
+ return PN_EOM;
}
}
Modified: qpid/proton/proton-c/src/proton.c
URL:
http://svn.apache.org/viewvc/qpid/proton/proton-c/src/proton.c?rev=1300321&r1=1300320&r2=1300321&view=diff
==============================================================================
--- qpid/proton/proton-c/src/proton.c (original)
+++ qpid/proton/proton-c/src/proton.c Tue Mar 13 20:02:59 2012
@@ -173,7 +173,7 @@ void server_callback(pn_selectable_t *se
printf(" payload = \"");
while (true) {
ssize_t n = pn_recv(receiver, msg, 1024);
- if (n == EOM) {
+ if (n == PN_EOM) {
pn_advance(link);
pn_disposition(delivery, PN_ACCEPTED);
break;
@@ -307,7 +307,7 @@ void client_callback(pn_selectable_t *se
printf(" payload = \"");
while (true) {
size_t n = pn_recv(rcv, msg, 1024);
- if (n == EOM) {
+ if (n == PN_EOM) {
pn_advance(link);
pn_disposition(delivery, PN_ACCEPTED);
pn_settle(delivery);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
