trafficserver-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zw...@apache.org
Subject svn commit: r1056140 - in /trafficserver/traffic/trunk: example/append-transform/ example/cache_scan/ example/gzip-transform/ example/null-transform/ example/protocol/ example/thread-pool/ iocore/cluster/ iocore/dns/ iocore/eventsystem/ iocore/hostdb/ ...
Date Fri, 07 Jan 2011 00:36:10 GMT
Author: zwoop
Date: Fri Jan  7 00:36:08 2011
New Revision: 1056140

URL: http://svn.apache.org/viewvc?rev=1056140&view=rev
Log:
TS-620 More 64-bit fixes to the SM

Modified:
    trafficserver/traffic/trunk/example/append-transform/append-transform.c
    trafficserver/traffic/trunk/example/cache_scan/cache_scan.cc
    trafficserver/traffic/trunk/example/gzip-transform/gunzip.c
    trafficserver/traffic/trunk/example/gzip-transform/gzip.c
    trafficserver/traffic/trunk/example/null-transform/null-transform.c
    trafficserver/traffic/trunk/example/protocol/TxnSM.c
    trafficserver/traffic/trunk/example/thread-pool/psi.c
    trafficserver/traffic/trunk/iocore/cluster/P_ClusterCache.h
    trafficserver/traffic/trunk/iocore/dns/test_P_DNS.cc
    trafficserver/traffic/trunk/iocore/eventsystem/I_IOBuffer.h
    trafficserver/traffic/trunk/iocore/eventsystem/P_VIO.h
    trafficserver/traffic/trunk/iocore/hostdb/test_P_HostDB.cc
    trafficserver/traffic/trunk/iocore/net/I_NetVConnection.h
    trafficserver/traffic/trunk/iocore/net/NetTest-http-server.c
    trafficserver/traffic/trunk/iocore/net/NetTest-simple-proxy.c
    trafficserver/traffic/trunk/iocore/net/test_I_simple_proxy.cc
    trafficserver/traffic/trunk/iocore/net/test_P_Net.cc
    trafficserver/traffic/trunk/iocore/utils/I_OneWayMultiTunnel.h
    trafficserver/traffic/trunk/iocore/utils/I_OneWayTunnel.h
    trafficserver/traffic/trunk/iocore/utils/OneWayMultiTunnel.cc
    trafficserver/traffic/trunk/iocore/utils/OneWayTunnel.cc
    trafficserver/traffic/trunk/lib/ts/ink_port.h
    trafficserver/traffic/trunk/proxy/FetchSM.cc
    trafficserver/traffic/trunk/proxy/MuxVC.cc
    trafficserver/traffic/trunk/proxy/Prefetch.cc
    trafficserver/traffic/trunk/proxy/Prefetch.h
    trafficserver/traffic/trunk/proxy/SimpleHttp.cc
    trafficserver/traffic/trunk/proxy/SocksProxy.cc
    trafficserver/traffic/trunk/proxy/Stuffer.cc
    trafficserver/traffic/trunk/proxy/TestHook.cc
    trafficserver/traffic/trunk/proxy/TestProxy.cc
    trafficserver/traffic/trunk/proxy/TestSimpleProxy.cc
    trafficserver/traffic/trunk/proxy/Transform.cc
    trafficserver/traffic/trunk/proxy/Update.cc
    trafficserver/traffic/trunk/proxy/http2/HttpClientSession.cc
    trafficserver/traffic/trunk/proxy/http2/HttpSM.cc
    trafficserver/traffic/trunk/proxy/http2/HttpSessionManager.cc
    trafficserver/traffic/trunk/proxy/http2/test_socket_close.cc
    trafficserver/traffic/trunk/proxy/logging/LogConfig.cc
    trafficserver/traffic/trunk/test/plugin/INKContinuations/ServerSM.cc
    trafficserver/traffic/trunk/test/plugin/assembly/assembly.c
    trafficserver/traffic/trunk/test/plugin/plugin_as_origin/http_connect_bridge.c
    trafficserver/traffic/trunk/test/plugin/plugin_as_origin/net_bridge.c
    trafficserver/traffic/trunk/test/plugin/plugin_as_origin/serve_file.c
    trafficserver/traffic/trunk/test/plugin/test-protocol/test-protocol.c
    trafficserver/traffic/trunk/test/plugin/test-protocol/test-protocol.cc

Modified: trafficserver/traffic/trunk/example/append-transform/append-transform.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/example/append-transform/append-transform.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/example/append-transform/append-transform.c (original)
+++ trafficserver/traffic/trunk/example/append-transform/append-transform.c Fri Jan  7 00:36:08 2011
@@ -108,7 +108,7 @@ handle_transform(TSCont contp)
   data = TSContDataGet(contp);
   if (!data) {
     towrite = TSVIONBytesGet(write_vio);
-    if (towrite != INT_MAX) {
+    if (towrite != INT64_MAX) {
       towrite += append_buffer_length;
     }
     data = my_data_alloc();

Modified: trafficserver/traffic/trunk/example/cache_scan/cache_scan.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/example/cache_scan/cache_scan.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/example/cache_scan/cache_scan.cc (original)
+++ trafficserver/traffic/trunk/example/cache_scan/cache_scan.cc Fri Jan  7 00:36:08 2011
@@ -25,11 +25,11 @@
  * cache_scan.cc:  use TSCacheScan to print URLs and headers for objects in
  *                 the cache when endpoint /show-cache is requested
  */
-
 #include <stdio.h>
 #include <string.h>
 #include <limits.h>
 #include <stdlib.h>
+#define __STDC_LIMIT_MACROS
 #include <ts/ts.h>
 #include <ts/experimental.h>
 
@@ -71,7 +71,7 @@ handle_scan(TSCont contp, TSEvent event,
     cstate->done = 1;
     const char error[] = "Cache remove operation succeeded";
     cstate->cache_vc = (TSVConn) edata;
-    cstate->write_vio = TSVConnWrite(cstate->net_vc, contp, cstate->resp_reader, INT_MAX);
+    cstate->write_vio = TSVConnWrite(cstate->net_vc, contp, cstate->resp_reader, INT64_MAX);
     cstate->total_bytes += TSIOBufferWrite(cstate->resp_buffer, error, sizeof(error) - 1);
     TSVIONBytesSet(cstate->write_vio, cstate->total_bytes);
     TSVIOReenable(cstate->write_vio);
@@ -84,7 +84,7 @@ handle_scan(TSCont contp, TSEvent event,
     char rc[12];
     snprintf(rc, 12, "%p", edata);
     cstate->cache_vc = (TSVConn) edata;
-    cstate->write_vio = TSVConnWrite(cstate->net_vc, contp, cstate->resp_reader, INT_MAX);
+    cstate->write_vio = TSVConnWrite(cstate->net_vc, contp, cstate->resp_reader, INT64_MAX);
     cstate->total_bytes += TSIOBufferWrite(cstate->resp_buffer, error, sizeof(error) - 1);
     cstate->total_bytes += TSIOBufferWrite(cstate->resp_buffer, rc, strlen(rc));
 
@@ -96,7 +96,7 @@ handle_scan(TSCont contp, TSEvent event,
   //first scan event, save vc and start write
   if (event == TS_EVENT_CACHE_SCAN) {
     cstate->cache_vc = (TSVConn) edata;
-    cstate->write_vio = TSVConnWrite(cstate->net_vc, contp, cstate->resp_reader, INT_MAX);
+    cstate->write_vio = TSVConnWrite(cstate->net_vc, contp, cstate->resp_reader, INT64_MAX);
     return TS_EVENT_CONTINUE;
   }
   //just stop scanning if blocked or failed
@@ -195,7 +195,7 @@ handle_accept(TSCont contp, TSEvent even
       cstate->resp_buffer = TSIOBufferCreate();
       cstate->resp_reader = TSIOBufferReaderAlloc(cstate->resp_buffer);
 
-      cstate->read_vio = TSVConnRead(cstate->net_vc, contp, cstate->req_buffer, INT_MAX);
+      cstate->read_vio = TSVConnRead(cstate->net_vc, contp, cstate->req_buffer, INT64_MAX);
     } else {
       TSVConnClose(vc);
       TSContDestroy(contp);

Modified: trafficserver/traffic/trunk/example/gzip-transform/gunzip.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/example/gzip-transform/gunzip.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/example/gzip-transform/gunzip.c (original)
+++ trafficserver/traffic/trunk/example/gzip-transform/gunzip.c Fri Jan  7 00:36:08 2011
@@ -157,7 +157,7 @@ gzip_transform_init(TSCont contp, GzipDa
 
   data->output_buffer = TSIOBufferCreate();
   data->output_reader = TSIOBufferReaderAlloc(data->output_buffer);
-  data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, INT_MAX);
+  data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, INT64_MAX);
 }
 
 

Modified: trafficserver/traffic/trunk/example/gzip-transform/gzip.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/example/gzip-transform/gzip.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/example/gzip-transform/gzip.c (original)
+++ trafficserver/traffic/trunk/example/gzip-transform/gzip.c Fri Jan  7 00:36:08 2011
@@ -186,7 +186,7 @@ gzip_transform_init(TSCont contp, GzipDa
 
   data->output_buffer = TSIOBufferCreate();
   data->output_reader = TSIOBufferReaderAlloc(data->output_buffer);
-  data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, INT_MAX);
+  data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, INT64_MAX);
 }
 
 

Modified: trafficserver/traffic/trunk/example/null-transform/null-transform.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/example/null-transform/null-transform.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/example/null-transform/null-transform.c (original)
+++ trafficserver/traffic/trunk/example/null-transform/null-transform.c Fri Jan  7 00:36:08 2011
@@ -34,6 +34,7 @@
  */
 
 #include <stdio.h>
+#include <unistd.h>
 #include <ts/ts.h>
 
 // This gets the PRI*64 types
@@ -109,7 +110,9 @@ handle_transform(TSCont contp)
     data->output_buffer = TSIOBufferCreate();
     data->output_reader = TSIOBufferReaderAlloc(data->output_buffer);
     TSDebug("null-transform", "\tWriting %d bytes on VConn", TSVIONBytesGet(input_vio));
-    data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, TSVIONBytesGet(input_vio));
+    //data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, INT32_MAX);
+    data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, INT64_MAX);
+    // data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, TSVIONBytesGet(input_vio));
     if (TSContDataSet(contp, data) == TS_ERROR) {
       TSError("[null-transform] unable to set continuation " "data!\n");
       goto Lerror;
@@ -168,6 +171,8 @@ handle_transform(TSCont contp)
         TSError("[null-plugin] unable to copy IO buffers\n");
         goto Lerror;
       }
