test_class.declarator: connCtx = mock(ClientConnectionContext.class)
test_class.modifier: private static final
test_class.original_string: private static final ClientConnectionContext connCtx = mock(ClientConnectionContext.class);
test_class.type: ClientConnectionContext
test_class.var_name: connCtx
test_class.declarator: conf = new IgniteConfiguration()
          .setDiscoverySpi(new TcpDiscoverySpi()
              .setIpFinder(new TcpDiscoveryVmIpFinder()
                  .setAddresses(Collections.singletonList("127.0.0.1:47500..47509"))))
test_class.modifier: private static final
test_class.original_string: private static final IgniteConfiguration conf = new IgniteConfiguration()
          .setDiscoverySpi(new TcpDiscoverySpi()
              .setIpFinder(new TcpDiscoveryVmIpFinder()
                  .setAddresses(Collections.singletonList("127.0.0.1:47500..47509"))));
test_class.type: IgniteConfiguration
test_class.var_name: conf
test_class.declarator: bctx = new BinaryContext(
          BinaryNoopMetadataHandler.instance(),
          conf,
          new NullLogger()
      )
test_class.modifier: private static final
test_class.original_string: private static final BinaryContext bctx = new BinaryContext(
          BinaryNoopMetadataHandler.instance(),
          conf,
          new NullLogger()
      );
test_class.type: BinaryContext
test_class.var_name: bctx
test_class.declarator: file1 = new byte[] {0, 1, 2, 3, 4, 5}
test_class.modifier: private static final
test_class.original_string: private static final byte[] file1 = new byte[] {0, 1, 2, 3, 4, 5};
test_class.type: byte[]
test_class.var_name: file1
test_class.declarator: pathToFile1 = "/a/b/file_1"
test_class.modifier: private static final
test_class.original_string: private static final String pathToFile1 = "/a/b/file_1";
test_class.type: String
test_class.var_name: pathToFile1
test_class.declarator: ignite
test_class.modifier: private
test_class.original_string: private Ignite ignite;
test_class.type: Ignite
test_class.var_name: ignite
test_class.declarator: ms
test_class.modifier: private
test_class.original_string: private ModelStorage ms;
test_class.type: ModelStorage
test_class.var_name: ms
test_class.declarator: msp
test_class.modifier: private
test_class.original_string: private ModelStorateThinClientProcessor msp;
test_class.type: ModelStorateThinClientProcessor
test_class.var_name: msp
test_class.declarator: cache
test_class.modifier: private
test_class.original_string: private IgniteCache<String, FileOrDirectory> cache;
test_class.type: IgniteCache<String, FileOrDirectory>
test_class.var_name: cache
test_class.file: modules/ml/src/test/java/org/apache/ignite/ml/inference/storage/model/thinclient/ModelStorateThinClientProcessorTest.java
test_class.identifier: ModelStorateThinClientProcessorTest
test_class.superclass: extends GridCommonAbstractTest
test_case.body: @Test
      public void testPutFile3() {
          long reqId = 21;
  
          String path = "/a/b/testPutFile3";
          boolean create = false;
          boolean append = true;
          byte[] data = new byte[] {6, 5, 4, 3, 2, 1, 0};
  
          BinaryRawWriterEx message = createMessage(reqId, ModelStorateThinClientProcessor.PROCESSOR_ID, ModelStorateThinClientProcessor.Method.WRITE_FILE);
          message.writeString(path);
          message.writeBoolean(create);
          message.writeBoolean(append);
          message.writeByteArray(data);
  
          ClientCustomQueryRequest req = new ClientCustomQueryRequest(toReader(message));
          ClientResponse resp = req.process(connCtx);
          assertEquals(ClientStatus.FAILED, resp.status()); // error
          assertFalse(resp.error().isEmpty());
      }
