aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/interfaces/jdbc/org/postgresql/PG_Stream.java41
-rw-r--r--src/interfaces/jdbc/org/postgresql/fastpath/Fastpath.java17
2 files changed, 1 insertions, 57 deletions
diff --git a/src/interfaces/jdbc/org/postgresql/PG_Stream.java b/src/interfaces/jdbc/org/postgresql/PG_Stream.java
index 5c8a3c6e0b9..fb97d3a24b6 100644
--- a/src/interfaces/jdbc/org/postgresql/PG_Stream.java
+++ b/src/interfaces/jdbc/org/postgresql/PG_Stream.java
@@ -56,12 +56,6 @@ public class PG_Stream
*/
public void SendChar(int val) throws IOException
{
- // Original code
- //byte b[] = new byte[1];
- //b[0] = (byte)val;
- //pg_output.write(b);
-
- // Optimised version by Sverre H. Huseby Aug 22 1999 Applied Sep 13 1999
pg_output.write((byte)val);
}
@@ -85,30 +79,6 @@ public class PG_Stream
}
/**
- * Sends an integer to the back end in reverse order.
- *
- * This is required when the backend uses the routines in the
- * src/backend/libpq/pqcomprim.c module.
- *
- * As time goes by, this should become obsolete.
- *
- * @param val the integer to be sent
- * @param siz the length of the integer in bytes (size of structure)
- * @exception IOException if an I/O error occurs
- */
- public void SendIntegerReverse(int val, int siz) throws IOException
- {
- byte[] buf = bytePoolDim1.allocByte(siz);
- int p=0;
- while (siz-- > 0)
- {
- buf[p++] = (byte)(val & 0xff);
- val >>= 8;
- }
- Send(buf);
- }
-
- /**
* Send an array of bytes to the backend
*
* @param buf The array of bytes to be sent
@@ -156,17 +126,6 @@ public class PG_Stream
}
/**
- * Sends a packet, prefixed with the packet's length
- * @param buf buffer to send
- * @exception SQLException if an I/O Error returns
- */
- public void SendPacket(byte[] buf) throws IOException
- {
- SendInteger(buf.length+4,4);
- Send(buf);
- }
-
- /**
* Receives a single character from the backend
*
* @return the character received
diff --git a/src/interfaces/jdbc/org/postgresql/fastpath/Fastpath.java b/src/interfaces/jdbc/org/postgresql/fastpath/Fastpath.java
index 9e9b07f89be..4566f562d28 100644
--- a/src/interfaces/jdbc/org/postgresql/fastpath/Fastpath.java
+++ b/src/interfaces/jdbc/org/postgresql/fastpath/Fastpath.java
@@ -18,19 +18,6 @@ import org.postgresql.util.*;
*
* <p>It is based around the file src/interfaces/libpq/fe-exec.c
*
- *
- * <p><b>Implementation notes:</b>
- *
- * <p><b><em>Network protocol:</em></b>
- *
- * <p>The code within the backend reads integers in reverse.
- *
- * <p>There is work in progress to convert all of the protocol to
- * network order but it may not be there for v6.3
- *
- * <p>When fastpath switches, simply replace SendIntegerReverse() with
- * SendInteger()
- *
* @see org.postgresql.FastpathFastpathArg
* @see org.postgresql.LargeObject
*/
@@ -80,9 +67,7 @@ public class Fastpath
// that confuses the backend. The 0 terminates the command line.
stream.SendInteger(70,1);
stream.SendInteger(0,1);
-
- //stream.SendIntegerReverse(fnid,4);
- //stream.SendIntegerReverse(args.length,4);
+
stream.SendInteger(fnid,4);
stream.SendInteger(args.length,4);