summaryrefslogtreecommitdiff
path: root/src/interfaces/jdbc/postgresql/fastpath
diff options
context:
space:
mode:
Diffstat (limited to 'src/interfaces/jdbc/postgresql/fastpath')
-rw-r--r--src/interfaces/jdbc/postgresql/fastpath/Fastpath.java10
-rw-r--r--src/interfaces/jdbc/postgresql/fastpath/FastpathArg.java6
2 files changed, 9 insertions, 7 deletions
diff --git a/src/interfaces/jdbc/postgresql/fastpath/Fastpath.java b/src/interfaces/jdbc/postgresql/fastpath/Fastpath.java
index ce278acef71..fdb68686554 100644
--- a/src/interfaces/jdbc/postgresql/fastpath/Fastpath.java
+++ b/src/interfaces/jdbc/postgresql/fastpath/Fastpath.java
@@ -75,8 +75,10 @@ public class Fastpath
stream.SendInteger(70,1);
stream.SendInteger(0,1);
- stream.SendIntegerReverse(fnid,4);
- stream.SendIntegerReverse(args.length,4);
+ //stream.SendIntegerReverse(fnid,4);
+ //stream.SendIntegerReverse(args.length,4);
+ stream.SendInteger(fnid,4);
+ stream.SendInteger(args.length,4);
for(int i=0;i<args.length;i++)
args[i].send(stream);
@@ -114,12 +116,12 @@ public class Fastpath
// Function returned properly
//
case 'G':
- int sz = stream.ReceiveInteger(4);
+ int sz = stream.ReceiveIntegerR(4);
DriverManager.println("G: size="+sz); //debug
// Return an Integer if
if(resulttype)
- result = new Integer(stream.ReceiveInteger(sz));
+ result = new Integer(stream.ReceiveIntegerR(sz));
else {
byte buf[] = new byte[sz];
stream.Receive(buf,0,sz);
diff --git a/src/interfaces/jdbc/postgresql/fastpath/FastpathArg.java b/src/interfaces/jdbc/postgresql/fastpath/FastpathArg.java
index 9b800073c22..32c62d761cd 100644
--- a/src/interfaces/jdbc/postgresql/fastpath/FastpathArg.java
+++ b/src/interfaces/jdbc/postgresql/fastpath/FastpathArg.java
@@ -94,11 +94,11 @@ public class FastpathArg
{
if(type) {
// argument is an integer
- s.SendIntegerReverse(4,4); // size of an integer
- s.SendIntegerReverse(value,4); // integer value of argument
+ s.SendInteger(4,4); // size of an integer
+ s.SendInteger(value,4); // integer value of argument
} else {
// argument is a byte array
- s.SendIntegerReverse(bytes.length,4); // size of array
+ s.SendInteger(bytes.length,4); // size of array
s.Send(bytes);
}
}