3 Commits
Author SHA1 Message Date
pancake edac98d26e * Shift doc/faq to doc/faq2
* Add 'doc/faq' with most used commands
* -e can be used with -u to specify the path to extract the files
* Remove gui directory
  - GUI source is in src/gui
  - Incrusted inside the build and install targets
    (ignores build and install errors)
2008-03-07 00:20:45 +01:00
pancake 83c25d7eb2 * Initial working version of the flash gui - Renamed to goxf - Needs 'sudo' to be enabled to the user without password - Identify and ban piece files while including them in the list - Support for flashing multiple piece files - progressbar and warn/error messages handled - Supports reboot mobo command
* Make qmode be functional
* Lot of hardcore fixups on squeue_open
  - Should work now everywhere fine asumid UID 1000 as allowed user
  - Reduce timeouts
  - Add push2 method
2008-03-06 17:58:06 +01:00
pancake 2ddb2923c6 * Initial import of the GtkAML gui frontend - Mostly implemented in just one night :)
* Import the squeue c and vapi sources
* Make 0xFFFF run as squeue daemon with -Q flag
* Up to 0.4
2008-03-05 18:38:42 +01:00
22 changed files with 1128 additions and 524 deletions

No files matched your search

+5 -1
View File
@@ -1,9 +1,12 @@
include config.mk
PREFIX?=/usr/local
all: logot
all: logot frontend
cd src && ${MAKE} all
frontend:
-cd src/gui && ${MAKE} all
static: logot
cd libusb && ${MAKE} all
cd src && ${MAKE} static
@@ -21,6 +24,7 @@ clean:
install:
cp src/0xFFFF ${PREFIX}/bin
-cp src/gui/goxf ${PREFIX}/bin
cp logotool/logotool ${PREFIX}/bin
deinstall:
+1 -1
View File
@@ -1,4 +1,4 @@
VERSION=0.3.2
VERSION=0.3.9
PREFIX=/usr
# NetBSD stuff
+29 -59
View File
@@ -1,79 +1,49 @@
<b>FAQ</b>
<h2>FAQ</h2>
This file tries to collect a bunch of common questions/answers about flashing
<b>*) How can I set my Internet Tablet into RD mode with 0xFFFF?</b>
<b>*) Why implement a free software flasher?</b>
The Nokia Internet Tablets are based on Free Software (software libre), but
not everything included *is* free software, for instance, the firmware flasher
tool.
The 0xFFFF project aims to feed the minds of those who really want to
understand how these gadgets work internally, free the knowledge to
avoid the restrictions and fill the lack of information on the most
important part of the system.
That's it, now you can build and run this flasher on *BSD, w32, MacOSX on ARM,
powerpc, x86, mips, etc...
Just type '0xFFFF -r 1' as root
<b>*) Can I brick my device?</b>
<b>*) How can I unpack a FIASCO firmware?
Of course! You're free to do what you want with your device :)
Seriously. Flashing a device is not a safe thing, so I give no warranty
of what will happen to your device when using this tool.
BTW, after a huge number of tests I can say that these devices are hard
to brick, but if you are scared about bricking your device you should
use the flasher provided by Nokia, it's better for your heart's health.
Just type '0xFFFF -r 1' as root
<b>*) What can I do with 0xFFFF?</b>
<b>*) How can I unpack a FIASCO firmware?</b>
Actually 0xFFFF allows you to:
- flash separated pieces of the firmware.
- retrieve information about the device
- reboot de mother board
- extract the current firmware pieces from the device (reverse flash)
- set the USB host/slave mode
- set the R&R mode
- identify firmware pieces
Just type '0xFFFF -u FiascoFirmware.bin -e /tmp' as root
<b>*) What is NOLO?</b>
<b>*) How can I flash a new rootfs?
NOLO is the 'server-side' part of the flasher from Nokia. NOLO means
NOkia LOader and it's composed by two pieces of the firmware that are
flashed together.
Unpack the pieces from the fiasco firmware (the one distributed by Nokia for example) and then type:
On the n800 firmwares, these two pieces are distributed in a single
file, but when flashing a n770, NOLO requires to provide the xloader
(without commiting) and then the secondary piece.
This piece of software is closed source and is the responsable of
handling the requests from the client-side flasher. It provides a
query-like interface via usb control messages for doing different
actions on the device.
# 0xFFFF -R -p rootfs.jffs
<b>*) How can I identify my device?</b>
<b>*) How can I flash a full FIASCO image?</b>
Theorically n770 and n800 have different USB device ID, but this is not
true at all. The first series of the n800 comes with the same usb-id
than n770. That's weird!
It is not recommended to use, it needs more testing, and is more secure to unpack them first manually
and flash the pieces manually with multiple '-p' flags. If you are brave try:
So, the only way to identify the device is by asking nolo for the version
information of different pieces of the firmware. This can be faked, because
you can flash n770 stuff on n800 and viceversa, but it's not recommended
because it wouldn't work :)
# 0xFFFF -F FiascoFirmware.fiasco
<b>*) Can I unpack fiasco blobs?</b>
<h2>Advanced commands</h2>
Actually the fiasco format is not yet supported and not planned in
short term. There is no real need for supporting a proprietary
format image containing a proprietary system.
<b>*) How to extract the firmware pieces from a running device?</b>
We can just use tarballs containing the desired pieces.
It is possible to dump the firmware pieces from the internal MTD to reconstruct a FIASCO image.
To do this recompile the flasher for ARM and run this command in the device:
# mkdir /media/mmc1/backup
# 0xFFFF -e /media/mmc1/backup
<b>*) Dumping configuration region</b>
There's a hidden mtd partition containing undocumented configuration information. This one can be
dumped from the device using the following command:
# 0xFFFF -x
+80
View File
@@ -0,0 +1,80 @@
<b>FAQ</b>
This file tries to collect a bunch of common questions/answers about flashing
<b>*) Why implement a free software flasher?</b>
The Nokia Internet Tablets are based on Free Software (software libre), but
not everything included *is* free software, for instance, the firmware flasher
tool.
The 0xFFFF project aims to feed the minds of those who really want to
understand how these gadgets work internally, free the knowledge to
avoid the restrictions and fill the lack of information on the most
important part of the system.
That's it, now you can build and run this flasher on *BSD, w32, MacOSX on ARM,
powerpc, x86, mips, etc...
<b>*) Can I brick my device?</b>
Of course! You're free to do what you want with your device :)
Seriously. Flashing a device is not a safe thing, so I give no warranty
of what will happen to your device when using this tool.
BTW, after a huge number of tests I can say that these devices are hard
to brick, but if you are scared about bricking your device you should
use the flasher provided by Nokia, it's better for your heart's health.
<b>*) What can I do with 0xFFFF?</b>
Actually 0xFFFF allows you to:
- flash separated pieces of the firmware.
- retrieve information about the device
- reboot de mother board
- extract the current firmware pieces from the device (reverse flash)
- set the USB host/slave mode
- set the R&R mode
- identify firmware pieces
<b>*) What is NOLO?</b>
NOLO is the 'server-side' part of the flasher from Nokia. NOLO means
NOkia LOader and it's composed by two pieces of the firmware that are
flashed together.
On the n800 firmwares, these two pieces are distributed in a single
file, but when flashing a n770, NOLO requires to provide the xloader
(without commiting) and then the secondary piece.
This piece of software is closed source and is the responsable of
handling the requests from the client-side flasher. It provides a
query-like interface via usb control messages for doing different
actions on the device.
<b>*) How can I identify my device?</b>
Theorically n770 and n800 have different USB device ID, but this is not
true at all. The first series of the n800 comes with the same usb-id
than n770. That's weird!
So, the only way to identify the device is by asking nolo for the version
information of different pieces of the firmware. This can be faked, because
you can flash n770 stuff on n800 and viceversa, but it's not recommended
because it wouldn't work :)
<b>*) Can I unpack fiasco blobs?</b>
Actually the fiasco format is not yet supported and not planned in
short term. There is no real need for supporting a proprietary
format image containing a proprietary system.
We can just use tarballs containing the desired pieces.
-53
View File
@@ -1,53 +0,0 @@
- preferences
* choose flasher type.
by default 0xFFFF is used
*
piece [file]
|
+-- radio
|
+-- nbh
info
|
+-- -i
reboot
|
+-- ???
----------
piece [file]
|
+-- xloader
|
+-- secondary
|
+-- kernel
|
+-- initfs
|
+-- rootfs
|
+-- autodetected
info
|
+-- -i
usb-host-mode
|
+-- -U [0|1]
rd-mode
|
+-- -r 0|1
reboot
|
+-- -R
-11
View File
@@ -1,11 +0,0 @@
OBJ=main.o
BIN=goxf
CFLAGS=`pkg-config gladeui-1.0 libglade-2.0 gmodule-2.0 --cflags`
LDFLAGS=`pkg-config gladeui-1.0 libglade-2.0 gmodule-2.0 --libs`
all: ${OBJ}
${CC} ${LDFLAGS} ${OBJ} -o ${BIN}
clean:
-rm -f ${BIN} ${OBJ}
-279
View File
@@ -1,279 +0,0 @@
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<!DOCTYPE glade-interface SYSTEM "glade-2.0.dtd">
<!--*- mode: xml -*-->
<glade-interface>
<widget class="GtkWindow" id="main_window">
<property name="border_width">5</property>
<property name="title" translatable="yes" context="yes">g0xFFFF</property>
<property name="default_width">501</property>
<property name="default_height">329</property>
<property name="icon_name">gtk-connect</property>
<signal name="destroy_event" handler="gtk_main_quit" object="0"/>
<child>
<widget class="GtkVBox" id="vbox1">
<property name="visible">True</property>
<property name="spacing">3</property>
<child>
<widget class="GtkHButtonBox" id="hbuttonbox2">
<property name="visible">True</property>
<property name="layout_style">GTK_BUTTONBOX_START</property>
<child>
<widget class="GtkComboBox" id="combobox2">
<property name="visible">True</property>
<property name="active">0</property>
<property name="items" translatable="yes" context="yes">n770/n800/n810
HERMflasher</property>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
</packing>
</child>
<child>
<placeholder/>
</child>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
</packing>
</child>
<child>
<widget class="GtkHBox" id="hbox1">
<property name="visible">True</property>
<property name="spacing">6</property>
<child>
<widget class="GtkScrolledWindow" id="scrolledwindow1">
<property name="visible">True</property>
<property name="can_focus">False</property>
<property name="hscrollbar_policy">GTK_POLICY_AUTOMATIC</property>
<property name="vscrollbar_policy">GTK_POLICY_AUTOMATIC</property>
<child>
<widget class="GtkTreeView" id="tree">
<property name="visible">True</property>
</widget>
</child>
</widget>
</child>
<child>
<widget class="GtkVBox" id="vbox2">
<property name="visible">True</property>
<property name="border_width">3</property>
<property name="spacing">2</property>
<child>
<widget class="GtkFileChooserButton" id="file">
</widget>
<packing>
<property name="expand">False</property>
</packing>
</child>
<child>
<widget class="GtkComboBox" id="piece">
<property name="row_span_column">0</property>
<property name="column_span_column">0</property>
<property name="active">0</property>
<property name="tearoff_title">patata</property>
<property name="items" translatable="yes" context="yes">rootfs
initfs
kernel
secondary
xloader</property>
</widget>
<packing>
<property name="expand">False</property>
<property name="position">1</property>
</packing>
</child>
<child>
<widget class="GtkHBox" id="hbox4">
<property name="visible">True</property>
<child>
<widget class="GtkButton" id="button2">
<property name="visible">True</property>
<property name="label" context="yes">Remove</property>
<property name="response_id">0</property>
<signal name="clicked" handler="gui_remove"/>
<signal name="activate" handler="gui_remove"/>
</widget>
</child>
<child>
<widget class="GtkButton" id="add">
<property name="visible">True</property>
<property name="label" context="yes">Add</property>
<property name="response_id">0</property>
<signal name="clicked" handler="gui_add"/>
<signal name="activate" handler="gui_add"/>
</widget>
<packing>
<property name="position">1</property>
</packing>
</child>
</widget>
<packing>
<property name="expand">False</property>
<property name="position">2</property>
</packing>
</child>
<child>
<widget class="GtkCheckButton" id="usbhost">
<property name="visible">True</property>
<property name="label" translatable="yes" context="yes">USB host mode</property>
<property name="response_id">0</property>
<property name="draw_indicator">True</property>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
<property name="position">3</property>
</packing>
</child>
<child>
<widget class="GtkCheckButton" id="rdmode">
<property name="visible">True</property>
<property name="label" translatable="yes" context="yes">R&amp;D mode</property>
<property name="response_id">0</property>
<property name="draw_indicator">True</property>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
<property name="position">4</property>
</packing>
</child>
<child>
<widget class="GtkCheckButton" id="reboot">
<property name="visible">True</property>
<property name="label" translatable="yes" context="yes">Reboot</property>
<property name="response_id">0</property>
<property name="draw_indicator">True</property>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
<property name="position">5</property>
</packing>
</child>
</widget>
<packing>
<property name="expand">False</property>
<property name="pack_type">GTK_PACK_END</property>
<property name="position">1</property>
</packing>
</child>
</widget>
<packing>
<property name="padding">3</property>
<property name="position">1</property>
</packing>
</child>
<child>
<widget class="GtkHBox" id="hbox3">
<property name="visible">True</property>
<property name="spacing">6</property>
<child>
<widget class="GtkProgressBar" id="pbar">
<property name="visible">True</property>
<property name="show_text">True</property>
</widget>
</child>
<child>
<widget class="GtkHBox" id="hbox5">
<property name="visible">True</property>
<child>
<widget class="GtkButton" id="info">
<property name="visible">True</property>
<property name="label" translatable="yes" context="yes">gtk-dialog-info</property>
<property name="use_stock">True</property>
<property name="response_id">0</property>
<signal name="clicked" handler="gui_information" object="main_window"/>
<signal name="activate" handler="gui_information" object="main_window"/>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
</packing>
</child>
<child>
<widget class="GtkButton" id="but_commit">
<property name="visible">True</property>
<property name="label" translatable="yes" context="yes">gtk-execute</property>
<property name="use_stock">True</property>
<property name="response_id">0</property>
<signal name="clicked" handler="gui_run"/>
<signal name="activate" handler="gui_run"/>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
<property name="position">1</property>
</packing>
</child>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
<property name="pack_type">GTK_PACK_END</property>
<property name="position">1</property>
</packing>
</child>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
<property name="position">2</property>
</packing>
</child>
</widget>
</child>
</widget>
<widget class="GtkAboutDialog" id="information">
<property name="events">GDK_POINTER_MOTION_MASK | GDK_POINTER_MOTION_HINT_MASK | GDK_BUTTON_PRESS_MASK | GDK_BUTTON_RELEASE_MASK</property>
<property name="border_width">5</property>
<property name="title" translatable="yes" context="yes">About Glade</property>
<property name="resizable">False</property>
<property name="window_position">GTK_WIN_POS_CENTER_ON_PARENT</property>
<property name="type_hint">GDK_WINDOW_TYPE_HINT_DIALOG</property>
<property name="has_separator">False</property>
<property name="program_name">Glade</property>
<child internal-child="vbox">
<widget class="GtkVBox" id="dialog-vbox3">
<property name="visible">True</property>
<property name="events">GDK_POINTER_MOTION_MASK | GDK_POINTER_MOTION_HINT_MASK | GDK_BUTTON_PRESS_MASK | GDK_BUTTON_RELEASE_MASK</property>
<property name="spacing">2</property>
<child>
<widget class="GtkScrolledWindow" id="scrolledwindow2">
<property name="visible">True</property>
<property name="can_focus">True</property>
<property name="events">GDK_POINTER_MOTION_MASK | GDK_POINTER_MOTION_HINT_MASK | GDK_BUTTON_PRESS_MASK | GDK_BUTTON_RELEASE_MASK</property>
<property name="hscrollbar_policy">GTK_POLICY_AUTOMATIC</property>
<property name="vscrollbar_policy">GTK_POLICY_AUTOMATIC</property>
<child>
<widget class="GtkTextView" id="textview1">
<property name="visible">True</property>
<property name="can_focus">True</property>
<property name="events">GDK_POINTER_MOTION_MASK | GDK_POINTER_MOTION_HINT_MASK | GDK_BUTTON_PRESS_MASK | GDK_BUTTON_RELEASE_MASK</property>
<property name="pixels_below_lines">2</property>
<property name="editable">False</property>
<property name="cursor_visible">False</property>
</widget>
</child>
</widget>
<packing>
<property name="position">2</property>
</packing>
</child>
<child internal-child="action_area">
<widget class="GtkHButtonBox" id="dialog-action_area3">
<property name="visible">True</property>
<property name="events">GDK_POINTER_MOTION_MASK | GDK_POINTER_MOTION_HINT_MASK | GDK_BUTTON_PRESS_MASK | GDK_BUTTON_RELEASE_MASK</property>
<property name="layout_style">GTK_BUTTONBOX_END</property>
</widget>
<packing>
<property name="expand">False</property>
<property name="pack_type">GTK_PACK_END</property>
</packing>
</child>
</widget>
</child>
</widget>
</glade-interface>
-77
View File
@@ -1,77 +0,0 @@
/*
* 0xFFFF - Open Free Fiasco Firmware Flasher
* Copyright (C) 2007 pancake <pancake@youterm.com>
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include <glade/glade.h>
#include <gtk/gtk.h>
#define U(x) printf("%d\n",x); fflush(stdout);
GladeXML *xml;
int main(int argc, char **argv)
{
GtkWidget *w;
gtk_init(&argc, &argv);
xml = glade_xml_new("g0xFFFF.glade", "main_window", "");
//xml = glade_xml_new("test.glade", "window1", NULL);
if(!xml) {
g_warning("We could not load the interface!");
return 1;
}
glade_xml_signal_autoconnect(xml);
w = glade_xml_get_widget(xml, "main_window");
gtk_signal_connect(GTK_OBJECT(w), "destroy",
GTK_SIGNAL_FUNC(gtk_main_quit),NULL);
{
GtkComboBox *piece = GTK_COMBO_BOX(glade_xml_get_widget(xml, "piece"));
gtk_combo_box_set_active(piece, 0);
}
gtk_widget_show_all(w);
gtk_object_unref(GTK_OBJECT(xml));
gtk_main();
return 0;
}
extern void gui_run();
extern void gui_run()
{
printf("run\n");
}
extern void gui_add();
extern void gui_add()
{
GtkTreeView *tree = glade_xml_get_widget(xml, "tree");
GtkFileChooser *file = GTK_FILE_CHOOSER(glade_xml_get_widget(xml, "file"));
GtkComboBox *piece = GTK_COMBO_BOX(glade_xml_get_widget(xml, "piece"));
printf("ADD %s\n", gtk_file_chooser_get_filename(file));
printf("ADD %d\n", gtk_combo_box_get_active(piece));
}
extern void gui_information();
void gui_information()
{
printf("FUCKMENOT!\n");
fflush(stdout);
}
+2 -1
View File
@@ -1,6 +1,7 @@
include ../config.mk
OBJ=main.o fiasco.o hexdump.o dump.o flash.o serial.o
OBJ=main.o fiasco.o hexdump.o dump.o flash.o serial.o qmode.o
OBJ+=hash.o fpid.o query.o pieces.o utils.o devices.o console.o
OBJ+=squeue/squeue.o
BIN=0xFFFF
#LIBS=`${HAVE_USB} && echo -- '-lusb'`
LIBS=`if [ "${HAVE_USB}" = 1 ]; then echo '-lusb'; fi`
+26
View File
@@ -20,6 +20,29 @@
#include <stdio.h>
#include <string.h>
/* global structs */
char *pieces[] = {
"xloader", // xloader.bin
"2nd", // 2nd
"secondary", // secondary.bin
"kernel", // zImage
"initfs", // jffs'd initfs
"rootfs", // 80mB of blob
"omap-nand", // 8kB of food for the nand
"fiasco", // FIASCO IMAGE
NULL
};
long fpid_size(const char *filename)
{
long sz;
FILE *fd = fopen(filename, "r");
fseek(fd, 0, SEEK_END);
sz = ftell(fd);
fclose(fd);
return sz;
}
const char *fpid_file(const char *filename)
{
FILE *fd;
@@ -45,6 +68,9 @@ const char *fpid_file(const char *filename)
size = ftell(fd);
fclose(fd);
if (!memcmp(b, "\xb4", 1))
return pieces[PIECE_FIASCO];
else
if (!memcmp(b+0x34, "2NDAPE", 6))
return pieces[PIECE_2ND];
else
+6
View File
@@ -0,0 +1,6 @@
all:
gtkamlc --save-temps --Xcc=-I../squeue ../squeue/squeue.c ../fpid.c ../squeue/squeue.vapi gui.gtkaml extras.vapi --pkg gtk+-2.0 -o goxf
test:
valac --save-temps --Xcc=-I.. squeue.vapi test.vala ../squeue.c -o v
valac --save-temps --Xcc=-I.. squeue.vapi client.vala ../squeue.c -o c
+10
View File
@@ -0,0 +1,10 @@
namespace Extras {
public class External {
[CCode (cname = "system")]
public static int system(string cmd);
[CCode (cname = "fpid_file")]
public static string fpid_file(string file);
[CCode (cname = "fpid_size")]
public static long fpid_size(string file);
}
}
+360
View File
@@ -0,0 +1,360 @@
<!--
Frontend for the 0xFFFF flasher in gtkaml
author: pancake <youterm.com>
-->
<Window xmlns="Gtk"
xmlns:GLib="GLib"
xmlns:Extras="Extras"
xmlns:SQueues="SQueues"
xmlns:class="http://gtkaml.org/0.2"
class:name="MainWindow"
title="0xFFFF GUI"
delete-event="{OnWindow1DeleteEvent}">
<VBox>
<MenuBar expand="false">
<MenuItem label="_File" with-mnemonic="true">
<submenu>
<Menu>
<ImageMenuItem stock-id="gtk-new" activate="{OnFileNewEvent}"/>
<ImageMenuItem stock-id="gtk-open" activate="{OnFileOpenEvent}"/>
<SeparatorMenuItem />
<ImageMenuItem stock-id="gtk-quit" activate="{OnQuitEvent}"/>
</Menu>
</submenu>
</MenuItem>
<!-- Help menu -->
<MenuItem label="_Target" with-mnemonic="true">
<submenu>
<Menu>
<ImageMenuItem stock-id="gtk-connect" activate="{OnConnect}"/>
<ImageMenuItem stock-id="gtk-info" activate="{OnGetInformation}"/>
<ImageMenuItem label="Reset" activate="{OnReset}"/>
</Menu>
</submenu>
</MenuItem>
<!-- Help menu -->
<MenuItem label="_Help" with-mnemonic="true">
<submenu>
<Menu>
<ImageMenuItem stock-id="gtk-about" activate="{OnMenuHelpAboutActivatedEvent}"/>
</Menu>
</submenu>
</MenuItem>
</MenuBar>
<HBox border-width="5">
<VBox border-width="3" spacing="3">
<ScrolledWindow can-focus="true" hscrollbar-policy="{PolicyType.AUTOMATIC}" vscrollbar-policy="{PolicyType.AUTOMATIC}">
<TreeView class:private="tv">
</TreeView>
</ScrolledWindow>
</VBox>
<VBox expand="false" border-width="3" spacing="3">
<Button label="gtk-connect" use-stock="true" expand="false" clicked="{OnConnect}"/>
<Button label="gtk-info" use-stock="true" expand="false" clicked="{OnGetInformation}"/>
<Label label="" />
<!-- <Button label="Options" use-stock="false" expand="false"/>
<Button label="Fiasco!" use-stock="false" expand="false"/>
<Button label="Unpack!" use-stock="false" expand="false"/> -->
<Button label="gtk-add" use-stock="true" expand="false" clicked="{OnFileOpenEvent}" />
<Button label="gtk-remove" use-stock="true" expand="false" clicked="{list_del}"/>
<Label label="" />
<Button label="gtk-media-record" use-stock="true" expand="false" clicked="{OnFileFlashEvent}"/>
</VBox>
</HBox>
<ProgressBar class:private="pb" expand="false" />
<!-- <Statusbar expand="false"/> -->
</VBox>
<AboutDialog class:standalone="true" class:private="aboutdialog1" delete-event="{aboutdialog1.hide_on_delete}"
border-width="5" title="About 0xFFFF gui" resizable="false" modal="true"
window-position="{WindowPosition.CENTER_ON_PARENT}" has-separator="false"
program-name="0xFFFF" version="0.3.9" copyright="Copyright (c) 2008 pancake"
comments="The Free Nokia Internet Tablet flasher"
website="http://www.nopcode.org/0xFFFF/"
authors='{new string[] {"pancake (pancake@youterm.com)", null}}'>
</AboutDialog>
<![CDATA[
private void OnWindow1DeleteEvent ()
{
doCloseApplication ();
}
private void doCloseApplication ()
{
Gtk.main_quit ();
}
private void OnReset()
{
q->push("reset:device", 1);
}
private void OnFileFlashEvent()
{
ListStore ls = (ListStore)tv.get_model();
weak string str;
TreeIter iter;
int n = ls.iter_n_children(null);
if (n >0) {
if (showYesNo("Do you want to flash these files?")) {
ls.get_iter_first(out iter);
do {
ls.get(iter, 2, out str, -1);
//stdout.printf("polla:%s\n", str);
q->push2("flash", str, 1);
} while(ls.iter_next(ref iter));
}
} else {
showMessage("No files selected", MessageType.ERROR);
}
}
private void OnFileOpenEvent ()
{
FileChooserDialog fc = new FileChooserDialog("Select file to open",
this, FileChooserAction.OPEN,
"gtk-cancel", ResponseType.CANCEL,
"gtk-open", ResponseType.ACCEPT);
int resp = fc.run ();
fc.hide ();
if (resp == ResponseType.ACCEPT) {
string file = fc.get_filename();
string *type = External.fpid_file(file);
string size = "%ld".printf(External.fpid_size(file));
if (type == null) {
showMessage("Invalid file type", MessageType.ERROR);
} else {
add_file(type, size, file);
}
}
fc.destroy ();
}
public bool loadFile( string filename )
{
int err = 0;
try {
string contents; int length;
FileUtils.get_contents (filename, out contents, out length);
//textview1.buffer.set_text (contents, length);
} catch(Error e) {
showError ("Unexpected error while loading the file, please contact the author with the following information:\n\n" + e.message);
err++;
}
return err == 0;
}
public bool showYesNo(string s)
{
MessageDialog md = new MessageDialog (this,
DialogFlags.DESTROY_WITH_PARENT,
MessageType.QUESTION, ButtonsType.YES_NO, s);
int ret = md.run ();
md.destroy ();
return ret==ResponseType.YES;
}
public void showMessage(string s, MessageType mt)
{
MessageDialog md = new MessageDialog (this,
DialogFlags.DESTROY_WITH_PARENT,
mt, ButtonsType.CLOSE, s);
md.run ();
md.destroy ();
}
private void OnMenuHelpAboutActivatedEvent ()
{
aboutdialog1.transient_for = this;
aboutdialog1.run ();
}
public void showError (string s)
{
MessageDialog md = new MessageDialog (this,
DialogFlags.DESTROY_WITH_PARENT,
MessageType.ERROR,
ButtonsType.CLOSE,
s);
md.run ();
md.destroy ();
}
private void OnFileNewEvent ()
{
list_clear();
// TODO: clear file list
}
private void OnQuitEvent ()
{
doCloseApplication();
External.system("sudo pkill 0xFFFF");
// TODO: send message to gracefully kill 0xFFFF
// TODO: handle ^C when flashing
}
public void list_clear()
{
((ListStore)tv.model).clear();
}
public void list_del()
{
TreeIter iter;
TreeModel model;
weak string str = "";
TreeSelection sel = tv.get_selection();
if (sel.count_selected_rows() == 1) {
sel.get_selected(out model, out iter);
//((ListStore)tv.model)).get(ref iter, 2, out str, -1);
//stdout.printf("NAME IS: "+str);
((ListStore)tv.model).remove(iter);
}
//return str;
}
public void add_file(string type, string size, string file)
{
ListStore listmodel = (ListStore)tv.get_model();
Gtk.TreeIter iter;
listmodel.append (out iter);
listmodel.set (iter, 0, type, 1, size, 2, file, -1);
}
public static void setup_treeview (Gtk.TreeView view)
{
/* use liststore to hold accountname, accounttype, balance and color attribute */
/* for more info how gtkTreeview works take a look in the GTK API */
var listmodel = new Gtk.ListStore(4, typeof(string), typeof(string), typeof(string), typeof(string));
view.set_model(listmodel);
view.insert_column_with_attributes (-1, "Type", new Gtk.CellRendererText(), "text", 0, null);
view.insert_column_with_attributes (-1, "Size", new Gtk.CellRendererText(), "text", 1, null);
var cell = new Gtk.CellRendererText ();
cell.set ("foreground_set", true, null);
view.insert_column_with_attributes (-1, "Name", cell, "text", 2, "foreground", 3, null);
// Gtk.TreeIter iter;
// listmodel.append (out iter);
// listmodel.set (iter, 0, "initfs", 1, "3M", 2, "initfs.jffs", -1);
//listmodel.set (iter, 0, "initfs", 1, "3M", 2, "initfs.jffs", 3, "green", -1);
// listmodel.append (out iter);
// listmodel.set (iter, 0, "rootfs", 1, "52M", 2, "rootfs.jffs", -1);
}
public static bool readFunc()
{
weak string msg = p->get(0);
if (msg != null && msg[0]!='\0') {
stdout.printf("[<] msg received: %s\n", msg);
string[] foo = msg.split(":",2);
if (foo[1] != null) {
switch(foo[0]) {
case "bar":
viewer.pb.fraction = foo[1].to_int() / 100;
viewer.pb.text = foo[1]+"%";
break;
case "error":
viewer.showMessage(foo[1], MessageType.ERROR);
break;
case "info":
viewer.showMessage(foo[1], MessageType.INFO);
break;
default:
stderr.printf("[E] Unknown message type\n");
break;
}
//viewer.showMessage(msg, MessageType.INFO);
}
p->pop();
}
return true;
}
static SQueue *q = null;
static SQueue *p = null;
private void OnGetInformation()
{
msg("info:device");
}
private void OnConnect()
{
//msg("connect:device");
External.system("sudo pkill 0xFFFF");
External.system("sudo ../0xFFFF -Q &");
p->close();
q->close();
p = q = null;
}
private bool chk_queues()
{
if (p == null)
p = SQueue.open("/tmp/0xFFFF.1", SQueueMode.OPEN);
if (q == null)
q = SQueue.open("/tmp/0xFFFF.2", SQueueMode.OPEN);
if (p == null || q == null) {
showMessage("Cannot connect to queues", MessageType.ERROR);
return false;
}
return true;
}
public void msg(string str)
{
if (!chk_queues())
return;
if (q->push(str, 0)<1) {
stderr.printf("Oops on push\n");
q->free();
q = null;
p->free();
p = null;
}
}
static MainWindow viewer;
static int main (string[] args)
{
Gtk.init (ref args);
viewer = new MainWindow();
if (args.length > 1)
viewer.loadFile (args[1]);
viewer.resize(600,400);
viewer.set_position(WindowPosition.CENTER);
setup_treeview(viewer.tv);
viewer.show_all ();
viewer.showMessage("This software is beta and does not guaranties correct functionality", MessageType.WARNING);
Timeout.add(200, (SourceFunc)(readFunc));
Gtk.main ();
return 0;
}
]]>
</Window>
+22 -20
View File
@@ -1,6 +1,6 @@
/*
* 0xFFFF - Open Free Fiasco Firmware Flasher
* Copyright (C) 2007 pancake <pancake@youterm.com>
* Copyright (C) 2007, 2008 pancake <pancake@youterm.com>
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
@@ -40,20 +40,9 @@ int verbose = 0;
int identify = 0;
int moboreboot = 0;
int unpack = 0;
int qmode = 0;
int info = 0;
/* global structs */
char *pieces[] = {
"xloader", // xloader.bin
"2nd", // 2nd
"secondary", // secondary.bin
"kernel", // zImage
"initfs", // jffs'd initfs
"rootfs", // 80mB of blob
"omap-nand", // 8kB of food for the nand
NULL
};
char *modes[]={
"host",
"peripheral",
@@ -86,16 +75,19 @@ void show_usage()
printf(" -f <flags> set the given RD flags (see '-f help')\n");
printf(" -i show device information (let standby mode)\n");
printf(" -l list supported usb device ids\n");
printf(" -p [[p%%]file] piece-of-firmware %% file-where-this-piece-is\n");
printf(" -p [[p%%]file] piece-of-firmware %% file-where-this-piece-is\n");
printf(" -r [0|1] disable/enable R&D mode\n");
printf(" -R reboot the omap board\n");
printf(" -U [0|1] disable/enable the usb host mode\n");
#endif
#if HAVE_SQUEUE
printf(" -Q enter shared queues server mode (for gui or remote)\n");
#endif
printf("Local stuff:\n");
printf(" -s [serial] serial port console (minicom like terminal)\n");
printf(" -h show this help message\n");
printf(" -C [/dev/mtd] check bad blocks on mtd\n");
printf(" -e [path] dump and extract pieces to path\n");
printf(" -e [path] dump/extract pieces to path\n");
printf(" -F [fiasco] flash a fiasco firmware image\n");
printf(" -H [file] calculate hash for file\n");
printf(" -I [piece] identify a firmware piece\n");
@@ -222,7 +214,7 @@ int main(int argc, char **argv)
{
int c;
while((c = getopt(argc, argv, "C:cp:PvVhRu:ib:U:r:e:ld:I:D:f:F:s:xH:")) != -1) {
while((c = getopt(argc, argv, "QC:cp:PvVhRu:ib:U:r:e:ld:I:D:f:F:s:xH:")) != -1) {
switch(c) {
case 'H':
printf("xorpair: %04x\n", do_hash_file(optarg));
@@ -286,6 +278,9 @@ int main(int argc, char **argv)
fiasco_image = optarg;
unpack = 1;
break;
case 'Q':
qmode = 1;
break;
case 'P':
return fiasco_pack(optind, argv);
case 'I':
@@ -306,6 +301,9 @@ int main(int argc, char **argv)
}
}
if (qmode)
return queue_mode();
if (identify)
return 0;
@@ -317,17 +315,21 @@ int main(int argc, char **argv)
&& (rd_flags == -1)
&& (rd_mode == -1)
&& (info == 0)
&& (moboreboot == 0)
&& (moboreboot == 0)
&& (usb_mode == -1)
&& (root_device == -1))
{
printf("0xFFFF [-chilRvVx] [-C mtd-dev] [-d vid:pid] [-D 0|1|2] [-e path] [-f flags]\n");
printf(" [-F fiasco] [-H hash-file] [-I piece] [-p [piece%%]file]] [-r 0|1]\n");
printf(" [-s serial-dev] [-u fiasco-image] [-U 0|1] | [-P new-fiasco] [piece1] [2] ..\n");
printf("# The Free Fiasco Firmware Flasher v"VERSION"\n"
"0xFFFF [-chilQRvVx] [-C mtd-dev] [-d vid:pid] [-D 0|1|2] [-e path] [-f flags]\n"
" [-F fiasco] [-H hash-file] [-I piece] [-p [piece%%]file]] [-r 0|1]\n"
" [-s serial-dev] [-u fiasco-image] [-U 0|1] | [-P new-fiasco] [piece1] [2] ..\n");
return 1;
}
if (unpack) {
if (reverseto)
chdir(reverseto);
unpack_fiasco_image(fiasco_image);
return 0;
}
+5
View File
@@ -4,6 +4,9 @@
#include "hash.h"
#include "nolo.h"
#include "os.h"
extern char strbuf[1024];
#define _FILE_OFFSET_BITS 64
#define _GNU_SOURCE
@@ -11,6 +14,7 @@
// Forward declaration for use in function arguments.
struct devices;
int queue_mode();
int reverse_extract_pieces(char *dir);
void flash_image(char *filename, char *piece, char *version);
int fiasco_read_image(char *file);
@@ -80,6 +84,7 @@ enum {
PIECE_INITFS,
PIECE_ROOTFS,
PIECE_OMAPNAND,
PIECE_FIASCO,
PIECE_LAST
};
+19
View File
@@ -0,0 +1,19 @@
#ifndef _OS_H_
#define _OS_H_
#if __linux__ || __NetBSD__ || __FreBSD__ || __OpenBSD__ || __Darwin__ || __MacOSX__
#define HAVE_SQUEUE 1
#else
#define HAVE_SQUEUE 0
#endif
#if HAVE_SQUEUE
#include "squeue/squeue.h"
extern int qmode;
extern struct squeue_t *p;
#endif
#endif
+144
View File
@@ -0,0 +1,144 @@
/*
* 0xFFFF - Open Free Fiasco Firmware Flasher
* Copyright (C) 2008 pancake <pancake@youterm.com>
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include "main.h"
#include "os.h"
#include <stdio.h>
#include <signal.h>
#if HAVE_SQUEUE
struct squeue_t *q;
struct squeue_t *p;
int fork_enabled = 0;
int dofork()
{
if (fork_enabled)
return fork();
return 0;
}
void process_message(char *msg)
{
char *str;
char *arg;
int c;
if (msg == NULL)
return;
printf("[x] (%s)\n", msg);
str = strdup(msg);
arg = strchr(str, ':');
if (c!=NULL) {
arg[0]='\0';
arg = arg +1;
if (!strcmp(str, "flash")) {
char buf[1024];
char *type = fpid_file(arg);
if (type == NULL) {
squeue_push2(p, "error", "Unknown piece format", 1);
} else {
flash_image(arg, type, NULL);
}
} else
if (!strcmp(str, "reset")) {
if (reboot_board() == 0) {
squeue_push2(p,"info", "Device reboots", 1);
} else
squeue_push2(p,"error", "Cannot reboot device", 1);
} else
if (!strcmp(str, "info")) {
get_rd_flags();
squeue_push2(p, "info", strbuf, 1);
get_nolo_version();
squeue_push2(p, "info", strbuf, 1);
get_usb_mode();
squeue_push2(p, "info", strbuf, 1);
} else
squeue_push2(p, "error", "invalid command", 0);
} else {
squeue_push2(p, "error", "invalid command format", 0);
}
free(str);
}
static void cc()
{
squeue_close(p);
squeue_close(q);
printf("pipes closed\n");
squeue_release("/tmp/0xFFFF.1");
squeue_release("/tmp/0xFFFF.2");
exit(1);
}
int queue_mode()
{
int pid = 0;
char *msg;
signal(SIGINT, cc);
pid = dofork();
if (pid) {
wait(pid);
return 0;
} else {
p = squeue_open("/tmp/0xFFFF.1", Q_CREAT);
q = squeue_open("/tmp/0xFFFF.2", Q_CREAT);
if (p == NULL || q == NULL) {
fprintf(stderr, "Cannot open queue files\n");
return 0;
}
chmod("/tmp/0xFFFF.1", 0666);
chmod("/tmp/0xFFFF.2", 0666);
pid = dofork();
if (pid) {
printf( "Entering into shared queue server mode.\n"
"Type $ kill -9 %d # to stop\n"
"NOTE: Manually remove the /tmp/.0xFFFF.* files to solve perm problems\n", pid);
} else {
do {
#if HAVE_USB
if (connect_via_usb()) {
fprintf(stderr, "Cannot connect to device. It is possibly not in boot stage.\n");
squeue_push2(p, "error", "Cannot connect to the device", 1);
return 0;
}
#endif
printf("Waiting for a client in shared queues..\n");
setsid();
while(1) {
msg = squeue_get(q, 1);
if (msg) {
process_message(msg);
squeue_pop(q);
}
}
printf("Connection restarted\n");
} while (1);
}
}
return 0;
}
#else
int queue_mode()
{
/* dummy */
fprintf(stderr, "No HAVE_SQUEUE support\n");
}
#endif
+35 -13
View File
@@ -24,6 +24,8 @@
#include <stdlib.h>
#include <usb.h>
char strbuf[1024];
/* wait for status = 0 */
int get_status()
{
@@ -76,7 +78,8 @@ int get_usb_mode()
return -1;
}
printf("Device's USB mode is '%s'\n", (mode) ? "host" : "client");
sprintf(strbuf, "Device's USB mode is '%s'\n", (mode) ? "host" : "client");
printf(strbuf);
return 0;
}
@@ -160,11 +163,12 @@ int get_rd_mode()
{
char isrd = 1;
strbuf[0]='\0';
if (usb_control_msg(dev, CMD_QUERY, NOLO_GET_RDFLAGS, 0, 0, (char *)&isrd, 1, 2000) == -1) {
fprintf(stderr, "Cannot query rd mode.\n");
return -1;
}
printf("RD mode is: %s\n", isrd?"on":"off");
sprintf(strbuf, "RD mode is: %s\n", isrd?"on":"off");
return isrd;
}
@@ -173,16 +177,19 @@ int get_root_device()
{
unsigned char opcode;
strbuf[0] = '\0';
if (usb_control_msg(dev, CMD_QUERY, NOLO_GET_RDFLAGS, 0, 1, (char *)&opcode, 1, 2000) < 0) {
fprintf(stderr, "Cannot query root device\n");
return -1;
}
if (opcode>2) { // use sizeof || enum
printf("Invalid root device received from the device '%d'.\n", opcode);
fprintf(stderr, "Invalid root device received from the device '%d'.\n", opcode);
return -1;
}
printf("Root device is: %s\n", root_devices[opcode]);
sprintf(strbuf, "Root device is: %s\n", root_devices[opcode]);
printf(strbuf);
return 0;
}
@@ -286,15 +293,23 @@ int get_rd_flags()
if (usb_control_msg(dev, CMD_QUERY, NOLO_GET_RDFLAGS, 0, 3, (void *) &flags, sizeof(flags), 2000) == -1) {
fprintf(stderr, "Cannot get rd flags\n");
sprintf(strbuf, "error: Cannot read rd flags\n");
return -1;
}
printf("Current rd flag setting:\n");
printf("disable OMAP watchdog : %s\n", (flags & 0x02) ? "set" : "not set");
printf("disable RETU watchdog : %s\n", (flags & 0x04) ? "set" : "not set");
printf("disable lifeguard reset: %s\n", (flags & 0x08) ? "set" : "not set");
printf("enable serial console : %s\n", (flags & 0x10) ? "set" : "not set");
printf("disable USB timeout : %s\n", (flags & 0x20) ? "set" : "not set");
sprintf(strbuf,
"Current rd flag setting:\n"
"disable OMAP watchdog : %s\n"
"disable RETU watchdog : %s\n"
"disable lifeguard reset: %s\n"
"enable serial console : %s\n"
"disable USB timeout : %s\n"
, (flags & 0x02) ? "set" : "not set"
, (flags & 0x04) ? "set" : "not set"
, (flags & 0x08) ? "set" : "not set"
, (flags & 0x10) ? "set" : "not set"
, (flags & 0x20) ? "set" : "not set");
printf(strbuf);
return 0;
}
@@ -306,10 +321,12 @@ int get_nolo_version()
//if (usb_control_msg(dev, CMD_QUERY, 3, 0, 1, (char *)&version, 4 , 2000) < 0) {
if (usb_control_msg(dev, CMD_QUERY, NOLO_GET_VERSION, 0, 0, (char *)&version, 4 , 2000) < 0) {
fprintf(stderr, "Cannot query nolo version. Old bootloader version?\n");
exit(1);
sprintf(strbuf, "error: Cannot query nolo version. Old bootloader?");
return -1;
}
printf("NOLO Version %d.%d.%d\n",
sprintf(strbuf,
"NOLO Version %d.%d.%d\n",
version >> 20 & 15,
version >> 16 & 15,
version >> 8 & 255);
@@ -320,6 +337,7 @@ int get_nolo_version()
return 0;
}
int get_sw_version()
{
int ret;
@@ -337,7 +355,11 @@ int get_sw_version()
fprintf(stderr, "error: b0rken swversion read!\n");
return 0;
}
printf("SWVERSION GOT: %s\n", bytes); //???+strlen(bytes)+1));
if (bytes[0]) {
sprintf(strbuf, "Software Version: %s\n", bytes);
printf("Software Version: %s\n", bytes); //???+strlen(bytes)+1));
} else
printf("No software version detected\n");
return 1;
}
+290
View File
@@ -0,0 +1,290 @@
#include "squeue.h"
#include <unistd.h>
#include <errno.h>
#include <stdlib.h>
#include <sys/ipc.h>
#include <signal.h>
#include <sys/shm.h>
#include <sys/mman.h>
#include <fcntl.h>
#include <stdio.h>
#include <string.h>
#define POOL_SIZE ITEM_MAX*ITEM_SIZE
#define ITEM_SIZE 512
#define ITEM_MAX 10
int squeue_release(const char *file)
{
int shmid;
key_t k = ftok(file, 0xa3);
if (k == -1) {
perror("ftok");
return -1;
}
shmid = shmget(k, POOL_SIZE, 0666);
if (shmid == -1)
return -1; // not released
return shmctl(shmid, IPC_RMID,NULL);
}
extern int errno;
struct squeue_t *squeue_open(const char *file, int mode)
{
struct squeue_t *q;
char *pool;
int shmid;
key_t k;
k = ftok(file, 0x34);
if (k == -1) {
perror("ftok");
squeue_release(file);
close(creat(file, 0666));
chmod(file, 0666);
k = ftok(file, 0xa3);
if (k == -1) {
perror("ftok");
return NULL;
}
}
_retry:
shmid = shmget(k, POOL_SIZE, 0666|(mode==Q_CREAT)?IPC_CREAT:0);
if (shmid == -1) {
perror("shmget1");
shmid = shmget(k, POOL_SIZE, 0666|((mode==Q_CREAT)?IPC_CREAT:0));
if (shmid == -1) {
perror("shmget2");
if (errno == EEXIST)
shmid = shmget(k, POOL_SIZE, 0666 |IPC_CREAT);
if (shmid == -1) {
if (mode == Q_WAIT) {
usleep(100);
goto _retry;
}
perror("shmget");
return NULL;
}
}
}
if (mode == Q_WAIT)
mode = Q_OPEN;
/* fix perms */
if (mode == Q_CREAT) {
struct shmid_ds sd;
shmctl(shmid, IPC_STAT, &sd);
sd.shm_perm.uid = 1000;
sd.shm_perm.gid = 1000;
sd.shm_perm.mode = sd.shm_perm.mode|0666;
shmctl(shmid, IPC_SET, &sd);
}
pool = shmat(shmid, NULL, 0);
if (((int)pool) == -1) {
perror("shmat");
return NULL;
}
if (mode == Q_CREAT)
memset(pool, '\0', POOL_SIZE);
q = (struct squeue_t *)malloc(sizeof(struct squeue_t));
memset(q, '\0', sizeof(struct squeue_t));
q->shmid = shmid;
q->pool = pool;
q->mode = mode;
return q;
}
void squeue_free(struct squeue_t *q)
{
free(q);
}
int squeue_close(struct squeue_t *q)
{
char *pool;
if (q==NULL)
return -1;
pool = q->pool;
shmctl(q->shmid, IPC_RMID, NULL);
free(q);
return shmdt(pool);
}
int squeue_push(struct squeue_t *q, const char *str, int lock)
{
int i;
if (q==NULL)
return -1;
// if (q->mode == Q_CREAT) {
// printf("squeue_push: cannot push from the creator\n");
// return -1;
// }
if (str==NULL||strlen(str)>ITEM_SIZE)
return -1;
do {
if (q->squeue_idx >= ITEM_MAX) {
while (q->pool[0]!='\0') {
q->squeue_locks++;
if (!lock) {
printf("buffer is full\n");
return -1;
}
usleep(100);
}
q->squeue_idx = 0;
}
for(i=q->squeue_idx*ITEM_SIZE;i<POOL_SIZE;i+=ITEM_SIZE) {
if (q->pool[i]=='\0') {
strcpy(q->pool+i, str);
q->squeue_idx++;
return 1;
}
}
q->squeue_locks++;
} while (lock);
q->squeue_lost++;
return 0;
}
int squeue_push2(struct squeue_t *q, const char *head, const char *str, int lock)
{
int ret;
char *buf = malloc(strlen(head) + strlen(str) + 2);
strcpy(buf, head);
strcat(buf, ":");
strcat(buf, str);
ret = squeue_push(q, buf, lock);
free(buf);
return ret;
}
int squeue_pop(struct squeue_t *q)
{
int i;
int two = 1;
if (q==NULL)
return -1;
// if (q->mode == Q_OPEN) { // cannot pop when not owner of squeue
// fprintf(stderr, "squeue_pop: cannot pop when you are not owner.\n");
// return -1;
// }
for(two=1;two--;q->head_idx = 0)
for(i=q->head_idx*ITEM_SIZE;i<POOL_SIZE;i+=ITEM_SIZE) {
if (q->pool[i]!='\0') {
q->pool[i]='\0';
q->head_idx++;
q->squeue_pops++;
return 1;
}
}
q->squeue_oops++;
fprintf(stderr, "WARNING: race condition detected in squeue.\n");
return 0;
}
char *squeue_get(struct squeue_t *q, int lock)
{
int i=0;
int two = 1;
if(q==NULL)
return NULL;
// if (q->mode == Q_OPEN) { // cannot pop when not owner of squeue
// fprintf(stderr, "squeue_get: cannot pop when you are not owner.\n");
// return NULL;
// }
do {
for(two=1;two--;q->head_idx = 0) {
for(i=q->head_idx*ITEM_SIZE;i<POOL_SIZE;i+=ITEM_SIZE)
if (q->pool[i]!='\0')
return q->pool+i;
}
if (lock)
usleep(100);
} while (lock);
return NULL;
}
void squeue_stats(struct squeue_t *q)
{
if(q==NULL)
return;
printf("Queue locks: %d\n", q->squeue_locks);
printf("Queue lost: %d\n", q->squeue_lost);
printf("Queue oops: %d\n", q->squeue_oops);
printf("Queue pops: %d\n", q->squeue_pops);
}
#if _MAIN_
struct squeue_t *q;
int sigc()
{
squeue_stats(q);
exit(1);
}
int main()
{
char buf[102];
int i;
int pid;
signal(SIGINT, sigc);
squeue_release("/dev/null");
pid = fork();
if (pid) {
q = squeue_open("/dev/null", Q_CREAT);
if (q == NULL) {
perror("oops");
kill(pid, SIGINT);
return;
}
squeue_push(q, "Hello World", 0);
squeue_push(q, "jeje msg 2", 0);
while(1) {
char *uh = squeue_get(q,1);
if (uh) {
printf("get: (%s)\n", uh);
squeue_pop(q);
}
usleep(100);
}
squeue_close(q);
} else {
q = squeue_open("/dev/null", Q_WAIT);
if (q == NULL) {
perror("oops");
return;
}
for(i=0;i<128;i++) {
sprintf(buf, "puta%d", i);
squeue_push(q, buf, 1);
usleep(100);
}
squeue_stats(q);
printf("cya\n");
squeue_close(q);
}
return 0;
}
#endif
+28
View File
@@ -0,0 +1,28 @@
struct squeue_t {
int shmid;
int mode;
char *pool;
/* pointers */
int head_idx;
int squeue_idx;
/* counters */
int squeue_locks;
int squeue_lost;
int squeue_oops;
int squeue_pops;
};
#define Q_OPEN 0
#define Q_CREAT 1
#define Q_WAIT 2
int squeue_release(const char *file);
struct squeue_t *squeue_open(const char *file, int init);
int squeue_close(struct squeue_t *q);
void squeue_free(struct squeue_t *q);
int squeue_push(struct squeue_t *q, const char *str, int lock);
int squeue_push2(struct squeue_t *q, const char *head, const char *str, int lock);
int squeue_pop(struct squeue_t *q);
char *squeue_get(struct squeue_t *q, int lock);
void squeue_stats(struct squeue_t *q);
+45
View File
@@ -0,0 +1,45 @@
using GLib;
[CCode (lower_case_cprefix = "squeue_", cheader_filename = "squeue.h")]
namespace SQueues {
[CCode (cname = "struct squeue_t", free_function = "squeue_free")]
public struct SQueue {
int shmid;
int mode;
char *pool;
/* pointers */
int head_idx;
int queue_idx;
/* counters */
int locks;
int lost;
int oops;
int pops;
[CCode (cname = "squeue_open")]
public static SQueue* open(string file, int mode);
[CCode (cname = "squeue_push")]
public int push(string msg, int l);
[CCode (cname = "squeue_push2")]
public int push2(string cmd, string msg, int l);
[CCode (cname = "squeue_get")]
public weak string get(int l);
[CCode (cname = "squeue_pop")]
public int pop();
[CCode (cname = "squeue_stats")]
public int stats();
[CCode (cname = "squeue_close")]
public int close();
[CCode (cname = "squeue_free")]
public int free();
[CCode (cname = "squeue_release")]
public static int release(string file);
}
[CCode (cprefix = "Q_", cheader_fileneme = "squeue.h")]
public enum SQueueMode {
OPEN = 0,
CREAT = 1,
WAIT = 2
}
}
+21 -9
View File
@@ -42,16 +42,28 @@ void progressbar(unsigned long long part, unsigned long long total)
int pc;
int tmp, cols = 80;
/* percentage calculation */
pc = (int)(part*100/total);
(pc<0)?pc=0:(pc>100)?pc=100:0;
printf("\e[K %3d%% [", pc);
if (columns)
cols = atoi(columns);
cols-=15;
for(tmp=cols*pc/100;tmp;tmp--) printf("#");
for(tmp=cols-(cols*pc/100);tmp;tmp--) printf("-");
printf("]\r");
fflush(stdout);
(pc<0)?pc=0:(pc>100)?pc=100:0;
#if HAVE_SQUEUE
if (qmode) {
char msg[128];
sprintf(msg, "%d%%", pc);
squeue_push2(p, "bar", msg, 0);
} else {
#endif
printf("\e[K %3d%% [", pc);
if (columns)
cols = atoi(columns);
cols-=15;
for(tmp=cols*pc/100;tmp;tmp--) printf("#");
for(tmp=cols-(cols*pc/100);tmp;tmp--) printf("-");
printf("]\r");
fflush(stdout);
#if HAVE_SQUEUE
}
#endif
}
void eprintf(const char *format, ...)