Skip to content

Commit

Permalink
fix typo (#1302)
Browse files Browse the repository at this point in the history
  • Loading branch information
epugh committed Apr 2, 2020
1 parent f779bc6 commit 927587d
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions solr/core/src/java/org/apache/solr/handler/StreamHandler.java
Original file line number Diff line number Diff line change
Expand Up @@ -245,9 +245,9 @@ public void handleRequestBody(SolrQueryRequest req, SolrQueryResponse rsp) throw
daemons.remove(daemonStream.getId()).close();
}
daemonStream.setDaemons(daemons);
daemonStream.open(); // This will start the deamonStream
daemonStream.open(); // This will start the daemonStream
daemons.put(daemonStream.getId(), daemonStream);
rsp.add("result-set", new DaemonResponseStream("Deamon:" + daemonStream.getId() + " started on " + coreName));
rsp.add("result-set", new DaemonResponseStream("Daemon:" + daemonStream.getId() + " started on " + coreName));
} else {
rsp.add("result-set", new TimerStream(new ExceptionStream(tupleStream)));
}
Expand All @@ -269,14 +269,14 @@ private void handleAdmin(SolrQueryRequest req, SolrQueryResponse rsp, SolrParams
String id = params.get(ID);
DaemonStream d = daemons.get(id);
if (d == null) {
rsp.add("result-set", new DaemonResponseStream("Deamon:" + id + " not found on " + coreName));
rsp.add("result-set", new DaemonResponseStream("Daemon:" + id + " not found on " + coreName));
return;
}

switch (action) {
case "stop":
d.close();
rsp.add("result-set", new DaemonResponseStream("Deamon:" + id + " stopped on " + coreName));
rsp.add("result-set", new DaemonResponseStream("Daemon:" + id + " stopped on " + coreName));
break;

case "start":
Expand All @@ -285,17 +285,17 @@ private void handleAdmin(SolrQueryRequest req, SolrQueryResponse rsp, SolrParams
} catch (IOException e) {
rsp.add("result-set", new DaemonResponseStream("Daemon: " + id + " error: " + e.getMessage()));
}
rsp.add("result-set", new DaemonResponseStream("Deamon:" + id + " started on " + coreName));
rsp.add("result-set", new DaemonResponseStream("Daemon:" + id + " started on " + coreName));
break;

case "kill":
daemons.remove(id);
d.close(); // we already found it in the daemons list, so we don't need to verify we removed it.
rsp.add("result-set", new DaemonResponseStream("Deamon:" + id + " killed on " + coreName));
rsp.add("result-set", new DaemonResponseStream("Daemon:" + id + " killed on " + coreName));
break;

default:
rsp.add("result-set", new DaemonResponseStream("Deamon:" + id + " action '"
rsp.add("result-set", new DaemonResponseStream("Daemon:" + id + " action '"
+ action + "' not recognized on " + coreName));
break;
}
Expand Down

0 comments on commit 927587d

Please sign in to comment.