knopflerfish / knopflerfish.org Goto Github PK

Factory Configuration

> cd osgi
> ant

java -jar framework.jar

java -jar framework.jar -help

ant distrib

-plugin.org.knopflerfish.kf6: \
	aQute.bnd.repository.osgi.OSGiRepository; \
		locations=https://www.knopflerfish.org/releases/6.2.0/osgi/jars/index.xml; \
		name=kf6

-  <property name="osgi.annotation.jar" location="${topdir}/annotations/osgi.annotation-6.0.1.jar"/>
+  <property name="osgi.annotation.jar" location="/usr/share/java/osgi.annotation.jar"/>

[javac]
/home/felix/knopflerfish-osgi-unstable/knopflerfish-osgi/osgi/framework/src/org/osgi/framework/Constants.java:19:
error: package org.osgi.annotation.versioning does not exist

$ jar tf /usr/share/java/osgi.annotation.jar
META-INF/
META-INF/MANIFEST.MF
org/
org/osgi/
org/osgi/annotation/
org/osgi/annotation/versioning/
org/osgi/annotation/versioning/ConsumerType.class
org/osgi/annotation/versioning/ProviderType.class
org/osgi/annotation/versioning/Version.class
org/osgi/annotation/versioning/package-info.class

-  <import file="${ant.dir}/android.xml"/>
+  <!--<import file="${ant.dir}/android.xml"/>-->

@org.osgi.service.component.annotations.Component(name = "Component", configurationPolicy = ConfigurationPolicy.REQUIRE, immediate = true)
public class Component {

    public Component( ) {
        println("=== Constructor ===");
    }

    @Activate
    public void activate(Map properties) {
        println("=== Activate " + properties.get("number") + " ===");
        println(properties);
    }

    @Deactivate
    public void deactivate(Map properties) {
        println("=== Deactivate " + properties.get("number") + " ===");
        println(properties);
    }

    private void println(Map properties) {
        if (properties != null) {
            Iterator it = properties.entrySet().iterator( );
            while (it.hasNext()) {
                println(it.next().toString());
            }
        }
    }

    private void println(String message) {
        System.out.println(message);
    }
}

enter configuration
configuration> create -f Component
configuration> set number 1
configuration> save
configuration> [stdout] === Constructor ===
[stdout] === Activate 1 ===
[stdout] service.pid=Component._0
[stdout] service.factoryPid=Component
[stdout] component.name=Component
[stdout] number=1
[stdout] component.id=1
create -f Component
configuration> set number 2
configuration> save
configuration> create -f Component
configuration> set number 3
configuration> save
configuration> show
[-] Component._0
 factory PID: Component
 location: -
 change count: 1
 properties:
  number= 1
  service.factoryPid= Component
  service.pid= Component._0
[-] Component._1
 factory PID: Component
 location: -
 change count: 1
 properties:
  number= 2
  service.factoryPid= Component
  service.pid= Component._1
[-] Component._2
 factory PID: Component
 location: -
 change count: 1
 properties:
  number= 3
  service.factoryPid= Component
  service.pid= Component._2
configuration> 

Failure: Condperm210a - P3 not exporting bundle, BundleImpl[id=140] != BundleImpl[id=142] :CONDPERM210A:FAIL
junit.framework.AssertionFailedError: P3 not exporting bundle, BundleImpl[id=140] != BundleImpl[id=142] :CONDPERM210A:FAIL
 at junit.framework.Assert.fail(Assert.java:47)
 at org.knopflerfish.bundle.condpermadmin_test.CondPermAdminTestSuite$Condperm210a.runTest(CondPermAdminTestSuite.java:618)
 at junit.framework.TestCase.runBare(TestCase.java:127)
 at junit.framework.TestResult$1.protect(TestResult.java:106)
 at junit.framework.TestResult.runProtected(TestResult.java:124)
 at junit.framework.TestResult.run(TestResult.java:109)
 at junit.framework.TestCase.run(TestCase.java:118)
 at junit.framework.TestSuite.runTest(TestSuite.java:208)
 at junit.framework.TestSuite.run(TestSuite.java:203)
 at org.knopflerfish.bundle.junit.JUnitServiceImpl.runTestCase(JUnitServiceImpl.java:177)
 at org.knopflerfish.bundle.junit.JUnitServiceImpl.runTestXML(JUnitServiceImpl.java:82)
 at org.knopflerfish.bundle.junit.JUnitServiceImpl.runTest(JUnitServiceImpl.java:62)
 at org.knopflerfish.bundle.junit_runner.Grunt.doRun(Grunt.java:198)
 at org.knopflerfish.bundle.junit_runner.Grunt.doGrunt(Grunt.java:79)
 at org.knopflerfish.bundle.junit_runner.Activator.start(Activator.java:57)
 at org.knopflerfish.framework.BundleImpl.start0(BundleImpl.java:387)
 at org.knopflerfish.framework.BundleThread.run(BundleThread.java:145)