+      printf("wrote %d\n", (int)towrite);
+      sleep(1);
 
       /* Tell the read buffer that we have read the data and are no
        * longer interested in it.

Modified: trafficserver/traffic/trunk/example/protocol/TxnSM.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/example/protocol/TxnSM.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/example/protocol/TxnSM.c (original)
+++ trafficserver/traffic/trunk/example/protocol/TxnSM.c Fri Jan  7 00:36:08 2011
@@ -166,11 +166,10 @@ state_start(TSCont contp, TSEvent event,
   /* Now the IOBuffer and IOBufferReader is ready, the data from
      client_vc can be read into the IOBuffer. Since we don't know
      the size of the client request, set the expecting size to be
-     INT_MAX, so that we will always get TS_EVENT_VCONN_READ_READY
+     INT64_MAX, so that we will always get TS_EVENT_VCONN_READ_READY
      event, but never TS_EVENT_VCONN_READ_COMPLETE event. */
   set_handler(txn_sm->q_current_handler, &state_interface_with_client);
-  txn_sm->q_client_read_vio = TSVConnRead(txn_sm->q_client_vc, (TSCont) contp,
-                                           txn_sm->q_client_request_buffer, INT_MAX);
+  txn_sm->q_client_read_vio = TSVConnRead(txn_sm->q_client_vc, (TSCont) contp, txn_sm->q_client_request_buffer, INT64_MAX);
 
   return TS_SUCCESS;
 }
@@ -526,7 +525,7 @@ state_send_request_to_server(TSCont cont
 
     /* Waiting for the incoming response. */
     set_handler(txn_sm->q_current_handler, &state_interface_with_server);
-    txn_sm->q_server_read_vio = TSVConnRead(txn_sm->q_server_vc, contp, txn_sm->q_server_response_buffer, INT_MAX);
+    txn_sm->q_server_read_vio = TSVConnRead(txn_sm->q_server_vc, contp, txn_sm->q_server_response_buffer, INT64_MAX);
     break;
 
     /* it could be failure of TSNetConnect */
@@ -554,7 +553,7 @@ state_interface_with_server(TSCont contp
     /* Otherwise, handle events from server. */
   case TS_EVENT_VCONN_READ_READY:
     /* Actually, we shouldn't get READ_COMPLETE because we set bytes
-       count to be INT_MAX. */
+       count to be INT64_MAX. */
   case TS_EVENT_VCONN_READ_COMPLETE:
     return state_read_response_from_server(contp, event, vio);
 

Modified: trafficserver/traffic/trunk/example/thread-pool/psi.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/example/thread-pool/psi.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/example/thread-pool/psi.c (original)
+++ trafficserver/traffic/trunk/example/thread-pool/psi.c Fri Jan  7 00:36:08 2011
@@ -712,8 +712,8 @@ handle_transform(TSCont contp)
     data->output_buffer = TSIOBufferCreate();
     data->output_reader = TSIOBufferReaderAlloc(data->output_buffer);
 
-    /* INT_MAX because we don't know yet how much bytes we'll produce */
-    data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, INT_MAX);
+    /* INT64_MAX because we don't know yet how much bytes we'll produce */
+    data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, INT64_MAX);
 
     if (data->output_vio == TS_ERROR_PTR) {
       TSError("[handle_transform] Error while writing to downstream VC");

Modified: trafficserver/traffic/trunk/iocore/cluster/P_ClusterCache.h
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/cluster/P_ClusterCache.h?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/cluster/P_ClusterCache.h (original)
+++ trafficserver/traffic/trunk/iocore/cluster/P_ClusterCache.h Fri Jan  7 00:36:08 2011
@@ -493,7 +493,7 @@ struct ClusterVConnection: public Cluste
   // virtual VIO * do_io(
   //   int                   op,
   //   Continuation        * c = NULL,
-  //   int                   nbytes = INT_MAX,
+  //   int                   nbytes = INT64_MAX,
   //   MIOBuffer           * buf = 0,
   //   int                   whence = SEEK_CUR);
   //

Modified: trafficserver/traffic/trunk/iocore/dns/test_P_DNS.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/dns/test_P_DNS.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/dns/test_P_DNS.cc (original)
+++ trafficserver/traffic/trunk/iocore/dns/test_P_DNS.cc Fri Jan  7 00:36:08 2011
@@ -39,7 +39,7 @@ struct NetTesterSM:public Continuation
     SET_HANDLER(&NetTesterSM::handle_read);
     buf = new_MIOBuffer(8);
     reader = buf->alloc_reader();
-    read_vio = vc->do_io_read(this, INT_MAX, buf);
+    read_vio = vc->do_io_read(this, INT64_MAX, buf);
   }
 
 

