Revert "Close connection to PXF when query to external table is cance…

…led (#42)"

This reverts commit 21efde5.

external-table/src/pxfbridge.c

@@ -40,7 +40,7 @@ gpbridge_cleanup(gphadoop_context *context)
 	if (context == NULL)
 		return;
 
-	churl_cleanup(context->churl_handle, context->after_error);
+	churl_cleanup(context->churl_handle, false);
 	context->churl_handle = NULL;
 
 	churl_headers_cleanup(context->churl_headers);

external-table/src/pxfbridge.h

@@ -43,7 +43,6 @@ typedef struct
 	ProjectionInfo *proj_info;
 	List           *quals;
 	bool           completed;
-	bool           after_error;
 } gphadoop_context;
 
 /*

external-table/src/pxfprotocol.c

@@ -26,7 +26,6 @@
 #include "access/fileam.h"
 #endif
 #include "utils/elog.h"
-#include "utils/resowner.h"
 
 /* define magic module unless run as a part of test cases */
 #ifndef UNIT_TESTING
@@ -155,21 +154,6 @@ pxfprotocol_import(PG_FUNCTION_ARGS)
 	PG_RETURN_INT32(bytes_read);
 }
 
-static void
-url_curl_abort_callback(ResourceReleasePhase phase,
-						bool isCommit,
-						bool isTopLevel,
-						void *arg)
-{
-	gphadoop_context *context = arg;
-
-	if (phase != RESOURCE_RELEASE_AFTER_LOCKS || isCommit || !isTopLevel)
-		return;
-
-	context->after_error = true;
-	cleanup_context(context);
-}
-
 /*
  * Allocates context and sets values for the segment
  */
@@ -206,8 +190,6 @@ create_context(PG_FUNCTION_ARGS, bool is_import)
 	context->proj_info = proj_info;
 	context->quals     = filter_quals;
 	context->completed = false;
-	context->after_error = false;
-	RegisterResourceReleaseCallback(url_curl_abort_callback, context);
 	return context;
 }
 
@@ -219,7 +201,6 @@ cleanup_context(gphadoop_context *context)
 {
 	if (context != NULL)
 	{
-		UnregisterResourceReleaseCallback(url_curl_abort_callback, context);
 		gpbridge_cleanup(context);
 		pfree(context->uri.data);
 		pfree(context);