Failure: Condperm220a - started test bundleP4! :CONDPERM220A:FAIL
junit.framework.AssertionFailedError: started test bundleP4! :CONDPERM220A:FAIL
 at junit.framework.Assert.fail(Assert.java:47)
 at org.knopflerfish.bundle.condpermadmin_test.CondPermAdminTestSuite$Condperm220a.runTest(CondPermAdminTestSuite.java:703)
 at junit.framework.TestCase.runBare(TestCase.java:127)
 at junit.framework.TestResult$1.protect(TestResult.java:106)
 at junit.framework.TestResult.runProtected(TestResult.java:124)
 at junit.framework.TestResult.run(TestResult.java:109)
 at junit.framework.TestCase.run(TestCase.java:118)
 at junit.framework.TestSuite.runTest(TestSuite.java:208)
 at junit.framework.TestSuite.run(TestSuite.java:203)
 at org.knopflerfish.bundle.junit.JUnitServiceImpl.runTestCase(JUnitServiceImpl.java:177)
 at org.knopflerfish.bundle.junit.JUnitServiceImpl.runTestXML(JUnitServiceImpl.java:82)
 at org.knopflerfish.bundle.junit.JUnitServiceImpl.runTest(JUnitServiceImpl.java:62)
 at org.knopflerfish.bundle.junit_runner.Grunt.doRun(Grunt.java:198)
 at org.knopflerfish.bundle.junit_runner.Grunt.doGrunt(Grunt.java:79)
 at org.knopflerfish.bundle.junit_runner.Activator.start(Activator.java:57)
 at org.knopflerfish.framework.BundleImpl.start0(BundleImpl.java:387)
 at org.knopflerfish.framework.BundleThread.run(BundleThread.java:145)