Modified: trafficserver/traffic/trunk/iocore/eventsystem/I_IOBuffer.h
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/eventsystem/I_IOBuffer.h?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/eventsystem/I_IOBuffer.h (original)
+++ trafficserver/traffic/trunk/iocore/eventsystem/I_IOBuffer.h Fri Jan  7 00:36:08 2011
@@ -879,8 +879,8 @@ public:
 
   /**
     Add by data from IOBufferReader r to the this buffer by reference. If
-    len is INT_MAX, all available data on the reader is added. If len is
-    less than INT_MAX, the smaller of len or the amount of data on the
+    len is INT64_MAX, all available data on the reader is added. If len is
+    less than INT64_MAX, the smaller of len or the amount of data on the
     buffer is added. If offset is greater than zero, than the offset
     bytes of data at the front of the reader are skipped. Bytes skipped
     by offset reduce the number of bytes available on the reader used

Modified: trafficserver/traffic/trunk/iocore/eventsystem/P_VIO.h
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/eventsystem/P_VIO.h?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/eventsystem/P_VIO.h (original)
+++ trafficserver/traffic/trunk/iocore/eventsystem/P_VIO.h Fri Jan  7 00:36:08 2011
@@ -28,17 +28,14 @@
 
 TS_INLINE
 VIO::VIO(int aop)
-  :
-_cont(NULL),
-nbytes(0),
-ndone(0),
-op(aop),
-buffer(),
-vc_server(0),
-mutex(0)
-{
-  return;
-}
+  :_cont(NULL),
+   nbytes(0),
+   ndone(0),
+   op(aop),
+   buffer(),
+   vc_server(0),
+   mutex(0)
+{ }
 
 /////////////////////////////////////////////////////////////
 //
@@ -47,17 +44,14 @@ mutex(0)
 /////////////////////////////////////////////////////////////
 TS_INLINE
 VIO::VIO()
-  :
-_cont(0),
-nbytes(0),
-ndone(0),
-op(VIO::NONE),
-buffer(),
-vc_server(0),
-mutex(0)
-{
-  return;
-}
+  :_cont(0),
+   nbytes(0),
+   ndone(0),
+   op(VIO::NONE),
+   buffer(),
+   vc_server(0),
+   mutex(0)
+{ }
 
 TS_INLINE Continuation *
 VIO::get_continuation()

Modified: trafficserver/traffic/trunk/iocore/hostdb/test_P_HostDB.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/hostdb/test_P_HostDB.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/hostdb/test_P_HostDB.cc (original)
+++ trafficserver/traffic/trunk/iocore/hostdb/test_P_HostDB.cc Fri Jan  7 00:36:08 2011
@@ -39,7 +39,7 @@ struct NetTesterSM:public Continuation
     SET_HANDLER(&NetTesterSM::handle_read);
     buf = new_MIOBuffer(8);
     reader = buf->alloc_reader();
-    read_vio = vc->do_io_read(this, INT_MAX, buf);
+    read_vio = vc->do_io_read(this, INT64_MAX, buf);
   }
 
 

Modified: trafficserver/traffic/trunk/iocore/net/I_NetVConnection.h
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/net/I_NetVConnection.h?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/net/I_NetVConnection.h (original)
+++ trafficserver/traffic/trunk/iocore/net/I_NetVConnection.h Fri Jan  7 00:36:08 2011
@@ -182,7 +182,7 @@ public:
     from the vconnection.
 
     @param c continuation to be called back after (partial) read
-    @param nbytes no of bytes to read, if unknown set to INT_MAX
+    @param nbytes no of bytes to read, if unknown set to INT64_MAX
     @param buf buffer to put the data into
     @return vio
 
@@ -217,7 +217,7 @@ public:
     when it is destroyed.
 
     @param c continuation to be called back after (partial) write
-    @param nbytes no of bytes to write, if unknown msut be set to INT_MAX
+    @param nbytes no of bytes to write, if unknown msut be set to INT64_MAX
     @param buf source of data
     @param owner
     @return vio pointer

Modified: trafficserver/traffic/trunk/iocore/net/NetTest-http-server.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/net/NetTest-http-server.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/net/NetTest-http-server.c (original)
+++ trafficserver/traffic/trunk/iocore/net/NetTest-http-server.c Fri Jan  7 00:36:08 2011
@@ -45,7 +45,7 @@ struct NetTesterSM:public Continuation
     SET_HANDLER(&NetTesterSM::handle_read);
     req_buf = new_MIOBuffer(1);
     reader = req_buf->alloc_reader();
-    read_vio = vc->do_io_read(this, INT_MAX, req_buf);
+    read_vio = vc->do_io_read(this, INT64_MAX, req_buf);
     //vc->set_inactivity_timeout(HRTIME_SECONDS(60));
     resp_buf = new_empty_MIOBuffer(6);
     resp_buf->append_block(resp_blk->clone());

Modified: trafficserver/traffic/trunk/iocore/net/NetTest-simple-proxy.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/net/NetTest-simple-proxy.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/net/NetTest-simple-proxy.c (original)
+++ trafficserver/traffic/trunk/iocore/net/NetTest-simple-proxy.c Fri Jan  7 00:36:08 2011
@@ -171,8 +171,8 @@ struct NetTesterSM:public Continuation
       resp_reader = response_buf->alloc_reader();
 
       response_buf->autopilot = 1;
-      server_resp_read_vio = server_vc->do_io_read(this, INT_MAX, response_buf);
-      client_resp_write_vio = client_vc->do_io_write(this, INT_MAX, resp_reader);
+      server_resp_read_vio = server_vc->do_io_read(this, INT64_MAX, response_buf);
+      client_resp_write_vio = client_vc->do_io_write(this, INT64_MAX, resp_reader);
       response_buf->assign_reader_vio(client_resp_write_vio, resp_reader);
       response_buf->assign_writer_vio(server_resp_read_vio);
       break;

Modified: trafficserver/traffic/trunk/iocore/net/test_I_simple_proxy.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/net/test_I_simple_proxy.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/net/test_I_simple_proxy.cc (original)
+++ trafficserver/traffic/trunk/iocore/net/test_I_simple_proxy.cc Fri Jan  7 00:36:08 2011
@@ -74,7 +74,7 @@ struct NetTesterSM:public Continuation
     response_buf = new_MIOBuffer(8);
     client_reader = request_buf->alloc_reader();
     client_parse_reader = request_buf->alloc_reader();
-    client_read_vio = client_vc->do_io_read(this, INT_MAX, request_buf);
+    client_read_vio = client_vc->do_io_read(this, INT64_MAX, request_buf);
     client_vc->set_inactivity_timeout(HRTIME_SECONDS(60));
     req_len = 0;
   }

Modified: trafficserver/traffic/trunk/iocore/net/test_P_Net.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/net/test_P_Net.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/net/test_P_Net.cc (original)
+++ trafficserver/traffic/trunk/iocore/net/test_P_Net.cc Fri Jan  7 00:36:08 2011
@@ -39,7 +39,7 @@ struct NetTesterSM:public Continuation
     SET_HANDLER(&NetTesterSM::handle_read);
     buf = new_MIOBuffer(8);
     reader = buf->alloc_reader();
-    read_vio = vc->do_io_read(this, INT_MAX, buf);
+    read_vio = vc->do_io_read(this, INT64_MAX, buf);
   }
 
 

Modified: trafficserver/traffic/trunk/iocore/utils/I_OneWayMultiTunnel.h
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/utils/I_OneWayMultiTunnel.h?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/utils/I_OneWayMultiTunnel.h (original)
+++ trafficserver/traffic/trunk/iocore/utils/I_OneWayMultiTunnel.h Fri Jan  7 00:36:08 2011
@@ -110,7 +110,7 @@ struct OneWayMultiTunnel: public OneWayT
 
   */
   void init(VConnection * vcSource, VConnection ** vcTargets, int n_vcTargets, Continuation * aCont = NULL, int size_estimate = 0,      // 0 == best guess
-            int nbytes = TUNNEL_TILL_DONE,
+            int64_t nbytes = TUNNEL_TILL_DONE,
             bool asingle_buffer = true,
             bool aclose_source = true,
             bool aclose_target = true, Transform_fn manipulate_fn = NULL, int water_mark = 0);
@@ -133,8 +133,8 @@ struct OneWayMultiTunnel: public OneWayT
       end. If aCont is not specified, this should be set to true.
 
   */
-  void init(Continuation * aCont,
-            VIO * SourceVio, VIO ** TargetVios, int n_vioTargets, bool aclose_source = true, bool aclose_target = true);
+  void init(Continuation * aCont, VIO * SourceVio, VIO ** TargetVios, int n_vioTargets, bool aclose_source = true,
+            bool aclose_target = true);
 
   //
   // Private
@@ -142,7 +142,6 @@ struct OneWayMultiTunnel: public OneWayT
   int startEvent(int event, void *data);
 
   virtual void reenable_all();
-
   virtual void close_target_vio(int result, VIO * vio = NULL);
 
   int n_vioTargets;

Modified: trafficserver/traffic/trunk/iocore/utils/I_OneWayTunnel.h
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/utils/I_OneWayTunnel.h?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/utils/I_OneWayTunnel.h (original)
+++ trafficserver/traffic/trunk/iocore/utils/I_OneWayTunnel.h Fri Jan  7 00:36:08 2011
@@ -39,7 +39,7 @@
 //
 //////////////////////////////////////////////////////////////////////////////
 
-#define TUNNEL_TILL_DONE   INT_MAX
+#define TUNNEL_TILL_DONE   INT64_MAX
 
 #define ONE_WAY_TUNNEL_CLOSE_ALL NULL
 
@@ -124,7 +124,7 @@ struct OneWayTunnel: public Continuation
   */
   void init(VConnection * vcSource, VConnection * vcTarget, Continuation * aCont = NULL, int size_estimate = 0, // 0 = best guess
             ProxyMutex * aMutex = NULL,
-            int nbytes = TUNNEL_TILL_DONE,
+            int64_t nbytes = TUNNEL_TILL_DONE,
             bool asingle_buffer = true,
             bool aclose_source = true,
             bool aclose_target = true, Transform_fn manipulate_fn = NULL, int water_mark = 0);

Modified: trafficserver/traffic/trunk/iocore/utils/OneWayMultiTunnel.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/utils/OneWayMultiTunnel.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/utils/OneWayMultiTunnel.cc (original)
+++ trafficserver/traffic/trunk/iocore/utils/OneWayMultiTunnel.cc Fri Jan  7 00:36:08 2011
@@ -59,7 +59,7 @@ OneWayMultiTunnel::OneWayMultiTunnel_fre
 }
 
 void
