[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r17896 - in gnunet-java: . src src/org src/org/gnunet src/o
|
From: |
gnunet |
|
Subject: |
[GNUnet-SVN] r17896 - in gnunet-java: . src src/org src/org/gnunet src/org/gnunet/service src/org/gnunet/util src/org/gnunet/util/client src/org/gnunet/util/config src/org/gnunet/util/connection src/org/gnunet/util/scheduler src/org/gnunet/util/time |
|
Date: |
Tue, 1 Nov 2011 22:25:18 +0100 |
Author: dold
Date: 2011-11-01 22:25:18 +0100 (Tue, 01 Nov 2011)
New Revision: 17896
Added:
gnunet-java/ISSUES
gnunet-java/src/
gnunet-java/src/org/
gnunet-java/src/org/gnunet/
gnunet-java/src/org/gnunet/service/
gnunet-java/src/org/gnunet/service/StatisticsService.java
gnunet-java/src/org/gnunet/util/
gnunet-java/src/org/gnunet/util/client/
gnunet-java/src/org/gnunet/util/client/Client.java
gnunet-java/src/org/gnunet/util/client/MessageHandler.java
gnunet-java/src/org/gnunet/util/config/
gnunet-java/src/org/gnunet/util/config/Configuration.java
gnunet-java/src/org/gnunet/util/connection/
gnunet-java/src/org/gnunet/util/connection/Connection.java
gnunet-java/src/org/gnunet/util/connection/Receiver.java
gnunet-java/src/org/gnunet/util/connection/TransmitReadyNotify.java
gnunet-java/src/org/gnunet/util/scheduler/
gnunet-java/src/org/gnunet/util/scheduler/Scheduler.java
gnunet-java/src/org/gnunet/util/scheduler/Task.java
gnunet-java/src/org/gnunet/util/scheduler/TaskCallback.java
gnunet-java/src/org/gnunet/util/scheduler/TaskContext.java
gnunet-java/src/org/gnunet/util/time/
gnunet-java/src/org/gnunet/util/time/AbsoluteTime.java
gnunet-java/src/org/gnunet/util/time/RelativeTime.java
Modified:
gnunet-java/
Log:
testing eclipse svn integration
Property changes on: gnunet-java
___________________________________________________________________
Added: svn:ignore
+ .settings
.classpath
.project
Added: gnunet-java/ISSUES
===================================================================
--- gnunet-java/ISSUES (rev 0)
+++ gnunet-java/ISSUES 2011-11-01 21:25:18 UTC (rev 17896)
@@ -0,0 +1,5 @@
+* java has no native unix domain sockets (=>use library, licensing issues?)
+* package structure, inner classes vs. packages
+* naming conventions: stick with java standards?
+* ugly cross-reference to TransmitReadyNotify.java in
org.gnunet.util.client.Client
+*
\ No newline at end of file
Added: gnunet-java/src/org/gnunet/service/StatisticsService.java
===================================================================
--- gnunet-java/src/org/gnunet/service/StatisticsService.java
(rev 0)
+++ gnunet-java/src/org/gnunet/service/StatisticsService.java 2011-11-01
21:25:18 UTC (rev 17896)
@@ -0,0 +1,128 @@
+
+
+
+package org.gnunet.service;
+
+import java.util.LinkedList;
+
+import org.gnunet.util.client.Client;
+import org.gnunet.util.config.Configuration;
+import org.gnunet.util.time.AbsoluteTime;
+import org.gnunet.util.time.RelativeTime;
+
+public class StatisticsService {
+
+ interface Iterator {
+ public int call(String subsystem, String name, int value,
boolean is_persistent);
+ }
+
+ interface Callback {
+
+ }
+
+ enum ActionType {GET,SET,WATCH,UPDATE};
+
+ class GetHandle {
+ private StatisticsService sh;
+ private String subsystem;
+ private String name;
+ private Callback cont;
+ private Iterator proc;
+ private AbsoluteTime timeout;
+ private ActionType type;
+ private int msize;
+ void cancel() {
+ throw new UnsupportedOperationException();
+ }
+ }
+
+ private class WatchEntry {
+ String subssytem;
+ String name;
+ Iterator proc;
+ public WatchEntry(String subssytem, String name, Iterator proc)
{
+ this.subssytem = subssytem;
+ this.name = name;
+ this.proc = proc;
+ }
+ }
+
+
+
+ private Client client;
+ private RelativeTime backoff;
+
+ private String subsystem;
+ private Configuration cfg;
+
+ LinkedList<WatchEntry> watches;
+
+ LinkedList<GetHandle> actions;
+
+ GetHandle currentAction;
+
+ Client.TransmitHandle th;
+
+
+ public StatisticsService(String subsystem, Configuration cfg) {
+ this.backoff = new RelativeTime(1);
+ this.subsystem = subsystem;
+ this.cfg = cfg;
+ this.client = new Client("statistics", cfg);
+ this.watches = new LinkedList<StatisticsService.WatchEntry>();
+ this.actions = new LinkedList<StatisticsService.GetHandle>();
+ }
+
+
+ public void watch(String subsystem, String name, Iterator cb) {
+ throw new UnsupportedOperationException();
+ /*
+ WatchEntry w = new WatchEntry(subsystem, name, cb);
+ this.watches.add(w);
+ scheduleWatchRequest(w);
+ */
+ }
+
+
+
+
+ public GetHandle get(String subsystem, String name, RelativeTime
timeout,
+ Callback cb, Iterator it) {
+ GetHandle h = new GetHandle();
+ h.sh = this;
+ h.subsystem = subsystem;
+ h.name = name;
+ h.cont = cb;
+ h.proc = it;
+ h.type = ActionType.GET;
+ insertGetHandle(h);
+ return h;
+ }
+
+ private void insertGetHandle(GetHandle h) {
+ actions.add(h);
+ if (h == actions.getFirst()) {
+ scheduleAction();
+ }
+ }
+
+ private void scheduleAction() {
+ if (currentAction != null) {
+ return;
+ }
+ // XXX: What about reconnect stuff?
+ currentAction = actions.removeFirst();
+ // XXX: what about destruction?
+ this.th = client.notifyTransmitReady(currentAction.msize,
/*XXX:dummy*/ null, true, new StatisticsTransmitAction());
+
+ // XXX totally incomplete
+ }
+
+ public void set(String name, int value, boolean make_persistent) {
+ throw new UnsupportedOperationException();
+ }
+
+ public void update(String name, int delta, boolean make_persistent) {
+ throw new UnsupportedOperationException();
+ }
+}
Added: gnunet-java/src/org/gnunet/util/client/Client.java
===================================================================
--- gnunet-java/src/org/gnunet/util/client/Client.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/client/Client.java 2011-11-01 21:25:18 UTC
(rev 17896)
@@ -0,0 +1,29 @@
+package org.gnunet.util.client;
+
+import org.gnunet.util.config.Configuration;
+import org.gnunet.util.connection.TransmitReadyNotify;
+import org.gnunet.util.time.RelativeTime;
+
+public class Client {
+ interface MessageHandler {
+
+ }
+
+ public static class TransmitHandle {
+ void cancel() {
+ throw new UnsupportedOperationException();
+ }
+
+ }
+ public Client(String service_name, Configuration c) {
+ throw new UnsupportedOperationException();
+ }
+
+ public void receive(MessageHandler handler, RelativeTime timeout) {
+ throw new UnsupportedOperationException();
+ }
+ public TransmitHandle notifyTransmitReady(int size, RelativeTime
timeout, boolean auto_retry,
+ TransmitReadyNotify cb) {
+ throw new UnsupportedOperationException();
+ }
+}
Added: gnunet-java/src/org/gnunet/util/client/MessageHandler.java
===================================================================
--- gnunet-java/src/org/gnunet/util/client/MessageHandler.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/client/MessageHandler.java 2011-11-01
21:25:18 UTC (rev 17896)
@@ -0,0 +1,5 @@
+package org.gnunet.util.client;
+
+public class MessageHandler {
+
+}
Added: gnunet-java/src/org/gnunet/util/config/Configuration.java
===================================================================
--- gnunet-java/src/org/gnunet/util/config/Configuration.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/config/Configuration.java 2011-11-01
21:25:18 UTC (rev 17896)
@@ -0,0 +1,13 @@
+package org.gnunet.util.config;
+
+import java.io.*;
+
+public class Configuration {
+ public Configuration(String filename) throws FileNotFoundException {
+ FileInputStream fstream = new FileInputStream(filename);
+ DataInputStream in = new DataInputStream(fstream);
+ BufferedReader br = new BufferedReader(new
InputStreamReader(in));
+ throw new UnsupportedOperationException();
+ }
+
+}
Added: gnunet-java/src/org/gnunet/util/connection/Connection.java
===================================================================
--- gnunet-java/src/org/gnunet/util/connection/Connection.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/connection/Connection.java 2011-11-01
21:25:18 UTC (rev 17896)
@@ -0,0 +1,75 @@
+package org.gnunet.util.connection;
+
+import java.net.*;
+
+import org.gnunet.util.time.RelativeTime;
+
+public class Connection {
+ public class TransmitHandle {
+ void cancel() {
+ throw new UnsupportedOperationException();
+ }
+ }
+
+ private boolean persist;
+
+ private Connection(Socket s) {
+ }
+
+ public static Connection fromAccept(ServerSocket ss) {
+ throw new UnsupportedOperationException();
+ }
+
+ public static Connection fromExisting(Socket ss) {
+ return new Connection(ss);
+ }
+
+ public static Connection fromConnect(String hostname, long port) {
+ throw new UnsupportedOperationException();
+ }
+
+ public static Connection fromUnixPath(String path) {
+ // problematic as java has no nativ support for unix domain
sockets
+ throw new UnsupportedOperationException();
+ }
+
+ public static Connection fromSocketAddress(SocketAddress addr) {
+ throw new UnsupportedOperationException();
+ }
+
+ public void receive(int max, RelativeTime timeout, Receiver r) {
+ throw new UnsupportedOperationException();
+ }
+
+ public void receive_cancel() {
+ throw new UnsupportedOperationException();
+ }
+
+
+ public TransmitHandle notifyTransmitReady(int size, RelativeTime
timeout, boolean auto_retry,
+ TransmitReadyNotify cb) {
+ throw new UnsupportedOperationException();
+ }
+
+ public void persist() {
+ this.persist = true;
+ }
+
+ // XXX: error code / exception
+ public void disableCorking() {
+ throw new UnsupportedOperationException();
+ }
+
+ public boolean check() {
+ throw new UnsupportedOperationException();
+ }
+
+ public void ignoreShutdown(boolean doIgnore) {
+
+ }
+
+ /*
+ * not implemented: GNUNET_CONNECTION_get_address (never used outside
testing)
+ */
+
+}
Added: gnunet-java/src/org/gnunet/util/connection/Receiver.java
===================================================================
--- gnunet-java/src/org/gnunet/util/connection/Receiver.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/connection/Receiver.java 2011-11-01
21:25:18 UTC (rev 17896)
@@ -0,0 +1,6 @@
+package org.gnunet.util.connection;
+
+public interface Receiver {
+ public void receive(byte[] buf, long available, Object sockaddr, int
addrlen, int errCode);
+
+}
Added: gnunet-java/src/org/gnunet/util/connection/TransmitReadyNotify.java
===================================================================
--- gnunet-java/src/org/gnunet/util/connection/TransmitReadyNotify.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/connection/TransmitReadyNotify.java
2011-11-01 21:25:18 UTC (rev 17896)
@@ -0,0 +1,5 @@
+package org.gnunet.util.connection;
+
+public interface TransmitReadyNotify {
+
+}
Added: gnunet-java/src/org/gnunet/util/scheduler/Scheduler.java
===================================================================
--- gnunet-java/src/org/gnunet/util/scheduler/Scheduler.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/scheduler/Scheduler.java 2011-11-01
21:25:18 UTC (rev 17896)
@@ -0,0 +1,47 @@
+package org.gnunet.util.scheduler;
+
+import java.util.LinkedList;
+
+import javax.naming.OperationNotSupportedException;
+
+public class Scheduler {
+ enum Reason {STARTUP, SHUTDOWN, TIMEOUT, READ_READY, WRITE_READY,
PREREQ_DONE};
+ enum Priority {KEEP, IDLE, BACKGROUND, DEFAULT, HIGH, UI, URGENT,
SHUTDOWN, COUNT};
+
+ LinkedList<Task> pending;
+ LinkedList<Task> pending_timeout;
+
+ LinkedList<Task> ready;
+
+ Task pending_timeout_last;
+ Task active_task;
+
+ int last_id;
+
+ int lowest_pending_id;
+
+ int ready_count;
+
+ long tasks_run;
+
+
+ public void run(Task t) {
+ throw new UnsupportedOperationException();
+ }
+
+ public void addContinuation(TaskCallback t, Reason r) {
+ throw new UnsupportedOperationException();
+ }
+
+ public void addAfter(Task prereq, TaskCallback t) {
+
+ }
+
+ public void shutdown() {
+ throw new UnsupportedOperationException();
+ }
+
+
+
+
+}
Added: gnunet-java/src/org/gnunet/util/scheduler/Task.java
===================================================================
--- gnunet-java/src/org/gnunet/util/scheduler/Task.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/scheduler/Task.java 2011-11-01 21:25:18 UTC
(rev 17896)
@@ -0,0 +1,21 @@
+package org.gnunet.util.scheduler;
+
+import org.gnunet.util.time.AbsoluteTime;
+
+public class Task {
+ private TaskCallback cb;
+
+ // Unique Task Identifier
+ int id;
+
+ int prereq_id;
+
+ AbsoluteTime timeout;
+
+ AbsoluteTime start_time;
+
+ int read_fd, write_fd;
+
+ int lifeness;
+
+}
Added: gnunet-java/src/org/gnunet/util/scheduler/TaskCallback.java
===================================================================
--- gnunet-java/src/org/gnunet/util/scheduler/TaskCallback.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/scheduler/TaskCallback.java 2011-11-01
21:25:18 UTC (rev 17896)
@@ -0,0 +1,5 @@
+package org.gnunet.util.scheduler;
+
+public interface TaskCallback {
+
+}
Added: gnunet-java/src/org/gnunet/util/scheduler/TaskContext.java
===================================================================
--- gnunet-java/src/org/gnunet/util/scheduler/TaskContext.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/scheduler/TaskContext.java 2011-11-01
21:25:18 UTC (rev 17896)
@@ -0,0 +1,5 @@
+package org.gnunet.util.scheduler;
+
+public class TaskContext {
+
+}
Added: gnunet-java/src/org/gnunet/util/time/AbsoluteTime.java
===================================================================
--- gnunet-java/src/org/gnunet/util/time/AbsoluteTime.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/time/AbsoluteTime.java 2011-11-01
21:25:18 UTC (rev 17896)
@@ -0,0 +1,71 @@
+package org.gnunet.util.time;
+
+public class AbsoluteTime {
+
+ public final static AbsoluteTime ZERO = new AbsoluteTime(0);
+ public final static AbsoluteTime FOREVER = new
AbsoluteTime(Long.MAX_VALUE);
+
+ private static long offset;
+
+ private final long abs_value;
+
+ public static void setOffset(long offset) {
+ throw new UnsupportedOperationException();
+ }
+
+ public AbsoluteTime() {
+ this.abs_value = System.currentTimeMillis();
+ }
+
+ public AbsoluteTime(long abs_value) {
+ this.abs_value = abs_value;
+ }
+
+ public long getMilliseconds() {
+ return rel_value;
+ }
+
+ public AbsoluteTime min(AbsoluteTime other) {
+ throw new UnsupportedOperationException();
+ }
+
+ public AbsoluteTime max(AbsoluteTime other) {
+ throw new UnsupportedOperationException();
+
+ }
+
+ public RelativeTime getRemaining() {
+ throw new UnsupportedOperationException();
+
+ }
+
+ public RelativeTime calculateETA(AbsoluteTime start, long finished,
+ long total) {
+ throw new UnsupportedOperationException();
+ }
+
+ public RelativeTime getDifference(AbsoluteTime other) {
+ throw new UnsupportedOperationException();
+ }
+
+ public RelativeTime getDuration(AbsoluteTime whence) {
+ throw new UnsupportedOperationException();
+ }
+
+ public AbsoluteTime add(RelativeTime duration) {
+ throw new UnsupportedOperationException();
+ }
+
+ public AbsoluteTime subtract(RelativeTime duration) {
+ throw new UnsupportedOperationException();
+ }
+
+ public byte[] toNetwork() {
+ throw new UnsupportedOperationException();
+ }
+
+ static AbsoluteTime fromNetwork(byte[] b) {
+ throw new UnsupportedOperationException();
+ }
+
+}
Added: gnunet-java/src/org/gnunet/util/time/RelativeTime.java
===================================================================
--- gnunet-java/src/org/gnunet/util/time/RelativeTime.java
(rev 0)
+++ gnunet-java/src/org/gnunet/util/time/RelativeTime.java 2011-11-01
21:25:18 UTC (rev 17896)
@@ -0,0 +1,66 @@
+package org.gnunet.util.time;
+
+public class RelativeTime {
+
+ public final static RelativeTime MILLISECOND = new RelativeTime(1);
+ public final static RelativeTime SECOND = MILLISECOND.multiply(1000);
+ public final static RelativeTime MINUTE = SECOND.multiply(60);
+ public final static RelativeTime HOUR = MINUTE.multiply(60);
+ public final static RelativeTime DAY = HOUR.multiply(24);
+ public final static RelativeTime WEEK = DAY.multiply(7);
+ public final static RelativeTime MONTH = DAY.multiply(30);
+ public final static RelativeTime YEAR = DAY.multiply(365);
+
+ public final static RelativeTime FOREVER = new
RelativeTime(Long.MAX_VALUE);
+
+ private final long abs_value;
+
+ public RelativeTime(long abs_value) {
+ this.abs_value = abs_value;
+ }
+
+ public long getMilliseconds() {
+ return abs_value;
+ }
+
+ public AbsoluteTime toAbsolute() {
+ throw new UnsupportedOperationException();
+ }
+
+ public RelativeTime min(RelativeTime other) {
+ throw new UnsupportedOperationException();
+ }
+
+ public RelativeTime max(RelativeTime other) {
+ throw new UnsupportedOperationException();
+ }
+
+ public RelativeTime multiply(int factor) {
+ throw new UnsupportedOperationException();
+ }
+
+ public RelativeTime divide(int factor) {
+ throw new UnsupportedOperationException();
+ }
+
+ public RelativeTime add(RelativeTime other) {
+ throw new UnsupportedOperationException();
+ }
+
+ public RelativeTime subtract(RelativeTime other) {
+ throw new UnsupportedOperationException();
+ }
+
+ public byte[] toNetwork() {
+ throw new UnsupportedOperationException();
+ }
+
+ static RelativeTime fromNetwork(byte[] b) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public String toString() {
+ throw new UnsupportedOperationException();
+ }
+}
| [Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r17896 - in gnunet-java: . src src/org src/org/gnunet src/org/gnunet/service src/org/gnunet/util src/org/gnunet/util/client src/org/gnunet/util/config src/org/gnunet/util/connection src/org/gnunet/util/scheduler src/org/gnunet/util/time,
gnunet <=