Failure: Condperm230a - started test bundleP5! :CONDPERM230A:FAIL
junit.framework.AssertionFailedError: started test bundleP5! :CONDPERM230A:FAIL
 at junit.framework.Assert.fail(Assert.java:47)
 at org.knopflerfish.bundle.condpermadmin_test.CondPermAdminTestSuite$Condperm230a.runTest(CondPermAdminTestSuite.java:795)
 at junit.framework.TestCase.runBare(TestCase.java:127)
 at junit.framework.TestResult$1.protect(TestResult.java:106)
 at junit.framework.TestResult.runProtected(TestResult.java:124)
 at junit.framework.TestResult.run(TestResult.java:109)
 at junit.framework.TestCase.run(TestCase.java:118)
 at junit.framework.TestSuite.runTest(TestSuite.java:208)
 at junit.framework.TestSuite.run(TestSuite.java:203)
 at org.knopflerfish.bundle.junit.JUnitServiceImpl.runTestCase(JUnitServiceImpl.java:177)
 at org.knopflerfish.bundle.junit.JUnitServiceImpl.runTestXML(JUnitServiceImpl.java:82)
 at org.knopflerfish.bundle.junit.JUnitServiceImpl.runTest(JUnitServiceImpl.java:62)
 at org.knopflerfish.bundle.junit_runner.Grunt.doRun(Grunt.java:198)
 at org.knopflerfish.bundle.junit_runner.Grunt.doGrunt(Grunt.java:79)
 at org.knopflerfish.bundle.junit_runner.Activator.start(Activator.java:57)
 at org.knopflerfish.framework.BundleImpl.start0(BundleImpl.java:387)
 at org.knopflerfish.framework.BundleThread.run(BundleThread.java:145)

 BundleImpl install0(String location, InputStream in, Object checkContext, Bundle caller)
    throws BundleException {
    InputStream bin;
    BundleArchive ba = null;
    try {
      if (in == null) {
        // Do it the manual way to have a chance to
        // set request properties
        final URL url  = new URL(location);
        final URLConnection conn = url.openConnection();

       try {
            Constructor<ServiceURLStreamHandlerFactory> constructor = ServiceURLStreamHandlerFactory.class.getDeclaredConstructor();
            constructor.setAccessible(true);
            ServiceURLStreamHandlerFactory systemUrlStreamHandlerFactory = constructor.newInstance();
            TomcatURLStreamHandlerFactory.getInstance().addUserFactory(systemUrlStreamHandlerFactory);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }

 [ERROR] 2016-11-18 05:42:54.142 [HttpServer-WorkerThread-6] org.knopflerfish.bundle.http.5.2.0 - [Unknown]Internal error: java.lang.NullPointerException
java.lang.NullPointerException: null
	at org.knopflerfish.bundle.http.ResponseImpl.setContentType(ResponseImpl.java:736) ~[?:?]
	at javax.servlet.ServletResponseWrapper.setContentType(ServletResponseWrapper.java:130) ~[org.knopflerfish.bundle-jsdk-API-2.5.0.kf3-2.jar:?]
	at org.apache.felix.webconsole.AbstractWebConsolePlugin.spoolResource0(AbstractWebConsolePlugin.java:594) ~[?:?]
	at org.apache.felix.webconsole.AbstractWebConsolePlugin$1.run(AbstractWebConsolePlugin.java:526) ~[?:?]
	at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_60]
	at org.apache.felix.webconsole.AbstractWebConsolePlugin.spoolResource(AbstractWebConsolePlugin.java:521) ~[?:?]
	at org.apache.felix.webconsole.AbstractWebConsolePlugin.doGet(AbstractWebConsolePlugin.java:181) ~[?:?]
	at org.apache.felix.webconsole.plugins.ds.internal.WebConsolePlugin.doGet(WebConsolePlugin.java:194) ~[?:?]
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:691) ~[org.knopflerfish.bundle-jsdk-API-2.5.0.kf3-2.jar:?]
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:804) ~[org.knopflerfish.bundle-jsdk-API-2.5.0.kf3-2.jar:?]
	at org.apache.felix.webconsole.internal.servlet.OsgiManager.service(OsgiManager.java:567) ~[?:?]
	at org.apache.felix.webconsole.internal.servlet.OsgiManager$3.run(OsgiManager.java:465) ~[?:?]
	at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_60]
	at org.apache.felix.webconsole.internal.servlet.OsgiManager.service(OsgiManager.java:461) ~[?:?]
	at org.knopflerfish.bundle.http.RequestDispatcherImpl.service(RequestDispatcherImpl.java:162) ~[org.knopflerfish.bundle-http-5.2.0.jar:?]
	at org.knopflerfish.bundle.http.RequestDispatcherImpl.forward(RequestDispatcherImpl.java:461) ~[org.knopflerfish.bundle-http-5.2.0.jar:?]
	at org.knopflerfish.bundle.http.Transaction.run(Transaction.java:177) [org.knopflerfish.bundle-http-5.2.0.jar:?]
	at org.knopflerfish.bundle.http.TransactionManager$WorkerThread.run(TransactionManager.java:288) [org.knopflerfish.bundle-http-5.2.0.jar:?]

<?xml version="1.0" encoding="UTF-8"?>

<components>

  <component name="org.knopflerfish.bundle.componentFilter_testA"
	     immediate="true"
             xmlns="http://www.osgi.org/xmlns/scr/v1.0.0">
    <implementation
       class="org.knopflerfish.bundle.componentFilter_test.GeneralComponentImplA"/>

    <service>
      <provide
         interface="org.knopflerfish.service.componentFilter_test.GeneralComponent"/>
    </service>

    <property name="actionName" value="A" />

    <reference  name = "org.knopflerfish.service.componentFilter_test.OtherComponent"
		interface = "org.knopflerfish.service.componentFilter_test.OtherComponent"
		bind = "setOtherComponent"
		policy="static"
		cardinality="1..1"
		/>

  </component>

  <component name="org.knopflerfish.bundle.componentFilter_testB"
	     immediate="true"
             xmlns="http://www.osgi.org/xmlns/scr/v1.0.0">

    <implementation
       class="org.knopflerfish.bundle.componentFilter_test.GeneralComponentImplB"/>

    <service>
      <provide
         interface="org.knopflerfish.service.componentFilter_test.GeneralComponent"/>
    </service>

    <property name="actionName" value="B" /> 

    <reference  name = "org.knopflerfish.service.componentFilter_test.GeneralComponent"
		interface = "org.knopflerfish.service.componentFilter_test.GeneralComponent"
		target = "(actionName=A)"
		bind = "setGeneralComponentImplA"
		policy="static"
		cardinality="1..1"
		/>

  </component>