-OneWayMultiTunnel::init(VConnection * vcSource, VConnection ** vcTargets, int n_vcTargets, Continuation * aCont, int size_estimate, int nbytes, bool asingle_buffer,    /* = true */
+OneWayMultiTunnel::init(VConnection * vcSource, VConnection ** vcTargets, int n_vcTargets, Continuation * aCont, int size_estimate, int64_t nbytes, bool asingle_buffer,    /* = true */
                         bool aclose_source,     /* = false */
                         bool aclose_targets,    /* = false */
                         Transform_fn aManipulate_fn, int water_mark)
@@ -100,7 +100,7 @@ OneWayMultiTunnel::init(VConnection * vc
 
   ink_assert(n_vcTargets <= ONE_WAY_MULTI_TUNNEL_LIMIT);
   for (int i = 0; i < n_vcTargets; i++)
-    vioTargets[i] = vcTargets[i]->do_io(VIO::WRITE, this, INT_MAX, buf2, 0);
+    vioTargets[i] = vcTargets[i]->do_io(VIO::WRITE, this, INT64_MAX, buf2, 0);
 
   return;
 }

Modified: trafficserver/traffic/trunk/iocore/utils/OneWayTunnel.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/iocore/utils/OneWayTunnel.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/iocore/utils/OneWayTunnel.cc (original)
+++ trafficserver/traffic/trunk/iocore/utils/OneWayTunnel.cc Fri Jan  7 00:36:08 2011
@@ -116,7 +116,7 @@ OneWayTunnel::init(VConnection * vcSourc
                    Continuation * aCont,
                    int size_estimate,
                    ProxyMutex * aMutex,
-                   int nbytes,
+                   int64_t nbytes,
                    bool asingle_buffer,
                    bool aclose_source, bool aclose_target, Transform_fn aManipulate_fn, int water_mark)
 {

Modified: trafficserver/traffic/trunk/lib/ts/ink_port.h
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/lib/ts/ink_port.h?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/lib/ts/ink_port.h (original)
+++ trafficserver/traffic/trunk/lib/ts/ink_port.h Fri Jan  7 00:36:08 2011
@@ -36,6 +36,7 @@
 #include <stddef.h>
 
 #ifdef HAVE_STDINT_H
+#define __STDC_LIMIT_MACROS
 # include <stdint.h>
 #else
 // TODO: Add "standard" int types?

Modified: trafficserver/traffic/trunk/proxy/FetchSM.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/FetchSM.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/FetchSM.cc (original)
+++ trafficserver/traffic/trunk/proxy/FetchSM.cc Fri Jan  7 00:36:08 2011
@@ -52,7 +52,7 @@ FetchSM::httpConnect()
   Debug(DEBUG_TAG, "[%s] calling httpconnect write", __FUNCTION__);
   TSHttpConnect(_ip, _port, &(http_vc));
   PluginVC *vc = (PluginVC *) http_vc;
-  read_vio = vc->do_io_read(this, INT_MAX, resp_buffer);
+  read_vio = vc->do_io_read(this, INT64_MAX, resp_buffer);
   write_vio = vc->do_io_write(this, getReqLen(), req_reader);
 }
 

Modified: trafficserver/traffic/trunk/proxy/MuxVC.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/MuxVC.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/MuxVC.cc (original)
+++ trafficserver/traffic/trunk/proxy/MuxVC.cc Fri Jan  7 00:36:08 2011
@@ -1015,8 +1015,8 @@ void
 MuxVC::init_io()
 {
   SET_HANDLER(MuxVC::state_handle_mux);
-  read_vio = net_vc->do_io_read(this, INT_MAX, read_buffer);
-  write_vio = net_vc->do_io_write(this, INT_MAX, write_buffer->alloc_reader());
+  read_vio = net_vc->do_io_read(this, INT64_MAX, read_buffer);
+  write_vio = net_vc->do_io_write(this, INT64_MAX, write_buffer->alloc_reader());
 }
 
 
@@ -1241,7 +1241,7 @@ MuxVC::setup_connect_check()
   net_vc->set_inactivity_timeout(HRTIME_SECONDS(30));
 
   ink_debug_assert(write_vio == NULL);
-  write_vio = net_vc->do_io_write(this, INT_MAX, r);
+  write_vio = net_vc->do_io_write(this, INT64_MAX, r);
 }
 
 
@@ -2094,7 +2094,7 @@ MuxVC::state_idle(int event, void *data)
         write_vio->nbytes = write_vio->ndone + avail;
 
         // check for rollover in bytes
