use streaming mode for long poll grpc calls

streaming mode would create separate grpc connections for each call.
this is to ensure the long poll connections are properly closed.

1 files changed, 9 insertions, 9 deletions

diff --git a/weed/pb/filer_pb/filer_client.go b/weed/pb/filer_pb/filer_client.go
index 719039d88..266bdae51 100644
--- a/weed/pb/filer_pb/filer_client.go
+++ b/weed/pb/filer_pb/filer_client.go
@@ -20,7 +20,7 @@ var (
 )
 
 type FilerClient interface {
-	WithFilerClient(fn func(SeaweedFilerClient) error) error
+	WithFilerClient(streamingMode bool, fn func(SeaweedFilerClient) error) error
 	AdjustedUrl(location *Location) string
 }
 
@@ -28,7 +28,7 @@ func GetEntry(filerClient FilerClient, fullFilePath util.FullPath) (entry *Entry
 
 	dir, name := fullFilePath.DirAndName()
 
-	err = filerClient.WithFilerClient(func(client SeaweedFilerClient) error {
+	err = filerClient.WithFilerClient(false, func(client SeaweedFilerClient) error {
 
 		request := &LookupDirectoryEntryRequest{
 			Directory: dir,
@@ -83,13 +83,13 @@ func ReadDirAllEntries(filerClient FilerClient, fullDirPath util.FullPath, prefi
 }
 
 func List(filerClient FilerClient, parentDirectoryPath, prefix string, fn EachEntryFunciton, startFrom string, inclusive bool, limit uint32) (err error) {
-	return filerClient.WithFilerClient(func(client SeaweedFilerClient) error {
+	return filerClient.WithFilerClient(false, func(client SeaweedFilerClient) error {
 		return doSeaweedList(client, util.FullPath(parentDirectoryPath), prefix, fn, startFrom, inclusive, limit)
 	})
 }
 
 func doList(filerClient FilerClient, fullDirPath util.FullPath, prefix string, fn EachEntryFunciton, startFrom string, inclusive bool, limit uint32) (err error) {
-	return filerClient.WithFilerClient(func(client SeaweedFilerClient) error {
+	return filerClient.WithFilerClient(false, func(client SeaweedFilerClient) error {
 		return doSeaweedList(client, fullDirPath, prefix, fn, startFrom, inclusive, limit)
 	})
 }
@@ -157,7 +157,7 @@ func doSeaweedList(client SeaweedFilerClient, fullDirPath util.FullPath, prefix
 
 func Exists(filerClient FilerClient, parentDirectoryPath string, entryName string, isDirectory bool) (exists bool, err error) {
 
-	err = filerClient.WithFilerClient(func(client SeaweedFilerClient) error {
+	err = filerClient.WithFilerClient(false, func(client SeaweedFilerClient) error {
 
 		request := &LookupDirectoryEntryRequest{
 			Directory: parentDirectoryPath,
@@ -185,7 +185,7 @@ func Exists(filerClient FilerClient, parentDirectoryPath string, entryName strin
 
 func Touch(filerClient FilerClient, parentDirectoryPath string, entryName string, entry *Entry) (err error) {
 
-	return filerClient.WithFilerClient(func(client SeaweedFilerClient) error {
+	return filerClient.WithFilerClient(false, func(client SeaweedFilerClient) error {
 
 		request := &UpdateEntryRequest{
 			Directory: parentDirectoryPath,
@@ -204,7 +204,7 @@ func Touch(filerClient FilerClient, parentDirectoryPath string, entryName string
 }
 
 func Mkdir(filerClient FilerClient, parentDirectoryPath string, dirName string, fn func(entry *Entry)) error {
-	return filerClient.WithFilerClient(func(client SeaweedFilerClient) error {
+	return filerClient.WithFilerClient(false, func(client SeaweedFilerClient) error {
 		return DoMkdir(client, parentDirectoryPath, dirName, fn)
 	})
 }
@@ -241,7 +241,7 @@ func DoMkdir(client SeaweedFilerClient, parentDirectoryPath string, dirName stri
 }
 
 func MkFile(filerClient FilerClient, parentDirectoryPath string, fileName string, chunks []*FileChunk, fn func(entry *Entry)) error {
-	return filerClient.WithFilerClient(func(client SeaweedFilerClient) error {
+	return filerClient.WithFilerClient(false, func(client SeaweedFilerClient) error {
 
 		entry := &Entry{
 			Name:        fileName,
@@ -276,7 +276,7 @@ func MkFile(filerClient FilerClient, parentDirectoryPath string, fileName string
 }
 
 func Remove(filerClient FilerClient, parentDirectoryPath, name string, isDeleteData, isRecursive, ignoreRecursiveErr, isFromOtherCluster bool, signatures []int32) error {
-	return filerClient.WithFilerClient(func(client SeaweedFilerClient) error {
+	return filerClient.WithFilerClient(false, func(client SeaweedFilerClient) error {
 		return DoRemove(client, parentDirectoryPath, name, isDeleteData, isRecursive, ignoreRecursiveErr, isFromOtherCluster, signatures)
 	})
 }