</components>

final File f = new File(new File(sysPkgFile).getAbsolutePath());

    if (!f.exists() || !f.isFile()) {
      url = SystemBundle.class.getResource(sysPkgFile);
      if (null == url) {
        url = SystemBundle.class.getResource("/" + sysPkgFile);
      }

public interface TargetService {
}

@org.osgi.service.component.annotations.Component(
        name = "TargetService",

        configurationPolicy = ConfigurationPolicy.REQUIRE,
        immediate = true)
public class TargetServiceImpl implements TargetService {

    @Activate
    public void activate(Map properties) {
        println("=== TargetService Activate " + properties.get("number") + " ===");
    }

    @Deactivate
    public void deactivate(Map properties) {
        println("=== TargetService Deactivate " + properties.get("number") + " ===");
    }

    private void println(String message) {
        System.out.println(message);
    }
}

@org.osgi.service.component.annotations.Component(
        name = "Component",
        configurationPolicy = ConfigurationPolicy.REQUIRE,
        immediate = true)
public class Component {

    private TargetService target;

    @Reference(unbind = "unbindTargetService")
    public void bindTargetService(TargetService target) {
        this.target = target;
    }

    public void unbindTargetService(TargetService target) {
        this.target = null;
    }

    @Activate
    public void activate(Map properties) {
        println("=== Component Activate " + properties.get("number") + " ===");
        println(properties);
    }

    @Deactivate
    public void deactivate(Map properties) {
        println("=== Component Deactivate " + properties.get("number") + " ===");
        println(properties);
    }

    private void println(Map properties) {
        if (properties != null) {
            Iterator it = properties.entrySet().iterator( );
            while (it.hasNext()) {
                println(it.next().toString());
            }
        }
    }

    private void println(String message) {
        System.out.println(message);
    }
}

> enter configuration
configuration> create -f Component
configuration> set TargetService.target (number=1)
configuration> set number 101
configuration> save
configuration> create -f Component
configuration> set TargetService.target (number=1)
configuration> set number 102
configuration> save
configuration> create -f Component
configuration> set TargetService.target (number=2)
configuration> set number 201
configuration> save
configuration> show
[-] Component._0
 factory PID: Component
 location: -
 change count: 1
 properties:
  TargetService.target= (number=1)
  number= 101
  service.factoryPid= Component
  service.pid= Component._0
[-] Component._1
 factory PID: Component
 location: -
 change count: 1
 properties:
  TargetService.target= (number=1)
  number= 102
  service.factoryPid= Component
  service.pid= Component._1
[-] Component._2
 factory PID: Component
 location: -
 change count: 1
 properties:
  TargetService.target= (number=2)
  number= 201
  service.factoryPid= Component
  service.pid= Component._2

configuration> create -f TargetService
configuration> set number 1
configuration> save
configuration> [stderr] ## DEBUG: errors - FrameworkErrorEvent bundle #28
[stderr] ## DEBUG: errors - FrameworkErrorEvent throwable: 
[stderr] java.lang.NullPointerException
[stderr] 	at org.knopflerfish.bundle.component.Component.newComponentConfiguration(Component.java:774)
[stderr] 	at org.knopflerfish.bundle.component.Component.newComponentConfigurations(Component.java:752)
[stderr] 	at org.knopflerfish.bundle.component.Component.satisfied(Component.java:483)
[stderr] 	at org.knopflerfish.bundle.component.Component.refAvailable(Component.java:714)
[stderr] 	at org.knopflerfish.bundle.component.Reference.refAvailable(Reference.java:456)
[stderr] 	at org.knopflerfish.bundle.component.ReferenceListener.serviceChanged(ReferenceListener.java:497)
[stderr] 	at org.knopflerfish.bundle.component.ReferenceListener.serviceEvent(ReferenceListener.java:455)
[stderr] 	at org.knopflerfish.bundle.component.ComponentServiceListener.serviceChanged(ComponentServiceListener.java:71)
[stderr] 	at org.knopflerfish.framework.Listeners.serviceChanged(Listeners.java:430)
[stderr] 	at org.knopflerfish.framework.PermissionOps.callServiceChanged(PermissionOps.java:340)
[stderr] 	at org.knopflerfish.framework.Services.register(Services.java:179)
[stderr] 	at org.knopflerfish.framework.BundleContextImpl.registerService(BundleContextImpl.java:274)
[stderr] 	at org.knopflerfish.bundle.component.ComponentService.registerService(ComponentService.java:72)
[stderr] 	at org.knopflerfish.bundle.component.ComponentConfiguration.registerComponentService(ComponentConfiguration.java:376)
[stderr] 	at org.knopflerfish.bundle.component.ImmediateComponent.activateComponentConfiguration(ImmediateComponent.java:60)
[stderr] 	at org.knopflerfish.bundle.component.Component.satisfied(Component.java:485)
[stderr] 	at org.knopflerfish.bundle.component.Component.resolvedConstraint(Component.java:582)
[stderr] 	at org.knopflerfish.bundle.component.Component.cmConfigUpdated(Component.java:645)
[stderr] 	at org.knopflerfish.bundle.component.CMConfig.cmPidSet(CMConfig.java:241)
[stderr] 	at org.knopflerfish.bundle.component.CMConfig.access$100(CMConfig.java:53)
[stderr] 	at org.knopflerfish.bundle.component.CMConfig$CMPid.set(CMConfig.java:341)
[stderr] 	at org.knopflerfish.bundle.component.CMConfig$CMPid.configUpdated(CMConfig.java:391)
[stderr] 	at org.knopflerfish.bundle.component.CMHandler.configurationEvent(CMHandler.java:116)
[stderr] 	at org.knopflerfish.bundle.cm.ListenerEvent.sendEvent(ListenerEvent.java:84)
[stderr] 	at org.knopflerfish.bundle.cm.ListenerEventQueue.run(ListenerEventQueue.java:90)
[stderr] 	at java.lang.Thread.run(Thread.java:745)
[stdout] === TargetService Activate 1 ===

  void update(String ccid, Map dict, boolean useNoId) {
    boolean before = isSatisfied();
    boolean doCheck = updateMinCardinality(dict) && isSatisfied() != before;
    if (listener != null) {
      // We only have one listener, check if it still is true;
      if (listener.checkTargetChanged(ccid, dict)) {
        if (listener.isOnlyId(useNoId ? Component.NO_CCID : ccid)) {
          // Only one ccid change listener target
          listener.setTarget(ccid, dict);
        } else {
          // We have multiple listener we need multiple listeners
          factoryListeners = new TreeMap();
          for (String p : listener.getIds()) {
            factoryListeners.put(p, listener);
          }
          listener = null;
          // NYI, optimize, we don't have to checkTargetChanged again
        }
      } else if (useNoId) {
        // No change, just make sure that ccid is registered
        listener.addId(ccid, true);
      }
    }
    ...

factoryListeners = {TreeMap@3447}  size = 2
 0 = {TreeMap$Entry@3453} "Component._0" -> "ReferenceListener(Reference TargetService in Immediate component: Component, target=(number=1))"
 1 = {TreeMap$Entry@3454} "Component._2" -> "ReferenceListener(Reference TargetService in Immediate component: Component, target=(number=2))"

knopflerfish / knopflerfish.org Goto Github PK

knopflerfish.org's Introduction

Knopflerfish

Building Knopflerfish OSGi

Prerequisites

Java compatibility

How to build

Building the Knopflerfish OSGi SDK

Working with bndtools

Working with maven

About Knopflerfish

knopflerfish.org's People

Contributors

Stargazers

Watchers

Forkers

knopflerfish.org's Issues

repository> list -help Usage: list [-help] [-l] [] List repositories. Mark with a '*' in the first column if a repository is enabled. -l Verbose output Name or id of repository repository> list -l E Id Rank Description

DEBUG: errors - FrameworkErrorEvent throwable:

TargetService

Component

DEBUG: errors - FrameworkErrorEvent bundle #85

DEBUG: errors - FrameworkErrorEvent throwable:

Recommend Projects

Recommend Topics

Recommend Org

repository> list -help
Usage: list [-help] [-l] []
List repositories. Mark with a '*' in the first
column if a repository is enabled.
-l Verbose output
Name or id of repository
repository> list -l
E Id Rank Description