(airavata) branch master updated: Clean dead members from VirtualStreamProducer (#669)

[yasith]

This is an automated email from the ASF dual-hosted git repository.

yasithdev pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/master by this push:
     new fa9fdd1d5a Clean dead members from VirtualStreamProducer (#669)
fa9fdd1d5a is described below

commit fa9fdd1d5a59ffb8ed4cbe6338bfce7749625525
Author: Yasith Jayawardana <yas...@gatech.edu>
AuthorDate: Sat Jun 13 00:59:04 2026 -0400

    Clean dead members from VirtualStreamProducer (#669)
    
    Remove the unused setInputStream/setOutputStream setters (0 callers; the 
streams
    are only ever set in the constructor and read via the getters), the dead 
local
    `ConcurrentLinkedQueue q` (the real buffer is the LinkedBlockingQueue 
`queue`),
    and the now-unused ConcurrentLinkedQueue import. The class stays — it is 
live
    via its constructor and getters in DataStagingTask.
---
 .../apache/airavata/storage/util/VirtualStreamProducer.java    | 10 ----------
 1 file changed, 10 deletions(-)

diff --git 
a/airavata-api/storage-service/src/main/java/org/apache/airavata/storage/util/VirtualStreamProducer.java
 
b/airavata-api/storage-service/src/main/java/org/apache/airavata/storage/util/VirtualStreamProducer.java
index 9ecd3c2d18..59a80c465c 100644
--- 
a/airavata-api/storage-service/src/main/java/org/apache/airavata/storage/util/VirtualStreamProducer.java
+++ 
b/airavata-api/storage-service/src/main/java/org/apache/airavata/storage/util/VirtualStreamProducer.java
@@ -22,7 +22,6 @@ package org.apache.airavata.storage.util;
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 
 public class VirtualStreamProducer {
@@ -31,7 +30,6 @@ public class VirtualStreamProducer {
     private OutputStream outputStream;
 
     public VirtualStreamProducer(int bufferSize, long streamLength) {
-        ConcurrentLinkedQueue q = new ConcurrentLinkedQueue();
         BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(bufferSize);
         inputStream = new VirtualInputStream(queue, streamLength);
         outputStream = new VirtualOutputStream(queue, streamLength);
@@ -41,15 +39,7 @@ public class VirtualStreamProducer {
         return inputStream;
     }
 
-    public void setInputStream(InputStream inputStream) {
-        this.inputStream = inputStream;
-    }
-
     public OutputStream getOutputStream() {
         return outputStream;
     }
-
-    public void setOutputStream(OutputStream outputStream) {
-        this.outputStream = outputStream;
-    }
 }