test_case.class_method_signature: ModelStorateThinClientProcessorTest.testPutFile3()
test_case.full_signature: @Test public void testPutFile3()
test_case.identifier: testPutFile3
test_case.invocations: createMessage writeString writeBoolean writeBoolean writeByteArray toReader process assertEquals status assertFalse isEmpty error
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testPutFile3()
focal_class.declarator: PROCESSOR_ID = "ML_MODEL_STORAGE"
focal_class.modifier: public static final
focal_class.original_string: public static final String PROCESSOR_ID = "ML_MODEL_STORAGE";
focal_class.type: String
focal_class.var_name: PROCESSOR_ID
focal_class.declarator: modelStorage
focal_class.modifier: private final
focal_class.original_string: private final ModelStorage modelStorage;
focal_class.type: ModelStorage
focal_class.var_name: modelStorage
focal_class.file: modules/ml/src/main/java/org/apache/ignite/ml/inference/storage/model/thinclient/ModelStorateThinClientProcessor.java
focal_class.identifier: ModelStorateThinClientProcessor
focal_class.interfaces: implements CustomQueryProcessor
focal_class.class_method_signature: ModelStorateThinClientProcessor.ModelStorateThinClientProcessor(ModelStorage modelStorage)
focal_class.full_signature: public  ModelStorateThinClientProcessor(ModelStorage modelStorage)
focal_class.identifier: ModelStorateThinClientProcessor
focal_class.modifiers: public
focal_class.parameters: (ModelStorage modelStorage)
focal_class.signature:  ModelStorateThinClientProcessor(ModelStorage modelStorage)
focal_class.class_method_signature: ModelStorateThinClientProcessor.call(long requestId, byte methodId, BinaryRawReader reader)
focal_class.full_signature: @Override public ClientResponse call(long requestId, byte methodId, BinaryRawReader reader)
focal_class.identifier: call
focal_class.modifiers: @Override public
focal_class.parameters: (long requestId, byte methodId, BinaryRawReader reader)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse call(long requestId, byte methodId, BinaryRawReader reader)
focal_class.class_method_signature: ModelStorateThinClientProcessor.writeFile(long reqId, BinaryRawReader reader)
focal_class.full_signature: private ClientResponse writeFile(long reqId, BinaryRawReader reader)
focal_class.identifier: writeFile
focal_class.modifiers: private
focal_class.parameters: (long reqId, BinaryRawReader reader)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse writeFile(long reqId, BinaryRawReader reader)
focal_class.class_method_signature: ModelStorateThinClientProcessor.readFile(long reqId, BinaryRawReader reader)
focal_class.full_signature: private ClientResponse readFile(long reqId, BinaryRawReader reader)
focal_class.identifier: readFile
focal_class.modifiers: private
focal_class.parameters: (long reqId, BinaryRawReader reader)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse readFile(long reqId, BinaryRawReader reader)
focal_class.class_method_signature: ModelStorateThinClientProcessor.moveFile(long reqId, BinaryRawReader reader)
focal_class.full_signature: private ClientResponse moveFile(long reqId, BinaryRawReader reader)
focal_class.identifier: moveFile
focal_class.modifiers: private
focal_class.parameters: (long reqId, BinaryRawReader reader)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse moveFile(long reqId, BinaryRawReader reader)
focal_class.class_method_signature: ModelStorateThinClientProcessor.getFileStat(long reqId, BinaryRawReader reader)
focal_class.full_signature: private ClientResponse getFileStat(long reqId, BinaryRawReader reader)
focal_class.identifier: getFileStat
focal_class.modifiers: private
focal_class.parameters: (long reqId, BinaryRawReader reader)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse getFileStat(long reqId, BinaryRawReader reader)
focal_class.class_method_signature: ModelStorateThinClientProcessor.isExists(long reqId, BinaryRawReader reader)
focal_class.full_signature: private ClientResponse isExists(long reqId, BinaryRawReader reader)
focal_class.identifier: isExists
focal_class.modifiers: private
focal_class.parameters: (long reqId, BinaryRawReader reader)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse isExists(long reqId, BinaryRawReader reader)
focal_class.class_method_signature: ModelStorateThinClientProcessor.remove(long reqId, BinaryRawReader reader)
focal_class.full_signature: private ClientResponse remove(long reqId, BinaryRawReader reader)
focal_class.identifier: remove
focal_class.modifiers: private
focal_class.parameters: (long reqId, BinaryRawReader reader)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse remove(long reqId, BinaryRawReader reader)
focal_class.class_method_signature: ModelStorateThinClientProcessor.mkdir(long reqId, BinaryRawReader reader)
focal_class.full_signature: private ClientResponse mkdir(long reqId, BinaryRawReader reader)
focal_class.identifier: mkdir
focal_class.modifiers: private
focal_class.parameters: (long reqId, BinaryRawReader reader)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse mkdir(long reqId, BinaryRawReader reader)
focal_class.class_method_signature: ModelStorateThinClientProcessor.mkdirs(long reqId, BinaryRawReader reader)
focal_class.full_signature: private ClientResponse mkdirs(long reqId, BinaryRawReader reader)
focal_class.identifier: mkdirs
focal_class.modifiers: private
focal_class.parameters: (long reqId, BinaryRawReader reader)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse mkdirs(long reqId, BinaryRawReader reader)
focal_class.class_method_signature: ModelStorateThinClientProcessor.listFiles(long reqId, BinaryRawReader reader)
focal_class.full_signature: private ClientResponse listFiles(long reqId, BinaryRawReader reader)
focal_class.identifier: listFiles
focal_class.modifiers: private
focal_class.parameters: (long reqId, BinaryRawReader reader)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse listFiles(long reqId, BinaryRawReader reader)
focal_class.class_method_signature: ModelStorateThinClientProcessor.error(long requestId, String msg)
focal_class.full_signature: private ClientResponse error(long requestId, String msg)
focal_class.identifier: error
focal_class.modifiers: private
focal_class.parameters: (long requestId, String msg)
focal_class.return: ClientResponse
focal_class.signature: ClientResponse error(long requestId, String msg)
focal_class.class_method_signature: ModelStorateThinClientProcessor.id()
focal_class.full_signature: @Override public String id()
focal_class.identifier: id
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String id()
focal_method.body: private ClientResponse error(long requestId, String msg) {
          return new ClientResponse(requestId, msg);
      }
focal_method.class_method_signature: ModelStorateThinClientProcessor.error(long requestId, String msg)
focal_method.full_signature: private ClientResponse error(long requestId, String msg)
focal_method.identifier: error
focal_method.modifiers: private
focal_method.parameters: (long requestId, String msg)
focal_method.return: ClientResponse
focal_method.signature: ClientResponse error(long requestId, String msg)