-        if (write_vio->nbytes < 0 || write_vio->nbytes == INT_MAX) {
+        if (write_vio->nbytes < 0 || write_vio->nbytes == INT64_MAX) {
           write_vio = net_vc->do_io_write(this, avail, write_vio->get_reader());
         } else {
           write_vio->reenable();
@@ -2170,11 +2170,11 @@ MuxVC::state_handle_mux(int event, void 
 
   switch (event) {
   case VC_EVENT_WRITE_COMPLETE:
-    // We hit INT_MAX bytes.  Reset the I/O
+    // We hit INT64_MAX bytes.  Reset the I/O
     ink_debug_assert(data == write_vio);
-    ink_debug_assert(write_vio->ndone == INT_MAX);
+    ink_debug_assert(write_vio->ndone == INT64_MAX);
     write_bytes_added -= write_vio->ndone;
-    write_vio = net_vc->do_io_write(this, INT_MAX, write_vio->buffer.reader());
+    write_vio = net_vc->do_io_write(this, INT64_MAX, write_vio->buffer.reader());
     // FALL THROUGH
   case VC_EVENT_WRITE_READY:
     ink_debug_assert(data == write_vio);
@@ -2186,9 +2186,9 @@ MuxVC::state_handle_mux(int event, void 
     }
     break;
   case VC_EVENT_READ_COMPLETE:
-    // We hit INT_MAX bytes.  Reset the I/O
+    // We hit INT64_MAX bytes.  Reset the I/O
     ink_debug_assert(data == read_vio);
-    read_vio = net_vc->do_io_read(this, INT_MAX, read_buffer);
+    read_vio = net_vc->do_io_read(this, INT64_MAX, read_buffer);
     // FALL THROUGH
   case VC_EVENT_READ_READY:
     ink_debug_assert(data == read_vio);

Modified: trafficserver/traffic/trunk/proxy/Prefetch.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/Prefetch.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/Prefetch.cc (original)
+++ trafficserver/traffic/trunk/proxy/Prefetch.cc Fri Jan  7 00:36:08 2011
@@ -391,7 +391,7 @@ PrefetchTransform::handle_event(int even
         if (!m_output_vio) {
           m_output_buf = new_empty_MIOBuffer();
           m_output_reader = m_output_buf->alloc_reader();
-          m_output_vio = m_output_vc->do_io_write(this, INT_MAX, m_output_reader);
+          m_output_vio = m_output_vc->do_io_write(this, INT64_MAX, m_output_reader);
         }
         // If the write vio is null, it means it doesn't want
         // to get anymore event (WRITE_READY or WRITE_COMPLETE)
@@ -1566,7 +1566,7 @@ PrefetchBlaster::bufferObject(int event,
       buf->water_mark = prefetch_config.max_object_size;
       buf->fill(PRELOAD_HEADER_LEN);
 
-      int ntoread = INT_MAX;
+      int64_t ntoread = INT64_MAX;
       int len = copy_header(buf, request, NULL);
 
       if (cache_http_info) {
@@ -2111,10 +2111,10 @@ KeepAliveConn::handleEvent(int event, vo
 
     childVC->set_inactivity_timeout(HRTIME_SECONDS(prefetch_config.keepalive_timeout));
 
-    vio = childVC->do_io_write(this, INT_MAX, reader);
+    vio = childVC->do_io_write(this, INT64_MAX, reader);
 
     //his read lets us disconnect when the other side closes
-    childVC->do_io_read(this, INT_MAX, read_buf);
+    childVC->do_io_read(this, INT64_MAX, read_buf);
     break;
 
   case NET_EVENT_OPEN_FAILED:

Modified: trafficserver/traffic/trunk/proxy/Prefetch.h
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/Prefetch.h?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/Prefetch.h (original)
+++ trafficserver/traffic/trunk/proxy/Prefetch.h Fri Jan  7 00:36:08 2011
@@ -88,9 +88,9 @@ class PrefetchUrlEntry: public RefCountO
 {
 public:
   PrefetchUrlEntry()
-  :url(0), len(INT_MAX), resp_blaster(0),
-    object_buf_status(TS_PREFETCH_OBJ_BUF_NOT_NEEDED),
-    req_ip(0), child_ip(0), url_multicast_ip(0), data_multicast_ip(0), blaster_link(0), hash_link(0)
+    : url(0), len(INT_MAX), resp_blaster(0),
+      object_buf_status(TS_PREFETCH_OBJ_BUF_NOT_NEEDED),
+      req_ip(0), child_ip(0), url_multicast_ip(0), data_multicast_ip(0), blaster_link(0), hash_link(0)
   {
     refcount_inc();
   }
@@ -211,14 +211,12 @@ class BlasterUrlList:public Continuation
   int cur_len;
 
 public:
-    BlasterUrlList()
-  : Continuation(), timeout(0), action(0), mtu(0), blast_proto(ILL_BLAST), list_head(0), cur_len(0)
-  {
-  }
+  BlasterUrlList()
+    : Continuation(), timeout(0), action(0), mtu(0), blast_proto(ILL_BLAST), list_head(0), cur_len(0)
+  {  }
 
   void init(PrefetchBlastType btype = UDP_BLAST, int tout = 0, int xmtu = INT_MAX) {
-    SET_HANDLER((int (BlasterUrlList::*)(int, void *))
-                (&BlasterUrlList::handleEvent));
+    SET_HANDLER((int (BlasterUrlList::*)(int, void *))(&BlasterUrlList::handleEvent));
     mutex = new_ProxyMutex();
     blast_proto = btype;
     timeout = tout;

Modified: trafficserver/traffic/trunk/proxy/SimpleHttp.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/SimpleHttp.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/SimpleHttp.cc (original)
+++ trafficserver/traffic/trunk/proxy/SimpleHttp.cc Fri Jan  7 00:36:08 2011
@@ -226,7 +226,7 @@ SimpleCont::start(NetVConnection * ua)
 
   SET_HANDLER(&SimpleCont::ua_read_req_event);
 
-  m_ua_read_vio = m_ua_vc->do_io_read(this, INT_MAX, m_ua_read_buf);
+  m_ua_read_vio = m_ua_vc->do_io_read(this, INT64_MAX, m_ua_read_buf);
 }
 
 void
@@ -394,7 +394,7 @@ SimpleCont::os_read_resp()
 
   SET_HANDLER(&SimpleCont::os_read_resp_event);
 
-  m_os_read_vio = m_os_vc->do_io_read(this, INT_MAX, m_os_read_buf);
+  m_os_read_vio = m_os_vc->do_io_read(this, INT64_MAX, m_os_read_buf);
 }
 
 void
@@ -502,11 +502,11 @@ SimpleCont::os_ua_tunnel()
 {
   SET_HANDLER(&SimpleCont::os_ua_tunnel_event);
 
-  m_os_read_vio = m_os_vc->do_io_read(this, INT_MAX, m_ua_write_buf);
+  m_os_read_vio = m_os_vc->do_io_read(this, INT64_MAX, m_ua_write_buf);
   if (m_cache_write_vc) {
-    m_cache_write_vio = m_cache_write_vc->do_io_write(this, INT_MAX, m_ua_reader->clone());
+    m_cache_write_vio = m_cache_write_vc->do_io_write(this, INT64_MAX, m_ua_reader->clone());
   }
-  m_ua_write_vio = m_ua_vc->do_io_write(this, INT_MAX, m_ua_reader);
+  m_ua_write_vio = m_ua_vc->do_io_write(this, INT64_MAX, m_ua_reader);
 }
 
 void

Modified: trafficserver/traffic/trunk/proxy/SocksProxy.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/SocksProxy.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/SocksProxy.cc (original)
+++ trafficserver/traffic/trunk/proxy/SocksProxy.cc Fri Jan  7 00:36:08 2011
@@ -164,7 +164,7 @@ SocksProxy::mainEvent(int event, void *d
       buf->reset();
       timeout = this_ethread()
         ->schedule_in(this, HRTIME_SECONDS(netProcessor.socks_conf_stuff->socks_timeout));
-      clientVC->do_io_read(this, INT_MAX, buf);
+      clientVC->do_io_read(this, INT64_MAX, buf);
     }
 
     break;

Modified: trafficserver/traffic/trunk/proxy/Stuffer.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/Stuffer.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/Stuffer.cc (original)
+++ trafficserver/traffic/trunk/proxy/Stuffer.cc Fri Jan  7 00:36:08 2011
@@ -239,7 +239,7 @@ Stuffer::mainEvent(int event, void *data
     reader = buf->alloc_reader();
     buf->water_mark = buf->block_write_avail();
 
-    source_vio = source_vc->do_io_read(this, INT_MAX, buf);
+    source_vio = source_vc->do_io_read(this, INT64_MAX, buf);
     break;
 
   case VC_EVENT_EOS:

Modified: trafficserver/traffic/trunk/proxy/TestHook.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/TestHook.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/TestHook.cc (original)
+++ trafficserver/traffic/trunk/proxy/TestHook.cc Fri Jan  7 00:36:08 2011
@@ -465,7 +465,7 @@ public:
 //          printf("*** Got Request, %d Transactions Currently Open ***\n",
 //                 state_machine_count);
       StateMachine *sm = new StateMachine(nvc);
-        sm->ivio = nvc->do_io(VIO::READ, sm, INT_MAX, sm->ibuf);
+        sm->ivio = nvc->do_io(VIO::READ, sm, INT64_MAX, sm->ibuf);
     } else
     {
       printf("AcceptContinuation error %d\n", event);

Modified: trafficserver/traffic/trunk/proxy/TestProxy.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/TestProxy.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/TestProxy.cc (original)
+++ trafficserver/traffic/trunk/proxy/TestProxy.cc Fri Jan  7 00:36:08 2011
@@ -177,7 +177,7 @@ struct TestProxy:Continuation
       if (!data)
         return done();
       remote = (VConnection *) data;
-      clusterOutVIO = remote->do_io(VIO::WRITE, this, INT_MAX, inbuf);
+      clusterOutVIO = remote->do_io(VIO::WRITE, this, INT64_MAX, inbuf);
       ink_assert(clusterOutVIO);
       SET_HANDLER(tunnelEvent);
       tunnel = new OneWayTunnel(remote, vc, this, TUNNEL_TILL_DONE, true, true, true);
@@ -192,7 +192,7 @@ struct TestProxy:Continuation
     if (!vc)
       return done();
     SET_HANDLER(startEvent);
-    vc->do_io(VIO::READ, this, INT_MAX, inbuf);
+    vc->do_io(VIO::READ, this, INT64_MAX, inbuf);
     return EVENT_CONT;
   }
 
@@ -289,7 +289,7 @@ struct TestProxy:Continuation
     *url_end = 0;
     sprintf(outbuf->start, "GET %s HTTP/1.0\nHost: %s\n\n", url, host);
     outbuf->fill(strlen(outbuf->start) + 1);
-    remote->do_io(VIO::WRITE, this, INT_MAX, outbuf);
+    remote->do_io(VIO::WRITE, this, INT64_MAX, outbuf);
     // printf("sending [%s]\n",outbuf->start);
     return EVENT_CONT;
   }
@@ -324,7 +324,7 @@ struct TestProxy:Continuation
     *url_end = 0;
     sprintf(outbuf->start, "GET %s HTTP/1.0\nHost: %s\n\n", url, host);
     outbuf->fill(strlen(outbuf->start) + 1);
-    remote->do_io(VIO::WRITE, this, INT_MAX, outbuf);
+    remote->do_io(VIO::WRITE, this, INT64_MAX, outbuf);
     // printf("sending [%s]\n",outbuf->start);
     return EVENT_CONT;
   }
@@ -382,7 +382,7 @@ struct TestAccept:Continuation
   {
     if (event == NET_EVENT_ACCEPT) {
       MIOBuffer *buf = new_MIOBuffer();
-        e->do_io(VIO::READ, new TestProxy(buf), INT_MAX, buf);
+        e->do_io(VIO::READ, new TestProxy(buf), INT64_MAX, buf);
     } else
     {
       printf("TestAccept error %d\n", event);

Modified: trafficserver/traffic/trunk/proxy/TestSimpleProxy.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/TestSimpleProxy.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/TestSimpleProxy.cc (original)
+++ trafficserver/traffic/trunk/proxy/TestSimpleProxy.cc Fri Jan  7 00:36:08 2011
@@ -93,7 +93,7 @@ struct TestProxy:Continuation
     }
     remote = aremote;
     outbuf = new_MIOBuffer();
-    remote->do_io(VIO::WRITE, this, INT_MAX, outbuf);
+    remote->do_io(VIO::WRITE, this, INT64_MAX, outbuf);
     *url_end = 0;
     sprintf(outbuf->start, "GET %s HTTP/1.0\n\n\n", url);
     outbuf->fill(strlen(outbuf->start) + 1);
@@ -141,7 +141,7 @@ struct TestAccept:Continuation
   {
     if (!event) {
       MIOBuffer *buf = new_MIOBuffer();
-        e->do_io(VIO::READ, new TestProxy(buf), INT_MAX, buf);
+        e->do_io(VIO::READ, new TestProxy(buf), INT64_MAX, buf);
     } else
     {
       printf("TestAccept error %d\n", event);

Modified: trafficserver/traffic/trunk/proxy/Transform.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/Transform.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/Transform.cc (original)
+++ trafficserver/traffic/trunk/proxy/Transform.cc Fri Jan  7 00:36:08 2011
@@ -602,7 +602,7 @@ TransformControl::handle_event(int event
   case TRANSFORM_READ_READY:{
       MIOBuffer *buf = new_empty_MIOBuffer();
       m_read_buf = buf->alloc_reader();
-      m_tvc->do_io_read(this, INT_MAX, buf);
+      m_tvc->do_io_read(this, INT64_MAX, buf);
       break;
     }
 

Modified: trafficserver/traffic/trunk/proxy/Update.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/Update.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/Update.cc (original)
+++ trafficserver/traffic/trunk/proxy/Update.cc Fri Jan  7 00:36:08 2011
@@ -2643,7 +2643,7 @@ ObjectReloadCont::ObjectReloadEvent(int 
         _state = ObjectReloadCont::READING_DATA;
         _receive_data = new_MIOBuffer(max_iobuffer_size);
         _receive_data_reader = _receive_data->alloc_reader();
-        _read_vio = _netvc->do_io_read(this, INT_MAX, _receive_data);
+        _read_vio = _netvc->do_io_read(this, INT64_MAX, _receive_data);
         return EVENT_DONE;
       } else {
         // Write error, terminate processing

Modified: trafficserver/traffic/trunk/proxy/http2/HttpClientSession.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/http2/HttpClientSession.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/http2/HttpClientSession.cc (original)
+++ trafficserver/traffic/trunk/proxy/http2/HttpClientSession.cc Fri Jan  7 00:36:08 2011
@@ -293,7 +293,7 @@ HttpClientSession::do_io_close(int alerr
     //  the do_io_write() call (INKqa05309)
     client_vc->do_io_shutdown(IO_SHUTDOWN_WRITE);
 
-    ka_vio = client_vc->do_io_read(this, INT_MAX, read_buffer);
+    ka_vio = client_vc->do_io_read(this, INT64_MAX, read_buffer);
     ink_assert(slave_ka_vio != ka_vio);
 
     // [bug 2610799] Drain any data read.
@@ -545,7 +545,7 @@ HttpClientSession::attach_server_session
     //  have it call the client session back.  This IO also prevent
     //  the server net conneciton from calling back a dead sm
     SET_HANDLER(&HttpClientSession::state_keep_alive);
-    slave_ka_vio = ssession->do_io_read(this, INT_MAX, ssession->read_buffer);
+    slave_ka_vio = ssession->do_io_read(this, INT64_MAX, ssession->read_buffer);
     ink_assert(slave_ka_vio != ka_vio);
 
     // Transfer control of the write side as well
@@ -604,7 +604,7 @@ HttpClientSession::release(IOBufferReade
     Debug("http_cs", "[%" PRId64 "] initiating io for next header", con_id);
     read_state = HCS_KEEP_ALIVE;
     SET_HANDLER(&HttpClientSession::state_keep_alive);
-    ka_vio = this->do_io_read(this, INT_MAX, read_buffer);
+    ka_vio = this->do_io_read(this, INT64_MAX, read_buffer);
     ink_assert(slave_ka_vio != ka_vio);
     client_vc->set_inactivity_timeout(HRTIME_SECONDS(ka_in));
     client_vc->set_active_timeout(HRTIME_SECONDS(ka_in));

Modified: trafficserver/traffic/trunk/proxy/http2/HttpSM.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/http2/HttpSM.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/http2/HttpSM.cc (original)
+++ trafficserver/traffic/trunk/proxy/http2/HttpSM.cc Fri Jan  7 00:36:08 2011
@@ -684,7 +684,7 @@ HttpSM::setup_client_read_request_header
     }
   }
 
-  ua_entry->read_vio = ua_session->do_io_read(this, INT_MAX, ua_buffer_reader->mbuf);
+  ua_entry->read_vio = ua_session->do_io_read(this, INT64_MAX, ua_buffer_reader->mbuf);
 }
 
 void
@@ -866,7 +866,7 @@ HttpSM::state_drain_client_request_body(
 
       ua_buffer_reader->mbuf->size_index = HTTP_HEADER_BUFFER_SIZE_INDEX;
       ua_entry->vc_handler = &HttpSM::state_watch_for_client_abort;
-      ua_entry->read_vio = ua_entry->vc->do_io_read(this, INT_MAX, ua_buffer_reader->mbuf);
+      ua_entry->read_vio = ua_entry->vc->do_io_read(this, INT64_MAX, ua_buffer_reader->mbuf);
       call_transact_and_set_next_state(NULL);
       break;
     }
@@ -974,7 +974,7 @@ HttpSM::setup_push_read_response_header(
   //  the cache
   if (resp_hdr_state == VC_EVENT_CONT) {
     ink_assert(ua_entry->eos == false);
-    ua_entry->read_vio = ua_session->do_io_read(this, INT_MAX, ua_buffer_reader->mbuf);
+    ua_entry->read_vio = ua_session->do_io_read(this, INT64_MAX, ua_buffer_reader->mbuf);
   }
 }
 
@@ -1150,7 +1150,7 @@ HttpSM::state_request_wait_for_transform
 
   switch (event) {
   case TRANSFORM_READ_READY:
-    if (size != INT_MAX && size >= 0) {
+    if (size != INT64_MAX && size >= 0) {
       // We got a content length so update our internal
       //   data as well as fix up the request header
       t_state.hdr_info.transform_request_cl = size;
@@ -1190,7 +1190,7 @@ HttpSM::state_response_wait_for_transfor
 
   switch (event) {
   case TRANSFORM_READ_READY:
-    if (size != INT_MAX && size >= 0) {
+    if (size != INT64_MAX && size >= 0) {
       // We got a content length so update our internal state
       t_state.hdr_info.transform_response_cl = size;
       t_state.hdr_info.transform_response.value_set_int(MIME_FIELD_CONTENT_LENGTH, MIME_LEN_CONTENT_LENGTH, size);
@@ -3183,7 +3183,7 @@ HttpSM::tunnel_handler_cache_read(int ev
   case VC_EVENT_ERROR:
   case VC_EVENT_EOS:
     ink_debug_assert(t_state.cache_info.object_read->valid());
-    if (t_state.cache_info.object_read->object_size_get() != INT_MAX || event == VC_EVENT_ERROR) {
+    if (t_state.cache_info.object_read->object_size_get() != INT64_MAX || event == VC_EVENT_ERROR) {
       // Abnormal termination
       t_state.squid_codes.log_code = SQUID_LOG_TCP_SWAPFAIL;
       t_state.squid_codes.wuts_proxy_status_code =
@@ -3196,7 +3196,7 @@ HttpSM::tunnel_handler_cache_read(int ev
       break;
     } else {
       tunnel.local_finish_all(p);
-      // fall through for the case INT_MAX read with VC_EVENT_EOS
+      // fall through for the case INT64_MAX read with VC_EVENT_EOS
       // callback (read successful)
     }
   case VC_EVENT_READ_COMPLETE:
@@ -3312,7 +3312,7 @@ HttpSM::tunnel_handler_post_ua(int event
     // Initiate another read to watch catch aborts and
     //   timeouts
     ua_entry->vc_handler = &HttpSM::state_watch_for_client_abort;
-    ua_entry->read_vio = p->vc->do_io_read(this, INT_MAX, ua_buffer_reader->mbuf);
+    ua_entry->read_vio = p->vc->do_io_read(this, INT64_MAX, ua_buffer_reader->mbuf);
     break;
   default:
     ink_release_assert(0);
@@ -3405,7 +3405,7 @@ HttpSM::tunnel_handler_post_server(int e
     //do not shut down the client read
     if (enable_redirection) {
       if (ua_producer->vc_type == HT_STATIC && event != VC_EVENT_ERROR && event != VC_EVENT_EOS) {
-        ua_entry->read_vio = ua_producer->vc->do_io_read(this, INT_MAX, c->producer->read_buffer);
+        ua_entry->read_vio = ua_producer->vc->do_io_read(this, INT64_MAX, c->producer->read_buffer);
         //ua_producer->vc->do_io_shutdown(IO_SHUTDOWN_READ);
         t_state.client_info.pipeline_possible = false;
       } else {
@@ -3414,7 +3414,7 @@ HttpSM::tunnel_handler_post_server(int e
         }
       }
     } else {
-      ua_entry->read_vio = ua_producer->vc->do_io_read(this, INT_MAX, c->producer->read_buffer);
+      ua_entry->read_vio = ua_producer->vc->do_io_read(this, INT64_MAX, c->producer->read_buffer);
       // we should not shutdown read side of the client here to prevent sending a reset
       //ua_producer->vc->do_io_shutdown(IO_SHUTDOWN_READ);
       t_state.client_info.pipeline_possible = false;
@@ -4725,7 +4725,7 @@ HttpSM::handle_server_setup_error(int ev
       ink_assert(ua_entry->vc == ua_producer->vc);
 
       ua_entry->vc_handler = &HttpSM::state_watch_for_client_abort;
-      ua_entry->read_vio = ua_producer->vc->do_io_read(this, INT_MAX, c->producer->read_buffer);
+      ua_entry->read_vio = ua_producer->vc->do_io_read(this, INT64_MAX, c->producer->read_buffer);
       ua_producer->vc->do_io_shutdown(IO_SHUTDOWN_READ);
 
       ua_producer->alive = false;
@@ -4908,7 +4908,7 @@ HttpSM::do_setup_post_tunnel(HttpVC_t to
     }
     MIOBuffer *post_buffer = new_MIOBuffer(alloc_index);
     IOBufferReader *buf_start = post_buffer->alloc_reader();
-    int64_t post_bytes = chunked ? INT_MAX : t_state.hdr_info.request_content_length;
+    int64_t post_bytes = chunked ? INT64_MAX : t_state.hdr_info.request_content_length;
     t_state.hdr_info.request_body_start = true;
     // Note: Many browers, Netscape and IE included send two extra
     //  bytes (CRLF) at the end of the post.  We just ignore those
@@ -5152,7 +5152,7 @@ HttpSM::attach_server_session(HttpServer
   //  do the read with a buffer and a size so preallocate the
   //  buffer
   server_buffer_reader = server_session->get_reader();
-  server_entry->read_vio = server_session->do_io_read(this, INT_MAX, server_session->read_buffer);
+  server_entry->read_vio = server_session->do_io_read(this, INT64_MAX, server_session->read_buffer);
 
   // This call cannot be canceled or disabled on Windows at a different
   // time (callstack). After this function, all transactions will send
@@ -5162,7 +5162,7 @@ HttpSM::attach_server_session(HttpServer
   // reading until writing the request completed. That turned out to be
   // for the second do_io_read(), the way to reenable() reading once
   // disabled, but still the result of this do_io_read came in. For this
-  // read holds: server_entry->read_vio == INT_MAX
+  // read holds: server_entry->read_vio == INT64_MAX
   // This block of read events gets undone in setup_server_read_response()
 
   // Transfer control of the write side as well
@@ -5322,7 +5322,7 @@ HttpSM::setup_server_read_response_heade
         server_entry->read_vio->nbytes == server_entry->read_vio->ndone &&
         milestones.server_read_header_done == 0) {
       ink_assert(server_entry->eos == false);
-      server_entry->read_vio = server_session->do_io_read(this, INT_MAX, server_buffer_reader->mbuf);
+      server_entry->read_vio = server_session->do_io_read(this, INT64_MAX, server_buffer_reader->mbuf);
     }
   }
 }
@@ -5355,7 +5355,7 @@ HttpSM::setup_cache_read_transfer()
 
   HTTP_SM_SET_DEFAULT_HANDLER(&HttpSM::tunnel_handler);
 
-  doc_size = (doc_size == INT_MAX) ? INT_MAX : (doc_size + hdr_size);
+  doc_size = (doc_size == INT64_MAX) ? INT64_MAX : (doc_size + hdr_size);
   HttpTunnelProducer *p = tunnel.add_producer(cache_sm.cache_read_vc,
                                               doc_size, buf_start, &HttpSM::tunnel_handler_cache_read, HT_CACHE_READ,
                                               "cache read");
@@ -5721,7 +5721,7 @@ HttpSM::setup_transfer_from_transform()
   HTTP_SM_SET_DEFAULT_HANDLER(&HttpSM::tunnel_handler);
 
   HttpTunnelProducer *p = tunnel.add_producer(transform_info.vc,
-                                              INT_MAX,
+                                              INT64_MAX,
                                               buf_start,
                                               &HttpSM::tunnel_handler_transform_read,
                                               HT_TRANSFORM,
@@ -5753,7 +5753,7 @@ HttpSM::setup_transfer_from_transform_to
   HTTP_SM_SET_DEFAULT_HANDLER(&HttpSM::tunnel_handler);
 
   HttpTunnelProducer *p = tunnel.add_producer(transform_info.vc,
-                                              INT_MAX,
+                                              INT64_MAX,
                                               buf_start,
                                               &HttpSM::tunnel_handler_transform_read,
                                               HT_TRANSFORM,

Modified: trafficserver/traffic/trunk/proxy/http2/HttpSessionManager.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/http2/HttpSessionManager.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/http2/HttpSessionManager.cc (original)
+++ trafficserver/traffic/trunk/proxy/http2/HttpSessionManager.cc Fri Jan  7 00:36:08 2011
@@ -310,7 +310,7 @@ HttpSessionManager::release_session(Http
     //  if it closes on us.  We will get called back in the
     //  continuation for this bucket, ensuring we have the lock
     //  to remove the connection from our lists
-    to_release->do_io_read(bucket, INT_MAX, to_release->read_buffer);
+    to_release->do_io_read(bucket, INT64_MAX, to_release->read_buffer);
 
     // Transfer control of the write side as well
     to_release->do_io_write(bucket, 0, NULL);

Modified: trafficserver/traffic/trunk/proxy/http2/test_socket_close.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/http2/test_socket_close.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/http2/test_socket_close.cc (original)
+++ trafficserver/traffic/trunk/proxy/http2/test_socket_close.cc Fri Jan  7 00:36:08 2011
@@ -96,8 +96,8 @@ struct State
   State_t state;
   int tasks_count;
   Task_t tasks[100];
-  int nbytes_write;             // number of bytes to write
-  int nbytes_read;              // number of bytes to read
+  int64_t nbytes_write;             // number of bytes to write
+  intte_t nbytes_read;              // number of bytes to read
 
     State():state(STATE_IDLE), tasks_count(0)
   {

Modified: trafficserver/traffic/trunk/proxy/logging/LogConfig.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/proxy/logging/LogConfig.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/proxy/logging/LogConfig.cc (original)
+++ trafficserver/traffic/trunk/proxy/logging/LogConfig.cc Fri Jan  7 00:36:08 2011
@@ -604,18 +604,18 @@ LogConfig::read_configuration_variables(
   default value if we get garbage back from the config file.
   -------------------------------------------------------------------------*/
 
+// TODO: Is UINT_MAX here really correct?
 LogConfig::LogConfig()
-:
-initialized(false),
-reconfiguration_needed(false),
-logging_space_exhausted(false), m_space_used(0), m_partition_space_left((int64_t) UINT_MAX),
+  : initialized(false),
+    reconfiguration_needed(false),
+    logging_space_exhausted(false), m_space_used(0), m_partition_space_left((int64_t) UINT_MAX),
 #if defined (IOCORE_LOG_COLLATION)
-  m_log_collation_accept(NULL),
+    m_log_collation_accept(NULL),
 #endif
-  m_dir_entry(NULL),
-m_pDir(NULL),
-m_disk_full(false),
-m_disk_low(false), m_partition_full(false), m_partition_low(false), m_log_directory_inaccessible(false)
+    m_dir_entry(NULL),
+    m_pDir(NULL),
+    m_disk_full(false),
+    m_disk_low(false), m_partition_full(false), m_partition_low(false), m_log_directory_inaccessible(false)
 {
   // Setup the default values for all LogConfig public variables so that
   // a LogConfig object is valid upon return from the constructor even

Modified: trafficserver/traffic/trunk/test/plugin/INKContinuations/ServerSM.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/test/plugin/INKContinuations/ServerSM.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/test/plugin/INKContinuations/ServerSM.cc (original)
+++ trafficserver/traffic/trunk/test/plugin/INKContinuations/ServerSM.cc Fri Jan  7 00:36:08 2011
@@ -973,7 +973,7 @@ state_connect_to_server(TSCont contp, in
 
   set_handler(Server->q_server_current_handler, &state_main_event);
   assert(Server->q_server_response_buffer);
-  Server->q_server_read_vio = TSVConnRead(Server->q_server_vc, contp, Server->q_server_response_buffer, INT_MAX);
+  Server->q_server_read_vio = TSVConnRead(Server->q_server_vc, contp, Server->q_server_response_buffer, INT64_MAX);
 
   assert(Server->q_server_read_vio);
   server_send_request(contp);

Modified: trafficserver/traffic/trunk/test/plugin/assembly/assembly.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/test/plugin/assembly/assembly.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/test/plugin/assembly/assembly.c (original)
+++ trafficserver/traffic/trunk/test/plugin/assembly/assembly.c Fri Jan  7 00:36:08 2011
@@ -1353,7 +1353,7 @@ asm_ts_read_init(TSCont contp, AsmData *
   data->block_reader = TSIOBufferReaderAlloc(data->block_buffer);
 
   /* Read data on the socket back. Try to read the maximum */
-  data->ts_vio = TSVConnRead(data->ts_vc, contp, data->ts_output_buffer, INT_MAX);
+  data->ts_vio = TSVConnRead(data->ts_vc, contp, data->ts_output_buffer, INT64_MAX);
 
   return 0;
 }

Modified: trafficserver/traffic/trunk/test/plugin/plugin_as_origin/http_connect_bridge.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/test/plugin/plugin_as_origin/http_connect_bridge.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/test/plugin/plugin_as_origin/http_connect_bridge.c (original)
+++ trafficserver/traffic/trunk/test/plugin/plugin_as_origin/http_connect_bridge.c Fri Jan  7 00:36:08 2011
@@ -434,20 +434,20 @@ pvc_process_accept(TSVConn net_vc)
     LOG_ERROR_AND_CLEANUP("TSHttpConnect");
   }
 
-  my_state->h_read_vio = TSVConnRead(my_state->http_vc, contp, my_state->resp_buffer, INT_MAX);
+  my_state->h_read_vio = TSVConnRead(my_state->http_vc, contp, my_state->resp_buffer, INT64_MAX);
   if (my_state->h_read_vio == TS_ERROR_PTR) {
     LOG_ERROR_AND_CLEANUP("TSVConnRead");
   }
-  my_state->h_write_vio = TSVConnWrite(my_state->http_vc, contp, my_state->req_reader, INT_MAX);
+  my_state->h_write_vio = TSVConnWrite(my_state->http_vc, contp, my_state->req_reader, INT64_MAX);
   if (my_state->h_write_vio == TS_ERROR_PTR) {
     LOG_ERROR_AND_CLEANUP("TSVConnWrite");
   }
 
-  my_state->n_read_vio = TSVConnRead(my_state->net_vc, contp, my_state->req_buffer, INT_MAX);
+  my_state->n_read_vio = TSVConnRead(my_state->net_vc, contp, my_state->req_buffer, INT64_MAX);
   if (my_state->n_read_vio == TS_ERROR_PTR) {
     LOG_ERROR_AND_CLEANUP("TSVConnRead");
   }
-  my_state->n_write_vio = TSVConnWrite(my_state->net_vc, contp, my_state->resp_reader, INT_MAX);
+  my_state->n_write_vio = TSVConnWrite(my_state->net_vc, contp, my_state->resp_reader, INT64_MAX);
   if (my_state->n_write_vio == TS_ERROR_PTR) {
     LOG_ERROR_AND_CLEANUP("TSVConnWrite");
   }

Modified: trafficserver/traffic/trunk/test/plugin/plugin_as_origin/net_bridge.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/test/plugin/plugin_as_origin/net_bridge.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/test/plugin/plugin_as_origin/net_bridge.c (original)
+++ trafficserver/traffic/trunk/test/plugin/plugin_as_origin/net_bridge.c Fri Jan  7 00:36:08 2011
@@ -313,23 +313,23 @@ pvc_process_connect(TSCont contp, int ev
     */
     my_state->connect_timeout_event = TSContSchedule(contp, 30 * 1000, TS_THREAD_POOL_DEFAULT);
 
-    my_state->p_read_vio = TSVConnRead(my_state->p_vc, contp, my_state->req_buffer, INT_MAX);
+    my_state->p_read_vio = TSVConnRead(my_state->p_vc, contp, my_state->req_buffer, INT64_MAX);
     if (my_state->p_read_vio == TS_ERROR_PTR) {
       LOG_ERROR("TSVConnRead");
       return;
     }
-    my_state->p_write_vio = TSVConnWrite(my_state->p_vc, contp, my_state->resp_reader, INT_MAX);
+    my_state->p_write_vio = TSVConnWrite(my_state->p_vc, contp, my_state->resp_reader, INT64_MAX);
     if (my_state->p_write_vio == TS_ERROR_PTR) {
       LOG_ERROR("TSVConnWrite");
       return;
     }
 
-    my_state->n_read_vio = TSVConnRead(my_state->net_vc, contp, my_state->resp_buffer, INT_MAX);
+    my_state->n_read_vio = TSVConnRead(my_state->net_vc, contp, my_state->resp_buffer, INT64_MAX);
     if (my_state->n_read_vio == TS_ERROR_PTR) {
       LOG_ERROR("TSVConnRead");
       return;
     }
-    my_state->n_write_vio = TSVConnWrite(my_state->net_vc, contp, my_state->req_reader, INT_MAX);
+    my_state->n_write_vio = TSVConnWrite(my_state->net_vc, contp, my_state->req_reader, INT64_MAX);
     if (my_state->n_write_vio == TS_ERROR_PTR) {
       LOG_ERROR("TSVConnWrite");
       return;

Modified: trafficserver/traffic/trunk/test/plugin/plugin_as_origin/serve_file.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/test/plugin/plugin_as_origin/serve_file.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/test/plugin/plugin_as_origin/serve_file.c (original)
+++ trafficserver/traffic/trunk/test/plugin/plugin_as_origin/serve_file.c Fri Jan  7 00:36:08 2011
@@ -175,7 +175,7 @@ pvc_process_accept(TSCont contp, pvc_sta
     return;
   }
 
-  my_state->read_vio = TSVConnRead(my_state->net_vc, contp, my_state->req_buffer, INT_MAX);
+  my_state->read_vio = TSVConnRead(my_state->net_vc, contp, my_state->req_buffer, INT64_MAX);
   if (my_state->read_vio == TS_ERROR_PTR) {
     LOG_ERROR("TSVConnRead");
     return;
@@ -210,7 +210,7 @@ pvc_process_read(TSCont contp, TSEvent e
       TSDebug(NEG_DEBUG_TAG, "Negative Test TSVConnShutdown 1 passed");
 #endif
 
-    my_state->write_vio = TSVConnWrite(my_state->net_vc, contp, my_state->resp_reader, INT_MAX);
+    my_state->write_vio = TSVConnWrite(my_state->net_vc, contp, my_state->resp_reader, INT64_MAX);
     if (my_state->write_vio == TS_ERROR_PTR) {
       LOG_ERROR("TSVConnWrite");
       return;

Modified: trafficserver/traffic/trunk/test/plugin/test-protocol/test-protocol.c
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/test/plugin/test-protocol/test-protocol.c?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/test/plugin/test-protocol/test-protocol.c (original)
+++ trafficserver/traffic/trunk/test/plugin/test-protocol/test-protocol.c Fri Jan  7 00:36:08 2011
@@ -468,7 +468,7 @@ start_handler(TSCont contp, TSEvent even
 
   /* start reading request from the client */
   if ((conn_data->client_read_vio = TSVConnRead(conn_data->client_vconn, (TSCont) contp,
-                                                 conn_data->client_request_buffer, INT_MAX)) == TS_ERROR_PTR) {
+                                                 conn_data->client_request_buffer, INT64_MAX)) == TS_ERROR_PTR) {
     LOG_ERROR("TSVConnRead");
     clean_and_exit(contp);
     return -1;

Modified: trafficserver/traffic/trunk/test/plugin/test-protocol/test-protocol.cc
URL: http://svn.apache.org/viewvc/trafficserver/traffic/trunk/test/plugin/test-protocol/test-protocol.cc?rev=1056140&r1=1056139&r2=1056140&view=diff
==============================================================================
--- trafficserver/traffic/trunk/test/plugin/test-protocol/test-protocol.cc (original)
+++ trafficserver/traffic/trunk/test/plugin/test-protocol/test-protocol.cc Fri Jan  7 00:36:08 2011
@@ -436,7 +436,7 @@ start_handler(TSCont contp, TSEvent even
 
   /* start reading request from the client */
   if ((conn_data->client_read_vio = TSVConnRead(conn_data->client_vconn, (TSCont) contp,
-                                                 conn_data->client_request_buffer, INT_MAX)) == TS_ERROR_PTR) {
+                                                 conn_data->client_request_buffer, INT64_MAX)) == TS_ERROR_PTR) {
     LOG_ERROR("TSVConnRead");
     clean_and_exit(contp);
     return -1;



Mime
View raw message