Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Api for service registry #201

Open
wants to merge 53 commits into
base: master
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
53 commits
Select commit Hold shift + click to select a range
5f44f05
Test
hillm3 Jun 5, 2017
9a836e3
test2
hillm3 Jun 5, 2017
3d0dad7
asdgsdfg
hillm3 Jun 5, 2017
beea777
gdfg
hillm3 Jun 5, 2017
beda447
fsdfsd
hillm3 Jun 5, 2017
bf86baa
Contains batched (parallel fork/join) and complex workflows
hillm3 Jun 5, 2017
ef06a72
Batched parallel join/fork and complex workflow
hillm3 Jun 5, 2017
7628cba
Fix for QA/Imageservices
hillm3 Jun 13, 2017
afb299d
Update on fix
hillm3 Jun 13, 2017
21957f0
One tiny change
hillm3 Jun 13, 2017
ec8b1d6
Fix IMM
hillm3 Jun 13, 2017
782c5f8
Added some documentation and removed some commented code
hillm3 Jun 13, 2017
eef64e6
Allows longer email addresses (#189)
cassiosantos Jun 9, 2017
38e82ef
dynamic service registry
zhexuanc Jun 13, 2017
5d9c22a
adding workflow db
zhexuanc Jun 14, 2017
a6fb92d
update workflow
zhexuanc Jun 15, 2017
4595aaf
fix wf register
zhexuanc Jun 16, 2017
af1057e
add classifier
zhexuanc Jun 16, 2017
b73275b
service registry v1.0
zhexuanc Jun 19, 2017
59cf3e4
Merge remote-tracking branch 'upstream/master' into mason-zhexuan
zhexuanc Jun 19, 2017
69049b8
remove config file
zhexuanc Jun 19, 2017
b9998d1
service separate from db
zhexuanc Jun 20, 2017
108a91c
service independent of db
zhexuanc Jun 20, 2017
043b071
fix bug in template
zhexuanc Jun 21, 2017
99ce76d
adding server start script
zhexuanc Jun 23, 2017
fe302f1
fix on gui_backend.py
zhexuanc Jun 23, 2017
4519161
support multi instance
zhexuanc Jun 23, 2017
1e5ab0f
service registry gui backend
zhexuanc Jun 26, 2017
95e5f06
fix for workflow inputtype
zhexuanc Jun 27, 2017
07f19f5
fix create page display
zhexuanc Jun 27, 2017
40e6c76
add error handle and fix issues
zhexuanc Jun 28, 2017
7a52ca8
remove start_server and fix
zhexuanc Jun 28, 2017
ae99100
fix 2 service has same instance
zhexuanc Jun 28, 2017
47fecdf
add id for query
zhexuanc Jun 28, 2017
cf3de91
fix frontend bugs
zhexuanc Jun 28, 2017
34233e6
fix objectid issue
zhexuanc Jun 29, 2017
5ea8e63
fix timeout issue
zhexuanc Jun 29, 2017
0523af7
first
zhexuanc Jun 29, 2017
d64fda0
api for service registry
zhexuanc Jun 29, 2017
48617c3
fix some bugs and start frontend
zhexuanc Jun 30, 2017
4ef9220
update add_empty instance
zhexuanc Jul 3, 2017
0f22fa6
fix learn
zhexuanc Jul 6, 2017
5a601b7
add get workflow
zhexuanc Jul 6, 2017
9335bd6
(wif)update learn
zhexuanc Jul 7, 2017
1c16e04
separate learn
zhexuanc Jul 10, 2017
c4f9feb
add back button
zhexuanc Jul 11, 2017
b840455
fix config and thriftclient
zhexuanc Jul 12, 2017
e54e396
add stategraph into db
zhexuanc Jul 12, 2017
7e9d746
clean stuff
zhexuanc Jul 13, 2017
08a6e87
GUI Registry v1.0
zhexuanc Jul 13, 2017
d11a9b9
add dependency of GUI
zhexuanc Jul 14, 2017
488cf12
add template creation
zhexuanc Jul 18, 2017
04d7c31
clean up api
zhexuanc Jul 18, 2017
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 0 additions & 9 deletions Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -19,15 +19,6 @@ export LD_LIBRARY_PATH=/usr/local/lib
local:
cd tools && sudo make && cd ../lucida && make

start_all:
cd tools && ./start_all_tmux.sh

start_all_secure:
cd tools && ./start_all_tmux.sh secure

start_test_all:
cd tools && ./start_all_tmux.sh test

all_service:
cd lucida && make all

Expand Down
17 changes: 4 additions & 13 deletions lucida/calendar/CalendarClient/CalendarClient.java
Original file line number Diff line number Diff line change
@@ -1,9 +1,6 @@
//Java packages
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Properties;

//Thrift java libraries
import org.apache.thrift.TException;
Expand All @@ -22,17 +19,11 @@
public class CalendarClient {
public static void main(String [] args)
throws IOException {
// Collect the port number.
Properties port_cfg = new Properties();
InputStream input = new FileInputStream("../../config.properties");
port_cfg.load(input);
String port_str = port_cfg.getProperty("CA_PORT");
Integer port = Integer.valueOf(port_str);
if (args.length == 1) {
port = Integer.parseInt(args[0]);
} else {
System.out.println("Using default port for Calendar Client: " + port);
if (args.length != 1){
System.out.println("Wrong arguments!");
System.exit(1);
}
Integer port = Integer.valueOf(args[0]);

// Query.
String LUCID = "Clinc";
Expand Down
3 changes: 2 additions & 1 deletion lucida/calendar/CalendarClient/start-Calendar-client.sh
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
#!/bin/bash

# Add Thrift classes to class path
export JAVA_CLASS_PATH=$JAVA_CLASS_PATH:thrift
# Add other jar files to class path
export JAVA_CLASS_PATH=$JAVA_CLASS_PATH:lib/libthrift-0.9.3.jar:lib/slf4j-api-1.7.13.jar:lib/slf4j-simple-1.7.13.jar

# run the server
java -cp "$JAVA_CLASS_PATH" CalendarClient "$@"
java -cp "$JAVA_CLASS_PATH" CalendarClient "$1"
9 changes: 7 additions & 2 deletions lucida/calendar/Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,15 @@ corenlp:
fi

start_server:
./gradlew run
@if [ "$(port)" != "" ]; then \
./gradlew run -Pargs=$(port); \
fi

start_test:
cd CalendarClient; ./start-Calendar-client.sh
@if [ "$(port)" != "" ]; then \
cd CalendarClient; \
./start-Calendar-client.sh $(port); \
fi

clean:
rm -rf src/main/java/thrift && rm -rf CalendarClient/thrift && rm -rf CalendarClient/*.class && rm -rf build && rm -rf lib
Expand Down
1 change: 0 additions & 1 deletion lucida/calendar/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -39,5 +39,4 @@ dependencies {
compile name: 'stanford-corenlp-3.7.0'
compile name: 'xom-1.2.10-src'
compile name: 'xom'

}
16 changes: 7 additions & 9 deletions lucida/calendar/src/main/java/calendar/CalendarDaemon.java
Original file line number Diff line number Diff line change
@@ -1,13 +1,10 @@
package calendar;

import java.io.FileInputStream;
import java.io.InputStream;
import java.io.IOException;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.ArrayList;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.Properties;
import org.apache.thrift.TProcessor;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TNonblockingServer;
Expand All @@ -34,11 +31,12 @@
public class CalendarDaemon {
public static void main(String [] args)
throws TTransportException, IOException, InterruptedException {
Properties port_cfg = new Properties();
InputStream input = new FileInputStream("../config.properties");
port_cfg.load(input);
String port_str = port_cfg.getProperty("CA_PORT");
Integer port = Integer.valueOf(port_str);
if (args.length != 1){
System.out.println("Wrong arguments!");
System.exit(1);
}
Integer port = Integer.valueOf(args[0]);

TProcessor proc = new LucidaService.AsyncProcessor(
new CAServiceHandler.AsyncCAServiceHandler());
TNonblockingServerTransport transport = new TNonblockingServerSocket(port);
Expand All @@ -47,7 +45,7 @@ public static void main(String [] args)
.protocolFactory(new TBinaryProtocol.Factory())
.transportFactory(new TFramedTransport.Factory());
final TThreadedSelectorServer server = new TThreadedSelectorServer(arguments);
System.out.println("CA at port " + port_str);
System.out.println("CA at port " + port);
server.serve();
}
}
Loading