struct inst_info *inst;
};
+static inline int forward_lb_event_packet(const struct pkg_info *pkg, struct inst_info *inst, const struct packet *packet)
+{
+ struct buffer_info *buffer;
+ struct slave_node *slave;
+ int ret;
+
+ buffer = instance_lb_buffer(inst);
+ if (!buffer) {
+ ErrPrint("Instance[%s] has no buffer\n", instance_id(inst));
+ ret = LB_STATUS_ERROR_FAULT;
+ goto out;
+ }
+
+ slave = package_slave(pkg);
+ if (!slave) {
+ ErrPrint("Package[%s] has no slave\n", package_name(pkg));
+ ret = LB_STATUS_ERROR_INVALID;
+ goto out;
+ }
+
+ packet_ref((struct packet *)packet);
+ ret = slave_rpc_request_only(slave, package_name(pkg), (struct packet *)packet, 0);
+
+out:
+ return ret;
+}
+
+static inline int forward_pd_event_packet(const struct pkg_info *pkg, struct inst_info *inst, const struct packet *packet)
+{
+ struct buffer_info *buffer;
+ struct slave_node *slave;
+ int ret;
+
+ buffer = instance_pd_buffer(inst);
+ if (!buffer) {
+ ErrPrint("Instance[%s] has no buffer\n", instance_id(inst));
+ ret = LB_STATUS_ERROR_FAULT;
+ goto out;
+ }
+
+ slave = package_slave(pkg);
+ if (!slave) {
+ ErrPrint("Package[%s] has no slave\n", package_name(pkg));
+ ret = LB_STATUS_ERROR_INVALID;
+ goto out;
+ }
+
+ packet_ref((struct packet *)packet);
+ ret = slave_rpc_request_only(slave, package_name(pkg), (struct packet *)packet, 0);
+
+out:
+ return ret;
+}
+
+static inline int forward_pd_access_packet(const struct pkg_info *pkg, struct inst_info *inst, const char *command, double timestamp, int x, int y)
+{
+ int ret;
+ struct buffer_info *buffer;
+ struct slave_node *slave;
+ struct packet *p;
+
+ buffer = instance_pd_buffer(inst);
+ if (!buffer) {
+ ErrPrint("Instance[%s] has no buffer\n", instance_id(inst));
+ ret = LB_STATUS_ERROR_FAULT;
+ goto out;
+ }
+
+ slave = package_slave(pkg);
+ if (!slave) {
+ ErrPrint("Package[%s] has no slave\n", package_name(pkg));
+ ret = LB_STATUS_ERROR_INVALID;
+ goto out;
+ }
+
+ p = packet_create_noack(command, "ssdii", package_name(pkg), instance_id(inst), timestamp, x, y);
+ ret = slave_rpc_request_only(slave, package_name(pkg), p, 0);
+
+out:
+ return ret;
+}
+
+static inline int forward_lb_access_packet(const struct pkg_info *pkg, struct inst_info *inst, const char *command, double timestamp, int x, int y)
+{
+ int ret;
+ struct buffer_info *buffer;
+ struct slave_node *slave;
+ struct packet *p;
+
+ buffer = instance_lb_buffer(inst);
+ if (!buffer) {
+ ErrPrint("Instance[%s] has no buffer\n", instance_id(inst));
+ ret = LB_STATUS_ERROR_FAULT;
+ goto out;
+ }
+
+ slave = package_slave(pkg);
+ if (!slave) {
+ ErrPrint("Package[%s] has no slave\n", package_name(pkg));
+ ret = LB_STATUS_ERROR_INVALID;
+ goto out;
+ }
+
+ p = packet_create_noack(command, "ssdii", package_name(pkg), instance_id(inst), timestamp, x, y);
+ ret = slave_rpc_request_only(slave, package_name(pkg), p, 0);
+
+out:
+ return ret;
+}
+
static Eina_Bool lazy_access_status_cb(void *data)
{
struct access_cbdata *cbdata = data;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_event_packet(pkg, inst, packet);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_event_packet(pkg, inst, packet);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_event_packet(pkg, inst, packet);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_event_packet(pkg, inst, packet);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_event_packet(pkg, inst, packet);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_event_packet(pkg, inst, packet);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_event_packet(pkg, inst, packet);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_event_packet(pkg, inst, packet);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_event_packet(pkg, inst, packet);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_event_packet(pkg, inst, packet);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_event_packet(pkg, inst, packet);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_pd_type(pkg) == PD_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_pd_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_pd_event_packet(pkg, inst, packet);
} else if (package_pd_type(pkg) == PD_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Slave is not exists\n");
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
/*!
* Enen if it fails to send packet,
* The packet will be unref'd
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Slave is not exists\n");
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
/*!
* Enen if it fails to send packet,
* The packet will be unref'd
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Slave is not exists\n");
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
/*!
* Enen if it fails to send packet,
* The packet will be unref'd
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Slave is not exists\n");
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
/*!
* Enen if it fails to send packet,
* The packet will be unref'd
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Slave is not exists\n");
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
/*!
* Enen if it fails to send packet,
* The packet will be unref'd
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_access_packet(pkg, inst, packet_command(packet), timestamp, x, y);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_event_packet(pkg, inst, packet);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;
goto out;
if (package_lb_type(pkg) == LB_TYPE_BUFFER) {
- struct buffer_info *buffer;
- struct slave_node *slave;
-
- buffer = instance_lb_buffer(inst);
- if (!buffer) {
- ErrPrint("Instance[%s] has no buffer\n", id);
- ret = LB_STATUS_ERROR_FAULT;
- goto out;
- }
-
- slave = package_slave(pkg);
- if (!slave) {
- ErrPrint("Package[%s] has no slave\n", pkgname);
- ret = LB_STATUS_ERROR_INVALID;
- goto out;
- }
-
- packet_ref((struct packet *)packet);
- ret = slave_rpc_request_only(slave, pkgname, (struct packet *)packet, 0);
+ ret = forward_lb_event_packet(pkg, inst, packet);
} else if (package_lb_type(pkg) == LB_TYPE_SCRIPT) {
struct script_info *script;
Evas *e;