/lucene-3.6.0/solr/core/src/test/org/apache/solr/schema/ |
H A D | TestBinaryField.java | 41 CommonsHttpSolrServer server; field in class:TestBinaryField 87 server = new CommonsHttpSolrServer(url); 99 server.add(doc); 104 server.add(doc); 109 server.add(doc); 111 server.commit(); 113 QueryResponse resp = server.query(new SolrQuery("*:*"));
|
/lucene-3.6.0/solr/solrj/src/test/org/apache/solr/client/solrj/embedded/ |
H A D | JettyWebappTest.java | 51 Server server; field in class:JettyWebappTest 65 server = new Server(port); 67 server.setSessionIdManager(new HashSessionIdManager(new Random(random.nextLong()))); 68 new WebAppContext(server, path, context ); 74 server.setConnectors(new Connector[]{connector}); 75 server.setStopAtShutdown( true ); 77 server.start(); 85 server.stop();
|
/lucene-3.6.0/solr/test-framework/src/java/org/apache/solr/ |
H A D | SolrJettyTestBase.java | 37 public static SolrServer server; field in class:SolrJettyTestBase 67 server = null; 73 if (server == null) { 74 server = createNewSolrServer(); 76 return server; 81 * Create a new solr server. 89 // setup the server...
|
/lucene-3.6.0/solr/solrj/src/java/org/apache/solr/client/solrj/request/ |
H A D | DocumentAnalysisRequest.java | 89 public DocumentAnalysisResponse process(SolrServer server) throws SolrServerException, IOException { argument 92 res.setResponse(server.request(this));
|
H A D | FieldAnalysisRequest.java | 98 public FieldAnalysisResponse process(SolrServer server) throws SolrServerException, IOException { argument 107 res.setResponse(server.request(this));
|
H A D | CoreAdminRequest.java | 248 public CoreAdminResponse process(SolrServer server) throws SolrServerException, IOException argument 252 res.setResponse( server.request( this ) ); 261 public static CoreAdminResponse reloadCore( String name, SolrServer server ) throws SolrServerException, IOException 266 return req.process( server ); 269 public static CoreAdminResponse unloadCore( String name, SolrServer server ) throws SolrServerException, IOException 271 return unloadCore(name, false, server); 274 public static CoreAdminResponse unloadCore( String name, boolean deleteIndex, SolrServer server ) throws SolrServerException, IOException 278 return req.process( server ); 281 public static CoreAdminResponse renameCore(String coreName, String newName, SolrServer server ) throws SolrServerException, IOException 287 return req.process( server ); 312 createCore( String name, String instanceDir, SolrServer server, String configFile, String schemaFile ) argument 326 persist(String fileName, SolrServer server) argument 333 mergeIndexes(String name, String[] indexDirs, String[] srcCores, SolrServer server) argument [all...] |
/lucene-3.6.0/solr/core/src/java/org/apache/solr/client/solrj/embedded/ |
H A D | JettySolrRunner.java | 46 Server server; field in class:JettySolrRunner 80 server = new Server( port ); 83 // Normal SocketConnector is what solr's example server uses by default 87 server.setConnectors(new Connector[] { connector }); 88 server.setSessionIdManager(new HashSessionIdManager(new Random())); 90 server.setStopAtShutdown( true ); 93 Context root = new Context( server, context, Context.SESSIONS ); 110 if(!server.isRunning() ) { 111 server.start(); 119 if( server [all...] |
/lucene-3.6.0/solr/core/src/java/org/apache/solr/core/ |
H A D | JmxMonitoredMap.java | 52 private MBeanServer server = null; field in class:JmxMonitoredMap 73 // Try to find the first MBean server with the given agentId 85 server = servers.get(0); 87 + server); 91 server = MBeanServerFactory.newMBeanServer(); 94 null, server); 99 server = null; 111 if (server != null) { 131 if (server != null && infoBean != null) { 134 if (server [all...] |
/lucene-3.6.0/solr/solrj/src/java/org/apache/solr/client/solrj/impl/ |
H A D | ConcurrentUpdateSolrServer.java | 66 private HttpSolrServer server; field in class:ConcurrentUpdateSolrServer 79 * The Solr server URL 81 * The buffer size before the documents are sent to the server 92 * Uses the supplied HttpClient to send documents to the Solr server, the 99 this.server = new HttpSolrServer(solrServerUrl, client); 100 this.server.setFollowRedirects(false); 131 if (ClientUtils.TEXT_XML.equals(server.requestWriter 137 server.requestWriter.write(req, out); 138 if (ClientUtils.TEXT_XML.equals(server.requestWriter 161 if (ClientUtils.TEXT_XML.equals(server [all...] |
H A D | LBHttpSolrServer.java | 42 * It offers automatic failover when a server goes down and it detects when the server comes back up. 46 * If a request to a server fails by an IOException due to a connection timeout or read timeout then the host is taken 47 * off the list of live servers and moved to a 'dead server list' and the request is resent to the next live server. 48 * This process is continued till it tries all the live servers. If atleast one server is alive, the request succeeds, 56 * This detects if a dead server comes alive automatically. The check is done in fixed intervals in a dedicated thread. 116 public void addSolrServer(String server) throws MalformedURLException { argument 117 CommonsHttpSolrServer solrServer = new CommonsHttpSolrServer(server, httpClient); 126 public String removeSolrServer(String server) { argument [all...] |
/lucene-3.6.0/solr/solrj/src/test/org/apache/solr/client/solrj/ |
H A D | TestLBHttpSolrServer.java | 114 // Kill a server and test again 126 // Start the killed server once again 160 // try again after a pause in case the error is lack of time to start server 180 // Kill a server and test again 188 // Start the killed server once again 195 private void waitForServer(int maximum, LBHttpSolrServer server, int nServers, String serverName) throws Exception { argument 198 QueryResponse resp = server.query(new SolrQuery("*:*"));
|
/lucene-3.6.0/solr/core/src/test/org/apache/solr/handler/ |
H A D | TestReplicationHandler.java | 127 // setup the server... 161 private NamedList rQuery(int expectedDocCount, String query, SolrServer server) throws Exception { argument 166 res = query(query, server); 184 assertNotNull("null response from server", res);
|