#109

Committed 22 Sep 2023 07:20PM UTC coverage: 0.0%. Remained the same

Build # #109

Build Type

push

Committed by

Commit Message

Merge pull request #40 from WindhoverLabs/udp_plugin

-Minimally functional UDP plugin.

Run Details

60 of 60 new or added lines in 3 files covered. (100.0%)

0 of 6268 relevant lines covered (0.0%)

0.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/java/org/yamcs/http/api/UDPApi.java

package org.yamcs.http.api;

import com.windhoverlabs.yamcs.udp.api.AbstractUDPApi;
import com.windhoverlabs.yamcs.udp.api.StartUDPRequest;
import com.windhoverlabs.yamcs.udp.api.StopUDPRequest;
import com.windhoverlabs.yamcs.udp.api.UDPConfig;
import org.yamcs.AbstractYamcsService;
import org.yamcs.YamcsServer;
import org.yamcs.api.Observer;
import org.yamcs.events.EventProducer;
import org.yamcs.events.EventProducerFactory;
import org.yamcs.http.Context;

public class UDPApi extends AbstractUDPApi<Context> {

  private EventProducer eventProducer =
      EventProducerFactory.getEventProducer(null, this.getClass().getSimpleName(), 10000);
  ;

  @Override
  public void startUDP(Context ctx, StartUDPRequest request, Observer<UDPConfig> observer) {
    // TODO Auto-generated method stub
    org.yamcs.AbstractYamcsService l =
        (AbstractYamcsService)
            YamcsServer.getServer()
                .getInstance(request.getInstance())
                .getService(request.getLinkName());

    if (l == null) {
      eventProducer.sendInfo("Link:" + request.getLinkName() + " does not exist");
      observer.complete();
      return;
    }
    ((com.windhoverlabs.yamcs.tctm.UdpStreamOutProvider) l).startReceving();
    observer.complete(UDPConfig.newBuilder().build());
  }

  @Override
  public void stopUDP(Context ctx, StopUDPRequest request, Observer<UDPConfig> observer) {
    // TODO Auto-generated method stub
    org.yamcs.AbstractYamcsService l =
        (AbstractYamcsService)
            YamcsServer.getServer()
                .getInstance(request.getInstance())
                .getService(request.getLinkName());

    if (l == null) {
      eventProducer.sendInfo("Link:" + request.getLinkName() + " does not exist");
      observer.complete();
      return;
    }
    ((com.windhoverlabs.yamcs.tctm.UdpStreamOutProvider) l).stopReceving();
    observer.complete(UDPConfig.newBuilder().build());
  }
}

1	package org.yamcs.http.api;
2
3	import com.windhoverlabs.yamcs.udp.api.AbstractUDPApi;
4	import com.windhoverlabs.yamcs.udp.api.StartUDPRequest;
5	import com.windhoverlabs.yamcs.udp.api.StopUDPRequest;
6	import com.windhoverlabs.yamcs.udp.api.UDPConfig;
7	import org.yamcs.AbstractYamcsService;
8	import org.yamcs.YamcsServer;
9	import org.yamcs.api.Observer;
10	import org.yamcs.events.EventProducer;
11	import org.yamcs.events.EventProducerFactory;
12	import org.yamcs.http.Context;
13
14	public class UDPApi extends AbstractUDPApi<Context> {	×
15
16	private EventProducer eventProducer =	×
17	EventProducerFactory.getEventProducer(null, this.getClass().getSimpleName(), 10000);	×
18	;
19
20	@Override
21	public void startUDP(Context ctx, StartUDPRequest request, Observer<UDPConfig> observer) {
22	// TODO Auto-generated method stub
23	org.yamcs.AbstractYamcsService l =
24	(AbstractYamcsService)
25	YamcsServer.getServer()	×
26	.getInstance(request.getInstance())	×
27	.getService(request.getLinkName());	×
28
29	if (l == null) {	×
30	eventProducer.sendInfo("Link:" + request.getLinkName() + " does not exist");	×
31	observer.complete();	×
32	return;	×
33	}
34	((com.windhoverlabs.yamcs.tctm.UdpStreamOutProvider) l).startReceving();	×
35	observer.complete(UDPConfig.newBuilder().build());	×
36	}	×
37
38	@Override
39	public void stopUDP(Context ctx, StopUDPRequest request, Observer<UDPConfig> observer) {
40	// TODO Auto-generated method stub
41	org.yamcs.AbstractYamcsService l =
42	(AbstractYamcsService)
43	YamcsServer.getServer()	×
44	.getInstance(request.getInstance())	×
45	.getService(request.getLinkName());	×
46
47	if (l == null) {	×
48	eventProducer.sendInfo("Link:" + request.getLinkName() + " does not exist");	×
49	observer.complete();	×
50	return;	×
51	}
52	((com.windhoverlabs.yamcs.tctm.UdpStreamOutProvider) l).stopReceving();	×
53	observer.complete(UDPConfig.newBuilder().build());	×
54	}	×
55	}

WindhoverLabs / yamcs-cfs / #109

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous